Searched refs:executeQueue (Results 1 – 4 of 4) sorted by relevance
166 TriggerExecuteQueue *executeQueue = (TriggerExecuteQueue *)&workSpace->executeQueue; in DelJobTrigger_() local167 for (uint32_t i = executeQueue->startIndex; i < executeQueue->endIndex; i++) { in DelJobTrigger_()168 if (executeQueue->executeQueue[i] == trigger) { in DelJobTrigger_()169 executeQueue->executeQueue[i] = NULL; in DelJobTrigger_()328 uint32_t index = workSpace->executeQueue.endIndex++ % workSpace->executeQueue.queueCount; in ExecuteQueuePush()329 workSpace->executeQueue.executeQueue[index] = (TriggerNode *)trigger; in ExecuteQueuePush()338 if (workSpace->executeQueue.endIndex <= workSpace->executeQueue.startIndex) { in ExecuteQueuePop()342 trigger = workSpace->executeQueue.executeQueue[currIndex]; in ExecuteQueuePop()343 workSpace->executeQueue.executeQueue[currIndex] = NULL; in ExecuteQueuePop()556 …workSpace->executeQueue.queueCount, workSpace->executeQueue.startIndex, workSpace->executeQueue.en… in SystemDumpTriggers()[all …]
317 …g_triggerWorkSpace.executeQueue.executeQueue = calloc(1, TRIGGER_EXECUTE_QUEUE * sizeof(TriggerNod… in InitTriggerWorkSpace()318 PARAM_CHECK(g_triggerWorkSpace.executeQueue.executeQueue != NULL, in InitTriggerWorkSpace()320 g_triggerWorkSpace.executeQueue.queueCount = TRIGGER_EXECUTE_QUEUE; in InitTriggerWorkSpace()321 g_triggerWorkSpace.executeQueue.startIndex = 0; in InitTriggerWorkSpace()322 g_triggerWorkSpace.executeQueue.endIndex = 0; in InitTriggerWorkSpace()338 free(g_triggerWorkSpace.executeQueue.executeQueue); in CloseTriggerWorkSpace()339 g_triggerWorkSpace.executeQueue.executeQueue = NULL; in CloseTriggerWorkSpace()
152 TriggerNode **executeQueue; member161 TriggerExecuteQueue executeQueue; member
183 ExecuteQueue executeQueue; variable184 uint64_t result = executeQueue.DequeueTaskId();190 ExecuteQueue executeQueue; variable191 bool result = executeQueue.IsEmpty();197 ExecuteQueue executeQueue; variable198 uint32_t result = executeQueue.GetTaskNum();