X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Scheduler%2FWriteHelper.ct;h=2fa26020aca199ab7786dc6768caa8410ad92973;hb=85ab07d100a382467a42e19d741d403a7a96c951;hp=28bf5b6d2caf6e984d5b047476a106c86b1ce10b;hpb=3e42ecb22121f2e6df86b27bea73f890384a4ee4;p=senf.git diff --git a/Scheduler/WriteHelper.ct b/Scheduler/WriteHelper.ct index 28bf5b6..2fa2602 100644 --- a/Scheduler/WriteHelper.ct +++ b/Scheduler/WriteHelper.ct @@ -16,7 +16,7 @@ // along with this program; if not, write to the // Free Software Foundation, Inc., // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. -// Copyright (C) 2006 +// Copyright (C) 2006 /** \file \brief WriteHelper non-inline template implementation */ @@ -38,8 +38,8 @@ prefix_ senf::WriteHelper::WriteHelper(Handle handle, std::string data, offset_(0), errno_(0) { senf::Scheduler::instance() - .add(handle_, boost::bind(&WriteHelper::dispatchProcess, ptr(this), _1, _2), - senf::Scheduler::EV_WRITE); + .add(handle_, boost::bind(&WriteHelper::dispatchProcess, ptr(this), _1, _2), + senf::Scheduler::EV_WRITE); } template @@ -47,8 +47,8 @@ prefix_ std::string const & senf::WriteHelper::data() const { if (offset_ > 0) { - data_.erase(0,offset_); - offset_ = 0; + data_.erase(0,offset_); + offset_ = 0; } return data_; } @@ -58,7 +58,7 @@ prefix_ void senf::WriteHelper::revoke() { ptr guard (this); // To ensure, 'this' is deleted only after this method terminates ... senf::Scheduler::instance() - .remove(handle_, senf::Scheduler::EV_WRITE); + .remove(handle_, senf::Scheduler::EV_WRITE); } template @@ -77,17 +77,17 @@ prefix_ void senf::WriteHelper::process(Handle handle, { /** \fixme Move the done() calls to outside the try/catch block */ try { - 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(); - } + 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 (senf::SystemException const & ex) { - errno_ = ex.err; - done(); + errno_ = ex.err; + done(); } } @@ -104,4 +104,8 @@ prefix_ void senf::WriteHelper::done() // Local Variables: // mode: c++ +// fill-column: 100 +// c-file-style: "senf" +// indent-tabs-mode: nil +// ispell-local-dictionary: "american" // End: