9345049af8
- BJobStateListener: Add progress state and corresponding hook. - FetchFileJob: Notify job progress hook on libcurl notifications. - UserInteractionHandler: Add hooks for download progress and checksum validation progress. - PackageManager: inherit from JobStateListener and watch for job notifications for internally generated jobs. Forward to corresponding UserInteractionHandler hooks as needed. - Adapt pkgman, HaikuDepot and package_daemon to above changes. Neither HaikuDepot nor package_daemon's progress hooks are wired up to do anything yet though.
112 lines
2.1 KiB
C++
112 lines
2.1 KiB
C++
/*
|
|
* Copyright 2011-2013, Haiku, Inc.
|
|
* Distributed under the terms of the MIT License.
|
|
*/
|
|
#ifndef _PACKAGE__JOB_H_
|
|
#define _PACKAGE__JOB_H_
|
|
|
|
|
|
#include <ObjectList.h>
|
|
#include <String.h>
|
|
|
|
|
|
namespace BPackageKit {
|
|
|
|
|
|
class BContext;
|
|
class BJob;
|
|
|
|
|
|
struct BJobStateListener {
|
|
virtual ~BJobStateListener();
|
|
|
|
// these default implementations do nothing
|
|
virtual void JobStarted(BJob* job);
|
|
virtual void JobProgress(BJob* job);
|
|
virtual void JobSucceeded(BJob* job);
|
|
virtual void JobFailed(BJob* job);
|
|
virtual void JobAborted(BJob* job);
|
|
};
|
|
|
|
|
|
enum BJobState {
|
|
JOB_STATE_WAITING_TO_RUN,
|
|
JOB_STATE_STARTED,
|
|
JOB_STATE_IN_PROGRESS,
|
|
JOB_STATE_SUCCEEDED,
|
|
JOB_STATE_FAILED,
|
|
JOB_STATE_ABORTED,
|
|
};
|
|
|
|
|
|
namespace BPrivate {
|
|
class JobQueue;
|
|
}
|
|
|
|
|
|
class BJob {
|
|
public:
|
|
BJob(const BContext& context,
|
|
const BString& title);
|
|
virtual ~BJob();
|
|
|
|
status_t InitCheck() const;
|
|
|
|
virtual status_t Run();
|
|
|
|
const BString& Title() const;
|
|
BJobState State() const;
|
|
status_t Result() const;
|
|
const BString& ErrorString() const;
|
|
|
|
uint32 TicketNumber() const;
|
|
|
|
status_t AddStateListener(BJobStateListener* listener);
|
|
status_t RemoveStateListener(
|
|
BJobStateListener* listener);
|
|
|
|
bool IsRunnable() const;
|
|
status_t AddDependency(BJob* job);
|
|
status_t RemoveDependency(BJob* job);
|
|
int32 CountDependencies() const;
|
|
|
|
BJob* DependantJobAt(int32 index) const;
|
|
protected:
|
|
virtual status_t Execute() = 0;
|
|
virtual void Cleanup(status_t jobResult);
|
|
|
|
void SetErrorString(const BString&);
|
|
|
|
void NotifyStateListeners();
|
|
|
|
const BContext& fContext;
|
|
|
|
private:
|
|
friend class BPrivate::JobQueue;
|
|
void _SetTicketNumber(uint32 ticketNumber);
|
|
void _ClearTicketNumber();
|
|
|
|
private:
|
|
status_t fInitStatus;
|
|
BString fTitle;
|
|
|
|
BJobState fState;
|
|
status_t fResult;
|
|
BString fErrorString;
|
|
|
|
uint32 fTicketNumber;
|
|
|
|
typedef BObjectList<BJob> JobList;
|
|
JobList fDependencies;
|
|
JobList fDependantJobs;
|
|
|
|
typedef BObjectList<BJobStateListener> StateListenerList;
|
|
StateListenerList fStateListeners;
|
|
};
|
|
|
|
|
|
} // namespace BPackageKit
|
|
|
|
|
|
#endif // _PACKAGE__JOB_H_
|