Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 462 for slop (0.04 sec)

  1. guava/src/com/google/common/hash/LittleEndianByteArray.java

       * @return a long of a concatenated 8 bytes
       */
      static long load64Safely(byte[] input, int offset, int length) {
        long result = 0;
        // Due to the way we shift, we can stop iterating once we've run out of data, the rest
        // of the result already being filled with zeros.
    
        // This loop is critical to performance, so please check HashBenchmark if altering it.
        int limit = min(length, 8);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  2. docs/en/docs/advanced/events.md

    You could load it at the top level of the module/file, but that would also mean that it would **load the model** even if you are just running a simple automated test, then that test would be **slow** because it would have to wait for the model to load before being able to run an independent part of the code.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:36:22 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. istioctl/pkg/waypoint/waypoint.go

    				}
    				return err
    			}
    
    			if waitReady {
    				startTime := time.Now()
    				ticker := time.NewTicker(1 * time.Second)
    				defer ticker.Stop()
    				for range ticker.C {
    					programmed := false
    					gwc, err := kubeClient.GatewayAPI().GatewayV1().Gateways(ctx.NamespaceOrDefault(ctx.Namespace())).Get(context.TODO(), gw.Name, metav1.GetOptions{})
    					if err == nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  4. internal/config/api/api.go

    	}
    	cfg.ListQuorum = listQuorum
    
    	replicationPriority := env.Get(EnvAPIReplicationPriority, kvs.GetWithDefault(apiReplicationPriority, DefaultKVS))
    	switch replicationPriority {
    	case "slow", "fast", "auto":
    	default:
    		return cfg, fmt.Errorf("invalid value %v for replication_priority", replicationPriority)
    	}
    	cfg.ReplicationPriority = replicationPriority
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. internal/grid/muxserver.go

    	return handlerErr
    }
    
    // checkRemoteAlive will check if the remote is alive.
    func (m *muxServer) checkRemoteAlive() {
    	t := time.NewTicker(m.clientPingInterval)
    	defer t.Stop()
    	for {
    		select {
    		case <-m.ctx.Done():
    			return
    		case <-t.C:
    			last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0))
    			if last > 4*m.clientPingInterval {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  6. integration-tests/gradle/gradlew

    set -- \
            "-Dorg.gradle.appname=$APP_BASE_NAME" \
            -classpath "$CLASSPATH" \
            org.gradle.wrapper.GradleWrapperMain \
            "$@"
    
    # Stop when "xargs" is not available.
    if ! command -v xargs >/dev/null 2>&1
    then
        die "xargs is not available"
    fi
    
    # Use "xargs" to parse quoted args.
    #
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 31 19:07:19 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

                minDelayNanos = minOf(candidateDelay, minDelayNanos)
                continue@eachQueue
              }
    
              // If we already have more than one task, that's enough work for now. Stop searching.
              readyTask != null -> {
                multipleReadyTasks = true
                break@eachQueue
              }
    
              // We have a task to execute when we complete the loop.
              else -> {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  8. src/cmd/asm/internal/asm/asm.go

    	n := len(op)
    	if n < 3 || op[n-2].ScanToken != '/' || op[n-1].ScanToken != scanner.Int {
    		p.errorf("expect /size for DATA argument")
    		return
    	}
    	szop := op[n-1].String()
    	sz, err := strconv.Atoi(szop)
    	if err != nil {
    		p.errorf("bad size for DATA argument: %q", szop)
    	}
    	op = op[:n-2]
    	nameAddr := p.address(op)
    	if !p.validSymbol("DATA", &nameAddr, true) {
    		return
    	}
    	name := symbolName(&nameAddr)
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 21 14:11:44 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

            localhostIpv6,
          )
    
        client =
          clientTestRule.newClientBuilder()
            .eventListenerFactory(clientTestRule.wrap(listener))
            .connectTimeout(60, TimeUnit.SECONDS) // Deliberately exacerbate slow fallbacks.
            .dns { dnsResults }
            .fastFallback(true)
            .build()
        url =
          serverIpv4.url("/")
            .newBuilder()
            .host("localhost")
            .build()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. docs/contribute/concurrency.md

    So we have a dedicated thread for every socket that just reads frames and dispatches them.
    
    The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
Back to top