| /aosp12/frameworks/native/services/inputflinger/tests/ |
| H A D | BlockingQueue_test.cpp | 33 BlockingQueue<int> queue(capacity); in TEST()
44 BlockingQueue<int> queue(capacity); in TEST()
59 BlockingQueue<int> queue(capacity); in TEST()
71 BlockingQueue<int> queue(capacity); in TEST()
83 BlockingQueue<int> queue(capacity); in TEST()
100 BlockingQueue<int> queue(capacity); in TEST()
125 BlockingQueue<int> queue(capacity); in TEST()
|
| /aosp12/packages/apps/UniversalMediaPlayer/java/com/android/pump/concurrent/ |
| H A D | UniqueExecutor.java | 26 import java.util.concurrent.BlockingQueue;
37 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue) { in UniqueExecutor()
42 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor()
48 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor()
54 @NonNull TimeUnit unit, @NonNull BlockingQueue<Runnable> workQueue, in UniqueExecutor()
|
| /aosp12/packages/services/Car/tests/carservice_test/src/com/android/car/ |
| H A D | MockedVmsTestBase.java | 45 import java.util.concurrent.BlockingQueue;
127 private BlockingQueue<VmsSubscriptionState> mSubscriptionState =
153 private BlockingQueue<Pair<VmsLayer, byte[]>> mMessages = new LinkedBlockingQueue<>();
154 private BlockingQueue<VmsAvailableLayers> mAvailableLayers = new LinkedBlockingQueue<>();
178 private BlockingQueue<VehiclePropValue> mMessages = new LinkedBlockingQueue<>();
208 private static <T> T receiveWithTimeout(BlockingQueue<T> queue) { in receiveWithTimeout()
|
| /aosp12/packages/services/Car/tests/carservice_unit_test/src/android/car/test/util/ |
| H A D | BlockingResultReceiverTest.java | 27 import java.util.concurrent.BlockingQueue;
43 BlockingQueue<Integer> resultCodeBlockingQueue = new ArrayBlockingQueue<>(1); in testSend_andAssertCalled()
44 BlockingQueue<Bundle> dataBlockingQueue = new ArrayBlockingQueue<>(1); in testSend_andAssertCalled()
|
| /aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/adb/ |
| H A D | AdbDebuggingManagerTestActivity.java | 27 import java.util.concurrent.BlockingQueue;
43 private static BlockingQueue sBlockingQueue;
137 public Configurator setBlockingQueue(BlockingQueue blockingQueue) { in setBlockingQueue()
|
| /aosp12/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/policy/ |
| H A D | BlockingQueueIntentReceiver.java | 22 import java.util.concurrent.BlockingQueue;
27 private final BlockingQueue<Intent> mQueue = new ArrayBlockingQueue<Intent>(1);
|
| /aosp12/packages/services/Telecomm/src/com/android/server/telecom/bluetooth/ |
| H A D | BluetoothRouteManager.java | 45 import java.util.concurrent.BlockingQueue;
198 BlockingQueue<IState> sink = (BlockingQueue<IState>) args.arg3; in processMessage()
317 BlockingQueue<IState> sink = (BlockingQueue<IState>) args.arg3; in processMessage()
427 BlockingQueue<IState> sink = (BlockingQueue<IState>) args.arg3; in processMessage()
509 BlockingQueue<IState> stateQueue = new LinkedBlockingQueue<>(); in isBluetoothAudioConnectedOrPending()
|
| /aosp12/packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/common/ |
| H A D | BlockingBroadcastReceiver.java | 26 import java.util.concurrent.BlockingQueue;
48 private final BlockingQueue<Intent> mBlockingQueue;
|
| /aosp12/frameworks/native/services/inputflinger/ |
| H A D | BlockingQueue.h | 35 class BlockingQueue {
37 BlockingQueue(size_t capacity) : mCapacity(capacity) { in BlockingQueue() function
|
| /aosp12/frameworks/base/core/tests/coretests/src/android/os/ |
| H A D | BinderWorkSourceNestedService.java | 25 import java.util.concurrent.BlockingQueue;
52 BlockingQueue<IBinderWorkSourceService> blockingQueue =
|
| /aosp12/frameworks/base/packages/Shell/tests/src/com/android/shell/ |
| H A D | ActionSendMultipleConsumerActivity.java | 19 import java.util.concurrent.BlockingQueue;
90 private final BlockingQueue<Bundle> mQueue = new SynchronousQueue<>();
|
| /aosp12/packages/services/Car/tests/carservice_unit_test/src/android/car/test/mocks/ |
| H A D | SyncAnswerTest.java | 28 import java.util.concurrent.BlockingQueue;
75 final BlockingQueue<Exception> mExceptionReceiver = new ArrayBlockingQueue<>(1);
|
| /aosp12/packages/apps/ManagedProvisioning/tests/instrumentation/src/com/android/managedprovisioning/provisioning/ |
| H A D | ProvisioningControllerBaseTest.java | 36 import java.util.concurrent.BlockingQueue;
96 private BlockingQueue<AbstractProvisioningTask> mBlockingQueue
|
| /aosp12/frameworks/base/tests/ActivityManagerPerfTests/tests/src/com/android/frameworks/perftests/am/util/ |
| H A D | TimeReceiver.java | 23 import java.util.concurrent.BlockingQueue;
36 private BlockingQueue<ReceivedMessage> mQueue = new LinkedBlockingQueue<>();
|
| /aosp12/frameworks/base/services/core/java/com/android/server/pm/ |
| H A D | ParallelPackageParser.java | 32 import java.util.concurrent.BlockingQueue;
47 private final BlockingQueue<ParseResult> mQueue = new ArrayBlockingQueue<>(QUEUE_CAPACITY);
|
| /aosp12/frameworks/av/media/libmediatranscoding/transcoder/include/media/ |
| H A D | VideoTrackTranscoder.h | 52 class BlockingQueue {
98 BlockingQueue<std::function<void()>> mCodecMessageQueue;
|
| /aosp12/frameworks/base/apct-tests/perftests/autofill/src/android/view/autofill/ |
| H A D | MyAutofillCallback.java | 25 import java.util.concurrent.BlockingQueue;
47 private final BlockingQueue<MyEvent> mEvents = new LinkedBlockingQueue<>(2);
|
| H A D | MyAutofillService.java | 35 import java.util.concurrent.BlockingQueue;
50 private static final BlockingQueue<FillRequest> sFillRequests = new LinkedBlockingQueue<>();
51 private static final BlockingQueue<CannedResponse> sCannedResponses =
|
| /aosp12/system/bt/gd/common/ |
| H A D | blocking_queue_unittest.cc | 37 BlockingQueue<int> queue_;
132 BlockingQueue<std::vector<uint8_t>> queue_;
|
| /aosp12/packages/apps/Camera2/src/com/android/camera/async/ |
| H A D | ConcurrentBufferQueue.java | 22 import java.util.concurrent.BlockingQueue;
82 private final BlockingQueue<Entry<T>> mQueue;
|
| /aosp12/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/hid/ |
| H A D | HidDeviceTest.java | 55 import java.util.concurrent.BlockingQueue;
87 private final BlockingQueue<Intent> mConnectionStateChangedQueue = new LinkedBlockingQueue<>();
88 private final BlockingQueue<Integer> mCallbackQueue = new LinkedBlockingQueue<>();
175 private Intent waitForIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForIntent()
196 private void verifyCallback(int timeoutMs, int callbackType, BlockingQueue<Integer> queue) { in verifyCallback()
|
| /aosp12/packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/ |
| H A D | TestUtils.java | 45 import java.util.concurrent.BlockingQueue;
208 public static Intent waitForIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForIntent()
227 public static Intent waitForNoIntent(int timeoutMs, BlockingQueue<Intent> queue) { in waitForNoIntent()
|
| /aosp12/frameworks/base/apct-tests/perftests/utils/src/android/perftests/utils/ |
| H A D | TestPackageInstaller.java | 34 import java.util.concurrent.BlockingQueue;
118 private final BlockingQueue<Intent> mIntentSenderResults = new LinkedBlockingQueue<>();
|
| /aosp12/frameworks/base/tests/AmSlam/src/test/amslam/ |
| H A D | MainActivity.java | 31 import java.util.concurrent.BlockingQueue;
38 private static final BlockingQueue<Intent> sWorkQueue = new ArrayBlockingQueue<>(100);
|
| /aosp12/frameworks/layoutlib/remote/server/src/com/android/layoutlib/bridge/remote/server/ |
| H A D | ServerMain.java | 38 import java.util.concurrent.BlockingQueue;
124 BlockingQueue<String> outputQueue = new ArrayBlockingQueue<>(10); in forkAndStartServer()
|