Lines Matching refs:manager
134 let (mut manager, mut client_rx) = init_manager();
148 let task_id = manager.create(config).unwrap();
149 manager.start(uid, task_id);
150 manager.scheduler.reschedule();
190 let (mut manager, mut client_rx) = init_manager();
204 let task_id = manager.create(config).unwrap();
205 manager.start(uid, task_id);
206 manager.pause(uid, task_id);
207 manager.resume(uid, task_id);
242 let (mut manager, mut client_rx) = init_manager();
256 let task_id = manager.create(config).unwrap();
257 manager.remove(uid, task_id);
279 let (mut manager, mut client_rx) = init_manager();
293 let task_id = manager.create(config).unwrap();
294 manager.start(uid, task_id);
295 manager.scheduler.task_completed(uid, task_id);
317 let (mut manager, mut client_rx) = init_manager();
331 let task_id = manager.create(config).unwrap();
332 manager.start(uid, task_id);
333 manager.scheduler.task_failed(uid, task_id, Reason::IoError);
355 let (mut manager, mut client_rx) = init_manager();
369 let task_id = manager.create(config).unwrap();
370 manager.start(uid, task_id);
371 manager.pause(uid, task_id);
372 manager.scheduler.task_completed(uid, task_id);
373 manager.resume(uid, task_id);
393 let (mut manager, mut client_rx) = init_manager();
407 let task_id = manager.create(config).unwrap();
408 manager.start(uid, task_id);
409 manager.pause(uid, task_id);
410 manager.scheduler.task_failed(uid, task_id, Reason::IoError);
411 manager.resume(uid, task_id);