Lines Matching refs:manager
84 let mut manager = task_manager();
97 let task_id = manager.create(config).unwrap();
105 manager.start(uid, task_id);
115 manager.pause(uid, task_id);
125 manager.resume(uid, task_id);
135 manager.pause(uid, task_id);
145 manager.resume(uid, task_id);
155 manager.stop(uid, task_id);
165 manager.start(uid, task_id);
175 manager.scheduler.reschedule();
185 let msg = manager.rx.recv().await.unwrap();
187 let msg = manager.rx.recv().await.unwrap();
201 let mut manager = task_manager();
216 let task_id = manager.create(config.clone()).unwrap();
221 assert_eq!(manager.pause(uid, task_id), ErrorCode::TaskStateErr);
222 assert_eq!(manager.resume(uid, task_id), ErrorCode::TaskStateErr);
223 assert_eq!(manager.stop(uid, task_id), ErrorCode::TaskStateErr);
224 assert_eq!(manager.remove(uid, task_id), ErrorCode::ErrOk);
231 let task_id = manager.create(config.clone()).unwrap();
232 assert_eq!(manager.start(uid, task_id), ErrorCode::ErrOk);
233 assert_eq!(manager.resume(uid, task_id), ErrorCode::TaskStateErr);
234 assert_eq!(manager.start(uid, task_id), ErrorCode::TaskStateErr);
235 assert_eq!(manager.remove(uid, task_id), ErrorCode::ErrOk);
242 let task_id = manager.create(config.clone()).unwrap();
243 assert_eq!(manager.start(uid, task_id), ErrorCode::ErrOk);
244 assert_eq!(manager.pause(uid, task_id), ErrorCode::ErrOk);
245 assert_eq!(manager.pause(uid, task_id), ErrorCode::TaskStateErr);
246 assert_eq!(manager.stop(uid, task_id), ErrorCode::TaskStateErr);
247 assert_eq!(manager.start(uid, task_id), ErrorCode::TaskStateErr);
248 assert_eq!(manager.remove(uid, task_id), ErrorCode::ErrOk);
255 let task_id = manager.create(config.clone()).unwrap();
256 assert_eq!(manager.start(uid, task_id), ErrorCode::ErrOk);
257 assert_eq!(manager.stop(uid, task_id), ErrorCode::ErrOk);
258 assert_eq!(manager.pause(uid, task_id), ErrorCode::TaskStateErr);
259 assert_eq!(manager.stop(uid, task_id), ErrorCode::TaskStateErr);
260 assert_eq!(manager.resume(uid, task_id), ErrorCode::TaskStateErr);
261 assert_eq!(manager.start(uid, task_id), ErrorCode::ErrOk);
262 assert_eq!(manager.stop(uid, task_id), ErrorCode::ErrOk);
263 assert_eq!(manager.remove(uid, task_id), ErrorCode::ErrOk);
270 let task_id = manager.create(config.clone()).unwrap();
271 assert_eq!(manager.start(uid, task_id), ErrorCode::ErrOk);
272 assert_eq!(manager.pause(uid, task_id), ErrorCode::ErrOk);
273 assert_eq!(manager.resume(uid, task_id), ErrorCode::ErrOk);
274 assert_eq!(manager.resume(uid, task_id), ErrorCode::TaskStateErr);
275 assert_eq!(manager.start(uid, task_id), ErrorCode::TaskStateErr);
276 assert_eq!(manager.pause(uid, task_id), ErrorCode::ErrOk);
277 assert_eq!(manager.resume(uid, task_id), ErrorCode::ErrOk);
278 assert_eq!(manager.remove(uid, task_id), ErrorCode::ErrOk);
289 let mut manager = task_manager();
302 let task_id = manager.create(config.clone()).unwrap();
303 manager.rx.try_recv().unwrap_err();
304 manager.start(uid, task_id);
306 manager.rx.try_recv().unwrap(),
309 manager.scheduler.resort_scheduled = false;
310 manager.stop(uid, task_id);
312 manager.rx.try_recv().unwrap(),
315 manager.scheduler.resort_scheduled = false;
316 manager.start(uid, task_id);
318 manager.rx.try_recv().unwrap(),
321 manager.stop(uid, task_id);
322 manager.rx.try_recv().unwrap_err();
323 manager.scheduler.resort_scheduled = false;
324 manager.start(uid, task_id);
326 manager.rx.try_recv().unwrap(),
329 manager.scheduler.resort_scheduled = false;
330 manager.pause(uid, task_id);
332 manager.rx.try_recv().unwrap(),
335 manager.scheduler.resort_scheduled = false;
336 manager.resume(uid, task_id);
338 manager.rx.try_recv().unwrap(),