X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FScheduler%2FWriteHelper.ct;h=d05a9c8ae2715ebe0772c66d6f09dd7be0140fc1;hb=e3179a2123ad51d0d9eb63834a581145c4f77c92;hp=fe92ee2f08ad52f7671bdfaa0154b25e2637e82a;hpb=26610f603ebdd465307b9621f532c1fe19fd5571;p=senf.git diff --git a/senf/Scheduler/WriteHelper.ct b/senf/Scheduler/WriteHelper.ct index fe92ee2..d05a9c8 100644 --- a/senf/Scheduler/WriteHelper.ct +++ b/senf/Scheduler/WriteHelper.ct @@ -24,19 +24,17 @@ //#include "WriteHelper.ih" // Custom includes -#include #include #include -#include "Scheduler.hh" #define prefix_ -///////////////////////////////ct.p//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// template prefix_ senf::WriteHelper::WriteHelper(Handle handle, std::string const & data, Callback callback) - : handle_(handle), - fde_("WriteHelper", boost::bind(&WriteHelper::dispatchProcess, ptr(this), _1, _2), + : handle_(handle), + fde_("WriteHelper", boost::bind(&WriteHelper::dispatchProcess, ptr(this), _1, _2), handle, scheduler::FdEvent::EV_WRITE), data_(data), callback_(callback), offset_(data_.begin()), errno_(0) {} @@ -62,20 +60,20 @@ prefix_ void senf::WriteHelper::revoke() template prefix_ void senf::WriteHelper::dispatchProcess(ptr helper, Handle handle, - senf::scheduler::FdEvent::Events event) + scheduler::FdEvent::Events event) { // since we have a 'ptr' argument, the instance cannot be deleted // before this method returns - return helper->process(handle,event); + helper->process(handle, event); } template prefix_ void senf::WriteHelper::process(Handle handle, - senf::scheduler::FdEvent::Events event) + scheduler::FdEvent::Events event) { bool complete_ (false); try { - if (event != senf::scheduler::FdEvent::EV_WRITE) + if (event != scheduler::FdEvent::EV_WRITE) throw SystemException(EPIPE SENF_EXC_DEBUGINFO); offset_ = handle.write(std::make_pair(offset_,data_.end())); if (offset_ == data_.end()) { @@ -100,7 +98,7 @@ prefix_ void senf::WriteHelper::done() callback_(ptr(this)); } -///////////////////////////////ct.e//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_