- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 400 for Rollback (0.08 sec)
-
src/main/java/jcifs/smb/SmbTreeConnection.java
try (SmbSessionImpl treesess = t.getSession()) { if (treesess.getCredentials().isAnonymous() || treesess.getCredentials().isGuest()) { // refresh anonymous session or fallback to anonymous from guest login try (SmbSessionInternal s = trans.getSmbSession(this.ctx.withAnonymousCredentials(), treesess.getTargetHost(), treesess.getTargetDomain())
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 30.4K bytes - Viewed (1) -
docs/smb3-features/01-smb3-lease-design.md
} catch (TimeoutException e) { // Force lease release if break handling times out releaseLease(key); log.warn("Lease break timeout for key: {}", key); } } ``` ### 10.2 Fallback to Oplocks ```java if (!context.getConfig().isUseLeases() || !session.supports(SMB3_0)) { // Fall back to traditional oplock mechanism useOplockInstead(); } ``` ## 11. Monitoring and Metrics
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 22K bytes - Viewed (0) -
docs/smb3-features/04-directory-leasing-design.md
if (entry.getInconsistencyCount() > 5) { entry.invalidate(); } } } } ``` ### 9.2 Fallback Mechanisms ```java public class DirectoryOperationFallback { public SmbFile[] safeListFiles(SmbFile directory) throws IOException { try { // Try cached listing first
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 36.2K bytes - Viewed (0) -
internal/lru/lru.go
package lru // golang -lru // https://github.com/hashicorp/golang-lru import ( "sync" "time" ) // EvictCallback is used to get a callback when a cache entry is evicted type EvictCallback[K comparable, V any] func(key K, value V) // LRU implements a thread-safe LRU with expirable entries. type LRU[K comparable, V any] struct { size int evictList *LruList[K, V] items map[K]*Entry[K, V] onEvict EvictCallback[K, V]
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 12.5K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/OsddHelperTest.java
final StreamResponse streamResponse = osddHelper.asStream(); assertEquals("text/xml; charset=UTF-8", streamResponse.getContentType()); streamResponse.getStreamCall().callback(new WrittenStreamOut() { @Override public void write(final InputStream ins) throws IOException { assertEquals(""" <?xml version="1.0" encoding="UTF-8"?>Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 19 23:49:30 UTC 2025 - 23.9K bytes - Viewed (0) -
api/go1.txt
pkg database/sql/driver, type Stmt interface, Query([]Value) (Rows, error) pkg database/sql/driver, type Tx interface { Commit, Rollback } pkg database/sql/driver, type Tx interface, Commit() error pkg database/sql/driver, type Tx interface, Rollback() error pkg database/sql/driver, type Value interface {} pkg database/sql/driver, type ValueConverter interface { ConvertValue }
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Wed Aug 14 18:58:28 UTC 2013 - 1.7M bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/SuggestJobTest.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 31.4K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
} s += "}" } res = append(res, []byte(s)...) } res = append(res, '}') return res, nil } // files returns files as callback. func (x xlMetaInlineData) files(fn func(name string, data []byte)) error { if len(x) == 0 { return nil } if !x.versionOK() { return errors.New("xlMetaInlineData: unknown version") }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 40.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
} finally { SMailCallbackContext.clearPreparedMessageHookOnThread(); } } } /** * Retrieves a value from a map with a default fallback. * * @param dataMap the map to retrieve the value from * @param key the key to look up * @param defaultValue the default value to return if key is not found or value is blankRegistered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 31K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
// Some Android 5.0.x Samsung devices have bugs in JDK reflection APIs that cause // getDeclaredField to throw a NoSuchFieldException when the field is definitely there. // For these users fallback to a suboptimal implementation, based on synchronized. This // will be a definite performance hit to those users. thrownAtomicReferenceFieldUpdaterFailure = atomicReferenceFieldUpdaterFailure;Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0)