X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FFileHandle.cci;h=6db39f59ebc152913baa09ce9539402dd7a0e9dd;hb=a1fdb7bb122f0b05be809a922d4b7ef5e125fa67;hp=e04980a3ac4081bba7478ecd5981f782d560dcd6;hpb=10985d71f77b627bc4da543d7114feb7c4529329;p=senf.git diff --git a/Socket/FileHandle.cci b/Socket/FileHandle.cci index e04980a..6db39f5 100644 --- a/Socket/FileHandle.cci +++ b/Socket/FileHandle.cci @@ -72,25 +72,40 @@ prefix_ bool senf::FileBody::valid() prefix_ bool senf::FileBody::readable() const { - return pollCheck(fd(),true); + return pollCheck(fd(),true,0); } -prefix_ void senf::FileBody::waitReadable() +prefix_ bool senf::FileBody::waitReadable(senf::ClockService::clock_type timeout) const { - pollCheck(fd(),true,true); + return pollCheck(fd(), true, + (timeout==-1?-1:senf::ClockService::in_milliseconds(timeout)) ); } prefix_ bool senf::FileBody::writeable() const { - return pollCheck(fd(),false); + return pollCheck(fd(),false,0); } -prefix_ void senf::FileBody::waitWriteable() +prefix_ bool senf::FileBody::waitWriteable(senf::ClockService::clock_type timeout) const { - pollCheck(fd(),false,true); + return pollCheck(fd(), false, + (timeout==-1?-1:senf::ClockService::in_milliseconds(timeout)) ); +} + +prefix_ bool senf::FileBody::oobReadable() + const +{ + return pollCheck(fd(),true,0,true); +} + +prefix_ bool senf::FileBody::waitOOBReadable(senf::ClockService::clock_type timeout) + const +{ + return pollCheck(fd(), true, + (timeout==-1?-1:senf::ClockService::in_milliseconds(timeout)), true); } /////////////////////////////////////////////////////////////////////////// @@ -125,10 +140,10 @@ prefix_ bool senf::FileHandle::readable() return body().readable(); } -prefix_ void senf::FileHandle::waitReadable() +prefix_ bool senf::FileHandle::waitReadable(senf::ClockService::clock_type timeout) const { - body().waitReadable(); + return body().waitReadable(timeout); } prefix_ bool senf::FileHandle::writeable() @@ -137,10 +152,22 @@ prefix_ bool senf::FileHandle::writeable() return body().writeable(); } -prefix_ void senf::FileHandle::waitWriteable() +prefix_ bool senf::FileHandle::waitWriteable(senf::ClockService::clock_type timeout) + const +{ + return body().waitWriteable(timeout); +} + +prefix_ bool senf::FileHandle::oobReadable() + const +{ + return body().oobReadable(); +} + +prefix_ bool senf::FileHandle::waitOOBReadable(senf::ClockService::clock_type timeout) const { - body().waitWriteable(); + return body().waitOOBReadable(timeout); } prefix_ bool senf::FileHandle::blocking()