param_service.c - OpenGrok cross reference for /base/startup/init/services/param/linux/param

Lines Matching defs:extData
100 static int SendWatcherNotifyMessage(const TriggerExtInfo *extData, const char *content, uint32_t size)

103     PARAM_CHECK(extData != NULL && extData->stream != NULL, return -1, "Invalid extData");

126     if (extData->type == TRIGGER_PARAM_WAIT) {

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

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

133         (extData->type == TRIGGER_PARAM_WAIT) ? "wait" : "watcher",

135     ParamTaskSendMsg(extData->stream, msg);

207 static TriggerNode *AddWatcherTrigger(int triggerType, const char *condition, const TriggerExtInfo *extData)

210     TriggerHeader *header = (TriggerHeader *)&workSpace->triggerHead[extData->type];

211     return header->addTrigger(workSpace, condition, extData);

216     TriggerExtInfo extData = {};

217     extData.type = trigger->type;

220         extData.stream = node->stream;

221         extData.info.waitInfo.waitId = node->waitId;

222         extData.info.waitInfo.timeout = node->timeout;

225         extData.stream = g_paramService.watcherTask;

226         extData.info.watchInfo.watchId = node->watchId;

229         return SendWatcherNotifyMessage(&extData, "", 0);

231     return SendWatcherNotifyMessage(&extData, content, size);

252     TriggerExtInfo extData = {};

253     extData.addNode = AddWatchNode;

254     extData.type = TRIGGER_PARAM_WAIT;

255     extData.stream = worker;

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

257     extData.info.waitInfo.timeout = timeout;

261         SendWatcherNotifyMessage(&extData, param->data, param->valueLength);

271     TriggerNode *trigger = AddWatcherTrigger(TRIGGER_PARAM_WAIT, condition, &extData);

293     TriggerExtInfo extData = {};

294     extData.type = TRIGGER_PARAM_WATCH;

295     extData.addNode = AddWatchNode;

296     extData.stream = worker;

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

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