Lines Matching full:msg
87 static int SendResponseMsg(ParamTaskPtr worker, const ParamMessage *msg, int result) in SendResponseMsg() argument
90 …response = (ParamResponseMessage *)CreateParamMessage(msg->type, msg->key, sizeof(ParamResponseMes… in SendResponseMsg()
92 response->msg.id.msgId = msg->id.msgId; in SendResponseMsg()
94 response->msg.msgSize = sizeof(ParamResponseMessage); in SendResponseMsg()
96 PARAM_LOGV("Send response msg msgId %d result %d", msg->id.msgId, result); in SendResponseMsg()
105 ParamMessage *msg = (ParamMessage *)CreateParamMessage(MSG_NOTIFY_PARAM, "*", msgSize); in SendWatcherNotifyMessage() local
106 PARAM_CHECK(msg != NULL, return -1, "Failed to create msg "); in SendWatcherNotifyMessage()
112 ret = strncpy_s(msg->key, sizeof(msg->key) - 1, content, tmp - content); in SendWatcherNotifyMessage()
113 PARAM_CHECK(ret == 0, free(msg); in SendWatcherNotifyMessage()
116 ret = FillParamMsgContent(msg, &offset, PARAM_VALUE, tmp, strlen(tmp)); in SendWatcherNotifyMessage()
117 PARAM_CHECK(ret == 0, free(msg); in SendWatcherNotifyMessage()
120 ret = FillParamMsgContent(msg, &offset, PARAM_VALUE, content, strlen(content)); in SendWatcherNotifyMessage()
121 PARAM_CHECK(ret == 0, free(msg); in SendWatcherNotifyMessage()
125 msg->id.msgId = 0; in SendWatcherNotifyMessage()
127 msg->id.msgId = extData->info.waitInfo.waitId; in SendWatcherNotifyMessage()
129 msg->id.msgId = extData->info.watchInfo.watchId; in SendWatcherNotifyMessage()
131 msg->msgSize = sizeof(ParamMessage) + offset; in SendWatcherNotifyMessage()
134 msg->id.msgId, msg->msgSize, content); in SendWatcherNotifyMessage()
135 ParamTaskSendMsg(extData->stream, msg); in SendWatcherNotifyMessage()
161 static int HandleParamSet(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSet() argument
164 ParamMsgContent *valueContent = GetNextContent(msg, &offset); in HandleParamSet()
165 PARAM_CHECK(valueContent != NULL, return -1, "Invalid msg for %s", msg->key); in HandleParamSet()
172 return SendResponseMsg(worker, msg, -1); in HandleParamSet()
179 PARAM_LOGI("Handle set param msgId %d pid %d key: %s", msg->id.msgId, cr.pid, msg->key); in HandleParamSet()
180 int ret = SystemSetParam(msg->key, valueContent->content, &srcLabel); in HandleParamSet()
181 return SendResponseMsg(worker, msg, ret); in HandleParamSet()
234 static int HandleParamWaitAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWaitAdd() argument
236 PARAM_CHECK(msg != NULL, return -1, "Invalid message"); in HandleParamWaitAdd()
243 ParamMsgContent *valueContent = GetNextContent(msg, &offset); in HandleParamWaitAdd()
244 PARAM_CHECK(valueContent != NULL, return -1, "Invalid msg"); in HandleParamWaitAdd()
245 PARAM_CHECK(valueContent->contentSize <= PARAM_CONST_VALUE_LEN_MAX, return -1, "Invalid msg"); in HandleParamWaitAdd()
246 ParamMsgContent *timeoutContent = GetNextContent(msg, &offset); in HandleParamWaitAdd()
251 PARAM_LOGV("HandleParamWaitAdd name %s timeout %d", msg->key, timeout); in HandleParamWaitAdd()
256 extData.info.waitInfo.waitId = msg->id.watcherId; in HandleParamWaitAdd()
259 ParamNode *param = SystemCheckMatchParamWait(msg->key, valueContent->content); in HandleParamWaitAdd()
265 uint32_t buffSize = strlen(msg->key) + valueContent->contentSize + 1 + 1; in HandleParamWaitAdd()
267 PARAM_CHECK(condition != NULL, return -1, "Failed to create condition for %s", msg->key); in HandleParamWaitAdd()
268 int ret = sprintf_s(condition, buffSize - 1, "%s=%s", msg->key, valueContent->content); in HandleParamWaitAdd()
270 return -1, "Failed to copy name for %s", msg->key); in HandleParamWaitAdd()
273 return -1, "Failed to add trigger for %s", msg->key); in HandleParamWaitAdd()
277 PARAM_CHECK(ret == 0, return 0, "Failed to create timer %s", msg->key); in HandleParamWaitAdd()
282 return 0, "Failed to set timer %s", msg->key); in HandleParamWaitAdd()
287 static int HandleParamWatcherAdd(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherAdd() argument
289 PARAM_CHECK(msg != NULL, return -1, "Invalid message"); in HandleParamWatcherAdd()
297 extData.info.watchInfo.watchId = msg->id.watcherId; in HandleParamWatcherAdd()
298 TriggerNode *trigger = AddWatcherTrigger(TRIGGER_PARAM_WATCH, msg->key, &extData); in HandleParamWatcherAdd()
300 PARAM_LOGE("Failed to add trigger for %s", msg->key); in HandleParamWatcherAdd()
301 return SendResponseMsg(worker, msg, -1); in HandleParamWatcherAdd()
303 PARAM_LOGV("HandleParamWatcherAdd name %s watcher: %d", msg->key, msg->id.watcherId); in HandleParamWatcherAdd()
304 return SendResponseMsg(worker, msg, 0); in HandleParamWatcherAdd()
307 static int HandleParamWatcherDel(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamWatcherDel() argument
309 PARAM_CHECK(msg != NULL, return -1, "Invalid message"); in HandleParamWatcherDel()
310 PARAM_LOGV("HandleParamWatcherDel name %s watcher: %d", msg->key, msg->id.watcherId); in HandleParamWatcherDel()
311 DelWatchTrigger(TRIGGER_PARAM_WATCH, (const void *)&msg->id.watcherId); in HandleParamWatcherDel()
312 return SendResponseMsg(worker, msg, 0); in HandleParamWatcherDel()
315 static int HandleParamSave(const ParamTaskPtr worker, const ParamMessage *msg) in HandleParamSave() argument
317 PARAM_CHECK(msg != NULL, return -1, "Invalid message"); in HandleParamSave()
323 return SendResponseMsg(worker, msg, -1); in HandleParamSave()
328 …PARAM_CHECK(ret == 0, return SendResponseMsg(worker, msg, -1), "Failed to process save parameters … in HandleParamSave()
330 return SendResponseMsg(worker, msg, 0); in HandleParamSave()
333 PARAM_STATIC int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg) in ProcessMessage() argument
335 PARAM_CHECK((msg != NULL) && (msg->msgSize >= sizeof(ParamMessage)), return -1, "Invalid msg"); in ProcessMessage()
338 switch (msg->type) { in ProcessMessage()
340 ret = HandleParamSet(worker, msg); in ProcessMessage()
343 ret = HandleParamWaitAdd(worker, msg); in ProcessMessage()
346 ret = HandleParamWatcherAdd(worker, msg); in ProcessMessage()
349 ret = HandleParamWatcherDel(worker, msg); in ProcessMessage()
352 ret = HandleParamSave(worker, msg); in ProcessMessage()