Searched refs:executeQueue (Results 1 – 3 of 3) sorted by relevance
163 TriggerExecuteQueue *executeQueue = (TriggerExecuteQueue *)&workSpace->executeQueue; in DelJobTrigger_() local164 for (uint32_t i = executeQueue->startIndex; i < executeQueue->endIndex; i++) { in DelJobTrigger_()165 if (executeQueue->executeQueue[i] == trigger) { in DelJobTrigger_()166 executeQueue->executeQueue[i] = NULL; in DelJobTrigger_()321 uint32_t index = workSpace->executeQueue.endIndex++ % workSpace->executeQueue.queueCount; in ExecuteQueuePush()322 workSpace->executeQueue.executeQueue[index] = (TriggerNode *)trigger; in ExecuteQueuePush()331 if (workSpace->executeQueue.endIndex <= workSpace->executeQueue.startIndex) { in ExecuteQueuePop()334 … uint32_t currIndex = workSpace->executeQueue.startIndex % workSpace->executeQueue.queueCount; in ExecuteQueuePop()335 trigger = workSpace->executeQueue.executeQueue[currIndex]; in ExecuteQueuePop()336 workSpace->executeQueue.executeQueue[currIndex] = NULL; in ExecuteQueuePop()[all …]
303 …g_triggerWorkSpace.executeQueue.executeQueue = calloc(1, TRIGGER_EXECUTE_QUEUE * sizeof(TriggerNod… in InitTriggerWorkSpace()304 PARAM_CHECK(g_triggerWorkSpace.executeQueue.executeQueue != NULL, in InitTriggerWorkSpace()306 g_triggerWorkSpace.executeQueue.queueCount = TRIGGER_EXECUTE_QUEUE; in InitTriggerWorkSpace()307 g_triggerWorkSpace.executeQueue.startIndex = 0; in InitTriggerWorkSpace()308 g_triggerWorkSpace.executeQueue.endIndex = 0; in InitTriggerWorkSpace()322 free(g_triggerWorkSpace.executeQueue.executeQueue); in CloseTriggerWorkSpace()323 g_triggerWorkSpace.executeQueue.executeQueue = NULL; in CloseTriggerWorkSpace()
150 TriggerNode **executeQueue; member159 TriggerExecuteQueue executeQueue; member