X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Scheduler%2FReadHelper.ct;h=6a5d0b73f2be5dce647ead7411b4def996d931e1;hb=0fff17bd2bcdbb1e91e216bf6e1bebc414713548;hp=16d2850617a484bdc5b6cd45e9178dc2f4fdef84;hpb=c5ab87643518405aa5171ed4602f7234873a4900;p=senf.git diff --git a/Scheduler/ReadHelper.ct b/Scheduler/ReadHelper.ct index 16d2850..6a5d0b7 100644 --- a/Scheduler/ReadHelper.ct +++ b/Scheduler/ReadHelper.ct @@ -16,7 +16,7 @@ ///////////////////////////////ct.p//////////////////////////////////////// template -prefix_ satcom::lib::ReadHelper::ReadHelper(Handle handle, std::string::size_type maxSize, +prefix_ senf::ReadHelper::ReadHelper(Handle handle, std::string::size_type maxSize, InternalPredicate * predicate, Callback cb) : handle_(handle), maxSize_(maxSize), predicate_(predicate), callback_(cb), errno_(0), complete_(false) @@ -25,23 +25,23 @@ prefix_ satcom::lib::ReadHelper::ReadHelper(Handle handle, std::string:: // argumnet instead of a simple bound-member as callback to the // scheduler. This ensures, that the refcount is at least 1 as // long as the helper is registered with the scheduler. - satcom::lib::Scheduler::instance() + senf::Scheduler::instance() .add(handle,boost::bind(&ReadHelper::dispatchProcess,ptr(this),_1,_2), - satcom::lib::Scheduler::EV_READ); + senf::Scheduler::EV_READ); } template -prefix_ void satcom::lib::ReadHelper::revoke() +prefix_ void senf::ReadHelper::revoke() { ptr guard (this); // To ensure, 'this' is deleted only after this method terminates ... - satcom::lib::Scheduler::instance() - .remove(handle_,satcom::lib::Scheduler::EV_READ); + senf::Scheduler::instance() + .remove(handle_,senf::Scheduler::EV_READ); } template prefix_ void -satcom::lib::ReadHelper::dispatchProcess(ptr helper, Handle handle, - satcom::lib::Scheduler::EventId event) +senf::ReadHelper::dispatchProcess(ptr helper, Handle handle, + senf::Scheduler::EventId event) { // since we have a 'ptr' argument, the instance cannot be deleted // before this method returns @@ -49,11 +49,11 @@ satcom::lib::ReadHelper::dispatchProcess(ptr helper, Handle handle, } template -prefix_ void satcom::lib::ReadHelper::process(Handle handle, - satcom::lib::Scheduler::EventId event) +prefix_ void senf::ReadHelper::process(Handle handle, + senf::Scheduler::EventId event) { try { - if (event != satcom::lib::Scheduler::EV_READ) + if (event != senf::Scheduler::EV_READ) throw SystemException(EPIPE); std::string rcv (handle.read(maxSize_ - data_.size())); data_.append(rcv); @@ -67,14 +67,14 @@ prefix_ void satcom::lib::ReadHelper::process(Handle handle, done(); } } - catch (satcom::lib::SystemException const & ex) { + catch (senf::SystemException const & ex) { errno_ = ex.err; done(); } } template -prefix_ void satcom::lib::ReadHelper::done() +prefix_ void senf::ReadHelper::done() { revoke(); callback_(ptr(this)); @@ -83,7 +83,7 @@ prefix_ void satcom::lib::ReadHelper::done() template template prefix_ std::string::size_type -satcom::lib::ReadHelper::InternalPredicate::Dispatcher:: +senf::ReadHelper::InternalPredicate::Dispatcher:: operator()(std::string const & data) { return predicate(data);