Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 222) sorted by relevance

123456789

/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() argument
39 void* msg = fixed_queue_try_dequeue(queue); in fixed_queue_ready()
53 fixed_queue_t* queue; in TEST_F() local
56 queue = fixed_queue_new(0); in TEST_F()
57 EXPECT_TRUE(queue != NULL); in TEST_F()
58 fixed_queue_free(queue, NULL); in TEST_F()
61 queue = fixed_queue_new(1); in TEST_F()
62 EXPECT_TRUE(queue != NULL); in TEST_F()
63 fixed_queue_free(queue, NULL); in TEST_F()
66 queue = fixed_queue_new((size_t)-1); in TEST_F()
[all …]
/packages/modules/Bluetooth/system/osi/src/
Dfixed_queue.cc71 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free() argument
72 if (!queue) return; in fixed_queue_free()
74 fixed_queue_unregister_dequeue(queue); in fixed_queue_free()
77 for (const list_node_t* node = list_begin(queue->list); in fixed_queue_free()
78 node != list_end(queue->list); node = list_next(node)) in fixed_queue_free()
81 list_free(queue->list); in fixed_queue_free()
82 semaphore_free(queue->enqueue_sem); in fixed_queue_free()
83 semaphore_free(queue->dequeue_sem); in fixed_queue_free()
84 delete queue->mutex; in fixed_queue_free()
85 osi_free(queue); in fixed_queue_free()
[all …]
Dalarm.cc94 fixed_queue_t* queue; // The processing queue to add this alarm to member
133 fixed_queue_t* queue, bool for_msg_loop);
138 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
146 static void alarm_register_processing_queue(fixed_queue_t* queue,
222 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal() argument
231 alarm->queue = queue; in alarm_set_internal()
268 alarm->queue = NULL; in alarm_cancel_internal()
404 while (fixed_queue_try_remove_from_queue(alarm->queue, alarm) != NULL) { in remove_pending_alarm()
539 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue() argument
541 log::assert_that(queue != NULL, "assert failed: queue != NULL"); in alarm_register_processing_queue()
[all …]
/packages/modules/Bluetooth/system/common/
Dleaky_bonded_queue_unittest.cc54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); in TEST() local
55 EXPECT_EQ(queue->Capacity(), static_cast<size_t>(3)); in TEST()
56 EXPECT_EQ(queue->Length(), static_cast<size_t>(0)); in TEST()
57 queue->Enqueue(item1); in TEST()
58 EXPECT_EQ(queue->Length(), static_cast<size_t>(1)); in TEST()
59 queue->Enqueue(item2); in TEST()
60 EXPECT_EQ(queue->Length(), static_cast<size_t>(2)); in TEST()
61 queue->Enqueue(item3); in TEST()
62 EXPECT_EQ(queue->Length(), static_cast<size_t>(3)); in TEST()
64 queue->Enqueue(item4); in TEST()
[all …]
/packages/modules/Bluetooth/system/test/mock/
Dmock_osi_fixed_queue.h46 std::function<size_t(fixed_queue_t* queue)> body{
48 size_t operator()(fixed_queue_t* queue) { return body(queue); }; in operator()
57 std::function<void*(fixed_queue_t* queue)> body{
59 void* operator()(fixed_queue_t* queue) { return body(queue); }; in operator()
67 std::function<void(fixed_queue_t* queue, void* data)> body{
69 void operator()(fixed_queue_t* queue, void* data) { body(queue, data); }; in operator()
77 std::function<void(fixed_queue_t* queue, fixed_queue_free_cb free_cb)> body{
79 void operator()(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in operator()
80 body(queue, free_cb); in operator()
89 std::function<void(fixed_queue_t* queue, fixed_queue_free_cb free_cb)> body{
[all …]
Dmock_osi_fixed_queue.cc59 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity() argument
61 return test::mock::osi_fixed_queue::fixed_queue_capacity(queue); in fixed_queue_capacity()
63 void* fixed_queue_dequeue(fixed_queue_t* queue) { in fixed_queue_dequeue() argument
65 return test::mock::osi_fixed_queue::fixed_queue_dequeue(queue); in fixed_queue_dequeue()
67 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue() argument
69 test::mock::osi_fixed_queue::fixed_queue_enqueue(queue, data); in fixed_queue_enqueue()
71 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush() argument
73 test::mock::osi_fixed_queue::fixed_queue_flush(queue, 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() argument
77 test::mock::osi_fixed_queue::fixed_queue_free(queue, free_cb); in fixed_queue_free()
[all …]
/packages/modules/Bluetooth/system/osi/include/
Dfixed_queue.h31 typedef void (*fixed_queue_cb)(fixed_queue_t* queue, void* context);
44 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb);
49 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb);
53 bool fixed_queue_is_empty(fixed_queue_t* queue);
57 size_t fixed_queue_length(fixed_queue_t* queue);
61 size_t fixed_queue_capacity(fixed_queue_t* queue);
66 void fixed_queue_enqueue(fixed_queue_t* queue, void* data);
71 void* fixed_queue_dequeue(fixed_queue_t* queue);
77 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data);
82 void* fixed_queue_try_dequeue(fixed_queue_t* queue);
[all …]
/packages/modules/StatsD/lib/libstatssocket/tests/
Dstats_buffer_writer_queue_test.cpp64 BufferWriterQueueMock queue; in TEST() local
65 EXPECT_CALL(queue, handleCommand(_)).WillOnce(Return(true)); in TEST()
67 const bool addedToQueue = queue.write(buffer, eventBufferSize, atomId); in TEST()
73 queue.drainQueue(); in TEST()
74 EXPECT_EQ(queue.getQueueSize(), 0); in TEST()
87 BufferWriterQueueMock queue; in TEST() local
88 EXPECT_CALL(queue, handleCommand(_)).WillRepeatedly(Return(false)); in TEST()
91 const bool addedToQueue = queue.write(buffer, eventBufferSize, atomId); in TEST()
95 const bool addedToQueue = queue.write(buffer, eventBufferSize, atomId); in TEST()
99 EXPECT_EQ(queue.getQueueSize(), BufferWriterQueueMock::kQueueMaxSizeLimit); in TEST()
[all …]
/packages/modules/Bluetooth/system/gd/os/linux_generic/
Dqueue_unittest.cc77 explicit TestEnqueueEnd(Queue<std::string>* queue, Handler* handler) in TestEnqueueEnd() argument
78 : count(0), handler_(handler), queue_(queue), delay_(0) {} in TestEnqueueEnd()
122 std::queue<std::unique_ptr<std::string>> buffer_;
143 explicit TestDequeueEnd(Queue<std::string>* queue, Handler* handler, int capacity) in TestDequeueEnd() argument
144 : count(0), handler_(handler), queue_(queue), capacity_(capacity), delay_(0) {} in TestDequeueEnd()
186 std::queue<std::unique_ptr<std::string>> buffer_;
215 Queue<std::string> queue(kQueueSize); in TEST_F() local
216 TestEnqueueEnd test_enqueue_end(&queue, enqueue_handler_); in TEST_F()
239 Queue<std::string> queue(kQueueSize); in TEST_F() local
240 TestDequeueEnd test_dequeue_end(&queue, dequeue_handler_, kQueueSize); in TEST_F()
[all …]
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/le_scan/
DScanFilterQueueTest.java39 ScanFilterQueue queue = new ScanFilterQueue(); in scanFilterQueueParams() local
44 queue.addDeviceAddress(address, type, irk); in scanFilterQueueParams()
46 queue.addServiceChanged(); in scanFilterQueueParams()
49 queue.addUuid(uuid); in scanFilterQueueParams()
52 queue.addUuid(uuid, uuidMask); in scanFilterQueueParams()
56 queue.addSolicitUuid(solicitUuid, solicitUuidMask); in scanFilterQueueParams()
59 queue.addName(name); in scanFilterQueueParams()
63 queue.addManufacturerData(company, data); in scanFilterQueueParams()
67 queue.addManufacturerData(company, companyMask, data, dataMask); in scanFilterQueueParams()
71 queue.addServiceData(serviceData, serviceDataMask); in scanFilterQueueParams()
[all …]
/packages/modules/StatsD/statsd/tests/log_event/
DLogEventQueue_test.cpp58 LogEventQueue queue(50); in TEST() local
60 std::thread writer([&queue, eventTimeNs] { in TEST()
63 result = queue.push(makeLogEvent(eventTimeNs + i * 1000)); in TEST()
69 std::thread reader([&queue, eventTimeNs] { in TEST()
71 auto event = queue.waitPop(); in TEST()
83 LogEventQueue queue(50); in TEST() local
85 std::thread writer([&queue, eventTimeNs] { in TEST()
89 result = queue.push(makeLogEvent(eventTimeNs + i * 1000)); in TEST()
104 std::thread reader([&queue, eventTimeNs] { in TEST()
107 auto event = queue.waitPop(); in TEST()
[all …]
/packages/apps/Dialer/java/com/android/voicemail/impl/scheduling/
DTaskQueue.java40 private final Queue<Task> queue = new ArrayDeque<>(); field in TaskQueue
43 List<Bundle> result = new ArrayList<>(queue.size()); in toBundles()
44 for (Task task : queue) { in toBundles()
51 Assert.isTrue(queue.isEmpty()); in fromBundles()
82 queue.add(task); in add()
87 queue.remove(task); in remove()
92 for (Task task : queue) { in getTask()
125 for (Task task : queue) { in getNextTask()
139 queue.clear(); in clear()
143 return queue.size(); in size()
[all …]
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/
DSimpleSampleBuffer.java91 for (SampleQueue queue : mPlayingSampleQueues) { in getBufferedPositionUs()
92 if (queue == null) { in getBufferedPositionUs()
95 Long lastQueuedSamplePositionUs = queue.getLastQueuedPositionUs(); in getBufferedPositionUs()
113 SampleQueue queue = mPlayingSampleQueues[track]; in readSample() local
114 SoftPreconditions.checkNotNull(queue); in readSample()
115 int result = queue == null ? SampleSource.NOTHING_READ : queue.dequeueSample(sampleHolder); in readSample()
154 for (SampleQueue queue : mPlayingSampleQueues) { in continueBuffering()
155 if (queue == null) { in continueBuffering()
158 if (queue.getLastQueuedPositionUs() == null in continueBuffering()
159 || positionUs > queue.getLastQueuedPositionUs()) { in continueBuffering()
DRecordingSampleBuffer.java225 private boolean maybeReadSample(SampleQueue queue, int index) { in maybeReadSample() argument
226 if (queue.getLastQueuedPositionUs() != null in maybeReadSample()
227 && queue.getLastQueuedPositionUs() > mCurrentPlaybackPositionUs + BUFFER_NEEDED_US in maybeReadSample()
228 && queue.isDurationGreaterThan(MIN_SEEK_DURATION_US)) { in maybeReadSample()
238 queue.queueSample(sample); in maybeReadSample()
296 SampleQueue queue = mReadSampleQueues.get(i); in continueBuffering() local
297 maybeReadSample(queue, i); in continueBuffering()
298 if (queue.getLastQueuedPositionUs() == null in continueBuffering()
299 || positionUs > queue.getLastQueuedPositionUs()) { in continueBuffering()
/packages/modules/Bluetooth/system/gd/os/
Dqueue_benchmark.cc59 …explicit TestEnqueueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestEnqueueEnd() argument
60 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestEnqueueEnd()
93 std::queue<std::string> buffer_;
109 …explicit TestDequeueEnd(int64_t count, Queue<std::string>* queue, Handler* handler, std::promise<v… in TestDequeueEnd() argument
110 : count_(count), handler_(handler), queue_(queue), promise_(promise) {} in TestDequeueEnd()
127 std::queue<std::string> buffer_;
143 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
148 TestDequeueEnd test_dequeue_end(num_data_to_send_, &queue, enqueue_handler_, &dequeue_promise); in BENCHMARK_DEFINE_F()
153 TestEnqueueEnd test_enqueue_end(num_data_to_send_, &queue, enqueue_handler_, &enqueue_promise); in BENCHMARK_DEFINE_F()
177 Queue<std::string> queue(num_data_to_send_); in BENCHMARK_DEFINE_F() local
[all …]
/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/buffer/
DMemorySampleBuffer.java86 SampleQueue queue = mPlayingSampleQueues[track]; in readSample() local
87 SoftPreconditions.checkNotNull(queue); in readSample()
88 int result = queue == null ? C.RESULT_NOTHING_READ : queue.dequeueSample(sampleHolder); in readSample()
129 for (SampleQueue queue : mPlayingSampleQueues) { in continueLoading()
130 if (queue == null) { in continueLoading()
133 if (queue.getLastQueuedPositionUs() == null in continueLoading()
134 || positionUs > queue.getLastQueuedPositionUs()) { in continueLoading()
DRecordingSampleBuffer.java225 private boolean maybeReadSample(SampleQueue queue, int index) { in maybeReadSample() argument
226 if (queue.getLastQueuedPositionUs() != null in maybeReadSample()
227 && queue.getLastQueuedPositionUs() > mCurrentPlaybackPositionUs + BUFFER_NEEDED_US in maybeReadSample()
228 && queue.isDurationGreaterThan(MIN_SEEK_DURATION_US)) { in maybeReadSample()
238 queue.queueSample(sample); in maybeReadSample()
272 SampleQueue queue = mReadSampleQueues.get(i); in continueLoading() local
273 maybeReadSample(queue, i); in continueLoading()
274 if (queue.getLastQueuedPositionUs() == null in continueLoading()
275 || positionUs > queue.getLastQueuedPositionUs()) { in continueLoading()
/packages/modules/Bluetooth/system/test/stub/
Dosi.cc277 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty() argument
281 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_try_enqueue() argument
289 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd() argument
293 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) { in fixed_queue_get_enqueue_fd() argument
297 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list() argument
301 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity() argument
305 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length() argument
309 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue() argument
312 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush() argument
315 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free() argument
[all …]
/packages/modules/Bluetooth/system/gd/
Dmodule_dumper.cc51 std::queue<DumpsysDataFinisher> queue; in DumpState() local
59 queue.push(instance->second->GetDumpsysData(&builder)); in DumpState()
68 while (!queue.empty()) { in DumpState()
69 queue.front()(&data_builder); in DumpState()
70 queue.pop(); in DumpState()
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/audio_util/helpers/
DMediaData.java28 public List<Metadata> queue; field in MediaData
35 queue = q; in MediaData()
53 if (!Objects.equals(queue, u.queue)) { in equals()
63 return Objects.hash(metadata, queue); in hashCode()
/packages/modules/Bluetooth/system/stack/rfcomm/
Dport_utils.cc126 p_port->tx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
127 p_port->rx.queue = fixed_queue_new(SIZE_MAX); in port_set_defaults()
209 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != in port_release_port()
215 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != in port_release_port()
237 fixed_queue_free(p_port->tx.queue, nullptr); in port_release_port()
238 p_port->tx.queue = nullptr; in port_release_port()
239 fixed_queue_free(p_port->rx.queue, nullptr); in port_release_port()
240 p_port->rx.queue = nullptr; in port_release_port()
389 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
485 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
[all …]
/packages/modules/Bluetooth/system/gd/dumpsys/
Dfilter_test.cc60 std::queue<TableAddFunction> queue; in PopulateTestSchema() local
62 queue.push(test_data_class->GetTable(fb_builder)); in PopulateTestSchema()
77 while (!queue.empty()) { in PopulateTestSchema()
78 queue.front()(&builder); in PopulateTestSchema()
79 queue.pop(); in PopulateTestSchema()
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/audio_util/
DGPMWrapperTest.java69 List<MediaSession.QueueItem> queue = new ArrayList<>(); in isMetadataSynced_whenOutOfSync_returnsFalse() local
74 queue.add(queueItem); in isMetadataSynced_whenOutOfSync_returnsFalse()
75 when(mMediaController.getQueue()).thenReturn(queue); in isMetadataSynced_whenOutOfSync_returnsFalse()
99 List<MediaSession.QueueItem> queue = new ArrayList<>(); in isMetadataSynced_whenSynced_returnsTrue() local
103 queue.add(queueItem); in isMetadataSynced_whenSynced_returnsTrue()
104 when(mMediaController.getQueue()).thenReturn(queue); in isMetadataSynced_whenSynced_returnsTrue()
/packages/modules/IntentResolver/java/src/com/android/intentresolver/measurements/
DTracer.kt62 val queue = getUserShortcutRequestQueue(userHandle, createIfMissing = true) ?: return in <lambda>() constant
66 synchronized(queue) { in <lambda>()
68 queue.addFirst(longArrayOf(startTime, id.toLong())) in <lambda>()
78 val queue = getUserShortcutRequestQueue(userHandle, createIfMissing = false) ?: return -1L in <lambda>() constant
81 return synchronized(queue) { queue.removeLastOrNull() } in <lambda>()
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/audio_util/
DMediaPlayerWrapper.java99 mCurrentData.queue = Util.toMetadataList(mContext, getQueue()); in MediaPlayerWrapper()
150 for (Metadata metadata : mCurrentData.queue) { in getCurrentQueue()
163 return mCurrentData.queue; in getCurrentQueue()
255 List<MediaSession.QueueItem> queue = getQueue(); in isMetadataSynced() local
256 if (queue != null && getActiveQueueID() != -1) { in isMetadataSynced()
260 for (MediaSession.QueueItem item : queue) { in isMetadataSynced()
532 public void onQueueChanged(@Nullable List<MediaSession.QueueItem> queue) { in onQueueChanged() argument
540 if (!Objects.equals(queue, getQueue())) { in onQueueChanged()
544 List<Metadata> current_queue = Util.toMetadataList(mContext, queue); in onQueueChanged()
545 if (current_queue.equals(mCurrentData.queue)) { in onQueueChanged()
[all …]

123456789