102 static int SendWatcherNotifyMessage(const TriggerExtInfo *extData, const char *content, uint32_t si…  in SendWatcherNotifyMessage()  argument
105     PARAM_CHECK(extData != NULL && extData->stream != NULL, return -1, "Invalid extData");  in SendWatcherNotifyMessage()
128     if (extData->type == TRIGGER_PARAM_WAIT) {  in SendWatcherNotifyMessage()
129         msg->id.msgId = extData->info.waitInfo.waitId;  in SendWatcherNotifyMessage()
131         msg->id.msgId = extData->info.watchInfo.watchId;  in SendWatcherNotifyMessage()
135         (extData->type == TRIGGER_PARAM_WAIT) ? "wait" : "watcher",  in SendWatcherNotifyMessage()
137     ParamTaskSendMsg(extData->stream, msg);  in SendWatcherNotifyMessage()
203 …iggerNode *AddWatcherTrigger(int triggerType, const char *condition, const TriggerExtInfo *extData)  in AddWatcherTrigger()  argument
206     TriggerHeader *header = (TriggerHeader *)&workSpace->triggerHead[extData->type];  in AddWatcherTrigger()
207     return header->addTrigger(workSpace, condition, extData);  in AddWatcherTrigger()
212     TriggerExtInfo extData = {};  in ExecuteWatchTrigger_()  local
213     extData.type = trigger->type;  in ExecuteWatchTrigger_()
216         extData.stream = node->stream;  in ExecuteWatchTrigger_()
217         extData.info.waitInfo.waitId = node->waitId;  in ExecuteWatchTrigger_()
218         extData.info.waitInfo.timeout = node->timeout;  in ExecuteWatchTrigger_()
221         extData.stream = g_paramService.watcherTask;  in ExecuteWatchTrigger_()
222         extData.info.watchInfo.watchId = node->watchId;  in ExecuteWatchTrigger_()
225         return SendWatcherNotifyMessage(&extData, "", 0);  in ExecuteWatchTrigger_()
227     return SendWatcherNotifyMessage(&extData, content, size);  in ExecuteWatchTrigger_()
248     TriggerExtInfo extData = {};  in HandleParamWaitAdd()  local
249     extData.addNode = AddWatchNode;  in HandleParamWaitAdd()
250     extData.type = TRIGGER_PARAM_WAIT;  in HandleParamWaitAdd()
251     extData.stream = worker;  in HandleParamWaitAdd()
252     extData.info.waitInfo.waitId = msg->id.watcherId;  in HandleParamWaitAdd()
253     extData.info.waitInfo.timeout = timeout;  in HandleParamWaitAdd()
257         SendWatcherNotifyMessage(&extData, param->data, param->valueLength);  in HandleParamWaitAdd()
267     TriggerNode *trigger = AddWatcherTrigger(TRIGGER_PARAM_WAIT, condition, &extData);  in HandleParamWaitAdd()
290     TriggerExtInfo extData = {};  in HandleParamWatcherAdd()  local
291     extData.type = TRIGGER_PARAM_WATCH;  in HandleParamWatcherAdd()
292     extData.addNode = AddWatchNode;  in HandleParamWatcherAdd()
293     extData.stream = worker;  in HandleParamWatcherAdd()
294     extData.info.watchInfo.watchId = msg->id.watcherId;  in HandleParamWatcherAdd()
295     TriggerNode *trigger = AddWatcherTrigger(TRIGGER_PARAM_WATCH, msg->key, &extData);  in HandleParamWatcherAdd()