Home
last modified time | relevance | path

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

/cts/tests/sensor/src/android/hardware/cts/helpers/sensoroperations/
DTestSensorOperation.java85 public TestSensorOperation(TestSensorEnvironment environment, Executor executor) { in TestSensorOperation() argument
86 this(environment, executor, null /* handler */); in TestSensorOperation()
94 Executor executor, in TestSensorOperation() argument
97 mExecutor = executor; in TestSensorOperation()
237 Executor executor = new Executor() { in createOperation() local
249 return new TestSensorOperation(environment, executor); in createOperation()
265 Executor executor = new Executor() { in createOperation() local
339 return new TestSensorOperation(environment, executor); in createOperation()
353 Executor executor = new Executor() { in createOperation() local
365 return new TestSensorOperation(environment, executor); in createOperation()
[all …]
DParallelSensorOperation.java86 ThreadPoolExecutor executor = new ThreadPoolExecutor( in execute() local
92 executor.allowCoreThreadTimeOut(true); in execute()
93 executor.prestartAllCoreThreads(); in execute()
98 Future<SensorOperation> future = executor.submit(new Callable<SensorOperation>() { in execute()
135 executor.shutdownNow(); in execute()
/cts/tests/tests/telephony/current/LocationAccessingApp/src/android/telephony/cts/locationaccessingapp/
DCtsLocationAccessService.java90 Executor executor = new Handler(handlerThread.getLooper())::post; in listenForCellInfo() local
91 PhoneStateListener listener = new PhoneStateListener(executor) { in listenForCellInfo()
114 Executor executor = new Handler(handlerThread.getLooper())::post; in listenForCellLocation() local
115 PhoneStateListener listener = new PhoneStateListener(executor) { in listenForCellLocation()
138 Executor executor = new Handler(handlerThread.getLooper())::post; in listenForServiceState() local
139 PhoneStateListener listener = new PhoneStateListener(executor) { in listenForServiceState()
/cts/tests/tests/net/src/android/net/cts/
DDnsResolverTest.java321 public void doTestRawQuery(Executor executor) throws InterruptedException { in doTestRawQuery() argument
326 executor, null, callback); in doTestRawQuery()
334 public void doTestRawQueryBlob(Executor executor) throws InterruptedException { in doTestRawQueryBlob() argument
352 mDns.rawQuery(network, blob, FLAG_NO_CACHE_LOOKUP, executor, null, callback); in doTestRawQueryBlob()
360 public void doTestRawQueryRoot(Executor executor) throws InterruptedException { in doTestRawQueryRoot() argument
366 executor, null, callback); in doTestRawQueryRoot()
375 public void doTestRawQueryNXDomain(Executor executor) throws InterruptedException { in doTestRawQueryNXDomain() argument
389 executor, null, callback); in doTestRawQueryNXDomain()
397 public void doTestRawQueryNXDomainWithPrivateDns(Executor executor) in doTestRawQueryNXDomainWithPrivateDns() argument
411 executor, null, callback); in doTestRawQueryNXDomainWithPrivateDns()
[all …]
DConnectivityManagerTest.java1031 final Executor executor = mContext.getMainExecutor(); in testCreateTcpKeepalive() local
1035 try (SocketKeepalive sk = mCm.createSocketKeepalive(network, s, executor, callback)) { in testCreateTcpKeepalive() argument
1087 try (SocketKeepalive sk = mCm.createSocketKeepalive(network, s, executor, callback)) { in testCreateTcpKeepalive() argument
1139 final Executor executor = mContext.getMainExecutor(); in createConcurrentNattSocketKeepalives() local
1151 srcAddr, dstAddr, executor, callback)); in createConcurrentNattSocketKeepalives()
1160 final Executor executor = mContext.getMainExecutor(); in createConcurrentTcpSocketKeepalives() local
1169 return mCm.createSocketKeepalive(network, tcpSocket, executor, callback); in createConcurrentTcpSocketKeepalives()
/cts/tests/camera/src/android/hardware/camera2/cts/
DCameraManagerTest.java235 final Executor executor = useExecutor ? new HandlerExecutor(mHandler) : null; in testCameraManagerOpenCamerasSerially() local
245 mCameraManager.openCamera(ids[i], executor, mCameraListener); in testCameraManagerOpenCamerasSerially()
285 final Executor executor = useExecutor ? new HandlerExecutor(mHandler) : null; in testCameraManagerOpenAllCameras() local
306 mCameraManager.openCamera(cameraId, executor, mCameraListener); in testCameraManagerOpenAllCameras()
461 final Executor executor = useExecutor ? new HandlerExecutor(mHandler) : null; in testCameraManagerOpenCameraTwice() local
478 mCameraManager.openCamera(ids[i], executor, successListener); in testCameraManagerOpenCameraTwice()
479 mCameraManager.openCamera(ids[i], executor, failListener); in testCameraManagerOpenCameraTwice()
534 Executor executor = new HandlerExecutor(mHandler); in testCameraManagerListener() local
535 mCameraManager.registerAvailabilityCallback(executor, mListener); in testCameraManagerListener()
536 mCameraManager.registerAvailabilityCallback(executor, mListener); in testCameraManagerListener()
[all …]
DCameraDeviceTest.java816 HandlerExecutor executor = new HandlerExecutor(mHandler); in testSessionConfiguration() local
820 SessionConfiguration.SESSION_REGULAR, outConfigs, executor, mSessionMockListener); in testSessionConfiguration()
823 … SessionConfiguration.SESSION_HIGH_SPEED, outConfigs, executor, mSessionMockListener); in testSessionConfiguration()
840 regularSessionConfig.getExecutor(), executor); in testSessionConfiguration()
1675 final Executor executor = useExecutor ? new HandlerExecutor(mHandler) : null; in captureSingleShot() local
1687 if (executor != null) { in captureSingleShot()
1688 startCapture(requestBuilder.build(), repeating, mockCaptureCallback, executor); in captureSingleShot() local
1706 if (executor != null) { in captureSingleShot()
1707 mSession.captureSingleRequest(singleRequest, executor, resultCallback); in captureSingleShot()
1714 if (executor != null) { in captureSingleShot()
[all …]
DFlashlightTest.java136 final Executor executor = useExecutor ? new HandlerExecutor(mHandler) : null; in testTorchCallback()
147 mCameraManager.registerTorchCallback(executor, torchListener); in testTorchCallback()
/cts/tests/tests/os/src/android/os/cts/
DFileUtilsTest.java81 final Executor executor = AsyncTask.THREAD_POOL_EXECUTOR; in testCopyFileStreamListener() local
85 FileUtils.copy(in, out, null, executor, (progress) -> { in testCopyFileStreamListener()
102 final Executor executor = AsyncTask.THREAD_POOL_EXECUTOR; in testCopyFileDescriptorListener() local
106 FileUtils.copy(in.getFD(), out.getFD(), null, executor, (progress) -> { in testCopyFileDescriptorListener() local
/cts/tests/tests/telecom/src/android/telecom/cts/
DCtsRoleManagerAdapter.java129 Executor executor = mContext.getMainExecutor(); in addRoleHolder() local
132 mRoleManager.addRoleHolderAsUser(roleName, packageName, 0, user, executor, in addRoleHolder()
148 Executor executor = mContext.getMainExecutor(); in removeRoleHolder() local
151 mRoleManager.removeRoleHolderAsUser(roleName, packageName, 0, user, executor, in removeRoleHolder()
DCallRedirectionServiceTest.java253 Executor executor = mContext.getMainExecutor(); in addRoleHolder() local
257 packageName, RoleManager.MANAGE_HOLDERS_FLAG_DONT_KILL_APP, user, executor, in addRoleHolder()
272 Executor executor = mContext.getMainExecutor(); in removeRoleHolder() local
276 packageName, RoleManager.MANAGE_HOLDERS_FLAG_DONT_KILL_APP, user, executor, in removeRoleHolder()
DThirdPartyCallScreeningServiceTest.java557 Executor executor = mContext.getMainExecutor(); in addRoleHolder() local
561 packageName, RoleManager.MANAGE_HOLDERS_FLAG_DONT_KILL_APP, user, executor, in addRoleHolder()
576 Executor executor = mContext.getMainExecutor(); in removeRoleHolder() local
580 packageName, RoleManager.MANAGE_HOLDERS_FLAG_DONT_KILL_APP, user, executor, in removeRoleHolder()
DOutgoingCallTest.java156 Executor executor = (Runnable command)->count.countDown(); in testPhoneStateChangeAsExpected() local
157 PhoneStateListener listener = new PhoneStateListener(executor); in testPhoneStateChangeAsExpected()
DIncomingCallTest.java261 Executor executor = (Runnable command)->count.countDown(); in testPhoneStateChangeAsExpected() local
262 PhoneStateListener listener = new PhoneStateListener(executor); in testPhoneStateChangeAsExpected()
/cts/tests/tests/webkit/src/android/webkit/cts/
DWebViewRenderProcessClientTest.java118 private void testWebViewRenderProcessClientOnExecutor(Executor executor) throws Throwable { in testWebViewRenderProcessClientOnExecutor() argument
135 if (executor == null) { in testWebViewRenderProcessClientOnExecutor()
138 mOnUiThread.setWebViewRenderProcessClient(executor, client); in testWebViewRenderProcessClientOnExecutor()
DTracingControllerTest.java292 private void runTracingTestWithCallbacks(TracingReceiver tracingReceiver, Executor executor) {
305 assertTrue(tracingController.stop(tracingReceiver, executor));
/cts/tests/tests/telephonyprovider/src/android/telephonyprovider/cts/
DDefaultSmsAppHelper.java46 Executor executor = context.getMainExecutor(); in ensureDefaultSmsApp() local
58 executor, in ensureDefaultSmsApp()
/cts/libs/deviceutillegacy/src/android/webkit/cts/
DWebViewOnUiThread.java121 final Executor executor, final WebViewRenderProcessClient webViewRenderProcessClient) { in setWebViewRenderProcessClient() argument
122 setWebViewRenderProcessClient(mWebView, executor, webViewRenderProcessClient); in setWebViewRenderProcessClient()
131 final Executor executor, in setWebViewRenderProcessClient() argument
134 webView.setWebViewRenderProcessClient(executor, webViewRenderProcessClient) in setWebViewRenderProcessClient()
/cts/common/device-side/util/src/com/android/compatibility/common/util/
DBusinessLogicTestCase.java74 BusinessLogicExecutor executor = new BusinessLogicDeviceExecutor(getContext(), this); in executeBusinessLogic() local
75 mBusinessLogic.applyLogicFor(testName, executor); in executeBusinessLogic()
/cts/common/device-side/util-axt/src/com/android/compatibility/common/util/
DBusinessLogicTestCase.java75 BusinessLogicExecutor executor = new BusinessLogicDeviceExecutor(getContext(), this); in executeBusinessLogic() local
76 mBusinessLogic.applyLogicFor(testName, executor); in executeBusinessLogic()
/cts/tests/tests/permission/src/android/permission/cts/
DFileSystemPermissionTest.java860 ExecutorService executor = Executors.newCachedThreadPool(); in testReadingSysFilesDoesntFail() local
861 tryToReadFromAllIn(new File("/sys"), executor); in testReadingSysFilesDoesntFail()
862 executor.shutdownNow(); in testReadingSysFilesDoesntFail()
865 private static void tryToReadFromAllIn(File dir, ExecutorService executor) throws IOException { in tryToReadFromAllIn() argument
878 tryToReadFromAllIn(f, executor); in tryToReadFromAllIn()
880 tryFileOpenRead(f, executor); in tryToReadFromAllIn()
886 private static void tryFileOpenRead(final File f, ExecutorService executor) throws IOException { in tryFileOpenRead() argument
901 future = executor.submit(readFile); in tryFileOpenRead()
DPermissionControllerTest.java112 boolean doDryRun, int reason, @NonNull Executor executor) in revoke() argument
116 sController.revokeRuntimePermissions(request, doDryRun, reason, executor, in revoke()
/cts/tests/sensor/src/android/hardware/cts/
DSensorTest.java524 FlushExecutor executor = new FlushExecutor(environment, 500 /* eventCount */, in testBatchAndFlushWithMultipleSensors() local
526 parallelSensorOperation.add(new TestSensorOperation(environment, executor)); in testBatchAndFlushWithMultipleSensors()
653 FlushExecutor executor = new FlushExecutor(environment, 500 /* eventCount */, in verifyRegisterListenerCallFlush() local
655 TestSensorOperation operation = new TestSensorOperation(environment, executor, handler); in verifyRegisterListenerCallFlush()
/cts/tests/tests/telephony/current/src/android/telephony/cts/
DSubscriptionManagerTest.java719 Executor executor = (command)-> command.run(); in setPreferredDataSubId() local
730 executor, consumer)); in setPreferredDataSubId()
/cts/tests/tests/keystore/src/android/keystore/cts/
DKeyPairGeneratorTest.java1774 ExecutorService executor = Executors.newSingleThreadExecutor(); in assertSSLConnectionWithClientAuth() local
1775 Future<Certificate[]> future = executor.submit(new Callable<Certificate[]>() { in assertSSLConnectionWithClientAuth()
1784 executor.shutdown(); in assertSSLConnectionWithClientAuth()