diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-06-21 13:51:56 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-06-21 13:51:56 +0000 |
| commit | ca4940622c05e50a50f77c621ade914029663446 (patch) | |
| tree | 2715d87c6b4faa669ae317f6f95d9694630cd4a0 /src/LpdDispatchMessageCommand.cc | |
| parent | ae957baa98d4f97ea2437596db5073f9c33d22ae (diff) | |
2010-06-21 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Changed naming standards for class member variable: now it looks
like var_ instead of _var.
Diffstat (limited to 'src/LpdDispatchMessageCommand.cc')
| -rw-r--r-- | src/LpdDispatchMessageCommand.cc | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/src/LpdDispatchMessageCommand.cc b/src/LpdDispatchMessageCommand.cc index 778baf46..0996f480 100644 --- a/src/LpdDispatchMessageCommand.cc +++ b/src/LpdDispatchMessageCommand.cc @@ -53,40 +53,40 @@ LpdDispatchMessageCommand::LpdDispatchMessageCommand const SharedHandle<LpdMessageDispatcher>& dispatcher, DownloadEngine* e): Command(cuid), - _dispatcher(dispatcher), - _e(e), - _tryCount(0) {} + dispatcher_(dispatcher), + e_(e), + tryCount_(0) {} bool LpdDispatchMessageCommand::execute() { - if(_btRuntime->isHalt()) { + if(btRuntime_->isHalt()) { return true; } - if(_dispatcher->isAnnounceReady()) { + if(dispatcher_->isAnnounceReady()) { try { getLogger()->info("Dispatching LPD message for infohash=%s", - util::toHex(_dispatcher->getInfoHash()).c_str()); - if(_dispatcher->sendMessage()) { + util::toHex(dispatcher_->getInfoHash()).c_str()); + if(dispatcher_->sendMessage()) { getLogger()->info("Sending LPD message is complete."); - _dispatcher->resetAnnounceTimer(); - _tryCount = 0; + dispatcher_->resetAnnounceTimer(); + tryCount_ = 0; } else { - ++_tryCount; - if(_tryCount >= 5) { + ++tryCount_; + if(tryCount_ >= 5) { getLogger()->info("Sending LPD message %u times but all failed."); - _dispatcher->resetAnnounceTimer(); - _tryCount = 0; + dispatcher_->resetAnnounceTimer(); + tryCount_ = 0; } else { getLogger()->info("Could not send LPD message, retry shortly."); } } } catch(RecoverableException& e) { getLogger()->info("Failed to send LPD message.", e); - _dispatcher->resetAnnounceTimer(); - _tryCount = 0; + dispatcher_->resetAnnounceTimer(); + tryCount_ = 0; } } - _e->addCommand(this); + e_->addCommand(this); return false; } |
