Lines Matching refs:executeQueue
166 TriggerExecuteQueue *executeQueue = (TriggerExecuteQueue *)&workSpace->executeQueue; in DelJobTrigger_() local
167 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()
344 workSpace->executeQueue.startIndex++; in ExecuteQueuePop()
556 …workSpace->executeQueue.queueCount, workSpace->executeQueue.startIndex, workSpace->executeQueue.en… in SystemDumpTriggers()
557 …for (uint32_t index = workSpace->executeQueue.startIndex; index < workSpace->executeQueue.endIndex… in SystemDumpTriggers()
558 …TriggerNode *trigger = workSpace->executeQueue.executeQueue[index % workSpace->executeQueue.queueC… in SystemDumpTriggers()