Lines Matching refs:queue
134 SensorEventQueue* queue; member
141 SensorEventQueue* queue = ctx->queue; in writerTask() local
146 if (queue->waitForSpace(&queue_mutex)) { in writerTask()
149 int bufferSize = queue->getWritableRegion(SENSOR_EVENT_QUEUE_CAPACITY, &buffer); in writerTask()
164 queue->markAsWritten(eventsPolled); in writerTask()
225 SensorEventQueue *queue = new SensorEventQueue(SENSOR_EVENT_QUEUE_CAPACITY); in addSubHwDevice() local
226 this->queues.push_back(queue); in addSubHwDevice()
230 taskContext->queue = queue; in addSubHwDevice()
371 SensorEventQueue* queue = this->queues.at(this->nextReadIndex); in poll() local
372 sensors_event_t* event = queue->peek(); in poll()
384 queue->dequeue(); in poll()