blob: 8bd890b07cb510dbba2c2d2bc3a14ffaa8b8ac00 [file] [log] [blame]
// Copyright (c) 2010 The Chromium OS Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROMEOS_PLATFORM_UPDATE_ENGINE_ACTION_PROCESSOR_H__
#define CHROMEOS_PLATFORM_UPDATE_ENGINE_ACTION_PROCESSOR_H__
#include <deque>
#include "base/basictypes.h"
// The structure of these classes (Action, ActionPipe, ActionProcessor, etc.)
// is based on the KSAction* classes from the Google Update Engine code at
// http://code.google.com/p/update-engine/ . The author of this file sends
// a big thanks to that team for their high quality design, implementation,
// and documentation.
// See action.h for an overview of this class and other other Action* classes.
// An ActionProcessor keeps a queue of Actions and processes them in order.
namespace chromeos_update_engine {
// Action exit codes.
enum ActionExitCode {
kActionCodeSuccess = 0,
kActionCodeError = 1,
kActionCodeOmahaRequestError = 2,
kActionCodeOmahaResponseHandlerError = 3,
kActionCodeFilesystemCopierError = 4,
kActionCodePostinstallRunnerError = 5,
kActionCodeSetBootableFlagError = 6, // TODO(petkov): Unused. Recycle?
kActionCodeInstallDeviceOpenError = 7,
kActionCodeKernelDeviceOpenError = 8,
kActionCodeDownloadTransferError = 9,
kActionCodeDownloadHashMismatchError = 10,
kActionCodeDownloadSizeMismatchError = 11,
kActionCodeDownloadPayloadVerificationError = 12,
kActionCodeDownloadAppliedUpdateVerificationError = 13,
kActionCodeDownloadWriteError = 14,
kActionCodeOmahaRequestEmptyResponseError = 200,
kActionCodeOmahaRequestXMLParseError = 201,
kActionCodeOmahaRequestNoUpdateCheckNode = 202,
kActionCodeOmahaRequestNoUpdateCheckStatus = 203,
kActionCodeOmahaRequestBadUpdateCheckStatus = 204,
kActionCodeOmahaRequestHTTPResponseBase = 2000, // + HTTP response code
};
class AbstractAction;
class ActionProcessorDelegate;
class ActionProcessor {
public:
ActionProcessor();
virtual ~ActionProcessor();
// Starts processing the first Action in the queue. If there's a delegate,
// when all processing is complete, ProcessingDone() will be called on the
// delegate.
virtual void StartProcessing();
// Aborts processing. If an Action is running, it will have
// TerminateProcessing() called on it. The Action that was running
// will be lost and must be re-enqueued if this Processor is to use it.
void StopProcessing();
// Returns true iff an Action is currently processing.
bool IsRunning() const { return NULL != current_action_; }
// Adds another Action to the end of the queue.
virtual void EnqueueAction(AbstractAction* action);
// Sets/gets the current delegate. Set to NULL to remove a delegate.
ActionProcessorDelegate* delegate() const { return delegate_; }
void set_delegate(ActionProcessorDelegate *delegate) {
delegate_ = delegate;
}
// Returns a pointer to the current Action that's processing.
AbstractAction* current_action() const {
return current_action_;
}
// Called by an action to notify processor that it's done. Caller passes self.
void ActionComplete(AbstractAction* actionptr, ActionExitCode code);
private:
// Actions that have not yet begun processing, in the order in which
// they'll be processed.
std::deque<AbstractAction*> actions_;
// A pointer to the currrently processing Action, if any.
AbstractAction* current_action_;
// A pointer to the delegate, or NULL if none.
ActionProcessorDelegate *delegate_;
DISALLOW_COPY_AND_ASSIGN(ActionProcessor);
};
// A delegate object can be used to be notified of events that happen
// in an ActionProcessor. An instance of this class can be passed to an
// ActionProcessor to register itself.
class ActionProcessorDelegate {
public:
// Called when all processing in an ActionProcessor has completed. A pointer
// to the ActionProcessor is passed. |code| is set to the exit code of the
// last completed action.
virtual void ProcessingDone(const ActionProcessor* processor,
ActionExitCode code) {}
// Called when processing has stopped. Does not mean that all Actions have
// completed. If/when all Actions complete, ProcessingDone() will be called.
virtual void ProcessingStopped(const ActionProcessor* processor) {}
// Called whenever an action has finished processing, either successfully
// or otherwise.
virtual void ActionCompleted(ActionProcessor* processor,
AbstractAction* action,
ActionExitCode code) {}
};
} // namespace chromeos_update_engine
#endif // CHROMEOS_PLATFORM_UPDATE_ENGINE_ACTION_PROCESSOR_H__