X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FSocketSource.cti;h=6403b0317fe57ddfb9d76af8d8ea395f34130f6b;hb=c505c034e5fdc932c02aa3dc3847a5551011d87e;hp=8bb2e7c17a5e801c053d0a8fb94bffe58202153a;hpb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;p=senf.git diff --git a/senf/PPI/SocketSource.cti b/senf/PPI/SocketSource.cti index 8bb2e7c..6403b03 100644 --- a/senf/PPI/SocketSource.cti +++ b/senf/PPI/SocketSource.cti @@ -47,7 +47,36 @@ senf::ppi::module::ActiveSocketSource::handle() } template -prefix_ void senf::ppi::module::ActiveSocketSource::handle(Handle handle) +prefix_ void senf::ppi::module::ActiveSocketSource::handle(Handle const & handle) +{ + handle_ = handle; + event_.set(handle_, IOEvent::Read); +} + +template +prefix_ void senf::ppi::module::ActiveSocketSource::read() +{ + output(reader_(handle_)); +} + +/////////////////////////////////////////////////////////////////////////// +// senf::ppi::module::ActiveBurstSocketSource + +template +prefix_ Reader & senf::ppi::module::ActiveBurstSocketSource::reader() +{ + return reader_; +} + +template +prefix_ typename senf::ppi::module::ActiveBurstSocketSource::Handle +senf::ppi::module::ActiveBurstSocketSource::handle() +{ + return handle_; +} + +template +prefix_ void senf::ppi::module::ActiveBurstSocketSource::handle(Handle const & handle) { handle_ = handle; event_.set(handle_, IOEvent::Read);