Lines Matching refs:queue
133 SensorEventQueue* queue; member
140 SensorEventQueue* queue = ctx->queue; in writerTask() local
145 if (queue->waitForSpace(&queue_mutex)) { in writerTask()
148 int bufferSize = queue->getWritableRegion(SENSOR_EVENT_QUEUE_CAPACITY, &buffer); in writerTask()
159 queue->markAsWritten(eventsPolled); in writerTask()
213 SensorEventQueue *queue = new SensorEventQueue(SENSOR_EVENT_QUEUE_CAPACITY); in addSubHwDevice() local
214 this->queues.push_back(queue); in addSubHwDevice()
218 taskContext->queue = queue; in addSubHwDevice()
309 SensorEventQueue* queue = this->queues.at(this->nextReadIndex); in poll() local
310 sensors_event_t* event = queue->peek(); in poll()
322 queue->dequeue(); in poll()