Home
last modified time | relevance | path

Searched refs:LinkedBlockingQueue (Results 1 – 25 of 55) sorted by relevance

123

/frameworks/av/media/libstagefright/webm/include/webm/
DWebmFrameThread.h69 LinkedBlockingQueue<const sp<WebmFrame> >& videoSource,
70 LinkedBlockingQueue<const sp<WebmFrame> >& audioSource,
83 LinkedBlockingQueue<const sp<WebmFrame> >& mVideoFrames;
84 LinkedBlockingQueue<const sp<WebmFrame> >& mAudioFrames;
102 WebmFrameSourceThread(int type, LinkedBlockingQueue<const sp<WebmFrame> >& sink);
106 LinkedBlockingQueue<const sp<WebmFrame> >& mSink;
115 WebmFrameEmptySourceThread(int type, LinkedBlockingQueue<const sp<WebmFrame> >& sink) in WebmFrameEmptySourceThread()
129 LinkedBlockingQueue<const sp<WebmFrame> >& sink,
DLinkedBlockingQueue.h27 class LinkedBlockingQueue {
44 DISALLOW_EVIL_CONSTRUCTORS(LinkedBlockingQueue);
47 LinkedBlockingQueue() { in LinkedBlockingQueue() function
50 ~LinkedBlockingQueue() { in ~LinkedBlockingQueue()
/frameworks/base/tests/Input/src/com/android/test/input/
DSpyInputEventSenderAndReceiver.kt27 import java.util.concurrent.LinkedBlockingQueue
32 private fun <T> getEvent(queue: LinkedBlockingQueue<T>): T? { in getEvent()
36 private fun <T> assertNoEvents(queue: LinkedBlockingQueue<T>) { in assertNoEvents()
43 private val mInputEvents = LinkedBlockingQueue<InputEvent>()
64 private val mFinishedSignals = LinkedBlockingQueue<FinishedSignal>()
65 private val mTimelines = LinkedBlockingQueue<Timeline>()
/frameworks/opt/telephony/tests/telephonytests/src/android/telephony/ims/
DImsConfigImplTest.java35 import java.util.concurrent.LinkedBlockingQueue;
115 final LinkedBlockingQueue<Pair<Integer, Integer>> mConfigChanges = in testIntCaching()
116 new LinkedBlockingQueue<>(); in testIntCaching()
144 final LinkedBlockingQueue<Pair<Integer, String>> mConfigChanges = in testStringCaching()
145 new LinkedBlockingQueue<>(); in testStringCaching()
/frameworks/base/core/java/android/speech/tts/
DAudioPlaybackHandler.java21 import java.util.concurrent.LinkedBlockingQueue;
27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue =
28 new LinkedBlockingQueue<PlaybackQueueItem>();
/frameworks/base/core/java/android/os/
DTestLooperManager.java19 import java.util.concurrent.LinkedBlockingQueue;
38 private final LinkedBlockingQueue<MessageExecution> mExecuteQueue = new LinkedBlockingQueue<>();
DAsyncTask.java30 import java.util.concurrent.LinkedBlockingQueue;
227 private static LinkedBlockingQueue<Runnable> sBackupExecutorQueue;
237 sBackupExecutorQueue = new LinkedBlockingQueue<Runnable>();
/frameworks/ex/camera2/public/src/com/android/ex/camera2/utils/
DStateWaiter.java26 import java.util.concurrent.LinkedBlockingQueue;
55 private final LinkedBlockingQueue<Integer> mQueuedStates = new LinkedBlockingQueue<>();
/frameworks/ex/camera2/public/src/com/android/ex/camera2/blocking/
DBlockingStateCallback.java27 import java.util.concurrent.LinkedBlockingQueue;
52 private final LinkedBlockingQueue<Integer> mRecentStates =
53 new LinkedBlockingQueue<Integer>();
DBlockingOfflineSessionCallback.java29 import java.util.concurrent.LinkedBlockingQueue;
54 private final LinkedBlockingQueue<Integer> mRecentStates =
55 new LinkedBlockingQueue<Integer>();
/frameworks/base/telecomm/java/android/telecom/Logging/
DEventManager.java40 import java.util.concurrent.LinkedBlockingQueue;
71 private LinkedBlockingQueue<EventRecord> mEventRecords =
72 new LinkedBlockingQueue<>(DEFAULT_EVENTS_TO_CACHE);
363 LinkedBlockingQueue<EventRecord> oldEventLog = mEventRecords; in changeEventCacheSize()
364 mEventRecords = new LinkedBlockingQueue<>(newSize); in changeEventCacheSize()
395 public LinkedBlockingQueue<EventRecord> getEventRecords() { in getEventRecords()
/frameworks/base/core/tests/coretests/src/android/os/
DBinderWorkSourceNestedService.java26 import java.util.concurrent.LinkedBlockingQueue;
53 new LinkedBlockingQueue<>();
/frameworks/opt/net/ims/tests/src/com/android/ims/
DImsUtTest.java46 import java.util.concurrent.LinkedBlockingQueue;
61 private final LinkedBlockingQueue<ImsSsInfo> mPendingSsInfos = new LinkedBlockingQueue<>(1);
/frameworks/base/tests/ActivityManagerPerfTests/tests/src/com/android/frameworks/perftests/am/util/
DTimeReceiver.java24 import java.util.concurrent.LinkedBlockingQueue;
36 private BlockingQueue<ReceivedMessage> mQueue = new LinkedBlockingQueue<>();
/frameworks/av/media/tests/benchmark/MediaBenchmarkTest/src/main/java/com/android/media/benchmark/library/
DFrameReleaseQueue.java23 import java.util.concurrent.LinkedBlockingQueue;
37 private LinkedBlockingQueue<FrameInfo> mFrameInfoQueue;
131 this.mFrameInfoQueue = new LinkedBlockingQueue(); in FrameReleaseQueue()
/frameworks/base/packages/FusedLocation/test/src/com/android/location/gnss/tests/
DGnssOverlayLocationServiceTest.java52 import java.util.concurrent.LinkedBlockingQueue;
122 private final LinkedBlockingQueue<Location> mLocations;
125 mLocations = new LinkedBlockingQueue<>(); in LocationProviderManagerCapture()
/frameworks/opt/bitmap/src/com/android/bitmap/
DUnrefedPooledCache.java26 import java.util.concurrent.LinkedBlockingQueue;
47 private final LinkedBlockingQueue<V> mPool;
61 mPool = new LinkedBlockingQueue<V>(); in UnrefedPooledCache()
/frameworks/base/apct-tests/perftests/autofill/src/android/view/autofill/
DMyAutofillCallback.java26 import java.util.concurrent.LinkedBlockingQueue;
47 private final BlockingQueue<MyEvent> mEvents = new LinkedBlockingQueue<>(2);
DMyAutofillService.java36 import java.util.concurrent.LinkedBlockingQueue;
50 private static final BlockingQueue<FillRequest> sFillRequests = new LinkedBlockingQueue<>();
52 new LinkedBlockingQueue<>();
/frameworks/base/packages/FusedLocation/test/src/com/android/location/fused/tests/
DFusedLocationServiceTest.java53 import java.util.concurrent.LinkedBlockingQueue;
147 private final LinkedBlockingQueue<Location> mLocations;
150 mLocations = new LinkedBlockingQueue<>(); in LocationProviderManagerCapture()
/frameworks/av/media/libstagefright/webm/
DWebmFrameThread.cpp64 LinkedBlockingQueue<const sp<WebmFrame> >& sink) in WebmFrameSourceThread()
88 LinkedBlockingQueue<const sp<WebmFrame> >& videoSource, in WebmFrameSinkThread()
89 LinkedBlockingQueue<const sp<WebmFrame> >& audioSource, in WebmFrameSinkThread()
265 LinkedBlockingQueue<const sp<WebmFrame> >& sink, in WebmFrameMediaSourceThread()
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/decoder/
DMediaDecoder.java33 import java.util.concurrent.LinkedBlockingQueue;
91 private final LinkedBlockingQueue<Integer> mEventQueue;
141 mEventQueue = new LinkedBlockingQueue<Integer>(MAX_EVENTS); in MediaDecoder()
/frameworks/base/apct-tests/perftests/utils/src/android/perftests/utils/
DTestPackageInstaller.java35 import java.util.concurrent.LinkedBlockingQueue;
118 private final BlockingQueue<Intent> mIntentSenderResults = new LinkedBlockingQueue<>();
/frameworks/base/tools/lock_agent/java/com/android/lock_checker/
DOnThreadLockChecker.java29 import java.util.concurrent.LinkedBlockingQueue;
45 private final LinkedBlockingQueue<Violation> mQueue = new LinkedBlockingQueue<>();
/frameworks/base/services/core/java/com/android/server/pm/
DShortcutBitmapSaver.java44 import java.util.concurrent.LinkedBlockingQueue;
81 new LinkedBlockingQueue<>());

123