Home
last modified time | relevance | path

Searched refs:dispatch (Results 1 - 3 of 3) sorted by relevance

/base/msdp/device_status/rust/modules/scheduler/test/src/
H A Dlib.rs58 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 Dscheduler.rs59 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 Ddata_collect_manager_service.cpp269 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