| /aosp_15_r20/packages/providers/MediaProvider/tests/src/com/android/providers/media/photopicker/sync/ |
| D | PickerSyncLockManagerTest.java | 46 try (CloseableReentrantLock lock = mSyncLockManager.lock(CLOUD_SYNC_LOCK)) { in testLockIsCloseable() method
51 try (CloseableReentrantLock lockInLock = mSyncLockManager.lock(CLOUD_SYNC_LOCK)) { in testLockIsCloseable() method
70 try (CloseableReentrantLock lock = mSyncLockManager.tryLock(CLOUD_ALBUM_SYNC_LOCK)) { in testLockWithTimeoutIsCloseable() method
75 try (CloseableReentrantLock lockInLock = in testLockWithTimeoutIsCloseable() method
96 CloseableReentrantLock lock = new CloseableReentrantLock("testLock"); in testLockTimeout() local
97 try (CloseableReentrantLock ignored = in testLockTimeout() method
111 try (CloseableReentrantLock ignored = in testLockTimeout() method
124 private void acquireLock(Handler handler, CloseableReentrantLock lock) in acquireLock()
130 private void releaseLock(Handler handler, CloseableReentrantLock lock) in releaseLock()
|
| /aosp_15_r20/libcore/jsr166-tests/src/test/java/jsr166/ |
| H A D | ForkJoinPoolTest.java | 99 final ReentrantLock lock; field in ForkJoinPoolTest.ManagedLocker
101 ManagedLocker(ReentrantLock lock) { this.lock = lock; } in ManagedLocker()
138 final ReentrantLock lock; field in ForkJoinPoolTest.LockingFibTask
139 LockingFibTask(int n, ManagedLocker locker, ReentrantLock lock) { in LockingFibTask()
171 try (PoolCleaner cleaner = cleaner(p)) { in testDefaultInitialState() method
211 try (PoolCleaner cleaner = cleaner(p)) { in testGetParallelism() method
223 try (PoolCleaner cleaner = cleaner(p)) { in testGetPoolSize() method
247 try (PoolCleaner cleaner = cleaner(p)) { in testAwaitTermination_timesOut() method
288 try (PoolCleaner cleaner = cleaner(p)) { in testSetUncaughtExceptionHandler() method
307 try (PoolCleaner cleaner = cleaner(p)) { in testIsQuiescent() method
[all …]
|
| /aosp_15_r20/libcore/ojluni/src/test/java/util/concurrent/tck/ |
| H A D | ForkJoinPoolTest.java | 129 final ReentrantLock lock; field in ForkJoinPoolTest.ManagedLocker
131 ManagedLocker(ReentrantLock lock) { this.lock = lock; } in ManagedLocker()
168 final ReentrantLock lock; field in ForkJoinPoolTest.LockingFibTask
169 LockingFibTask(int n, ManagedLocker locker, ReentrantLock lock) { in LockingFibTask()
202 try (PoolCleaner cleaner = cleaner(p)) { in testDefaultInitialState() method
245 try (PoolCleaner cleaner = cleaner(p)) { in testGetParallelism() method
258 try (PoolCleaner cleaner = cleaner(p)) { in testGetPoolSize() method
283 try (PoolCleaner cleaner = cleaner(p)) { in testAwaitTermination_timesOut() method
325 try (PoolCleaner cleaner = cleaner(p)) { in testSetUncaughtExceptionHandler() method
345 try (PoolCleaner cleaner = cleaner(p)) { in testIsQuiescent() method
[all …]
|
| /aosp_15_r20/art/test/1932-monitor-events-misc/src/art/ |
| H A D | Test1932.java | 26 public default void handleMonitorEnter(Thread thd, Object lock) {} in handleMonitorEnter()
27 public default void handleMonitorEntered(Thread thd, Object lock) {} in handleMonitorEntered()
28 public default void handleMonitorWait(Thread thd, Object lock, long timeout) {} in handleMonitorWait()
29 public default void handleMonitorWaited(Thread thd, Object lock, boolean timed_out) {} in handleMonitorWaited()
222 try (AutoCloseable suppress = SuppressContention(controller2)) { in testWaitedMonitorEnter() method
256 try (AutoCloseable suppress = SuppressContention(controller2)) { in testWaitMonitorEnter() method
284 try (AutoCloseable suppress = SuppressContention(controller1)) { in testWaitExitInterleaving() method
624 public static void handleMonitorEnter(Thread thd, Object lock) { in handleMonitorEnter()
634 public static void handleMonitorEntered(Thread thd, Object lock) { in handleMonitorEntered()
643 public static void handleMonitorWait(Thread thd, Object lock, long timeout) { in handleMonitorWait()
[all …]
|
| /aosp_15_r20/libcore/luni/src/test/java/libcore/java/nio/channels/ |
| H A D | FileLockTest.java | 39 try(FileOutputStream fos = new FileOutputStream(tmp)) { in testToString() method
40 try(FileChannel fc = fos.getChannel()) { in testToString() method
41 FileLock lock = fc.lock(0, 42, false); in testToString() local
58 try(FileInputStream fis = new FileInputStream(tmp)) { in testToString() method
59 try(FileChannel fc = fis.getChannel()) { in testToString() method
60 FileLock lock = fc.lock(0, 42, true); in testToString() local
|
| /aosp_15_r20/art/test/1931-monitor-events/src/art/ |
| H A D | Test1931.java | 53 public static void handleMonitorEnter(Thread thd, Object lock) { in handleMonitorEnter()
60 public static void handleMonitorEntered(Thread thd, Object lock) { in handleMonitorEntered()
66 public static void handleMonitorWait(Thread thd, Object lock, long timeout) { in handleMonitorWait()
70 public static void handleMonitorWaited(Thread thd, Object lock, boolean timed_out) { in handleMonitorWaited()
191 try (AutoCloseable suppress = SuppressContention(controller2)) { in testWait() method
212 try (AutoCloseable suppress = SuppressContention(controller2)) { in testTimedWait() method
|
| /aosp_15_r20/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| H A D | OkHttpServerStream.java | 87 try (TaskCloseable ignore = in writeHeaders() method
98 try (TaskCloseable ignore = in writeFrame() method
114 try (TaskCloseable ignore = in writeTrailers() method
125 try (TaskCloseable ignore = in cancel() method
140 private final Object lock; field in OkHttpServerStream.TransportState
161 Object lock, in TransportState()
|
| H A D | OkHttpClientStream.java | 69 Object lock, in OkHttpClientStream()
143 try (TaskCloseable ignore = PerfMark.traceTask("OkHttpClientStream$Sink.writeHeaders")) { in writeHeaders() method
158 try (TaskCloseable ignore = PerfMark.traceTask("OkHttpClientStream$Sink.writeFrame")) { in writeFrame() method
179 try (TaskCloseable ignore = PerfMark.traceTask("OkHttpClientStream$Sink.cancel")) { in cancel() method
190 private final Object lock; field in OkHttpClientStream.TransportState
220 Object lock, in TransportState()
|
| H A D | AsyncSink.java | 45 private final Object lock = new Object(); field in AsyncSink
104 try (TaskCloseable ignore = PerfMark.traceTask("AsyncSink.write")) { in write() method
159 try (TaskCloseable ignore = PerfMark.traceTask("AsyncSink.flush")) { in flush() method
|
| /aosp_15_r20/frameworks/base/packages/WallpaperBackup/test/src/com/android/wallpaperbackup/ |
| H A D | WallpaperBackupAgentTest.java | 713 DataTypeResult lock = getLoggingResult(WALLPAPER_IMG_LOCK, in testOnRestore_imgMissingButWallpaperInfoHasLive_doesNotLogImg() local
737 DataTypeResult lock = getLoggingResult(WALLPAPER_IMG_LOCK, in testOnRestore_throwsException_logsErrors() local
765 DataTypeResult lock = getLoggingResult(WALLPAPER_LIVE_LOCK, logger.getLoggingResults()); in testUpdateWallpaperComponent_delayedRestore_logsSuccess() local
812 DataTypeResult lock = getLoggingResult(WALLPAPER_LIVE_LOCK, logger.getLoggingResults()); in testUpdateWallpaperComponent_delayedRestore_packageNotInstalled_logsFailure() local
873 try (FileOutputStream outputStream = new FileOutputStream(file)) { in createTemporaryFileWithContentString() method
880 try (FileInputStream inputStream = new FileInputStream(file)) { in assertFileContentEquals() method
|
| /aosp_15_r20/external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/file/common/ |
| H A D | LockScope.java | 101 try (SemaphoreResource semaphoreResource = SemaphoreResource.acquire(semaphore)) { in threadLock() method
117 try (SemaphoreResource semaphoreResource = SemaphoreResource.tryAcquire(semaphore)) { in tryThreadLock() method
159 FileLock lock = channel.tryLock(0L /* position */, Long.MAX_VALUE /* size */, shared); in tryFileLock() local
182 FileLock lock = channel.lock(0L /* position */, Long.MAX_VALUE /* size */, shared); in fileLockAndThrowIfNotDeadlock() local
|
| /aosp_15_r20/packages/providers/MediaProvider/src/com/android/providers/media/scan/ |
| D | ModernMediaScanner.java | 241 public final Lock lock = new ReentrantLock(); field in ModernMediaScanner.DirectoryLock
348 try (Scan scan = new Scan(file, reason)) { in scanDirectory() method
368 try (Scan scan = new Scan(file, reason)) { in scanFile() method
407 try (ContentProviderClient client = in invalidateFuseDentryInBg() method
700 try (Cursor c = mResolver.query(mFilesUri, in addUnknownIdsAndGetMediaTypeCount() method
739 try (Cursor c = mResolver.query(playlistsUri, new String[] { FileColumns._ID }, in resolvePlaylists() method
758 DirectoryLock lock; in acquireDirectoryLock() local
780 DirectoryLock lock; in releaseDirectoryLock() local
902 try (Cursor c = mResolver.query(mFilesUri, projection, queryArgs, mSignal)) { in visitFile() method
1005 try (ParcelFileDescriptor pfd = FileUtils.openSafely(file, in fetchOemMetadata() method
[all …]
|
| /aosp_15_r20/external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/file/openers/ |
| H A D | StreamMutationOpener.java | 95 private final Closeable lock; field in StreamMutationOpener.Mutator
114 try (InputStream backendIn = openForReadOrEmpty(openContext.encodedUri()); in mutate() method
118 try (OutputStream backendOut = openContext.backend().openForWrite(tempUri)) { in mutate() method
125 try (OutputStream out = outputChain.get(0)) { in mutate() method
|
| /aosp_15_r20/external/mobile-data-download/javatests/com/google/android/libraries/mobiledatadownload/file/common/ |
| H A D | LockScopeTest.java | 56 try (Lock lock = lockScope.threadLock(uri)) { in createWithSharedThreadLocks_sharesThreadLocksAcrossInstances() method
77 try (FileOutputStream stream = getStreamFromUri(uri); in createFileLockSucceedsInSingleProcess() method
|
| /aosp_15_r20/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| H A D | MigratingThreadDeframer.java | 47 private final Object lock = new Object(); field in MigratingThreadDeframer
111 try (TaskCloseable ignore = in runWhereAppropriate() method
156 try (TaskCloseable ignore = PerfMark.traceTask("MigratingThreadDeframer.request")) { in request() method
199 try (TaskCloseable ignore = PerfMark.traceTask("MigratingThreadDeframer.deframe")) { in deframe() method
|
| H A D | ServerImpl.java | 118 private final Object lock = new Object(); field in ServerImpl
465 try (TaskCloseable ignore = PerfMark.traceTask("ServerTransportListener.streamCreated")) { in streamCreated() method
525 try (TaskCloseable ignore = in streamCreatedInternal() method
599 try (TaskCloseable ignore = in streamCreatedInternal() method
818 try (TaskCloseable ignore = PerfMark.traceTask("ServerStreamListener.messagesAvailable")) { in messagesAvailable() method
829 try (TaskCloseable ignore = in messagesAvailable() method
847 try (TaskCloseable ignore = PerfMark.traceTask("ServerStreamListener.halfClosed")) { in halfClosed() method
857 try (TaskCloseable ignore = PerfMark.traceTask("ServerCallListener(app).halfClosed")) { in halfClosed() method
874 try (TaskCloseable ignore = PerfMark.traceTask("ServerStreamListener.closed")) { in closed() method
906 try (TaskCloseable ignore = PerfMark.traceTask("ServerCallListener(app).closed")) { in closedInternal() method
[all …]
|
| /aosp_15_r20/frameworks/base/services/core/java/com/android/server/ |
| H A D | Watchdog.java | 267 HandlerChecker(Handler handler, String name, Object lock, Clock clock) { in HandlerChecker()
275 HandlerChecker(Handler handler, String name, Object lock) { in HandlerChecker()
1061 try (FileWriter writer = new FileWriter(TIMEOUT_HISTORY_FILE)) { in writeTimeoutHistory() method
1073 try (BufferedReader reader = new BufferedReader(new FileReader(TIMEOUT_HISTORY_FILE))) { in readTimeoutHistory() method
1149 try (FileWriter kmsg = new FileWriter("/dev/kmsg_debug", /* append= */ true)) { in breakCrashLoop() method
|
| /aosp_15_r20/external/google-cloud-java/java-biglake/samples/snippets/generated/com/google/cloud/bigquery/biglake/v1alpha1/metastoreservice/createlock/ |
| H A D | SyncCreateLockStringLock.java | 36 try (MetastoreServiceClient metastoreServiceClient = MetastoreServiceClient.create()) { in syncCreateLockStringLock() method
39 Lock lock = Lock.newBuilder().build(); in syncCreateLockStringLock() local
|
| H A D | SyncCreateLockDatabasenameLock.java | 36 try (MetastoreServiceClient metastoreServiceClient = MetastoreServiceClient.create()) { in syncCreateLockDatabasenameLock() method
38 Lock lock = Lock.newBuilder().build(); in syncCreateLockDatabasenameLock() local
|
| /aosp_15_r20/frameworks/base/services/core/java/com/android/server/resources/ |
| H A D | ResourcesManagerShellCommand.java | 65 try (ParcelFileDescriptor pfd = ParcelFileDescriptor.dup(getOutFileDescriptor())) { in dumpResources() method
66 ConditionVariable lock = new ConditionVariable(); in dumpResources() local
|
| /aosp_15_r20/frameworks/base/services/accessibility/java/com/android/server/accessibility/ |
| H A D | BrailleDisplayConnection.java | 113 BrailleDisplayConnection(@NonNull Object lock, in BrailleDisplayConnection()
476 try (DirectoryStream<Path> hidrawNodePaths = Files.newDirectoryStream( in getDefaultNativeScanner() method
488 try (FileInputStream stream = new FileInputStream(path.toFile())) { in getDefaultNativeScanner() method
|
| /aosp_15_r20/external/dexmaker/dexmaker-mockito-inline/src/main/java/com/android/dx/mockito/inline/ |
| H A D | JvmtiAgent.java | 38 private static final Object lock = new Object(); field in JvmtiAgent
90 try (OutputStream os = new FileOutputStream(jarFile)) { in appendToBootstrapClassLoaderSearch() method
|
| /aosp_15_r20/external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/file/integration/downloader/ |
| H A D | DownloadDestinationOpener.java | 68 private final Object lock = new Object(); field in DownloadDestinationOpener.DownloadDestinationImpl
115 try (ReleasableResource<RandomAccessFile> file = in openByteChannel() method
|
| /aosp_15_r20/external/libtextclassifier/java/src/com/android/textclassifier/ |
| H A D | TextClassifierImpl.java | 97 private final Object lock = new Object(); field in TextClassifierImpl
525 try (AssetFileDescriptor afd = annotatorModelFile.open(context.getAssets())) { in loadAnnotatorModelFile() method
554 try (AssetFileDescriptor afd = bestModel.open(context.getAssets())) { in getLangIdImpl() method
574 try (AssetFileDescriptor afd = bestModel.open(context.getAssets())) { in getActionsImpl() method
|
| /aosp_15_r20/frameworks/base/services/core/java/com/android/server/locksettings/ |
| H A D | LockSettingsStorage.java | 237 public void writeChildProfileLock(int userId, byte[] lock) { in writeChildProfileLock()
238 writeFile(getChildProfileLockFile(userId), lock); in writeChildProfileLock() local
296 try (RandomAccessFile raf = new RandomAccessFile(path, "r")) { in readFile() method
312 try (FileChannel file = FileChannel.open(directory.toPath(), in fsyncDirectory() method
358 try (RandomAccessFile raf = new RandomAccessFile(path, "rws")) { in deleteFile() method
|