OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:mQueue
(Results
51 - 75
of
136
) sorted by null
1
2
3
4
5
6
/frameworks/base/services/core/jni/BroadcastRadio/
NativeCallbackThread.h
32
std::queue<Task>
mQueue
;
/frameworks/native/services/surfaceflinger/
MessageQueue.cpp
57
mQueue
.mLooper->sendMessage(this, Message(MessageQueue::REFRESH));
63
mQueue
.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE));
71
mQueue
.mFlinger->onMessageReceived(message.what);
75
mQueue
.mFlinger->onMessageReceived(message.what);
MessageQueue.h
102
MessageQueue&
mQueue
;
106
explicit Handler(MessageQueue& queue) :
mQueue
(queue), mEventMask(0) {}
/packages/apps/Gallery/src/com/android/camera/gallery/
ImageListUber.java
39
private final PriorityQueue<MergeSlot>
mQueue
;
55
mQueue
= new PriorityQueue<MergeSlot>(4,
63
mQueue
.clear();
67
if (slot.next())
mQueue
.add(slot);
136
if (slot.next())
mQueue
.add(slot);
139
if (slot.next())
mQueue
.add(slot);
144
MergeSlot slot =
mQueue
.poll();
234
if (slot.next())
mQueue
.add(slot);
237
if (slot.next())
mQueue
.add(slot);
/frameworks/av/media/libstagefright/rtsp/
ARTPSource.h
44
List<sp<ABuffer> > *queue() { return &
mQueue
; }
57
List<sp<ABuffer> >
mQueue
;
ARTPSource.cpp
114
mQueue
.push_back(buffer);
158
List<sp<ABuffer> >::iterator it =
mQueue
.begin();
159
while (it !=
mQueue
.end() && (uint32_t)(*it)->int32Data() < seqNum) {
163
if (it !=
mQueue
.end() && (uint32_t)(*it)->int32Data() == seqNum) {
168
mQueue
.insert(it, buffer);
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/
FrameManager.java
161
private PriorityQueue<Backing>
mQueue
;
164
mQueue
= new PriorityQueue<Backing>(4, new Comparator<Backing>() {
174
for (Backing backing :
mQueue
) {
181
mQueue
.remove(backing);
195
mQueue
.add(backing);
203
mQueue
.clear();
224
Backing dropped =
mQueue
.poll();
/frameworks/base/cmds/incidentd/src/
IncidentService.cpp
105
mQueue
.push_back(request);
110
if (
mQueue
.empty()) {
113
sp<ReportRequest> front(
mQueue
.front());
114
mQueue
.pop_front();
124
mQueue
(queue),
141
mQueue
->addRequest(request);
163
sp<ReportRequest> request =
mQueue
->getNextRequest();
202
:
mQueue
(new ReportRequestQueue()),
204
mHandler = new ReportHandler(handlerLooper,
mQueue
, mThrottler);
/art/test/079-phantom/src/
Bitmap.java
136
ReferenceQueue<PhantomWrapper>
mQueue
;
139
mQueue
= queue;
146
PhantomWrapper ref = (PhantomWrapper)
mQueue
.remove();
/cts/tests/inputmethod/src/android/view/inputmethod/cts/util/
WindowFocusStealer.java
41
final BlockingQueue<Integer>
mQueue
= new ArrayBlockingQueue<>(1);
49
mQueue
.add(resultCode);
55
result =
mQueue
.poll(timeout, TimeUnit.MILLISECONDS);
/external/volley/src/main/java/com/android/volley/
NetworkDispatcher.java
38
private final BlockingQueue<Request<?>>
mQueue
;
59
mQueue
= queue;
104
Request<?> request =
mQueue
.take();
/frameworks/base/services/core/java/com/android/server/pm/
ParallelPackageParser.java
52
private final BlockingQueue<ParseResult>
mQueue
= new ArrayBlockingQueue<>(QUEUE_CAPACITY);
92
return
mQueue
.take();
124
mQueue
.put(pr);
/frameworks/layoutlib/bridge/src/android/animation/
AnimationThread.java
69
private Queue<MessageBundle>
mQueue
= new PriorityQueue<MessageBundle>();
95
mQueue
.add(new MessageBundle(handler, msg, uptimeMillis));
118
MessageBundle bundle =
mQueue
.poll();
147
// the next message, so
mQueue
will have another one.
161
} while (mListener.isCanceled() == false &&
mQueue
.size() > 0);
/frameworks/native/libs/gui/
BufferQueueConsumer.cpp
84
if (mCore->
mQueue
.empty() && !sharedBufferAvailable) {
88
BufferQueueCore::Fifo::iterator front(mCore->
mQueue
.begin());
95
if (expectedPresent != 0 && !mCore->
mQueue
.empty()) {
116
while (mCore->
mQueue
.size() > 1 && !mCore->
mQueue
[0].mIsAutoTimestamp) {
117
const BufferItem& bufferItem(mCore->
mQueue
[1]);
150
desiredPresent, expectedPresent, mCore->
mQueue
.size());
174
mCore->
mQueue
.erase(front);
175
front = mCore->
mQueue
.begin();
203
if (sharedBufferAvailable && mCore->
mQueue
.empty())
[
all
...]
BufferHubConsumer.cpp
26
consumer->
mQueue
= queue;
37
consumer->
mQueue
= ConsumerQueue::Import(parcelable.TakeChannelHandle());
/frameworks/av/media/libmediaplayerservice/nuplayer/
NuPlayerStreamListener.h
65
List<QueueEntry>
mQueue
;
/frameworks/base/services/backup/java/com/android/server/backup/internal/
PerformInitializeTask.java
54
private final String[]
mQueue
;
83
mQueue
= transportNames;
112
List<TransportClient> transportClientsToDisposeOf = new ArrayList<>(
mQueue
.length);
115
for (String transportName :
mQueue
) {
/frameworks/base/services/net/java/android/net/util/
PacketReader.java
77
private final MessageQueue
mQueue
;
92
mQueue
= mHandler.getLooper().getQueue();
180
mQueue
.addOnFileDescriptorEventListener(
242
mQueue
.removeOnFileDescriptorEventListener(mFd);
/cts/tests/tests/graphics/jni/
VulkanPreTransformTestHelpers.h
41
VkQueue queue() const { return
mQueue
; }
50
VkQueue
mQueue
;
VulkanTestHelpers.h
36
VkQueue queue() { return
mQueue
; }
51
VkQueue
mQueue
= VK_NULL_HANDLE;
/frameworks/native/libs/ui/
FenceTime.cpp
276
while (
mQueue
.size() >= MAX_ENTRIES) {
282
std::shared_ptr<FenceTime> front =
mQueue
.front().lock();
288
mQueue
.pop();
290
mQueue
.push(fence);
294
while (!
mQueue
.empty()) {
296
std::shared_ptr<FenceTime> fence =
mQueue
.front().lock();
300
mQueue
.pop();
304
mQueue
.pop();
/frameworks/base/tests/OneMedia/src/com/android/onemedia/
PlayerSession.java
48
protected ArrayList<MediaSession.QueueItem>
mQueue
;
64
mQueue
= new ArrayList<MediaSession.QueueItem>();
121
mQueue
.clear();
122
mQueue
.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11));
132
mSession.setQueue(mUseQueue ?
mQueue
: null);
155
mQueue
.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11));
/packages/apps/Calendar/src/com/android/calendar/
EventLoader.java
161
LinkedBlockingQueue<LoadRequest>
mQueue
;
165
mQueue
= queue;
171
mQueue
.put(new ShutdownRequest());
186
LoadRequest request =
mQueue
.take();
190
while (!
mQueue
.isEmpty()) {
195
request =
mQueue
.take();
/frameworks/support/media/src/main/java/androidx/media/
MediaPlayer2Impl.java
[
all
...]
/frameworks/support/asynclayoutinflater/src/main/java/androidx/asynclayoutinflater/view/
AsyncLayoutInflater.java
171
private ArrayBlockingQueue<InflateRequest>
mQueue
= new ArrayBlockingQueue<>(10);
180
request =
mQueue
.take();
225
mQueue
.put(request);
Completed in 898 milliseconds
1
2
3
4
5
6