Searched refs:ParamMessage (Results 1 - 11 of 11) sorted by relevance
| /base/startup/init/services/param/linux/ |
| H A D | param_message.c | 44 int FillParamMsgContent(const ParamMessage *request, uint32_t *start, int type, const char *value, uint32_t length)
in FillParamMsgContent()
48 uint32_t bufferSize = request->msgSize - sizeof(ParamMessage);
in FillParamMsgContent()
65 ParamMessage *CreateParamMessage(int type, const char *name, uint32_t msgSize)
in CreateParamMessage()
70 if (msgSize < sizeof(ParamMessage)) {
in CreateParamMessage()
71 size = sizeof(ParamMessage);
in CreateParamMessage()
73 ParamMessage *msg = (ParamMessage *)calloc(1, size);
in CreateParamMessage()
84 ParamMsgContent *GetNextContent(const ParamMessage *request, uint32_t *offset)
in GetNextContent()
88 ParamMessage *msg = (ParamMessage *)reques in GetNextContent()
[all...] |
| H A D | param_message.h | 67 } ParamMessage;
typedef
70 ParamMessage msg;
74 typedef int (*RecvMessage)(const ParamTaskPtr stream, const ParamMessage *msg);
91 int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg);
98 int FillParamMsgContent(const ParamMessage *request, uint32_t *start, int type, const char *value, uint32_t length);
99 ParamMsgContent *GetNextContent(const ParamMessage *request, uint32_t *offset);
100 ParamMessage *CreateParamMessage(int type, const char *name, uint32_t msgSize);
105 int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg);
|
| H A D | param_request.c | 72 static int ProcessRecvMsg(const ParamMessage *recvMsg)
in ProcessRecvMsg()
117 if ((size_t)recvLen > sizeof(ParamMessage)) {
in ReadMessage()
147 static int StartRequest(int clientFd, ParamMessage *request, int timeout)
in StartRequest()
178 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, name, msgSize);
in SystemSetParameter_()
184 request->msgSize = offset + sizeof(ParamMessage);
in SystemSetParameter_()
233 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SAVE_PARAM, name, msgSize);
in SystemSaveParameters()
241 request->msgSize = offset + sizeof(ParamMessage);
in SystemSaveParameters()
260 uint32_t msgSize = sizeof(ParamMessage) in SystemWaitParameter()
[all...] |
| H A D | param_msgadp.c | 36 const ParamMessage *msg = (const ParamMessage *)(buffer + curr);
in OnReceiveRequest()
38 (nread - curr < sizeof(ParamMessage)) ||
in OnReceiveRequest()
39 (msg->msgSize < sizeof(ParamMessage))) {
in OnReceiveRequest()
87 int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg)
in ParamTaskSendMsg()
|
| H A D | param_service.c | 87 static int SendResponseMsg(ParamTaskPtr worker, const ParamMessage *msg, int result)
in SendResponseMsg()
95 ParamTaskSendMsg(worker, (ParamMessage *)response);
in SendResponseMsg()
104 uint32_t msgSize = sizeof(ParamMessage) + PARAM_ALIGN(strlen(content) + 1);
in SendWatcherNotifyMessage()
105 ParamMessage *msg = (ParamMessage *)CreateParamMessage(MSG_NOTIFY_PARAM, "*", msgSize);
in SendWatcherNotifyMessage()
131 msg->msgSize = sizeof(ParamMessage) + offset;
in SendWatcherNotifyMessage()
161 static int HandleParamSet(const ParamTaskPtr worker, const ParamMessage *msg)
in HandleParamSet()
234 static int HandleParamWaitAdd(const ParamTaskPtr worker, const ParamMessage *msg)
in HandleParamWaitAdd()
287 static int HandleParamWatcherAdd(const ParamTaskPtr worker, const ParamMessage *msg)
in HandleParamWatcherAdd()
307 static int HandleParamWatcherDel(const ParamTaskPtr worker, const ParamMessage *ms
[all...] |
| /base/startup/init/test/unittest/param/ |
| H A D | paramservice_unittest.cpp | 321 uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + PARAM_ALIGN(strlen(value) + 1); in TestServiceProcessMessage()
322 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, name, msgSize); in TestServiceProcessMessage()
329 ProcessMessage((const ParamTaskPtr)g_worker, (const ParamMessage *)request); in TestServiceProcessMessage()
344 uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + sizeof(ParamMsgContent) in AddWatch()
346 ParamMessage *request = (ParamMessage *)(ParamMessage *)CreateParamMessage(type, name, msgSize); in AddWatch()
358 request->msgSize = offset + sizeof(ParamMessage); in AddWatch()
360 ProcessMessage((const ParamTaskPtr)g_worker, (const ParamMessage *)reques in AddWatch()
[all...] |
| H A D | watcher_proxy_unittest.cpp | 169 uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + value.size(); in TestProcessWatcherMessage()
172 ParamMessage *msg = reinterpret_cast<ParamMessage *>(buffer.data()); in TestProcessWatcherMessage()
|
| H A D | param_unittest.cpp | 584 const int msgSize = sizeof(ParamMessage) + 128; // 128 TEST in HWTEST_F()
585 ParamMessage *msg = CreateParamMessage(0, nullptr, msgSize); in HWTEST_F()
611 msg->msgSize = start + sizeof(ParamMessage); in HWTEST_F()
|
| /base/startup/init/test/unittest/loopevent/ |
| H A D | loopevent_unittest.cpp | 165 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, "name", sizeof(ParamMessage));
167 sizeof(ParamMessage));
|
| /base/startup/init/services/param/watcher/proxy/ |
| H A D | watcher_manager.cpp | 156 ParamMessage *request = nullptr; in SendMessage()
161 request = (ParamMessage *)CreateParamMessage(type, key.c_str(), sizeof(ParamMessage)); in SendMessage()
164 request->msgSize = sizeof(ParamMessage); in SendMessage()
206 void WatcherManager::ProcessWatcherMessage(const ParamMessage *msg) in ProcessWatcherMessage()
285 if (sizeof(ParamMessage) >= dataLen - curr) { in RunLoop()
288 ParamMessage *msg = (ParamMessage *)(buffer.data() + curr); in RunLoop()
|
| H A D | watcher_manager.h | 108 void ProcessWatcherMessage(const ParamMessage *msg);
|
Completed in 9 milliseconds