Lines Matching refs:trigger
28 int AddCommand(JobNode *trigger, uint32_t cmdKeyIndex, const char *content) in AddCommand() argument
30 PARAM_CHECK(trigger != NULL, return -1, "trigger is null"); in AddCommand()
47 if (trigger->firstCmd == NULL) { in AddCommand()
48 trigger->firstCmd = node; in AddCommand()
49 trigger->lastCmd = node; in AddCommand()
51 PARAM_CHECK(trigger->lastCmd != NULL, free(node); in AddCommand()
53 trigger->lastCmd->next = node; in AddCommand()
54 trigger->lastCmd = node; in AddCommand()
59 CommandNode *GetNextCmdNode(const JobNode *trigger, const CommandNode *curr) in GetNextCmdNode() argument
61 PARAM_CHECK(trigger != NULL, return NULL, "trigger is null"); in GetNextCmdNode()
63 return trigger->firstCmd; in GetNextCmdNode()
99 static int32_t AddJobNode_(TriggerNode *trigger, const TriggerExtInfo *extInfo) in AddJobNode_() argument
101 JobNode *node = (JobNode *)trigger; in AddJobNode_()
135 static void DelJobTrigger_(const TriggerWorkSpace *workSpace, TriggerNode *trigger) in DelJobTrigger_() argument
138 PARAM_CHECK(trigger != NULL, return, "Trigger is null"); in DelJobTrigger_()
139 JobNode *jobNode = (JobNode *)trigger; in DelJobTrigger_()
140 TriggerHeader *triggerHead = GetTriggerHeader(workSpace, trigger->type); in DelJobTrigger_()
141 PARAM_CHECK(triggerHead != NULL, return, "Failed to get header %d", trigger->type); in DelJobTrigger_()
155 OH_ListRemove(&trigger->node); in DelJobTrigger_()
159 if (!TRIGGER_IN_QUEUE(trigger)) { in DelJobTrigger_()
165 if (executeQueue->executeQueue[i] == trigger) { in DelJobTrigger_()
200 static void DelWatchTrigger_(const TriggerWorkSpace *workSpace, TriggerNode *trigger) in DelWatchTrigger_() argument
203 TriggerHeader *triggerHead = GetTriggerHeader(workSpace, trigger->type); in DelWatchTrigger_()
204 PARAM_CHECK(triggerHead != NULL, return, "Failed to get header %d", trigger->type); in DelWatchTrigger_()
205 OH_ListRemove(&trigger->node); in DelWatchTrigger_()
206 if (trigger->type == TRIGGER_PARAM_WAIT) { in DelWatchTrigger_()
207 WaitNode *node = (WaitNode *)trigger; in DelWatchTrigger_()
209 } else if (trigger->type == TRIGGER_PARAM_WATCH) { in DelWatchTrigger_()
210 WatchNode *node = (WatchNode *)trigger; in DelWatchTrigger_()
213 PARAM_LOGV("DelWatchTrigger_ %s count %d", GetTriggerName(trigger), triggerHead->triggerCount); in DelWatchTrigger_()
215 free(trigger); in DelWatchTrigger_()
233 static const char *GetTriggerCondition_(const TriggerNode *trigger) in GetTriggerCondition_() argument
235 return (trigger == NULL || trigger->condition == NULL) ? "" : trigger->condition; in GetTriggerCondition_()
238 static const char *GetBootCondition_(const TriggerNode *trigger) in GetBootCondition_() argument
240 PARAM_CHECK(trigger != NULL, return "", "Invalid trigger"); in GetBootCondition_()
241 PARAM_CHECK(trigger->type == TRIGGER_BOOT, return "", "Invalid type"); in GetBootCondition_()
242 const JobNode *node = (const JobNode *)trigger; in GetBootCondition_()
246 static const char *GetJobName_(const TriggerNode *trigger) in GetJobName_() argument
248 PARAM_CHECK(trigger != NULL, return "", "Invalid trigger"); in GetJobName_()
249 PARAM_CHECK(trigger->type <= TRIGGER_UNKNOW, return "", "Invalid type"); in GetJobName_()
250 const JobNode *node = (const JobNode *)trigger; in GetJobName_()
254 static const char *GetWatchName_(const TriggerNode *trigger) in GetWatchName_() argument
256 PARAM_CHECK(trigger != NULL, return "", "Invalid trigger"); in GetWatchName_()
257 PARAM_CHECK(trigger->type < TRIGGER_MAX && trigger->type > TRIGGER_UNKNOW, in GetWatchName_()
259 return trigger->condition; in GetWatchName_()
291 JobNode *trigger = HASHMAP_ENTRY(node, JobNode, hashNode); in GetTriggerByName() local
292 return trigger; in GetTriggerByName()
295 void FreeTrigger(const TriggerWorkSpace *workSpace, TriggerNode *trigger) in FreeTrigger() argument
297 PARAM_CHECK(workSpace != NULL && trigger != NULL, return, "Invalid param"); in FreeTrigger()
298 TriggerHeader *head = GetTriggerHeader(workSpace, trigger->type); in FreeTrigger()
300 head->delTrigger(workSpace, trigger); in FreeTrigger()
309 TriggerNode *trigger = head->nextTrigger(head, NULL); in ClearTrigger() local
310 while (trigger != NULL) { in ClearTrigger()
311 TriggerNode *next = head->nextTrigger(head, trigger); in ClearTrigger()
312 FreeTrigger(workSpace, trigger); in ClearTrigger()
313 trigger = next; in ClearTrigger()
318 int ExecuteQueuePush(TriggerWorkSpace *workSpace, const TriggerNode *trigger) in ExecuteQueuePush() argument
322 workSpace->executeQueue.executeQueue[index] = (TriggerNode *)trigger; in ExecuteQueuePush()
329 TriggerNode *trigger = NULL; in ExecuteQueuePop() local
335 trigger = workSpace->executeQueue.executeQueue[currIndex]; in ExecuteQueuePop()
338 } while (trigger == NULL); in ExecuteQueuePop()
339 return trigger; in ExecuteQueuePop()
390 TriggerNode *trigger = head->nextTrigger(head, NULL); in ExecTriggerMatch_() local
391 while (trigger != NULL) { in ExecTriggerMatch_()
392 TriggerNode *next = head->nextTrigger(head, trigger); in ExecTriggerMatch_()
393 const char *condition = head->getCondition(trigger); in ExecTriggerMatch_()
395 calculator->triggerCheckDone(trigger, content, contentSize); in ExecTriggerMatch_()
397 trigger = next; in ExecTriggerMatch_()
445 TriggerNode *trigger = head->nextTrigger(head, NULL); in CheckAndMarkTrigger_() local
446 while (trigger != NULL) { in CheckAndMarkTrigger_()
447 if (head->getCondition(trigger) == NULL) { in CheckAndMarkTrigger_()
448 trigger = head->nextTrigger(head, trigger); in CheckAndMarkTrigger_()
451 if (CheckMatchSubCondition(head->getCondition(trigger), name, strlen(name)) == 1) { in CheckAndMarkTrigger_()
452 TRIGGER_SET_FLAG(trigger, TRIGGER_FLAGS_RELATED); in CheckAndMarkTrigger_()
455 trigger = head->nextTrigger(head, trigger); in CheckAndMarkTrigger_()
477 static void DumpJobTrigger_(const TriggerWorkSpace *workSpace, const TriggerNode *trigger) in DumpJobTrigger_() argument
479 const JobNode *node = (const JobNode *)trigger; in DumpJobTrigger_()
480 PARAM_DUMP("trigger flags: 0x%08x \n", trigger->flags); in DumpJobTrigger_()
494 static void DumpWatchTrigger_(const TriggerWorkSpace *workSpace, const TriggerNode *trigger) in DumpWatchTrigger_() argument
496 const WatchNode *node = (const WatchNode *)trigger; in DumpWatchTrigger_()
497 PARAM_DUMP("trigger flags: 0x%08x \n", trigger->flags); in DumpWatchTrigger_()
498 PARAM_DUMP("trigger condition: %s \n", trigger->condition); in DumpWatchTrigger_()
502 static void DumpWaitTrigger_(const TriggerWorkSpace *workSpace, const TriggerNode *trigger) in DumpWaitTrigger_() argument
504 const WaitNode *node = (const WaitNode *)trigger; in DumpWaitTrigger_()
505 PARAM_DUMP("trigger flags: 0x%08x \n", trigger->flags); in DumpWaitTrigger_()
506 PARAM_DUMP("trigger name: %s \n", GetTriggerName(trigger)); in DumpWaitTrigger_()
507 PARAM_DUMP("trigger condition: %s \n", trigger->condition); in DumpWaitTrigger_()
517 TriggerNode *trigger = head->nextTrigger(head, NULL); in DumpTrigger_() local
518 while (trigger != NULL) { in DumpTrigger_()
519 head->dumpTrigger(workSpace, trigger); in DumpTrigger_()
520 trigger = head->nextTrigger(head, trigger); in DumpTrigger_()
548 …TriggerNode *trigger = workSpace->executeQueue.executeQueue[index % workSpace->executeQueue.queueC… in SystemDumpTriggers() local
549 if (trigger != 0) { in SystemDumpTriggers()
550 PARAM_DUMP(" queue node trigger name: %s \n", GetTriggerName(trigger)); in SystemDumpTriggers()
555 static int32_t CompareData_(const struct tagTriggerNode_ *trigger, const void *data) in CompareData_() argument
557 PARAM_CHECK(trigger != NULL && data != NULL, return -1, "Invalid trigger"); in CompareData_()
558 if (trigger->type == TRIGGER_PARAM_WAIT) { in CompareData_()
559 WaitNode *node = (WaitNode *)trigger; in CompareData_()
561 } else if (trigger->type == TRIGGER_PARAM_WATCH) { in CompareData_()
562 WatchNode *node = (WatchNode *)trigger; in CompareData_()
683 TriggerNode *trigger = head->nextTrigger(head, NULL); in DelWatchTrigger() local
684 while (trigger != NULL) { in DelWatchTrigger()
685 if (head->compareData(trigger, data) == 0) { in DelWatchTrigger()
686 head->delTrigger(GetTriggerWorkSpace(), trigger); in DelWatchTrigger()
689 trigger = head->nextTrigger(head, trigger); in DelWatchTrigger()
700 TriggerNode *trigger = NULL; in ClearWatchTrigger() local
702 trigger = (TriggerNode *)ListEntry(node, WaitNode, item); in ClearWatchTrigger()
704 trigger = (TriggerNode *)ListEntry(node, WatchNode, item); in ClearWatchTrigger()
706 if (trigger == NULL || type != trigger->type) { in ClearWatchTrigger()
707 PARAM_LOGE("ClearWatchTrigger %s error type %d", GetTriggerName(trigger), type); in ClearWatchTrigger()
710 PARAM_LOGV("ClearWatchTrigger %s", GetTriggerName(trigger)); in ClearWatchTrigger()
712 FreeTrigger(GetTriggerWorkSpace(), trigger); in ClearWatchTrigger()
757 const char *GetTriggerName(const TriggerNode *trigger) in GetTriggerName() argument
759 PARAM_CHECK(trigger != NULL, return "", "Invalid trigger"); in GetTriggerName()
760 TriggerHeader *triggerHead = GetTriggerHeader(GetTriggerWorkSpace(), trigger->type); in GetTriggerName()
762 return triggerHead->getTriggerName(trigger); in GetTriggerName()