Home
last modified time | relevance | path

Searched refs:ParamMessage (Results 1 – 11 of 11) sorted by relevance

/ohos5.0/base/startup/init/services/param/linux/
H A Dparam_message.c44 int FillParamMsgContent(const ParamMessage *request, uint32_t *start, int type, const char *value, … 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 *)request; in GetNextContent()
89 if ((*offset + sizeof(ParamMessage) + sizeof(ParamMsgContent)) >= msg->msgSize) { in GetNextContent()
H A Dparam_message.h67 } 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, …
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 Dparam_request.c72 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()
263 ParamMessage *request = NULL; in SystemWaitParameter()
266 request = (ParamMessage *)CreateParamMessage(MSG_WAIT_PARAM, name, msgSize); in SystemWaitParameter()
271 request = (ParamMessage *)CreateParamMessage(MSG_WAIT_PARAM, name, msgSize); in SystemWaitParameter()
[all …]
H A Dparam_service.c87 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 *msg) in HandleParamWatcherDel()
315 static int HandleParamSave(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSave()
[all …]
H A Dparam_msgadp.c36 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()
/ohos5.0/base/startup/init/test/unittest/param/
H A Dparamservice_unittest.cpp321 …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 *)request); in AddWatch()
H A Dwatcher_proxy_unittest.cpp169 uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + value.size(); in TestProcessWatcherMessage()
172 ParamMessage *msg = reinterpret_cast<ParamMessage *>(buffer.data()); in TestProcessWatcherMessage()
H A Dparam_unittest.cpp565 const int msgSize = sizeof(ParamMessage) + 128; // 128 TEST
566 ParamMessage *msg = CreateParamMessage(0, nullptr, msgSize);
592 msg->msgSize = start + sizeof(ParamMessage);
/ohos5.0/base/startup/init/test/unittest/loopevent/
H A Dloopevent_unittest.cpp165 …ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, "name", sizeof(ParamMess… in LeTaskTest()
167 sizeof(ParamMessage)); in LeTaskTest()
/ohos5.0/base/startup/init/services/param/watcher/proxy/
H A Dwatcher_manager.cpp156 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 Dwatcher_manager.h108 void ProcessWatcherMessage(const ParamMessage *msg);