Lines Matching refs:msg

87 static int SendResponseMsg(ParamTaskPtr worker, const ParamMessage *msg, int result)

90     response = (ParamResponseMessage *)CreateParamMessage(msg->type, msg->key, sizeof(ParamResponseMessage));

92     response->msg.id.msgId = msg->id.msgId;

94     response->msg.msgSize = sizeof(ParamResponseMessage);

96     PARAM_LOGV("Send response msg msgId %d result %d", msg->id.msgId, result);

105     ParamMessage *msg = (ParamMessage *)CreateParamMessage(MSG_NOTIFY_PARAM, "*", msgSize);

106     PARAM_CHECK(msg != NULL, return -1, "Failed to create msg ");

112         ret = strncpy_s(msg->key, sizeof(msg->key) - 1, content, tmp - content);

113         PARAM_CHECK(ret == 0, free(msg);

116         ret = FillParamMsgContent(msg, &offset, PARAM_VALUE, tmp, strlen(tmp));

117         PARAM_CHECK(ret == 0, free(msg);

120         ret = FillParamMsgContent(msg, &offset, PARAM_VALUE, content, strlen(content));

121         PARAM_CHECK(ret == 0, free(msg);

125     msg->id.msgId = 0;

127         msg->id.msgId = extData->info.waitInfo.waitId;

129         msg->id.msgId = extData->info.watchInfo.watchId;

131     msg->msgSize = sizeof(ParamMessage) + offset;

134         msg->id.msgId, msg->msgSize, content);

135     ParamTaskSendMsg(extData->stream, msg);

161 static int HandleParamSet(const ParamTaskPtr worker, const ParamMessage *msg)

164     ParamMsgContent *valueContent = GetNextContent(msg, &offset);

165     PARAM_CHECK(valueContent != NULL, return -1, "Invalid msg for %s", msg->key);

172         return SendResponseMsg(worker, msg, -1);

179     PARAM_LOGI("Handle set param msgId %d pid %d key: %s", msg->id.msgId, cr.pid, msg->key);

180     int ret = SystemSetParam(msg->key, valueContent->content, &srcLabel);

181     return SendResponseMsg(worker, msg, ret);

234 static int HandleParamWaitAdd(const ParamTaskPtr worker, const ParamMessage *msg)

236     PARAM_CHECK(msg != NULL, return -1, "Invalid message");

243     ParamMsgContent *valueContent = GetNextContent(msg, &offset);

244     PARAM_CHECK(valueContent != NULL, return -1, "Invalid msg");

245     PARAM_CHECK(valueContent->contentSize <= PARAM_CONST_VALUE_LEN_MAX, return -1, "Invalid msg");

246     ParamMsgContent *timeoutContent = GetNextContent(msg, &offset);

251     PARAM_LOGV("HandleParamWaitAdd name %s timeout %d", msg->key, timeout);

256     extData.info.waitInfo.waitId = msg->id.watcherId;

259     ParamNode *param = SystemCheckMatchParamWait(msg->key, valueContent->content);

265     uint32_t buffSize = strlen(msg->key) + valueContent->contentSize + 1 + 1;

267     PARAM_CHECK(condition != NULL, return -1, "Failed to create condition for %s", msg->key);

268     int ret = sprintf_s(condition, buffSize - 1, "%s=%s", msg->key, valueContent->content);

270         return -1, "Failed to copy name for %s", msg->key);

273         return -1, "Failed to add trigger for %s", msg->key);

277         PARAM_CHECK(ret == 0, return 0, "Failed to create timer %s", msg->key);

282             return 0, "Failed to set timer %s", msg->key);

287 static int HandleParamWatcherAdd(const ParamTaskPtr worker, const ParamMessage *msg)

289     PARAM_CHECK(msg != NULL, return -1, "Invalid message");

297     extData.info.watchInfo.watchId = msg->id.watcherId;

298     TriggerNode *trigger = AddWatcherTrigger(TRIGGER_PARAM_WATCH, msg->key, &extData);

300         PARAM_LOGE("Failed to add trigger for %s", msg->key);

301         return SendResponseMsg(worker, msg, -1);

303     PARAM_LOGV("HandleParamWatcherAdd name %s watcher: %d", msg->key, msg->id.watcherId);

304     return SendResponseMsg(worker, msg, 0);

307 static int HandleParamWatcherDel(const ParamTaskPtr worker, const ParamMessage *msg)

309     PARAM_CHECK(msg != NULL, return -1, "Invalid message");

310     PARAM_LOGV("HandleParamWatcherDel name %s watcher: %d", msg->key, msg->id.watcherId);

311     DelWatchTrigger(TRIGGER_PARAM_WATCH, (const void *)&msg->id.watcherId);

312     return SendResponseMsg(worker, msg, 0);

315 static int HandleParamSave(const ParamTaskPtr worker, const ParamMessage *msg)

317     PARAM_CHECK(msg != NULL, return -1, "Invalid message");

323         return SendResponseMsg(worker, msg, -1);

328     PARAM_CHECK(ret == 0, return SendResponseMsg(worker, msg, -1), "Failed to process save parameters : ret %d", ret);

330     return SendResponseMsg(worker, msg, 0);

333 PARAM_STATIC int ProcessMessage(const ParamTaskPtr worker, const ParamMessage *msg)

335     PARAM_CHECK((msg != NULL) && (msg->msgSize >= sizeof(ParamMessage)), return -1, "Invalid msg");

338     switch (msg->type) {

340             ret = HandleParamSet(worker, msg);

343             ret = HandleParamWaitAdd(worker, msg);

346             ret = HandleParamWatcherAdd(worker, msg);

349             ret = HandleParamWatcherDel(worker, msg);

352             ret = HandleParamSave(worker, msg);