Cross Reference: /hardware/libhardware/modules/sensors/tests/SensorEventQueue

Lines Matching refs:queue
16 bool checkWritableBufferSize(SensorEventQueue* queue, int requested, int expected) {
18     int actual = queue->getWritableRegion(requested, &buffer);
26 bool checkSize(SensorEventQueue* queue, int expected) {
27     int actual = queue->getSize();
29         printf("Expected queue size was %d; actual was %d\n", expected, actual);
45     SensorEventQueue* queue = new SensorEventQueue(10);
46     if (!checkSize(queue, 0)) return false;
47     if (!checkWritableBufferSize(queue, 11, 10)) return false;
48     if (!checkWritableBufferSize(queue, 10, 10)) return false;
49     if (!checkWritableBufferSize(queue, 9, 9)) return false;
51     queue->markAsWritten(7);
52     if (!checkSize(queue, 7)) return false;
53     if (!checkWritableBufferSize(queue, 4, 3)) return false;
54     if (!checkWritableBufferSize(queue, 3, 3)) return false;
55     if (!checkWritableBufferSize(queue, 2, 2)) return false;
57     queue->markAsWritten(3);
58     if (!checkSize(queue, 10)) return false;
59     if (!checkWritableBufferSize(queue, 1, 0)) return false;
67     SensorEventQueue* queue = new SensorEventQueue(10);
68     queue->markAsWritten(9);
69     if (!checkSize(queue, 9)) return false;
72     queue->dequeue();
73     queue->dequeue();
74     if (!checkSize(queue, 7)) return false;
75     if (!checkWritableBufferSize(queue, 100, 1)) return false;
78     queue->markAsWritten(1);
79     if (!checkSize(queue, 8)) return false;
81     if (!checkWritableBufferSize(queue, 100, 2)) return false;
83     // Fill the queue again
84     queue->markAsWritten(2);
85     if (!checkSize(queue, 10)) return false;
95   SensorEventQueue* queue;
106     SensorEventQueue* queue = ctx->queue;
114         if (queue->waitForSpace(&mutex)) {
118         int writableSize = queue->getWritableRegion(FULL_QUEUE_CAPACITY, &buffer);
119         queue->markAsWritten(writableSize);
145     SensorEventQueue* queue = ctx->queue;
150         // and either the queue is full, or if we're reading the last few events.
151         while (!fullQueueReaderShouldRead(queue->getSize(), totalReads)) {
154         queue->dequeue();
164 // Test internal queue-full waiting and broadcasting.
167     SensorEventQueue* queue = new SensorEventQueue(FULL_QUEUE_CAPACITY);
171     readerCtx.queue = queue;
175     writerCtx.queue = queue;