blob: da2e6ce597e9da8bcee2564750f988e8db613914 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
// Copyright 2013 The Chromium 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 CHROME_BROWSER_SYNC_FILE_SYSTEM_SYNC_TASK_MANAGER_H_
#define CHROME_BROWSER_SYNC_FILE_SYSTEM_SYNC_TASK_MANAGER_H_
#include <deque>
#include "base/callback.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/non_thread_safe.h"
#include "chrome/browser/sync_file_system/sync_callbacks.h"
#include "chrome/browser/sync_file_system/sync_status_code.h"
class Profile;
namespace tracked_objects {
class Location;
}
namespace sync_file_system {
class SyncTaskManager
: public base::NonThreadSafe,
public base::SupportsWeakPtr<SyncTaskManager> {
public:
class TaskToken;
typedef base::Callback<void(const SyncStatusCallback& callback)> Task;
class Client {
public:
virtual ~Client() {}
// Called when the manager is idle.
virtual void MaybeScheduleNextTask() = 0;
// Called when the manager is notified a task is done.
virtual void NotifyLastOperationStatus(
SyncStatusCode last_operation_status) = 0;
};
explicit SyncTaskManager(base::WeakPtr<Client> client);
virtual ~SyncTaskManager();
// This needs to be called to start task scheduling.
// If |status| is not SYNC_STATUS_OK calling this may change the
// service status. This should not be called more than once.
void Initialize(SyncStatusCode status);
void ScheduleTask(const Task& task,
const SyncStatusCallback& callback);
// Runs the posted task only when we're idle.
void ScheduleTaskIfIdle(const Task& task);
void NotifyTaskDone(scoped_ptr<TaskToken> token,
const SyncStatusCallback& callback,
SyncStatusCode status);
private:
// This should be called when an async task needs to get a task token.
scoped_ptr<TaskToken> GetToken(const tracked_objects::Location& from_here);
// Creates a completion callback that calls NotifyTaskDone.
// It is ok to give null |callback|.
SyncStatusCallback CreateCompletionCallback(
scoped_ptr<TaskToken> token,
const SyncStatusCallback& callback);
base::WeakPtr<Client> client_;
SyncStatusCode last_operation_status_;
std::deque<base::Closure> pending_tasks_;
// Absence of |token_| implies a task is running. Incoming tasks should
// wait for the task to finish in |pending_tasks_| if |token_| is null.
// Each task must take TaskToken instance from |token_| and must hold it
// until it finished. And the task must return the instance through
// NotifyTaskDone when the task finished.
scoped_ptr<TaskToken> token_;
DISALLOW_COPY_AND_ASSIGN(SyncTaskManager);
};
} // namespace sync_file_system
#endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_SYNC_TASK_MANAGER_H_
|
