Home
last modified time | relevance | path

Searched refs:dispatcher (Results 1 - 25 of 116) sorted by relevance

12345

/drivers/hdf_core/framework/model/network/wifi/platform/src/message/
H A Dmessage_dispatcher.c84 ErrorCode AppendToLocalDispatcher(MessageDispatcher *dispatcher, const uint8_t priority, MessageContext *context) in AppendToLocalDispatcher() argument
90 if (dispatcher == NULL) { in AppendToLocalDispatcher()
91 HDF_LOGE("%s:Input dispatcher is NULL!", __func__); in AppendToLocalDispatcher()
95 if (dispatcher->messageQueue == NULL) { in AppendToLocalDispatcher()
100 if (dispatcher->status != ME_STATUS_RUNNING) { in AppendToLocalDispatcher()
105 return PushPriorityQueue(dispatcher->messageQueue, priority, context); in AppendToLocalDispatcher()
228 static void ReleaseAllMessage(MessageDispatcher *dispatcher) in ReleaseAllMessage() argument
233 context = PopPriorityQueue(dispatcher->messageQueue, 0); in ReleaseAllMessage()
240 MessageDispatcher *dispatcher = NULL; in RunDispatcher() local
243 HDF_LOGE("Start dispatcher faile in RunDispatcher()
284 StartDispatcher(MessageDispatcher *dispatcher) StartDispatcher() argument
344 ShutdownDispatcher(MessageDispatcher *dispatcher) ShutdownDispatcher() argument
373 DestroyLocalDispatcher(MessageDispatcher *dispatcher) DestroyLocalDispatcher() argument
397 CreateLocalDispatcher(MessageDispatcher **dispatcher, const DispatcherConfig *config) CreateLocalDispatcher() argument
[all...]
H A Dmessage_router.c109 static ErrorCode RegDispatcher(DispatcherId dispatcherId, MessageDispatcher *dispatcher) in RegDispatcher() argument
114 HDF_LOGE("%s:dispatcher id is too big!id=%u", __func__, dispatcherId); in RegDispatcher()
134 g_dispatchers[dispatcherId] = dispatcher; in RegDispatcher()
149 MessageDispatcher *dispatcher = NULL; in AddDispatcher() local
154 errCode = CreateLocalDispatcher(&dispatcher, config); in AddDispatcher()
156 HDF_LOGE("%s: Create local dispatcher failed! errCode=%d", __func__, errCode); in AddDispatcher()
159 if (dispatcher == NULL) { in AddDispatcher()
164 if (dispatcher->Start != NULL) { in AddDispatcher()
165 errCode = dispatcher->Start(dispatcher); in AddDispatcher()
276 MessageDispatcher *dispatcher = NULL; RegistServiceInner() local
[all...]
/drivers/hdf_core/framework/support/platform/src/watchdog/
H A Dwatchdog_if_u.c60 if (service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in WatchdogOpen()
73 ret = service->dispatcher->Dispatch(&service->object, WATCHDOG_IO_GET_PRIV, NULL, reply); in WatchdogOpen()
99 if (service == NULL ||service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in WatchdogClose()
105 ret = service->dispatcher->Dispatch(&service->object, WATCHDOG_IO_RELEASE_PRIV, NULL, NULL); in WatchdogClose()
124 if (service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in WatchdogGetStatus()
135 ret = service->dispatcher->Dispatch(&service->object, WATCHDOG_IO_GET_STATUS, NULL, reply); in WatchdogGetStatus()
162 if (service->dispatcher in WatchdogStart()
[all...]
/drivers/hdf_core/framework/support/platform/src/hdmi/
H A Dhdmi_if.c74 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in HdmiUserClose()
79 ret = service->dispatcher->Dispatch(&service->object, HDMI_CMD_CLOSE, NULL, NULL); in HdmiUserClose()
90 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in HdmiUserStart()
95 ret = service->dispatcher->Dispatch(&service->object, HDMI_CMD_START, NULL, NULL); in HdmiUserStart()
108 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in HdmiUserStop()
113 ret = service->dispatcher->Dispatch(&service->object, HDMI_CMD_STOP, NULL, NULL); in HdmiUserStop()
127 if (service == NULL || service->dispatcher in HdmiUserAvmuteSet()
[all...]
/drivers/hdf_core/framework/core/manager/test/unittest/common/
H A Dhdf_pm_test.cpp30 ioService->dispatcher->Dispatch(&ioService->object, HDF_PM_TEST_BEGEN, nullptr, nullptr); in SetUpTestCase()
36 ioService->dispatcher->Dispatch(&ioService->object, HDF_PM_TEST_END, nullptr, nullptr); in TearDownTestCase()
58 int32_t ret = ioService->dispatcher->Dispatch(&ioService->object, HDF_PM_TEST_ONE_DRIVER_ONCE, nullptr, nullptr); in HWTEST_F()
72 int32_t ret = ioService->dispatcher->Dispatch(&ioService->object, HDF_PM_TEST_ONE_DRIVER_TWICE, nullptr, nullptr); in HWTEST_F()
86 int32_t ret = ioService->dispatcher->Dispatch(&ioService->object, HDF_PM_TEST_ONE_DRIVER_TEN, nullptr, nullptr); in HWTEST_F()
100 int32_t ret = ioService->dispatcher->Dispatch( in HWTEST_F()
115 int32_t ret = ioService->dispatcher->Dispatch( in HWTEST_F()
130 int32_t ret = ioService->dispatcher->Dispatch(&ioService->object, HDF_PM_TEST_TWO_DRIVER_ONCE, nullptr, nullptr); in HWTEST_F()
144 int32_t ret = ioService->dispatcher->Dispatch(&ioService->object, HDF_PM_TEST_TWO_DRIVER_TWICE, nullptr, nullptr); in HWTEST_F()
158 int32_t ret = ioService->dispatcher in HWTEST_F()
[all...]
/drivers/hdf_core/framework/support/platform/src/clock/
H A Dclock_if_u.c40 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in ClockOpen()
65 ret = service->dispatcher->Dispatch(&service->object, CLOCK_IO_OPEN, data, reply); in ClockOpen()
94 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in ClockClose()
111 ret = service->dispatcher->Dispatch(&service->object, CLOCK_IO_CLOSE, data, NULL); in ClockClose()
131 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in ClockEnable()
148 ret = service->dispatcher->Dispatch(&service->object, CLOCK_IO_ENABLE, data, NULL); in ClockEnable()
168 if (service == NULL || service->dispatcher in ClockDisable()
[all...]
/drivers/peripheral/usb/sample/device/liteos/lib/src/
H A Dlib_acm_test.c46 if (g_acmService == NULL || g_acmService->dispatcher == NULL || g_acmService->dispatcher->Dispatch == NULL) { in check_service()
61 if (g_acmService == NULL || g_acmService->dispatcher == NULL || g_acmService->dispatcher->Dispatch == NULL) { in AcmOpen()
70 status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_OPEN, g_data, g_reply); in AcmOpen()
83 status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_CLOSE, g_data, g_reply); in AcmClose()
100 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_WRITE, g_data, g_reply); in AcmWrite()
118 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_READ, g_data, g_reply); in AcmRead()
145 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_REGIST_PROP, g_data, g_reply); in acm_prop_regist()
163 if (g_acmService == NULL || g_acmService->dispatcher in acm_prop_write()
[all...]
/drivers/hdf_core/framework/support/platform/src/rtc/
H A Drtc_if_u.c78 if (service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in RtcReadTime()
84 ret = service->dispatcher->Dispatch(&service->object, RTC_IO_READTIME, NULL, reply); in RtcReadTime()
142 if (service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in RtcWriteTime()
148 ret = service->dispatcher->Dispatch(&service->object, RTC_IO_WRITETIME, data, NULL); in RtcWriteTime()
193 if (service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in RtcReadAlarm()
199 ret = service->dispatcher->Dispatch(&service->object, RTC_IO_READALARM, data, reply); in RtcReadAlarm()
264 if (service->dispatcher in RtcWriteAlarm()
[all...]
/drivers/hdf_core/framework/support/platform/src/dac/
H A Ddac_if_u.c42 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in DacOpen()
66 ret = service->dispatcher->Dispatch(&service->object, DAC_IO_OPEN, data, reply); in DacOpen()
97 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in DacClose()
114 ret = service->dispatcher->Dispatch(&service->object, DAC_IO_CLOSE, data, NULL); in DacClose()
133 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in DacWrite()
162 ret = service->dispatcher->Dispatch(&service->object, DAC_IO_WRITE, data, NULL); in DacWrite()
/drivers/hdf_core/framework/support/platform/src/gpio/
H A Dgpio_if_u.c54 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in GpioRead()
79 ret = service->dispatcher->Dispatch(&service->object, GPIO_IO_READ, data, reply); in GpioRead()
106 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in GpioWrite()
129 ret = service->dispatcher->Dispatch(&service->object, GPIO_IO_WRITE, data, NULL); in GpioWrite()
153 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in GpioGetDir()
178 ret = service->dispatcher->Dispatch(&service->object, GPIO_IO_GETDIR, data, reply); in GpioGetDir()
205 if (service == NULL || service->dispatcher in GpioSetDir()
[all...]
/drivers/hdf_core/framework/model/network/wifi/platform/src/message/nodes/
H A Dlocal_node.c28 MessageDispatcher *dispatcher; member
98 if (localService->dispatcher == NULL || localService->dispatcher->AppendMessage == NULL) { in SendMessageLocalNode()
99 HDF_LOGE("This service has no dispatcher!"); in SendMessageLocalNode()
116 return localService->dispatcher->AppendMessage(localService->dispatcher, pri, context); in SendMessageLocalNode()
133 if (localService->dispatcher != NULL && localService->dispatcher->Disref != NULL) { in DestroyLocalNodeRemoteService()
134 localService->dispatcher->Disref(localService->dispatcher); in DestroyLocalNodeRemoteService()
142 CreateLocalNodeService(MessageNode *node, MessageDispatcher *dispatcher, struct ServiceDef *mapper) CreateLocalNodeService() argument
[all...]
/drivers/peripheral/usb/sample/host/src/
H A Dusbhost_ddk_test.c181 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, CMD_READ_PARM, g_data, g_reply); in UsbHostDdkTestAsyncRead()
183 int32_t status = g_acmService->dispatcher->Dispatch(g_acmService, CMD_READ_PARM, g_data, g_reply); in UsbHostDdkTestAsyncRead()
223 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, CMD_WRITE_PARM, g_data, g_reply); in UsbHostDdkTestAsyncWrite()
225 int32_t status = g_acmService->dispatcher->Dispatch(g_acmService, CMD_WRITE_PARM, g_data, g_reply); in UsbHostDdkTestAsyncWrite()
245 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, CMD_READ_DATA_SYNC, g_data, g_reply); in UsbHostDdkTestSyncRead()
247 int32_t status = g_acmService->dispatcher->Dispatch(g_acmService, CMD_READ_DATA_SYNC, g_data, g_reply); in UsbHostDdkTestSyncRead()
282 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, CMD_WRITE_DATA_SYNC, g_data, g_reply); in UsbHostDdkTestSyncWrite()
284 int32_t status = g_acmService->dispatcher->Dispatch(g_acmService, CMD_WRITE_DATA_SYNC, g_data, g_reply); in UsbHostDdkTestSyncWrite()
304 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, CMD_CLASS_CTRL_SYNC, g_data, g_reply); in UsbHostDdkTestCtrlClass()
306 int32_t status = g_acmService->dispatcher in UsbHostDdkTestCtrlClass()
[all...]
/drivers/hdf_core/framework/support/platform/src/pin/
H A Dpin_if_u.c102 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PinGet()
119 ret = service->dispatcher->Dispatch(&service->object, PIN_IO_GET, data, NULL); in PinGet()
149 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PinPut()
168 ret = service->dispatcher->Dispatch(&service->object, PIN_IO_PUT, data, NULL); in PinPut()
188 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PinSetPull()
211 ret = service->dispatcher->Dispatch(&service->object, PIN_IO_SET_PULL, data, NULL); in PinSetPull()
232 if (service == NULL || service->dispatcher in PinGetPull()
[all...]
/drivers/peripheral/usb/sample/device/liteos/
H A Dacm_speed_write.c60 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, in TestSpeed()
74 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, in GetTempSpeed()
92 int32_t status = g_acmService->dispatcher->Dispatch(g_acmService, in WriteSpeedDone()
147 if (g_acmService == NULL || g_acmService->dispatcher == NULL || g_acmService->dispatcher->Dispatch == NULL) { in AcmSpeedWrite()
159 status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_OPEN, g_data, g_reply); in AcmSpeedWrite()
174 status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_CLOSE, g_data, g_reply); in AcmSpeedWrite()
H A Dacm_speed_read.c61 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_READ_SPEED, g_data, g_reply); in TestSpeed()
73 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, in GetTempSpeed()
91 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, in ReadSpeedDone()
145 if (g_acmService == NULL || g_acmService->dispatcher == NULL || g_acmService->dispatcher->Dispatch == NULL) { in AcmSpeedRead()
157 status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_OPEN, g_data, g_reply); in AcmSpeedRead()
H A Dacm_test.c53 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_WRITE, g_data, g_reply); in TestWrite()
62 int32_t status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_READ, g_data, g_reply); in TestRead()
138 if (g_acmService == NULL || g_acmService->dispatcher == NULL || g_acmService->dispatcher->Dispatch == NULL) { in AcmTest()
150 status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_OPEN, g_data, g_reply); in AcmTest()
158 status = g_acmService->dispatcher->Dispatch(&g_acmService->object, USB_SERIAL_CLOSE, g_data, g_reply); in AcmTest()
/drivers/hdf_core/framework/support/platform/src/timer/
H A Dtimer_if_u.c53 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in HwTimerOpen()
77 ret = service->dispatcher->Dispatch(&service->object, TIMER_IO_OPEN, data, reply); in HwTimerOpen()
108 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in HwTimerClose()
125 ret = service->dispatcher->Dispatch(&service->object, TIMER_IO_CLOSE, data, NULL); in HwTimerClose()
145 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in HwTimerStart()
162 ret = service->dispatcher->Dispatch(&service->object, TIMER_IO_START, data, NULL); in HwTimerStart()
185 if (service == NULL || service->dispatcher in HwTimerStop()
[all...]
/drivers/peripheral/audio/test/systemtest/adm/audio_adm_interface/src/
H A Daudio_adm_interface_test.cpp91 ASSERT_NE(nullptr, service->dispatcher); in HWTEST_F()
101 ret = service->dispatcher->Dispatch(&service->object, CONTROL_DISP_METHOD_CMD_ILLEGAL, writeBuf, writeReply); in HWTEST_F()
127 ASSERT_NE(nullptr, service->dispatcher); in HWTEST_F()
138 ret = service->dispatcher->Dispatch(objectNull, AUDIODRV_CTRL_IOCTRL_ELEM_WRITE, writeBuf, writeReply); in HWTEST_F()
162 ASSERT_NE(nullptr, service->dispatcher); in HWTEST_F()
172 ret = service->dispatcher->Dispatch(&service->object, STREAM_DISP_METHOD_CMD_ILLEGAL, sBuf, reply); in HWTEST_F()
197 ASSERT_NE(nullptr, service->dispatcher); in HWTEST_F()
207 ret = service->dispatcher->Dispatch(objectNull, AUDIO_DRV_PCM_IOCTRL_HW_PARAMS, sBuf, reply); in HWTEST_F()
224 ASSERT_NE(nullptr, service->dispatcher); in HWTEST_F()
249 ASSERT_NE(nullptr, service->dispatcher); in HWTEST_F()
[all...]
/drivers/hdf_core/adapter/uhdf2/ipc/src/
H A Dhdf_remote_service.c31 struct HdfRemoteService *HdfRemoteServiceObtain(struct HdfObject *object, struct HdfRemoteDispatcher *dispatcher) in HdfRemoteServiceObtain() argument
34 if ((service != NULL) && (service->dispatcher == NULL)) { in HdfRemoteServiceObtain()
35 service->dispatcher = dispatcher; in HdfRemoteServiceObtain()
/drivers/hdf_core/framework/core/shared/src/
H A Dhdf_io_service.c39 if (ioService == NULL || ioService->dispatcher == NULL || ioService->dispatcher->Dispatch == NULL) { in HdfIoServiceDispatch()
43 return ioService->dispatcher->Dispatch(&ioService->object, cmdId, data, reply); in HdfIoServiceDispatch()
/drivers/hdf_core/framework/model/network/wifi/platform/include/message/
H A Dmessage_dispatcher.h29 ErrorCode (*Start)(struct MessageDispatcher * dispatcher); \
30 void (*Shutdown)(struct MessageDispatcher * dispatcher); \
43 ErrorCode CreateLocalDispatcher(MessageDispatcher **dispatcher, const DispatcherConfig *config);
/drivers/hdf_core/framework/support/platform/src/pcie/
H A Dpcie_if_u.c93 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PcieRead()
131 ret = service->dispatcher->Dispatch(&service->object, PCIE_CMD_READ, buf, reply); in PcieRead()
150 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PcieWrite()
184 ret = service->dispatcher->Dispatch(&service->object, PCIE_CMD_WRITE, buf, NULL); in PcieWrite()
271 if (service == NULL || service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PcieDmaMap()
301 ret = service->dispatcher->Dispatch(&service->object, PCIE_CMD_DMA_MAP, data, NULL); in PcieDmaMap()
319 if (service == NULL || service->dispatcher in PcieDmaUnmap()
[all...]
/drivers/hdf_core/framework/support/platform/src/pwm/
H A Dpwm_if_u.c59 if (service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PwmOpen()
65 ret = service->dispatcher->Dispatch(&service->object, PWM_IO_GET, NULL, NULL); in PwmOpen()
86 if (service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PwmClose()
92 ret = service->dispatcher->Dispatch(&service->object, PWM_IO_PUT, NULL, NULL); in PwmClose()
112 if (service->dispatcher == NULL || service->dispatcher->Dispatch == NULL) { in PwmSetConfig()
128 ret = service->dispatcher->Dispatch(&service->object, PWM_IO_SET_CONFIG, buf, NULL); in PwmSetConfig()
151 if (service->dispatcher in PwmGetConfig()
[all...]
/drivers/peripheral/wlan/client/src/sbuf/
H A Dsbuf_common_adapter.c55 if (g_wifiService == NULL || g_wifiService->dispatcher == NULL || in SendCmdSync()
56 g_wifiService->dispatcher->Dispatch == NULL) { in SendCmdSync()
60 int32_t ret = g_wifiService->dispatcher->Dispatch(&g_wifiService->object, cmd, reqData, respData); in SendCmdSync()
/drivers/peripheral/usb/sample/device/linux/
H A Dacm_speed_read.c37 int32_t status = g_acmService->dispatcher->Dispatch(g_acmService, in TestSpeed()
50 int32_t status = g_acmService->dispatcher->Dispatch(g_acmService, in GetTempSpeed()
68 int32_t status = g_acmService->dispatcher->Dispatch(g_acmService, in ReadSpeedDone()
108 status = g_acmService->dispatcher->Dispatch(g_acmService, USB_SERIAL_OPEN, g_data, g_reply); in AcmSpeedRead()
124 status = g_acmService->dispatcher->Dispatch(g_acmService, USB_SERIAL_CLOSE, g_data, g_reply); in AcmSpeedRead()

Completed in 12 milliseconds

12345