summaryrefslogtreecommitdiff
path: root/src/AbstractCommand.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/AbstractCommand.cc')
-rw-r--r--src/AbstractCommand.cc9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/AbstractCommand.cc b/src/AbstractCommand.cc
index 88a8193d..16352cd1 100644
--- a/src/AbstractCommand.cc
+++ b/src/AbstractCommand.cc
@@ -184,7 +184,8 @@ bool AbstractCommand::execute() {
void AbstractCommand::tryReserved() {
_requestGroup->removeServerHost(cuid);
- Commands commands = _requestGroup->createNextCommand(e, 1);
+ Commands commands;
+ _requestGroup->createNextCommand(commands, e, 1);
e->addCommand(commands);
}
@@ -323,7 +324,11 @@ bool AbstractCommand::nameResolveFinished() const {
void AbstractCommand::prepareForNextAction(Command* nextCommand)
{
CheckIntegrityEntryHandle entry(new StreamCheckIntegrityEntry(req, _requestGroup, nextCommand));
- e->addCommand(_requestGroup->processCheckIntegrityEntry(entry, e));
+
+ std::deque<Command*> commands;
+ _requestGroup->processCheckIntegrityEntry(commands, entry, e);
+
+ e->addCommand(commands);
e->setNoWait(true);
}