- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 402 for callBack (0.27 sec)
-
guava/src/com/google/common/base/MoreObjects.java
* * <p><b>Note:</b> if {@code first} is represented as an {@link Optional}, this can be * accomplished with {@link Optional#or(Object) first.or(second)}. That approach also allows for * lazy evaluation of the fallback instance, using {@link Optional#or(Supplier) * first.or(supplier)}. * * <p><b>Java 9 users:</b> use {@code java.util.Objects.requireNonNullElse(first, second)} * instead. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 16.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
/** * Base class for implementing services that can handle {@link #doStart} and {@link #doStop} * requests, responding to them with {@link #notifyStarted()} and {@link #notifyStopped()} * callbacks. Its subclasses must manage threads manually; consider {@link * AbstractExecutionThreadService} if you need only a single execution thread. * * @author Jesse Wilson * @author Luke Sandberg * @since 1.0 */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
) taskFaker.assertNoMoreTasks() } /** * This test puts several connections in flight that all fail at approximately the same time. It * confirms the fast fallback implements these invariants: * * * if there's no TCP connect in flight, start one. * * don't start a new TCP connect within 250 ms of the previous TCP connect. */ @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 20.9K bytes - Viewed (0) -
cmd/update.go
} { _, err = os.Stat(envfile) if err == nil { return true } } if osIsNotExist(err) { // if none of the files are present we may be running inside // CRI-O, Containerd etc.. // Fallback to our container specific ENVs if they are set. return env.IsSet("MINIO_ACCESS_KEY_FILE") } // Log error, as we will not propagate it to caller internalLogIf(GlobalContext, err) return err == nil
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 18.9K bytes - Viewed (0) -
misc/go_android_exec/main.go
gorootPath = runtime.GOROOT() if gorootPath != "" { return } // runtime.GOROOT is empty — perhaps go_android_exec was built with // -trimpath and GOROOT is unset. Try 'go env GOROOT' as a fallback, // assuming that the 'go' command in $PATH is the correct one. cmd := exec.Command("go", "env", "GOROOT") cmd.Stderr = os.Stderr out, err := cmd.Output() if err != nil {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Aug 21 17:46:57 UTC 2023 - 15.3K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
} meta, err := loadBucketMetadataParse(ctx, objAPI, bucket, parse) if err != nil { if !globalIsErasure && !globalIsDistErasure && errors.Is(err, errVolumeNotFound) { // Only single drive mode needs this fallback. meta = newBucketMetadata(bucket) } else { return updatedAt, err } } updatedAt = UTCNow() switch configFile { case bucketPolicyConfig: meta.PolicyConfigJSON = configData
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
/** * Base class for implementing services that can handle {@link #doStart} and {@link #doStop} * requests, responding to them with {@link #notifyStarted()} and {@link #notifyStopped()} * callbacks. Its subclasses must manage threads manually; consider {@link * AbstractExecutionThreadService} if you need only a single execution thread. * * @author Jesse Wilson * @author Luke Sandberg * @since 1.0 */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.3K bytes - Viewed (0) -
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) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
if (startBracket != -1 && endBracket != -1 && endBracket > startBracket) { return transportStr.substring(startBracket + 1, endBracket); } // Fallback: just use address return transport.getRemoteAddress().getHostAddress(); } /** * Get connection key from address and port */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
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)