Lines Matching refs:queue
134 SensorEventQueue* queue;
141 SensorEventQueue* queue = ctx->queue;
146 if (queue->waitForSpace(&queue_mutex)) {
149 int bufferSize = queue->getWritableRegion(SENSOR_EVENT_QUEUE_CAPACITY, &buffer);
160 queue->markAsWritten(eventsPolled);
214 SensorEventQueue *queue = new SensorEventQueue(SENSOR_EVENT_QUEUE_CAPACITY);
215 this->queues.push_back(queue);
219 taskContext->queue = queue;
340 SensorEventQueue* queue = this->queues.at(this->nextReadIndex);
341 sensors_event_t* event = queue->peek();
353 queue->dequeue();