diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2011-12-08 23:26:51 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2011-12-09 21:39:43 +0900 |
| commit | 7989cd898dc0bfef40ab1a7e2b747676620d6517 (patch) | |
| tree | 62552567c7890a84b3acd12c899ff9235e2523ee /src/DHTTaskExecutor.cc | |
| parent | 30e0e19e671697f8f62b43b1e03772ad29ca2407 (diff) | |
Use int or int32_t instead of size_t where suitable
Diffstat (limited to 'src/DHTTaskExecutor.cc')
| -rw-r--r-- | src/DHTTaskExecutor.cc | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/src/DHTTaskExecutor.cc b/src/DHTTaskExecutor.cc index 87949110..ba57c1f3 100644 --- a/src/DHTTaskExecutor.cc +++ b/src/DHTTaskExecutor.cc @@ -44,7 +44,7 @@ namespace aria2 { -DHTTaskExecutor::DHTTaskExecutor(size_t numConcurrent) +DHTTaskExecutor::DHTTaskExecutor(int numConcurrent) : numConcurrent_(numConcurrent) {} @@ -55,7 +55,12 @@ void DHTTaskExecutor::update() execTasks_.erase(std::remove_if(execTasks_.begin(), execTasks_.end(), mem_fun_sh(&DHTTask::finished)), execTasks_.end()); - size_t r = numConcurrent_-execTasks_.size(); + int r; + if(static_cast<size_t>(numConcurrent_) > execTasks_.size()) { + r = numConcurrent_-execTasks_.size(); + } else { + r = 0; + } while(r && !queue_.empty()) { SharedHandle<DHTTask> task = queue_.front(); queue_.pop_front(); |
