- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 582 for lose (0.02 sec)
-
guava/src/com/google/common/base/Stopwatch.java
return desiredUnit.convert(elapsedNanos(), NANOSECONDS); } /** * Returns the current elapsed time shown on this stopwatch as a {@link Duration}. Unlike {@link * #elapsed(TimeUnit)}, this method does not lose any precision due to rounding. * * @since 22.0 (but only since 33.4.0 in the Android flavor) */ @J2ktIncompatible @GwtIncompatible @J2ObjCIncompatible public Duration elapsed() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 08 18:55:33 UTC 2025 - 9.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
if (existingCounter == null) { if (expectedOldCount != 0) { return false; } else if (newCount == 0) { return true; } else { // if our write lost the race, it must have lost to a nonzero value, so we can stop return countMap.putIfAbsent(element, new AtomicInteger(newCount)) == null; } } int oldValue = existingCounter.get();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Dec 08 22:42:14 UTC 2025 - 22.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java
.testEquals(); } private interface Loser<E extends Throwable> { void lose() throws E; } public <T extends Loser<AssertionError>> void testMethod_exceptionTypes() throws NoSuchMethodException { Method failMethod = Loser.class.getMethod("lose"); Invokable<T, ?> invokable = new TypeToken<T>(getClass()) {}.method(failMethod);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:44:53 UTC 2025 - 89K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseManagerTest.java
entry.updateChild("file1.txt", 1024L, 1000L, false, 0x20, 500L, 800L); entry.markComplete(); // Break lease with loss of read cache int newState = Smb2LeaseState.SMB2_LEASE_HANDLE_CACHING; // Lost read cache directoryLeaseManager.handleDirectoryLeaseBreak(leaseKey, newState); // Cache should be invalidated assertFalse(entry.isComplete());
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 01:47:47 UTC 2025 - 15.9K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/CloseableUtil.java
* </p> * * @param closeable the closeable object * @see Closeable#close() */ public static void close(final Closeable closeable) { if (closeable == null) { return; } try {Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 2.5K bytes - Viewed (0) -
docs/smb3-features/02-persistent-handles-design.md
throw new IOException("Failed to reconnect durable handle"); } } @Override public void close() throws IOException { try { // Normal close operations super.close(); } finally { // Don't release durable handle on close if it's persistent if (handleManager != null && handleType != HandleType.PERSISTENT) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 31.6K bytes - Viewed (0) -
docs/smb3-features/04-directory-leasing-design.md
if ((newState & Smb2LeaseState.SMB2_LEASE_READ_CACHING) == 0) { // Lost read cache - invalidate directory cache entry.invalidate(); } if ((newState & Smb2LeaseState.SMB2_LEASE_HANDLE_CACHING) == 0) { // Lost handle cache - may need to close directory handle changeNotifier.stopWatching(directoryPath); }
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 36.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
internal val connectionSpecIndex: Int, internal val isTlsFallback: Boolean, ) : RoutePlanner.Plan, ExchangeCodec.Carrier { /** True if this connect was canceled; typically because it lost a race. */ @Volatile private var canceled = false // These properties are initialized by connect() and never reassigned. /** The low-level TCP socket. */ private var rawSocket: JavaNetSocket? = nullRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 19.3K bytes - Viewed (2) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
* finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */ public void testAllListenersCompleteSuccessfully() throws InterruptedException, ExecutionException { ExecutorService exec = newCachedThreadPool(); int listenerCount = 20;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* * ```java * client.connectionPool().evictAll(); * ``` * * If your client has a cache, call [close()][Cache.close]. Note that it is an error to create calls * against a cache that is closed, and doing so will cause the call to crash. * * ```java * client.cache().close(); * ``` * * OkHttp also uses daemon threads for HTTP/2 connections. These will exit automatically if they * remain idle.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:55:03 UTC 2025 - 51.4K bytes - Viewed (0)