OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
88 // | 88 // |
89 | 89 |
90 namespace rtc { | 90 namespace rtc { |
91 | 91 |
92 // Executes a sequence of steps | 92 // Executes a sequence of steps |
93 class Task : public TaskParent { | 93 class Task : public TaskParent { |
94 public: | 94 public: |
95 Task(TaskParent *parent); | 95 Task(TaskParent *parent); |
96 ~Task() override; | 96 ~Task() override; |
97 | 97 |
98 int32 unique_id() { return unique_id_; } | 98 int32_t unique_id() { return unique_id_; } |
99 | 99 |
100 void Start(); | 100 void Start(); |
101 void Step(); | 101 void Step(); |
102 int GetState() const { return state_; } | 102 int GetState() const { return state_; } |
103 bool HasError() const { return (GetState() == STATE_ERROR); } | 103 bool HasError() const { return (GetState() == STATE_ERROR); } |
104 bool Blocked() const { return blocked_; } | 104 bool Blocked() const { return blocked_; } |
105 bool IsDone() const { return done_; } | 105 bool IsDone() const { return done_; } |
106 int64 ElapsedTime(); | 106 int64_t ElapsedTime(); |
107 | 107 |
108 // Called from outside to stop task without any more callbacks | 108 // Called from outside to stop task without any more callbacks |
109 void Abort(bool nowake = false); | 109 void Abort(bool nowake = false); |
110 | 110 |
111 bool TimedOut(); | 111 bool TimedOut(); |
112 | 112 |
113 int64 timeout_time() const { return timeout_time_; } | 113 int64_t timeout_time() const { return timeout_time_; } |
114 int timeout_seconds() const { return timeout_seconds_; } | 114 int timeout_seconds() const { return timeout_seconds_; } |
115 void set_timeout_seconds(int timeout_seconds); | 115 void set_timeout_seconds(int timeout_seconds); |
116 | 116 |
117 sigslot::signal0<> SignalTimeout; | 117 sigslot::signal0<> SignalTimeout; |
118 | 118 |
119 // Called inside the task to signal that the task may be unblocked | 119 // Called inside the task to signal that the task may be unblocked |
120 void Wake(); | 120 void Wake(); |
121 | 121 |
122 protected: | 122 protected: |
123 | 123 |
124 enum { | 124 enum { |
125 STATE_BLOCKED = -1, | 125 STATE_BLOCKED = -1, |
126 STATE_INIT = 0, | 126 STATE_INIT = 0, |
127 STATE_START = 1, | 127 STATE_START = 1, |
128 STATE_DONE = 2, | 128 STATE_DONE = 2, |
129 STATE_ERROR = 3, | 129 STATE_ERROR = 3, |
130 STATE_RESPONSE = 4, | 130 STATE_RESPONSE = 4, |
131 STATE_NEXT = 5, // Subclasses which need more states start here and higher | 131 STATE_NEXT = 5, // Subclasses which need more states start here and higher |
132 }; | 132 }; |
133 | 133 |
134 // Called inside to advise that the task should wake and signal an error | 134 // Called inside to advise that the task should wake and signal an error |
135 void Error(); | 135 void Error(); |
136 | 136 |
137 int64 CurrentTime(); | 137 int64_t CurrentTime(); |
138 | 138 |
139 virtual std::string GetStateName(int state) const; | 139 virtual std::string GetStateName(int state) const; |
140 virtual int Process(int state); | 140 virtual int Process(int state); |
141 virtual void Stop(); | 141 virtual void Stop(); |
142 virtual int ProcessStart() = 0; | 142 virtual int ProcessStart() = 0; |
143 virtual int ProcessResponse(); | 143 virtual int ProcessResponse(); |
144 | 144 |
145 void ResetTimeout(); | 145 void ResetTimeout(); |
146 void ClearTimeout(); | 146 void ClearTimeout(); |
147 | 147 |
148 void SuspendTimeout(); | 148 void SuspendTimeout(); |
149 void ResumeTimeout(); | 149 void ResumeTimeout(); |
150 | 150 |
151 protected: | 151 protected: |
152 virtual int OnTimeout(); | 152 virtual int OnTimeout(); |
153 | 153 |
154 private: | 154 private: |
155 void Done(); | 155 void Done(); |
156 | 156 |
157 int state_; | 157 int state_; |
158 bool blocked_; | 158 bool blocked_; |
159 bool done_; | 159 bool done_; |
160 bool aborted_; | 160 bool aborted_; |
161 bool busy_; | 161 bool busy_; |
162 bool error_; | 162 bool error_; |
163 int64 start_time_; | 163 int64_t start_time_; |
164 int64 timeout_time_; | 164 int64_t timeout_time_; |
165 int timeout_seconds_; | 165 int timeout_seconds_; |
166 bool timeout_suspended_; | 166 bool timeout_suspended_; |
167 int32 unique_id_; | 167 int32_t unique_id_; |
168 | 168 |
169 static int32 unique_id_seed_; | 169 static int32_t unique_id_seed_; |
170 }; | 170 }; |
171 | 171 |
172 } // namespace rtc | 172 } // namespace rtc |
173 | 173 |
174 #endif // WEBRTC_BASE_TASK_H__ | 174 #endif // WEBRTC_BASE_TASK_H__ |
OLD | NEW |