Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 25 of 77) sorted by relevance

1234

/packages/modules/Bluetooth/system/test/mock/
Dmock_osi_fixed_queue.cc59 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
63 void* fixed_queue_dequeue(fixed_queue_t* queue) { in fixed_queue_dequeue()
67 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue()
71 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
75 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
79 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd()
83 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) { in fixed_queue_get_enqueue_fd()
87 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list()
91 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
95 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
[all …]
/packages/modules/Bluetooth/system/osi/src/
Dfixed_queue.cc76 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
97 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
110 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
119 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
128 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
134 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue()
148 void* fixed_queue_dequeue(fixed_queue_t* queue) { in fixed_queue_dequeue()
165 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_try_enqueue()
182 void* fixed_queue_try_dequeue(fixed_queue_t* queue) { in fixed_queue_try_dequeue()
203 void* fixed_queue_try_peek_first(fixed_queue_t* queue) { in fixed_queue_try_peek_first()
[all …]
Dalarm.cc96 fixed_queue_t* queue; // The processing queue to add this alarm to member
219 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal()
553 static void alarm_register_processing_queue(fixed_queue_t* queue, thread_t* thread) { in alarm_register_processing_queue()
606 static void alarm_queue_ready(fixed_queue_t* queue, void* /* context */) { in alarm_queue_ready()
/packages/modules/Bluetooth/system/osi/test/
Dfixed_queue_test.cc38 static void fixed_queue_ready(fixed_queue_t* queue, void* /* context */) { in fixed_queue_ready()
53 fixed_queue_t* queue; in TEST_F() local
81 fixed_queue_t* queue; in TEST_F() local
123 fixed_queue_t* queue; in TEST_F() local
145 fixed_queue_t* queue; in TEST_F() local
167 fixed_queue_t* queue; in TEST_F() local
195 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
232 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
262 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
289 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
[all …]
/packages/modules/Bluetooth/system/gd/os/linux_generic/
Dqueue_unittest.cc76 explicit TestEnqueueEnd(Queue<std::string>* queue, Handler* handler) in TestEnqueueEnd()
142 explicit TestDequeueEnd(Queue<std::string>* queue, Handler* handler, int capacity) in TestDequeueEnd()
214 Queue<std::string> queue(kQueueSize); in TEST_F() local
239 Queue<std::string> queue(kQueueSize); in TEST_F() local
257 Queue<std::string> queue(kQueueSize); in TEST_F() local
292 Queue<std::string> queue(kQueueSize); in TEST_F() local
327 Queue<std::string> queue(kQueueSize); in TEST_F() local
363 Queue<std::string> queue(kQueueSize); in TEST_F() local
400 Queue<std::string> queue(kQueueSize); in TEST_F() local
430 Queue<std::string> queue(kQueueSize); in TEST_F() local
[all …]
/packages/modules/Connectivity/tests/unit/java/com/android/server/
DCallbackQueueTest.kt51 val queue = CallbackQueue(intArrayOf()).apply { in <lambda>() constant
60 val queue = CallbackQueue(intArrayOf()).apply { in <lambda>() constant
79 val queue = CallbackQueue(intArrayOf()).apply { in <lambda>() constant
95 val queue = CallbackQueue(intArrayOf()).apply { in <lambda>() constant
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/le_scan/
DScanFilterQueueTest.java50 ScanFilterQueue queue = new ScanFilterQueue(); in scanFilterQueueParams() local
130 ScanFilterQueue queue = new ScanFilterQueue(); in popEmpty() local
138 ScanFilterQueue queue = new ScanFilterQueue(); in popFromQueue() local
151 ScanFilterQueue queue = new ScanFilterQueue(); in checkFeatureSelection() local
163 ScanFilterQueue queue = new ScanFilterQueue(); in convertQueueToArray() local
180 ScanFilterQueue queue = new ScanFilterQueue(); in queueAddScanFilter() local
243 ScanFilterQueue queue = new ScanFilterQueue(); in testServiceDataFilter() local
/packages/modules/Bluetooth/system/common/
Dleaky_bonded_queue_unittest.cc54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); in TEST() local
90 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
124 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
164 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
193 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
218 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
227 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(1); in TEST() local
237 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
/packages/modules/StatsD/lib/libstatssocket/tests/
Dstats_buffer_writer_queue_test.cpp64 BufferWriterQueueMock queue; in TEST() local
87 BufferWriterQueueMock queue; in TEST() local
117 BufferWriterQueueMock queue; in TEST() local
159 BufferWriterQueueMock queue; in TEST() local
/packages/modules/Bluetooth/system/test/stub/
Dosi.cc267 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
271 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_try_enqueue()
279 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd()
283 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) { in fixed_queue_get_enqueue_fd()
287 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list()
291 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
295 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
299 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { inc_func_call_count(__func__); } in fixed_queue_enqueue()
300 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
303 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
[all …]
/packages/modules/Bluetooth/system/gd/os/
Dqueue_benchmark.cc59 explicit TestEnqueueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, in TestEnqueueEnd()
112 explicit TestDequeueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, in TestDequeueEnd()
149 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
183 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/audio_util/
DGPMWrapperTest.java70 List<MediaSession.QueueItem> queue = new ArrayList<>(); in isMetadataSynced_whenOutOfSync_returnsFalse() local
100 List<MediaSession.QueueItem> queue = new ArrayList<>(); in isMetadataSynced_whenSynced_returnsTrue() local
/packages/modules/IntentResolver/java/src/com/android/intentresolver/measurements/
DTracer.kt62 val queue = getUserShortcutRequestQueue(userHandle, createIfMissing = true) ?: return in <lambda>() constant
78 val queue = getUserShortcutRequestQueue(userHandle, createIfMissing = false) ?: return -1L in <lambda>() constant
/packages/modules/StatsD/statsd/tests/log_event/
DLogEventQueue_test.cpp58 LogEventQueue queue(50); in TEST() local
83 LogEventQueue queue(50); in TEST() local
121 LogEventQueue queue(50); in TEST() local
/packages/modules/Profiling/tests/cts/src/android/profiling/cts/
DProfilingServiceTests.java1413 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_InvalidState() local
1452 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_OverMaxRetries() local
1490 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_ProfilingFinished() local
1529 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_TraceUnredacted() local
1567 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_TraceRedacted() local
1610 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_AlreadyCopied() local
1647 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_ErrorOccurred() local
1685 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_NotifiedRequester() local
1723 List<TracingSession> queue = new ArrayList<TracingSession>(); in testQueuedResult_Cleanup() local
/packages/modules/Bluetooth/system/gd/os/fuzz/
Ddev_null_queue.h29 DevNullQueue(IQueueDequeue<T>* queue, Handler* handler) : queue_(queue), handler_(handler) {} in DevNullQueue()
Dfuzz_inject_queue.h28 FuzzInjectQueue(IQueueEnqueue<T>* queue, Handler* handler) : handler_(handler) { in FuzzInjectQueue()
/packages/modules/StatsD/statsd/src/socket/
DBaseStatsSocketListener.cpp45 BaseStatsSocketListener::BaseStatsSocketListener(const std::shared_ptr<LogEventQueue>& queue, in BaseStatsSocketListener()
105 LogEventQueue& queue, in processStatsEventBuffer()
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/audio_util/helpers/
DMediaData.java28 public List<Metadata> queue; field in MediaData
/packages/modules/StatsD/statsd/fuzzers/
Dstatsd_socket_data_fuzzer.cpp24 std::shared_ptr<LogEventQueue> queue(new LogEventQueue(50000)); in fuzzSocket() local
/packages/modules/adb/
Dadb_utils.h67 std::vector<T> queue; variable
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/buffer/
DRecordingSampleBuffer.java225 private boolean maybeReadSample(SampleQueue queue, int index) { in maybeReadSample()
272 SampleQueue queue = mReadSampleQueues.get(i); in continueLoading() local
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/
DRecordingSampleBuffer.java225 private boolean maybeReadSample(SampleQueue queue, int index) { in maybeReadSample()
296 SampleQueue queue = mReadSampleQueues.get(i); in continueBuffering() local
/packages/apps/Gallery2/src/com/android/gallery3d/util/
DIdentityCache.java37 public Entry(K key, V value, ReferenceQueue<V> queue) { in Entry()
/packages/apps/Gallery/src/com/android/camera/gallery/
DLruCache.java45 public Entry(K key, V value, ReferenceQueue<V> queue) { in Entry()

1234