summaryrefslogtreecommitdiff
path: root/src/ActivePeerConnectionCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-06-09 14:47:13 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-06-09 14:47:13 +0000
commitf114c890961ef9a0f7666b077b40d22f39b6cdd3 (patch)
treeba0ce6530430b19e4419adc606e5725ddb72bb99 /src/ActivePeerConnectionCommand.cc
parentd4dfb6c4a8cfb2262d19a291e53870bf98e2f82a (diff)
2010-06-09 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Made protected member variable private. Added accessor funcs. * src/ActivePeerConnectionCommand.cc * src/ActivePeerConnectionCommand.h * src/CheckIntegrityDispatcherCommand.cc * src/DHTEntryPointNameResolveCommand.h * src/DHTInteractionCommand.h * src/FileAllocationDispatcherCommand.cc * src/LpdReceiveMessageCommand.h * src/PeerChokeCommand.cc * src/PeerChokeCommand.h * src/PeerListenCommand.cc * src/PeerListenCommand.h * src/SeedCheckCommand.cc * src/SeedCheckCommand.h * src/SequentialDispatcherCommand.h * src/SleepCommand.cc * src/SleepCommand.h * src/TrackerWatcherCommand.cc * src/TrackerWatcherCommand.h
Diffstat (limited to 'src/ActivePeerConnectionCommand.cc')
-rw-r--r--src/ActivePeerConnectionCommand.cc16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/ActivePeerConnectionCommand.cc b/src/ActivePeerConnectionCommand.cc
index 32996b5d..effdab88 100644
--- a/src/ActivePeerConnectionCommand.cc
+++ b/src/ActivePeerConnectionCommand.cc
@@ -66,8 +66,8 @@ ActivePeerConnectionCommand::ActivePeerConnectionCommand
:
Command(cuid),
_requestGroup(requestGroup),
- interval(interval),
- e(e),
+ _interval(interval),
+ _e(e),
_numNewConnection(5)
{
_requestGroup->increaseNumCommand();
@@ -82,8 +82,8 @@ bool ActivePeerConnectionCommand::execute() {
if(_btRuntime->isHalt()) {
return true;
}
- if(checkPoint.difference(global::wallclock) >= interval) {
- checkPoint = global::wallclock;
+ if(_checkPoint.difference(global::wallclock) >= _interval) {
+ _checkPoint = global::wallclock;
TransferStat tstat = _requestGroup->calculateStat();
const unsigned int maxDownloadLimit =
_requestGroup->getMaxDownloadSpeedLimit();
@@ -129,7 +129,7 @@ bool ActivePeerConnectionCommand::execute() {
}
}
}
- e->addCommand(this);
+ _e->addCommand(this);
return false;
}
@@ -138,13 +138,13 @@ void ActivePeerConnectionCommand::connectToPeer(const SharedHandle<Peer>& peer)
if(peer.isNull()) {
return;
}
- peer->usedBy(e->newCUID());
+ peer->usedBy(_e->newCUID());
PeerInitiateConnectionCommand* command =
- new PeerInitiateConnectionCommand(peer->usedBy(), _requestGroup, peer, e,
+ new PeerInitiateConnectionCommand(peer->usedBy(), _requestGroup, peer, _e,
_btRuntime);
command->setPeerStorage(_peerStorage);
command->setPieceStorage(_pieceStorage);
- e->addCommand(command);
+ _e->addCommand(command);
if(getLogger()->info()) {
getLogger()->info(MSG_CONNECTING_TO_PEER,
util::itos(getCuid()).c_str(), peer->ipaddr.c_str());