Searched refs:dispatch (Results 1 - 3 of 3) sorted by relevance
/base/msdp/device_status/rust/modules/scheduler/test/src/ |
H A D | lib.rs | 58 fn dispatch(&mut self, events: u32) in dispatch() functions 60 call_debug_enter!("EpollHandlerImpl::dispatch"); in dispatch() 70 info!(LOG_LABEL, "EpollHandlerImpl::dispatch({}), data:{}", @public(self.fds[0]), @public(data)); in dispatch() 150 fn dispatch(&self, events: u32) in dispatch() functions 152 call_debug_enter!("EpollHandler::dispatch"); in dispatch() 154 guard.dispatch(events); in dispatch()
|
/base/msdp/device_status/rust/modules/scheduler/sys/src/ |
H A D | scheduler.rs | 59 fn dispatch(&self, events: u32); in dispatch() functions 337 fn dispatch(&self, fd: RawFd, waker: &Waker) in dispatch() functions 339 call_debug_enter!("Epoll::dispatch"); in dispatch() 341 handler.dispatch(events); in dispatch() 386 self.epoll.dispatch(self.fd, cx.waker()); in poll() 434 fn dispatch(&self, events: u32) in dispatch() functions
|
/base/security/security_guard/services/data_collect/sa/ |
H A D | data_collect_manager_service.cpp | 269 std::string dispatch = nlohmann::json(dispatchVec).dump();
in PushDataCollectTask() 270 SGLOGD("dispatch size=%{public}zu", dispatch.size());
in PushDataCollectTask() 271 (void) proxy->ResponseRiskData(devId, dispatch, CONTINUE);
in PushDataCollectTask() 276 // last dispatch
in PushDataCollectTask() 278 std::string dispatch = nlohmann::json(dispatchVec).dump();
in PushDataCollectTask() 279 (void) proxy->ResponseRiskData(devId, dispatch, FINISH);
in PushDataCollectTask()
|
Completed in 3 milliseconds