X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FFileHandle.ih;h=b13f2feac59ebd4913ed69055232388e8c8128cd;hb=81f84badf27b66dbadec9890646ca1193e998505;hp=acde0153b661caa5b6e96a8361e1fa88c6a9871d;hpb=3d5b1045dc2531f239a3af4a8f3b17b1fe31549c;p=senf.git diff --git a/Socket/FileHandle.ih b/Socket/FileHandle.ih index acde015..b13f2fe 100644 --- a/Socket/FileHandle.ih +++ b/Socket/FileHandle.ih @@ -1,9 +1,9 @@ // $Id$ // // Copyright (C) 2006 -// Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS) -// Kompetenzzentrum fuer Satelitenkommunikation (SatCom) -// Stefan Bund +// Fraunhofer Institute for Open Communication Systems (FOKUS) +// Competence Center NETwork research (NET), St. Augustin, GERMANY +// Stefan Bund // // This program is free software; you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by @@ -24,18 +24,19 @@ \brief FileHandle internal header */ -#ifndef IH_FileHandle_ -#define IH_FileHandle_ 1 +#ifndef IH_SENF_Socket_FileHandle_ +#define IH_SENF_Socket_FileHandle_ 1 // Custom includes #include -#include "Utils/intrusive_refcount.hh" -#include "Utils/pool_alloc_mixin.hh" +#include "../Utils/intrusive_refcount.hh" +#include "../Utils/pool_alloc_mixin.hh" ///////////////////////////////ih.p//////////////////////////////////////// namespace senf { + class FileHandle; /** \brief FileHandle referenced body @@ -84,22 +85,31 @@ namespace senf { resulting body/handle is not valid() */ virtual ~FileBody(); + // NO DESTRUCTOR HERE (that is, only an empty virtual destructor) - destructors and virtual + // functions don't mix. What would be in the the destructor is in 'destroyClose()' which is + // called from FileHandle::~FileHandle() *before* the last handle dies. + // no copy // no conversion constructors ///@} /////////////////////////////////////////////////////////////////////////// + FileHandle handle(); + int fd() const; void fd(int fd); void close(); void terminate(); + void destroyClose(); bool readable() const; - void waitReadable() const; + bool waitReadable(senf::ClockService::clock_type timeout) const; bool writeable() const; - void waitWriteable() const; + bool waitWriteable(senf::ClockService::clock_type timeout) const; + bool oobReadable() const; + bool waitOOBReadable(senf::ClockService::clock_type timeout) const; bool blocking() const; void blocking(bool status); @@ -132,7 +142,7 @@ namespace senf { protected: private: - bool pollCheck(int fd, bool incoming, bool block=false) const; + bool pollCheck(int fd, bool incoming, int timeout, bool oob=false) const; int fd_; };