summaryrefslogtreecommitdiff
path: root/src/LpdDispatchMessageCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-06-21 13:51:56 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-06-21 13:51:56 +0000
commitca4940622c05e50a50f77c621ade914029663446 (patch)
tree2715d87c6b4faa669ae317f6f95d9694630cd4a0 /src/LpdDispatchMessageCommand.cc
parentae957baa98d4f97ea2437596db5073f9c33d22ae (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.cc32
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;
}