diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-06-09 14:47:13 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-06-09 14:47:13 +0000 |
| commit | f114c890961ef9a0f7666b077b40d22f39b6cdd3 (patch) | |
| tree | ba0ce6530430b19e4419adc606e5725ddb72bb99 /src/ActivePeerConnectionCommand.cc | |
| parent | d4dfb6c4a8cfb2262d19a291e53870bf98e2f82a (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.cc | 16 |
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()); |
