diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2008-03-09 12:24:01 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2008-03-09 12:24:01 +0000 |
| commit | 032c7c28083e17bdcfd763b3cf81447b06a07978 (patch) | |
| tree | e5cc5ceb050773165df41eb7f0aed3f2a48205a0 /src/DefaultBtInteractive.cc | |
| parent | ca3f6e57f35c67f67c3b4f64cedded8ca23237e8 (diff) | |
2008-03-09 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
type cleanup for allmost all remaining files.
Diffstat (limited to 'src/DefaultBtInteractive.cc')
| -rw-r--r-- | src/DefaultBtInteractive.cc | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/DefaultBtInteractive.cc b/src/DefaultBtInteractive.cc index 99767a0a..a86993cd 100644 --- a/src/DefaultBtInteractive.cc +++ b/src/DefaultBtInteractive.cc @@ -281,7 +281,7 @@ void DefaultBtInteractive::decideInterest() { } } -void DefaultBtInteractive::fillPiece(int maxPieceNum) { +void DefaultBtInteractive::fillPiece(size_t maxPieceNum) { if(pieceStorage->hasMissingPiece(peer)) { if(peer->peerChoking()) { if(peer->isFastExtensionEnabled()) { @@ -308,7 +308,7 @@ void DefaultBtInteractive::fillPiece(int maxPieceNum) { } void DefaultBtInteractive::addRequests() { - int32_t MAX_PENDING_REQUEST; + size_t MAX_PENDING_REQUEST; if(peer->getLatency() < 500) { MAX_PENDING_REQUEST = 24; } else if(peer->getLatency() < 1500) { @@ -316,16 +316,16 @@ void DefaultBtInteractive::addRequests() { } else { MAX_PENDING_REQUEST = 6; } - int32_t pieceNum; + size_t pieceNum; if(pieceStorage->isEndGame()) { pieceNum = 1; } else { - int32_t blocks = DIV_FLOOR(btContext->getPieceLength(), Piece::BLOCK_LENGTH); + size_t blocks = DIV_FLOOR(btContext->getPieceLength(), Piece::BLOCK_LENGTH); pieceNum = DIV_FLOOR(MAX_PENDING_REQUEST, blocks); } fillPiece(pieceNum); - int32_t reqNumToCreate = + size_t reqNumToCreate = MAX_PENDING_REQUEST <= dispatcher->countOutstandingRequest() ? 0 : MAX_PENDING_REQUEST-dispatcher->countOutstandingRequest(); if(reqNumToCreate > 0) { @@ -453,7 +453,7 @@ void DefaultBtInteractive::setLocalNode(const WeakHandle<DHTNode>& node) _localNode = node; } -int32_t DefaultBtInteractive::countPendingMessage() +size_t DefaultBtInteractive::countPendingMessage() { return dispatcher->countMessageInQueue(); } |