X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FScheduler%2FWriteHelper.ct;h=d05a9c8ae2715ebe0772c66d6f09dd7be0140fc1;hb=e3179a2123ad51d0d9eb63834a581145c4f77c92;hp=3d688ef5f61694eacc1b7639f8ab432f536f8d05;hpb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;p=senf.git diff --git a/senf/Scheduler/WriteHelper.ct b/senf/Scheduler/WriteHelper.ct index 3d688ef..d05a9c8 100644 --- a/senf/Scheduler/WriteHelper.ct +++ b/senf/Scheduler/WriteHelper.ct @@ -24,19 +24,17 @@ //#include "WriteHelper.ih" // Custom includes -#include #include -#include "../Utils/Exception.hh" -#include "Scheduler.hh" +#include #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_