Searched refs:executeQueue (Results 1 – 3 of 3) 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()341 … uint32_t currIndex = workSpace->executeQueue.startIndex % workSpace->executeQueue.queueCount; in ExecuteQueuePop()342 trigger = workSpace->executeQueue.executeQueue[currIndex]; in ExecuteQueuePop()343 workSpace->executeQueue.executeQueue[currIndex] = NULL; in ExecuteQueuePop()[all …]
311 …g_triggerWorkSpace.executeQueue.executeQueue = calloc(1, TRIGGER_EXECUTE_QUEUE * sizeof(TriggerNod… in InitTriggerWorkSpace()312 PARAM_CHECK(g_triggerWorkSpace.executeQueue.executeQueue != NULL, in InitTriggerWorkSpace()314 g_triggerWorkSpace.executeQueue.queueCount = TRIGGER_EXECUTE_QUEUE; in InitTriggerWorkSpace()315 g_triggerWorkSpace.executeQueue.startIndex = 0; in InitTriggerWorkSpace()316 g_triggerWorkSpace.executeQueue.endIndex = 0; in InitTriggerWorkSpace()332 free(g_triggerWorkSpace.executeQueue.executeQueue); in CloseTriggerWorkSpace()333 g_triggerWorkSpace.executeQueue.executeQueue = NULL; in CloseTriggerWorkSpace()
152 TriggerNode **executeQueue; member161 TriggerExecuteQueue executeQueue; member