X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FQueueingSocketSink.ct;h=594c5019e2aa0b1a64057b020cf7844b5767c223;hb=a0b6f53e5c464c6b84fed30a67fcce32da81012d;hp=3ae8cbfdb7c25c0e0fbc25e1b9bd4fb1a12cb1f2;hpb=fc1569e67cfda71bc8c406617a5e0b05f28f1b47;p=senf.git diff --git a/senf/PPI/QueueingSocketSink.ct b/senf/PPI/QueueingSocketSink.ct index 3ae8cbf..594c501 100644 --- a/senf/PPI/QueueingSocketSink.ct +++ b/senf/PPI/QueueingSocketSink.ct @@ -56,7 +56,7 @@ prefix_ senf::ppi::QueueingAlgorithm::ptr senf::ppi::detail::QueueingAlgorithmRe // senf::ppi::module::PassiveQueueingSocketSink template -prefix_ senf::ppi::module::PassiveQueueingSocketSink::PassiveQueueingSocketSink(Handle handle, QueueingAlgorithm::ptr qAlgorithm) +prefix_ senf::ppi::module::PassiveQueueingSocketSink::PassiveQueueingSocketSink(Handle const & handle, QueueingAlgorithm::ptr qAlgorithm) : dir( this), handle_( handle), writer_( ), qAlgo_( qAlgorithm), @@ -85,7 +85,7 @@ prefix_ void senf::ppi::module::PassiveQueueingSocketSink::write() } if (! writer_( handle_, p)) { if (qAlgo_->enqueue( p) && !event_.enabled()) { - event_.enabled( true); + event_.enabled( true); } } } @@ -138,4 +138,4 @@ prefix_ void senf::ppi::module::PassiveQueueingSocketSink::setQAlgorithm // indent-tabs-mode: nil // ispell-local-dictionary: "american" // compile-command: "scons -u test" -// End: +// End::