Lines Matching refs:command
76 status_t EnqueueCommand(WorkerCommand* command)
78 return fWorker._EnqueueCommand(command);
267 // Enqueue command to fetch the message bodies
406 // Add pending command to fetch the message headers
407 WorkerCommand* command = new FetchHeadersCommand(*fFolder,
410 if (!fFetchCommands.AddItem(command))
411 delete command;
495 inline void operator()(WorkerCommand* command)
497 delete command;
507 CommandDeleter(IMAPConnectionWorker& worker, WorkerCommand* command)
509 BPrivate::AutoDeleter<WorkerCommand, CommandDelete>(command),
734 WorkerCommand* command = fPendingCommands.RemoveItemAt(0);
735 if (command == NULL)
740 CommandDeleter deleter(*this, command);
742 if (dynamic_cast<QuitCommand*>(command) == NULL) { // do not connect on QuitCommand
748 status = command->Process(*this);
752 if (!command->IsDone()) {
754 command->SetContinuation();
756 _EnqueueCommand(command);
765 /*! Enqueues the given command to the worker queue. This method will take
766 over ownership of the given command even in the error case.
769 IMAPConnectionWorker::_EnqueueCommand(WorkerCommand* command)
773 if (!fPendingCommands.AddItem(command)) {
774 delete command;
778 if (dynamic_cast<SyncCommand*>(command) != NULL
779 && !command->IsContinuation())