Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 402 for callBack (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top