Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 409 for slop (0.06 sec)

  1. cmd/bucket-handlers_test.go

    	_, err := obj.PutObject(GlobalContext, bucketName, "test-object", mustGetPutObjReader(t, bytes.NewReader([]byte{}), int64(0), "", "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"), ObjectOptions{})
    	// if object upload fails stop the test.
    	if err != nil {
    		t.Fatalf("Error uploading object: <ERROR> %v", err)
    	}
    
    	// initialize httptest Recorder, this records any mutations to response writer inside the handler.
    	rec := httptest.NewRecorder()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/ImmutableRangeMapTest.java

        }
        ImmutableRangeMap<Integer, Integer> map = builder.build();
        for (int i = 0; i < 100; i++) {
          assertEquals(Integer.valueOf(i), map.get(i));
        }
      }
    
      @AndroidIncompatible // slow
      public void testAsMapOfRanges() {
        for (Range<Integer> range1 : RANGES) {
          for (Range<Integer> range2 : RANGES) {
            if (!range1.isConnected(range2) || range1.intersection(range2).isEmpty()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
             * If we have spun a lot, just park ourselves. This will save CPU while we wait for a slow
             * interrupting thread. In theory, interruptTask() should be very fast, but due to
             * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. cmd/veeam-sos-api.go

    //     higher task limit).
    //
    //     <S3ConcurrentTaskLimit>
    //
    //   - Defines how many S3 operations are executed parallel within one Repository Task Slot (and within one backup object
    //     that gets offloaded). The same registry key setting overwrites the storage-defined setting.
    //     Optional value, default 64, range: 1-unlimited
    //
    //   - <S3MultiObjectDeleteLimit>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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 11:42:11 UTC 2024
    - Last Modified: Sun Dec 24 09:00:26 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
             * If we have spun a lot, just park ourselves. This will save CPU while we wait for a slow
             * interrupting thread. In theory, interruptTask() should be very fast, but due to
             * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top