Searched refs:ParamTaskPtr (Results 1 – 13 of 13) sorted by relevance
| /base/startup/init/services/param/linux/ |
| D | param_message.h | 73 typedef int (*RecvMessage)(const ParamTaskPtr stream, const ParamMessage *msg);
86 int ParamTaskClose(const ParamTaskPtr stream);
87 int ParamServerCreate(ParamTaskPtr *stream, const ParamStreamInfo *streamInfo);
88 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server,
90 int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg);
92 int ParamEventTaskCreate(ParamTaskPtr *stream, LE_ProcessAsyncEvent eventProcess);
93 int ParamEventSend(const ParamTaskPtr stream, uint64_t eventId, const char *content, uint32_t size);
95 void *ParamGetTaskUserData(const ParamTaskPtr stream);
104 int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg);
|
| D | param_msgadp.c | 47 int ParamServerCreate(ParamTaskPtr *stream, const ParamStreamInfo *streamInfo) in ParamServerCreate()
59 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server, in ParamStreamCreate()
81 void *ParamGetTaskUserData(const ParamTaskPtr stream) in ParamGetTaskUserData()
87 int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg) in ParamTaskSendMsg()
103 int ParamEventTaskCreate(ParamTaskPtr *stream, LE_ProcessAsyncEvent eventProcess) in ParamEventTaskCreate()
109 int ParamEventSend(const ParamTaskPtr stream, uint64_t eventId, const char *content, uint32_t size) in ParamEventSend()
116 int ParamTaskClose(const ParamTaskPtr stream) in ParamTaskClose()
124 int ParamTimerCreate(ParamTaskPtr *timer, ProcessTimer process, void *context) in ParamTimerCreate()
131 int ParamTimerStart(const ParamTaskPtr timer, uint64_t timeout, uint64_t repeat) in ParamTimerStart()
137 void ParamTimerClose(ParamTaskPtr timer) in ParamTimerClose()
[all …]
|
| D | param_service.c | 37 PARAM_STATIC void OnClose(ParamTaskPtr client) in OnClose()
48 static void TimerCallback(const ParamTaskPtr timer, void *context) in TimerCallback()
85 static int SendResponseMsg(ParamTaskPtr worker, const ParamMessage *msg, int result) in SendResponseMsg()
155 static int HandleParamSet(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSet()
228 static int HandleParamWaitAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWaitAdd()
281 static int HandleParamWatcherAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherAdd()
301 static int HandleParamWatcherDel(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherDel()
309 PARAM_STATIC int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg) in ProcessMessage()
344 ParamTaskPtr client = NULL; in OnIncomingConnect()
|
| /base/startup/init/services/param/include/ |
| D | param_osadp.h | 115 typedef ParamTimer *ParamTaskPtr; typedef
117 typedef LoopBase *ParamTaskPtr;
118 typedef void (*ProcessTimer)(const ParamTaskPtr taskHandle, void *context);
121 int ParamTimerCreate(ParamTaskPtr *timer, ProcessTimer process, void *context);
122 int ParamTimerStart(const ParamTaskPtr timer, uint64_t timeout, uint64_t repeat);
123 void ParamTimerClose(ParamTaskPtr timer);
|
| D | param_manager.h | 79 ParamTaskPtr serverTask;
80 ParamTaskPtr timer;
81 ParamTaskPtr watcherTask;
87 ParamTaskPtr saveTimer;
|
| D | trigger_manager.h | 72 ParamTaskPtr stream;
145 ParamTaskPtr stream;
157 ParamTaskPtr stream;
164 ParamTaskPtr eventHandle;
201 void ProcessBeforeEvent(const ParamTaskPtr stream, uint64_t eventId, const uint8_t *content, uint32…
|
| D | param_persist.h | 50 void TimerCallbackForSave(ParamTaskPtr timer, void *context);
|
| /base/startup/init/services/param/liteos/ |
| D | param_osadp.c | 71 int ParamTimerCreate(ParamTaskPtr *timer, ProcessTimer process, void *context) in ParamTimerCreate()
94 int ParamTimerStart(const ParamTaskPtr timer, uint64_t timeout, uint64_t repeat) in ParamTimerStart()
104 void ParamTimerClose(ParamTaskPtr timer) in ParamTimerClose()
|
| /base/startup/init/test/unittest/loopevent/ |
| D | loopevent_unittest.cpp | 155 ParamTaskPtr client = nullptr; in LeTaskTest()
219 ParamTaskPtr serverTask = nullptr; in CreateSocketTest()
240 ParamTaskPtr serverTask_ = nullptr;
|
| /base/startup/init/test/unittest/param/ |
| D | paramservice_unittest.cpp | 45 static ParamTaskPtr g_worker = nullptr;
302 ParamTaskPtr CreateAndGetStreamTask() in CreateAndGetStreamTask()
330 ProcessMessage((const ParamTaskPtr)g_worker, (const ParamMessage *)request); in TestServiceProcessMessage()
361 ProcessMessage((const ParamTaskPtr)g_worker, (const ParamMessage *)request); in AddWatch()
|
| D | param_unittest.cpp | 611 ParamTaskPtr serverTask = nullptr;
627 ParamTaskPtr client = nullptr;
|
| /base/startup/init/services/param/manager/ |
| D | param_persist.c | 155 PARAM_STATIC void TimerCallbackForSave(const ParamTaskPtr timer, void *context) in TimerCallbackForSave()
|
| /base/startup/init/services/param/trigger/ |
| D | trigger_processor.c | 115 PARAM_STATIC void ProcessBeforeEvent(const ParamTaskPtr stream, in ProcessBeforeEvent()
|