| /base/startup/init/interfaces/innerkits/include/ |
| H A D | loop_event.h | 60 typedef LoopBase *TaskHandle;
typedef
71 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle);
77 void LE_FreeBuffer(const LoopHandle loopHandle, const TaskHandle taskHandle, const BufferHandle handle);
79 void *LE_GetUserData(const TaskHandle handle);
82 typedef void (*LE_Close)(const TaskHandle taskHandle);
99 typedef void (*LE_DisConnectComplete)(const TaskHandle client);
100 typedef void (*LE_ConnectComplete)(const TaskHandle client);
101 typedef void (*LE_SendMessageComplete)(const TaskHandle taskHandle, BufferHandle handle);
102 typedef void (*LE_RecvMessage)(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen);
103 typedef int (*LE_IncommingConnect)(const LoopHandle loopHandle, const TaskHandle serverTas
[all...] |
| /base/request/request/pre_download/native/src/download/ |
| H A D | wrapper.rs | 18 use super::task::{DownloadTask, TaskHandle};
20 pub fn pre_download(url: String, options: PreDownloadOptions) -> Box<TaskHandle> { in pre_download()
66 type TaskHandle; types
68 fn pre_download(url: String, options: PreDownloadOptions) -> Box<TaskHandle>; in pre_download()
69 fn cancel(self: &mut TaskHandle); in cancel()
|
| H A D | task.rs | 71 ) -> TaskHandle {
78 TaskHandle { inner: task }
82 pub struct TaskHandle { structure names
86 impl TaskHandle { impls
|
| /base/msdp/device_status/rust/modules/scheduler/sys/src/ |
| H A D | lib.rs | 41 pub use task::TaskHandle;
97 /// Calling `TaskHandle::result` to get the result of the task. Calling
98 /// `TaskHandle::result` will block current thread until the task finish.
100 /// Calling `TaskHandle::cancel` to cancel the posted task before it finish.
116 pub fn post_async_task<F, R>(&self, task: F) -> TaskHandle<R> in post_async_task()
125 TaskHandle::from(handle) in post_async_task()
130 /// Calling `TaskHandle::cancel` to cancel the posted task before it finish.
132 pub fn post_delayed_task<F, R>(&self, task: F, delay: Duration) -> TaskHandle<R> in post_delayed_task()
142 TaskHandle::from(handle) in post_delayed_task()
152 /// Calling `TaskHandle
[all...] |
| H A D | task.rs | 22 pub struct TaskHandle<R> { structure names
26 impl<R> From<JoinHandle<R>> for TaskHandle<R> {
35 impl<R> TaskHandle<R> { impls
|
| /base/startup/init/test/unittest/loopevent/ |
| H A D | loopevent_unittest.cpp | 48 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper)
53 static void OnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread)
60 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer, uint32_t buffLen)
68 static int IncomingConnect(LoopHandle loop, TaskHandle server)
110 TaskHandle clientTaskHandle = nullptr;
111 LE_AcceptStreamClient(LE_GetDefaultLoop(), (TaskHandle)serverTask_, &clientTaskHandle, &streamInfo);
116 (TaskHandle)clientTaskHandle, 0);
118 (TaskHandle)clientTaskHandle, EVENT_READ);
120 TaskHandle clientTaskHandlec = nullptr;
127 TaskHandle clientTaskHandle
[all...] |
| H A D | loopserver_unittest.cpp | 66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *message, ...) in SendMessage()
85 static void TestOnClose(const TaskHandle taskHandle) in TestOnClose()
89 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper) in TestHandleTaskEvent()
94 static void TestOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in TestOnReceiveRequest()
106 static void TestClientOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in TestClientOnReceiveRequest()
120 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer, uint32_t buffLen) in ProcessAsyncEvent()
128 static void TestSendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in TestSendMessageComplete()
140 static int TestTcpIncomingConnect(LoopHandle loop, TaskHandle server) in TestTcpIncomingConnect()
144 TaskHandle stream; in TestTcpIncomingConnect()
157 static int TestPipIncomingConnect(LoopHandle loop, TaskHandle serve
[all...] |
| H A D | loopsignal_unittest.cpp | 59 ((BaseTask *)g_sigHandler)->handleEvent(loopClient, (TaskHandle)&g_sigHandler, EVENT_WRITE); in HWTEST_F()
|
| /base/startup/init/services/loopevent/task/ |
| H A D | le_streamtask.c | 26 const TaskHandle taskHandle, const LE_SendMessageComplete complete)
in HandleSendMsg_()
54 const TaskHandle taskHandle, const LE_RecvMessage recvMessage, const LE_HandleRecvMsg handleRecvMsg)
in HandleRecvMsg_()
92 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t oper)
in HandleStreamEvent_()
113 static LE_STATUS HandleClientEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t oper)
in HandleClientEvent_()
137 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)
in HandleStreamTaskClose_()
147 static void DumpStreamServerTaskInfo_(const TaskHandle task)
in DumpStreamServerTaskInfo_()
161 static void DumpStreamConnectTaskInfo_(const TaskHandle task)
in DumpStreamConnectTaskInfo_()
166 TaskHandle taskHandle = (TaskHandle)connectTask;
in DumpStreamConnectTaskInfo_()
183 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTas
[all...] |
| H A D | le_asynctask.c | 39 asyncTask->processAsyncEvent((TaskHandle)asyncTask, eventId,
in DoAsyncEvent_()
58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle)
in LE_DoAsyncEvent()
67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper)
in HandleAsyncEvent_()
91 static void HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)
in HandleAsyncTaskClose_()
99 static void DumpEventTaskInfo_(const TaskHandle task)
in DumpEventTaskInfo_()
109 TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent)
in LE_CreateAsyncTask()
128 *taskHandle = (TaskHandle)task;
in LE_CreateAsyncTask()
133 const TaskHandle taskHandle, uint64_t eventId, const uint8_t *data, uint32_t buffLen)
in LE_StartAsyncEvent()
149 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle)
in LE_StopAsyncTask()
|
| H A D | le_watchtask.c | 18 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)
in HandleWatcherTaskClose_()
25 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper)
in HandleWatcherEvent_()
39 HandleWatcherTaskClose_((LoopHandle)loop, (TaskHandle)watcher);
in HandleWatcherEvent_()
43 HandleWatcherTaskClose_((LoopHandle)loop, (TaskHandle)watcher);
in HandleWatcherEvent_()
53 static void DumpWatcherTaskInfo_(const TaskHandle task)
in DumpWatcherTaskInfo_()
|
| H A D | le_task.h | 54 typedef LE_STATUS (*HandleTaskEvent)(const LoopHandle loop, const TaskHandle task, uint32_t oper);
55 typedef void (*HandleTaskClose)(const LoopHandle loop, const TaskHandle task);
56 typedef void (*DumpTaskInfo)(const TaskHandle task);
135 int GetSocketFd(const TaskHandle task);
|
| H A D | le_task.c | 30 int GetSocketFd(const TaskHandle task)
in GetSocketFd()
70 task->close((TaskHandle)task);
in CloseTask()
151 void LE_FreeBuffer(const LoopHandle loop, const TaskHandle taskHandle, const BufferHandle handle)
in LE_FreeBuffer()
170 const TaskHandle taskHandle, const BufferHandle buffHandle, uint32_t buffLen)
in LE_Send()
190 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle)
in LE_CloseTask()
205 void *LE_GetUserData(TaskHandle handle)
in LE_GetUserData()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| H A D | control_fd.h | 45 TaskHandle serverTask;
50 TaskHandle task;
57 TaskHandle task;
|
| H A D | control_fd_service.c | 31 static void OnClose(const TaskHandle task) in OnClose()
39 CONTROL_FD_STATIC int CheckSocketPermission(const TaskHandle task) in CheckSocketPermission()
55 CONTROL_FD_STATIC void CmdOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_t buffLen) in CmdOnRecvMessage()
98 CONTROL_FD_STATIC int SendMessage(LoopHandle loop, TaskHandle task, const char *message) in SendMessage()
117 CONTROL_FD_STATIC int CmdOnIncommingConnect(const LoopHandle loop, const TaskHandle server) in CmdOnIncommingConnect()
119 TaskHandle client = NULL; in CmdOnIncommingConnect()
|
| H A D | control_fd_client.c | 75 CONTROL_FD_STATIC void CmdClientOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_t buffLen) in CmdClientOnRecvMessage()
80 CONTROL_FD_STATIC void CmdOnConnectComplete(const TaskHandle client) in CmdOnConnectComplete()
85 CONTROL_FD_STATIC void CmdOnClose(const TaskHandle task) in CmdOnClose()
95 CONTROL_FD_STATIC void CmdDisConnectComplete(const TaskHandle client) in CmdDisConnectComplete()
100 CONTROL_FD_STATIC void CmdOnSendMessageComplete(const TaskHandle task, const BufferHandle handle) in CmdOnSendMessageComplete()
111 TaskHandle task = NULL; in CmdAgentCreate()
|
| /base/startup/appspawn/test/unittest/ |
| H A D | app_spawn_test_helper.h | 219 TaskHandle stream;
245 static int OnConnection(const LoopHandle loopHandle, const TaskHandle server);
246 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle);
247 static void OnClose(const TaskHandle taskHandle);
248 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen);
249 TaskHandle serverHandle_ = 0;
|
| H A D | app_spawn_test_helper.cpp | 249 static int HandleRecvMessage(const TaskHandle taskHandle, uint8_t * buffer, int bufferSize, int flags) in HandleRecvMessage()
284 int LocalTestServer::OnConnection(const LoopHandle loopHandle, const TaskHandle server) in OnConnection()
287 TaskHandle stream; in OnConnection()
315 void LocalTestServer::SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete()
320 void LocalTestServer::OnClose(const TaskHandle taskHandle) in OnClose()
339 void LocalTestServer::OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) in OnReceiveRequest()
|
| /base/startup/init/test/unittest/innerkits/ |
| H A D | innerkits_unittest.cpp | 36 void CmdDisConnectComplete(const TaskHandle client);
37 void CmdOnSendMessageComplete(const TaskHandle task, const BufferHandle handle);
38 void CmdOnClose(const TaskHandle task);
39 void CmdOnConnectComplete(const TaskHandle client);
40 void CmdOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_t buffLen);
43 int CmdOnIncommingConnect(const LoopHandle loop, const TaskHandle server);
45 void CmdClientOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_t buffLen);
47 int SendMessage(LoopHandle loop, TaskHandle task, const char *message);
50 int CheckSocketPermission(const TaskHandle task);
317 static int TestIncommingConnect(const LoopHandle loop, const TaskHandle serve
[all...] |
| /base/request/request/pre_download/native/include/ |
| H A D | pre_download.h | 24 struct TaskHandle;
|
| /base/startup/init/test/systest/ |
| H A D | loopserver_systest.c | 53 TaskHandle stream;
59 TaskHandle serverTask;
122 static int CreatePipeServer(TaskHandle *server, const char *name) in CreatePipeServer()
150 static int CreateTcpServer(TaskHandle *server, const char *name) in CreateTcpServer()
187 static int SendMessage(LoopHandle loop, TaskHandle task, const char *message) in SendMessage()
217 static int OnConnection(const LoopHandle loop, const TaskHandle server) in OnConnection()
219 TaskHandle stream = NULL; in OnConnection()
251 static void OnClose(const TaskHandle taskHandle) in OnClose()
260 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect()
271 static void SendMessageComplete(const TaskHandle taskHandl
[all...] |
| /base/startup/init/services/loopevent/signal/ |
| H A D | le_signal.c | 28 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper)
in HandleSignalEvent_()
43 static void HandleSignalTaskClose_(const LoopHandle loopHandle, const TaskHandle signalHandle)
in HandleSignalTaskClose_()
65 static void DumpSignalTaskInfo_(const TaskHandle task)
in DumpSignalTaskInfo_()
|
| /base/startup/appspawn/standard/ |
| H A D | appspawn_service.h | 57 TaskHandle stream;
|
| /base/startup/init/services/param/linux/ |
| H A D | param_message.h | 106 int OnIncomingConnect(LoopHandle loop, TaskHandle server);
|
| /base/startup/init/services/loopevent/loop/ |
| H A D | le_epoll.c | 55 int fd = GetSocketFd((const TaskHandle)task); in AddEvent_()
71 int fd = GetSocketFd((const TaskHandle)task); in ModEvent_()
|