summaryrefslogtreecommitdiff
path: root/src/FileAllocationCommand.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-06-09 14:21:10 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-06-09 14:21:10 +0000
commitd4dfb6c4a8cfb2262d19a291e53870bf98e2f82a (patch)
tree1ceddfbeadcea0c5fd7873c5eeacb823f0f15550 /src/FileAllocationCommand.cc
parentb357fd39fcc9b05a0d7ef87b1594c0ebd67cfdfe (diff)
2010-06-09 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Made protected member variable private. Added accessor funcs. * src/CheckIntegrityCommand.cc * src/FileAllocationCommand.cc * src/RealtimeCommand.h
Diffstat (limited to 'src/FileAllocationCommand.cc')
-rw-r--r--src/FileAllocationCommand.cc20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/FileAllocationCommand.cc b/src/FileAllocationCommand.cc
index 7e615c95..04bcc377 100644
--- a/src/FileAllocationCommand.cc
+++ b/src/FileAllocationCommand.cc
@@ -62,8 +62,8 @@ FileAllocationCommand::~FileAllocationCommand() {}
bool FileAllocationCommand::executeInternal()
{
- if(_requestGroup->isHaltRequested()) {
- _e->getFileAllocationMan()->dropPickedEntry();
+ if(getRequestGroup()->isHaltRequested()) {
+ getDownloadEngine()->getFileAllocationMan()->dropPickedEntry();
return true;
}
_fileAllocationEntry->allocateChunk();
@@ -72,34 +72,34 @@ bool FileAllocationCommand::executeInternal()
getLogger()->debug
(MSG_ALLOCATION_COMPLETED,
_timer.difference(global::wallclock),
- util::itos(_requestGroup->getTotalLength(), true).c_str());
+ util::itos(getRequestGroup()->getTotalLength(), true).c_str());
}
- _e->getFileAllocationMan()->dropPickedEntry();
+ getDownloadEngine()->getFileAllocationMan()->dropPickedEntry();
std::vector<Command*> commands;
try {
- _fileAllocationEntry->prepareForNextAction(commands, _e);
+ _fileAllocationEntry->prepareForNextAction(commands, getDownloadEngine());
} catch(RecoverableException& e) {
std::for_each(commands.begin(), commands.end(), Deleter());
throw;
}
- _e->addCommand(commands);
- _e->setNoWait(true);
+ getDownloadEngine()->addCommand(commands);
+ getDownloadEngine()->setNoWait(true);
return true;
} else {
- _e->addCommand(this);
+ getDownloadEngine()->addCommand(this);
return false;
}
}
bool FileAllocationCommand::handleException(Exception& e)
{
- _e->getFileAllocationMan()->dropPickedEntry();
+ getDownloadEngine()->getFileAllocationMan()->dropPickedEntry();
getLogger()->error
(MSG_FILE_ALLOCATION_FAILURE, e, util::itos(getCuid()).c_str());
getLogger()->error
(MSG_DOWNLOAD_NOT_COMPLETE, util::itos(getCuid()).c_str(),
- _requestGroup->getDownloadContext()->getBasePath().c_str());
+ getRequestGroup()->getDownloadContext()->getBasePath().c_str());
return true;
}