Lines Matching refs:u32
48 pub(crate) fn construct(config: TaskConfig) -> (Self, Recv<Result<u32, ErrorCode>>) { in construct() argument
49 let (tx, rx) = channel::<Result<u32, ErrorCode>>(); in construct()
59 pub(crate) fn pause(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) { in pause()
67 pub(crate) fn start(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) { in start()
75 pub(crate) fn stop(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) { in stop()
83 pub(crate) fn remove(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) { in remove()
91 pub(crate) fn resume(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) { in resume()
104 pub(crate) fn dump_one(task_id: u32) -> (Self, Recv<Option<DumpOneInfo>>) { in dump_one()
116 pub(crate) fn subscribe(task_id: u32, token_id: u64) -> (Self, Recv<ErrorCode>) { in subscribe() argument
127 Query(u32, Action, Sender<Option<TaskInfo>>),
128 Show(u32, u64, Sender<Option<TaskInfo>>),
129 Touch(u32, u64, String, Sender<Option<TaskInfo>>),
133 Construct(Box<ConstructMessage>, Sender<Result<u32, ErrorCode>>),
134 Pause(u64, u32, Sender<ErrorCode>),
135 Start(u64, u32, Sender<ErrorCode>),
136 Stop(u64, u32, Sender<ErrorCode>),
137 Remove(u64, u32, Sender<ErrorCode>),
138 Resume(u64, u32, Sender<ErrorCode>),
139 DumpOne(u32, Sender<Option<DumpOneInfo>>),
145 Completed(u32, u64, Mode),
146 Failed(u32, u64, Reason, Mode),
147 Offline(u32, u64, Mode),
148 Running(u32, u64, Mode),
149 Subscribe(u32, u64, Sender<ErrorCode>),