|
@@ -486,12 +486,13 @@ void RequestGroup::createNextCommandWithAdj(std::deque<Command*>& commands,
|
|
numCommand = 1+numAdj;
|
|
numCommand = 1+numAdj;
|
|
} else {
|
|
} else {
|
|
if(_numConcurrentCommand == 0) {
|
|
if(_numConcurrentCommand == 0) {
|
|
- numCommand = std::min(_downloadContext->getNumPieces(), _uris.size());
|
|
|
|
|
|
+ numCommand = _uris.size();
|
|
} else {
|
|
} else {
|
|
- numCommand = std::min(_downloadContext->getNumPieces(),
|
|
|
|
- _numConcurrentCommand);
|
|
|
|
|
|
+ numCommand = _numConcurrentCommand;
|
|
}
|
|
}
|
|
numCommand += numAdj;
|
|
numCommand += numAdj;
|
|
|
|
+ numCommand = std::min(static_cast<int>(_downloadContext->getNumPieces()),
|
|
|
|
+ numCommand);
|
|
}
|
|
}
|
|
if(numCommand > 0) {
|
|
if(numCommand > 0) {
|
|
createNextCommand(commands, e, numCommand);
|
|
createNextCommand(commands, e, numCommand);
|