Lines Matching full:queue
35 _queue1_writer: ResourceFmqMirror, writer of queue 1.
36 _queue1_reader: ResourceFmqMirror, reader of queue 1.
37 _queue2_writer: ResourceFmqMirror, writer of queue 2.
38 _queue2_reader: ResourceFmqMirror, reader of queue 2.
39 _queue3_writer: ResourceFmqMirror, writer of queue 3.
40 _queue3_reader1: ResourceFmqMirror, reader 1 of queue 3.
41 _queue3_reader2: ResourceFmqMirror, reader 2 of queue 3.
42 _queue4_writer: ResourceFmqMirror, writer of queue 4.
43 _queue4_reader: ResourceFmqMirror, reader of queue 4.
51 Queue 1: synchronized queue (without blocking) between
52 one writer and one reader, sending uint16_t type in the queue.
53 Queue 2: synchronized queue (with blocking feature) between
55 the queue.
56 Queue 3: unsynchronized queue (without blocking) between
58 the queue.
59 Queue 4: synchronized queue (without blocking) between
90 # This reader shares the same queue as self._queue1_writer.
108 # This reader shares the same queue as self._queue2_writer.
126 # This reader shares the same queue as self._queue3_writer.
134 # This reader shares the same queue as self._queue3_writer and self._queue3_reader1.
156 # This reader shares the same queue as self._queue4_writer.
165 # Check the correctness on queue 1, which uses primitive type uint32_t.
171 "Queue 1 writer should be valid.")
173 "Queue 1 reader should be valid.")
175 # Also check the correctness on queue 4, which uses predefined type
181 "Queue 4 writer should be valid.")
183 "Queue 4 reader should be valid.")
188 This test operates on queue 1, and tests basic read/write.
194 self._queue1_writer.write(write_data, 2048), "Write queue failed.")
197 asserts.assertTrue(read_success, "Read queue failed.")
201 """Test reading from an empty queue. """
205 "Read should fail because queue is empty.")
208 """Test writes fail when queue is full. """
215 # This write should fail because queue is full.
218 "Writer should fail because queue is full.")
221 """Test writing more than queue capacity. """
223 # Write overflows the capacity of the queue.
231 This test operates on queue 1, and tests consecutive read/write.
250 This test operates on queue 2, and tests blocking read/write.
306 """Test blocking is not allowed in unsynchronized queue.
308 This test operates on queue 3, and tests that blocking is not allowed
309 in unsynchronized queue.
314 "Blocking operation should fail in unsynchronized queue.")
317 """Test read/write on queue with predefined type in HAL service.
319 This test operates on queue 4, and tests reader and writer can interact
320 in a queue with predefined type ReadParameters defined in IStreamIn.hal.