summaryrefslogtreecommitdiff
path: root/src/FileAllocationDispatcherCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2009-01-24 09:00:36 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2009-01-24 09:00:36 +0000
commit8ca9db9f3ee007d40b85339f81a39ea3c1a22616 (patch)
tree70ad188c3350794c2ed42cdc817cda8cd51fc03b /src/FileAllocationDispatcherCommand.cc
parentea370b864e5ebffa71d8d21d2cf0835c5780cd3c (diff)
2009-01-24 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Replaced FileAllocationMan with SequentialPicker<FileAllocationEntry>. * src/BtCheckIntegrityEntry.cc * src/ConsoleStatCalc.cc * src/DownloadEngine.cc * src/DownloadEngine.h * src/DownloadEngineFactory.cc * src/FileAllocationCommand.cc * src/FileAllocationDispatcherCommand.cc * src/FileAllocationMan.h * src/Makefile.am * src/SequentialPicker.h * src/StatCalc.h * src/StreamCheckIntegrityEntry.cc * test/Makefile.am * test/SequentialPickerTest.cc
Diffstat (limited to 'src/FileAllocationDispatcherCommand.cc')
-rw-r--r--src/FileAllocationDispatcherCommand.cc5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/FileAllocationDispatcherCommand.cc b/src/FileAllocationDispatcherCommand.cc
index 72622dfe..b6ee18fa 100644
--- a/src/FileAllocationDispatcherCommand.cc
+++ b/src/FileAllocationDispatcherCommand.cc
@@ -56,9 +56,8 @@ bool FileAllocationDispatcherCommand::execute()
if(_e->_requestGroupMan->downloadFinished() || _e->isHaltRequested()) {
return true;
}
- if(_e->_fileAllocationMan->nextFileAllocationEntryExists() &&
- !_e->_fileAllocationMan->isFileAllocationBeingExecuted()) {
- FileAllocationEntryHandle entry = _e->_fileAllocationMan->popNextFileAllocationEntry();
+ if(_e->_fileAllocationMan->hasNext() && !_e->_fileAllocationMan->isPicked()) {
+ FileAllocationEntryHandle entry = _e->_fileAllocationMan->pickNext();
int32_t newCUID = _e->newCUID();
logger->info(MSG_FILE_ALLOCATION_DISPATCH, newCUID);
FileAllocationCommand* command =