Searched refs:pQueue (Results 1 – 3 of 3) sorted by relevance
72 phDal4Nfc_message_queue_t * pQueue; in phDal4Nfc_msgget() local73 pQueue = (phDal4Nfc_message_queue_t *) phOsalNfc_GetMemory(sizeof(phDal4Nfc_message_queue_t)); in phDal4Nfc_msgget()74 if (pQueue == NULL) in phDal4Nfc_msgget()76 memset(pQueue, 0, sizeof(phDal4Nfc_message_queue_t)); in phDal4Nfc_msgget()77 if (pthread_mutex_init (&pQueue->nCriticalSectionMutex, NULL) == -1) in phDal4Nfc_msgget()79 if (sem_init (&pQueue->nProcessSemaphore, 0, 0) == -1) in phDal4Nfc_msgget()81 return ((int)pQueue); in phDal4Nfc_msgget()98 phDal4Nfc_message_queue_t * pQueue; in phDal4Nfc_msgctl() local104 pQueue = (phDal4Nfc_message_queue_t *)msqid; in phDal4Nfc_msgctl()105 pthread_mutex_lock(&pQueue->nCriticalSectionMutex); in phDal4Nfc_msgctl()[all …]
78 private ConcurrentLinkedQueue<AppTask<?>> pQueue = new ConcurrentLinkedQueue<AppTask<?>>(); field in PhysicsSpace147 pQueueTL.set(pQueue); in create()185 AppTask task = pQueue.poll(); in preTick_native()186 task = pQueue.poll(); in preTick_native()189 task = pQueue.poll(); in preTick_native()196 task = pQueue.poll(); in preTick_native()383 pQueue.add(task); in enqueue()
95 private ConcurrentLinkedQueue<AppTask<?>> pQueue = new ConcurrentLinkedQueue<AppTask<?>>(); field in PhysicsSpace161 pQueueTL.set(pQueue); in create()238 AppTask task = pQueue.poll(); in setTickCallback()239 task = pQueue.poll(); in setTickCallback()242 task = pQueue.poll(); in setTickCallback()249 task = pQueue.poll(); in setTickCallback()357 pQueue.add(task); in enqueue()