Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 964 for happens (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/erasure-sets.go

    }
    
    // monitorAndConnectEndpoints this is a monitoring loop to keep track of disconnected
    // endpoints by reconnecting them and making sure to place them into right position in
    // the set topology, this monitoring happens at a given monitoring interval.
    func (s *erasureSets) monitorAndConnectEndpoints(ctx context.Context, monitorInterval time.Duration) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  2. guava/src/com/google/common/collect/ImmutableSet.java

                // we can skip them all.
                knownRunStart += maxRunBeforeFallback;
              } else {
                knownRunStart++; // the only case in which maxRunEnd doesn't increase by mRBF
                // happens about f * (1-f) for f = DESIRED_LOAD_FACTOR, so around 21% of the time
              }
              knownRunEnd = knownRunStart;
            } else {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Nov 07 16:09:47 GMT 2025
    - 35.3K bytes
    - Click Count (0)
  3. cmd/iam-store.go

    		if policy == "" {
    			continue
    		}
    		p, found := cache.iamPolicyDocsMap[policy]
    		if !found {
    			missingPolicies = append(missingPolicies, policy)
    			continue
    		}
    		policies = append(policies, policy)
    		toMerge = append(toMerge, p.Policy)
    	}
    	store.runlock()
    
    	if len(missingPolicies) > 0 {
    		m := make(map[string]PolicyDoc)
    		for _, policy := range missingPolicies {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 87.1K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // being resumed. To avoid a flake in this scenario, calculate how long that thread actually
        // waited and assert based on that time. Empirically, the race where the thread ends up waiting
        // for 5.5 seconds happens about 2% of the time.
        boolean longWait = NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5;
        // Count how long it actually took to return; we'll accept any number between the expected delay
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // being resumed. To avoid a flake in this scenario, calculate how long that thread actually
        // waited and assert based on that time. Empirically, the race where the thread ends up waiting
        // for 5.5 seconds happens about 2% of the time.
        boolean longWait = NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5;
        // Count how long it actually took to return; we'll accept any number between the expected delay
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  6. cmd/data-scanner.go

    				delete(abandonedChildren, h.Key()) // h.Key() already accounted for.
    				if exists {
    					existingFolders = append(existingFolders, this)
    					f.updateCache.copyWithChildren(&f.oldCache, h, &thisHash)
    				} else {
    					newFolders = append(newFolders, this)
    				}
    				return nil
    			}
    
    			wait := noWait
    			if f.weSleep() {
    				// Dynamic time delay.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

            tryDrainReferenceQueues();
            return null;
          }
    
          return value;
        }
    
        /**
         * Performs routine cleanup following a read. Normally cleanup happens during writes, or from
         * the cleanupExecutor. If cleanup is not observed after a sufficient number of reads, try
         * cleaning up from the read thread.
         */
        void postReadCleanup() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 89.9K bytes
    - Click Count (0)
  8. cmd/xl-storage.go

    // number of bytes copied. The error is EOF only if no bytes were
    // read. On return, n == len(buf) if and only if err == nil. n == 0
    // for io.EOF.
    //
    // If an EOF happens after reading some but not all the bytes,
    // ReadFile returns ErrUnexpectedEOF.
    //
    // If the BitrotVerifier is not nil or not verified ReadFile
    // tries to verify whether the disk has bitrot.
    //
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  9. internal/s3select/select_test.go

    </SelectObjectContentRequest>`
    
    	for _, testCase := range testTable {
    		t.Run(testCase.name, func(t *testing.T) {
    			// Hack cpuid to the CPU doesn't appear to support AVX2.
    			// Restore whatever happens.
    			if cpuid.CPU.Supports(cpuid.AVX2) {
    				cpuid.CPU.Disable(cpuid.AVX2)
    				defer cpuid.CPU.Enable(cpuid.AVX2)
    			}
    			if simdjson.SupportedCPU() {
    				t.Fatal("setup error: expected cpu to be unsupported")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 76.1K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/collect/MapsTest.java

          map1.put(i, null);
        }
        assertWithMessage("table size after adding %s elements", size)
            .that(bucketsOf(map1))
            .isEqualTo(initialBuckets);
    
        /*
         * Something slightly different happens when the entries are added all at
         * once; make sure that passes too.
         */
        map2.putAll(map1);
        assertWithMessage("table size after adding %s elements", size)
            .that(bucketsOf(map1))
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 22:56:33 GMT 2025
    - 65K bytes
    - Click Count (0)
Back to Top