X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Scheduler%2FWriteHelper.ct;h=04a4f1c46c3513ebf1d65def9d77cf531be89926;hb=331547d2a137f796eb5fcb390502aece3e01bb16;hp=8ef626da982856c34c621a56bf494976c6102e80;hpb=c5ab87643518405aa5171ed4602f7234873a4900;p=senf.git diff --git a/Scheduler/WriteHelper.ct b/Scheduler/WriteHelper.ct index 8ef626d..04a4f1c 100644 --- a/Scheduler/WriteHelper.ct +++ b/Scheduler/WriteHelper.ct @@ -15,18 +15,18 @@ ///////////////////////////////ct.p//////////////////////////////////////// template -prefix_ satcom::lib::WriteHelper::WriteHelper(Handle handle, std::string data, +prefix_ senf::WriteHelper::WriteHelper(Handle handle, std::string data, Callback callback) : handle_(handle), data_(data), callback_(callback), offset_(0), errno_(0) { - satcom::lib::Scheduler::instance() + senf::Scheduler::instance() .add(handle_, boost::bind(&WriteHelper::dispatchProcess, ptr(this), _1, _2), - satcom::lib::Scheduler::EV_WRITE); + senf::Scheduler::EV_WRITE); } template -prefix_ std::string const & satcom::lib::WriteHelper::data() +prefix_ std::string const & senf::WriteHelper::data() const { if (offset_ > 0) { @@ -37,17 +37,17 @@ prefix_ std::string const & satcom::lib::WriteHelper::data() } template -prefix_ void satcom::lib::WriteHelper::revoke() +prefix_ void senf::WriteHelper::revoke() { ptr guard (this); // To ensure, 'this' is deleted only after this method terminates ... - satcom::lib::Scheduler::instance() - .remove(handle_, satcom::lib::Scheduler::EV_WRITE); + senf::Scheduler::instance() + .remove(handle_, senf::Scheduler::EV_WRITE); } template prefix_ void -satcom::lib::WriteHelper::dispatchProcess(ptr helper, Handle handle, - satcom::lib::Scheduler::EventId event) +senf::WriteHelper::dispatchProcess(ptr helper, Handle handle, + senf::Scheduler::EventId event) { // since we have a 'ptr' argument, the instance cannot be deleted // before this method returns @@ -55,26 +55,26 @@ satcom::lib::WriteHelper::dispatchProcess(ptr helper, Handle handle, } template -prefix_ void satcom::lib::WriteHelper::process(Handle handle, - satcom::lib::Scheduler::EventId event) +prefix_ void senf::WriteHelper::process(Handle handle, + senf::Scheduler::EventId event) { try { - if (event != satcom::lib::Scheduler::EV_WRITE) - throw satcom::lib::SystemException(EPIPE); + if (event != senf::Scheduler::EV_WRITE) + throw senf::SystemException(EPIPE); offset_ += handle.write(data_.data()+offset_,data_.size()-offset_); if (offset_ >= data_.size()) { data_.erase(); done(); } } - catch (satcom::lib::SystemException const & ex) { + catch (senf::SystemException const & ex) { errno_ = ex.err; done(); } } template -prefix_ void satcom::lib::WriteHelper::done() +prefix_ void senf::WriteHelper::done() { revoke(); callback_(ptr(this));