github
/
aria2
mirror of https://github.com/aria2/aria2
1
0
Fork 0
Code Issues Releases Wiki Activity

2008-08-23 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com> 

Fixed the bug that the number of connected peer is exceeding the 
limit
	(55 by default) in seeding mode.
	Multiplied 0.8 to _maxUploadSpeedLimit.
	* src/ActivePeerConnectionCommand.cc
pull/1/head
Tatsuhiro Tsujikawa 2008-08-23 15:17:32 +00:00
parent df9d042d25
commit a12be22ecb
2 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ChangeLog
View File

@ -1,3 +1,10 @@
2008-08-23 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
Fixed the bug that the number of connected peer is exceeding the limit
(55 by default) in seeding mode.
Multiplied 0.8 to _maxUploadSpeedLimit.
* src/ActivePeerConnectionCommand.cc
2008-08-23 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com> 2008-08-23 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
Clear table item. Clear table item.

14
src/ActivePeerConnectionCommand.cc
View File

@ -81,11 +81,17 @@ bool ActivePeerConnectionCommand::execute() {
TransferStat tstat = peerStorage->calculateStat(); TransferStat tstat = peerStorage->calculateStat();
if(// for seeder state if(// for seeder state
(pieceStorage->downloadFinished() && btRuntime->lessThanMaxPeers() && (pieceStorage->downloadFinished() && btRuntime->lessThanMaxPeers() &&
(_maxUploadSpeedLimit == 0 || tstat.getUploadSpeed() < _maxUploadSpeedLimit)) || (_maxUploadSpeedLimit == 0 ||
tstat.getUploadSpeed() < _maxUploadSpeedLimit*0.8)) ||
// for leecher state // for leecher state
(tstat.getDownloadSpeed() < _thresholdSpeed || (!pieceStorage->downloadFinished() &&
btRuntime->lessThanMinPeers())) { (tstat.getDownloadSpeed() < _thresholdSpeed ||
for(size_t numAdd = _numNewConnection; btRuntime->lessThanMinPeers()))) {
size_t numConnection = pieceStorage->downloadFinished() ?
std::min(_numNewConnection,
BtRuntime::MAX_PEERS-btRuntime->getConnections()) :
_numNewConnection;
for(size_t numAdd = numConnection;
numAdd > 0 && peerStorage->isPeerAvailable(); --numAdd) { numAdd > 0 && peerStorage->isPeerAvailable(); --numAdd) {
PeerHandle peer = peerStorage->getUnusedPeer(); PeerHandle peer = peerStorage->getUnusedPeer();
connectToPeer(peer); connectToPeer(peer);