Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 287 for aloop (0.08 sec)

  1. pkg/scheduler/scheduler.go

    func (sched *Scheduler) Run(ctx context.Context) {
    	logger := klog.FromContext(ctx)
    	sched.SchedulingQueue.Run(logger)
    
    	// We need to start scheduleOne loop in a dedicated goroutine,
    	// because scheduleOne function hangs on getting the next item
    	// from the SchedulingQueue.
    	// If there are no new pods to schedule, it will be hanging there
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/collect/testing/AbstractIteratorTester.java

          throw new RuntimeException(Arrays.toString(stimuli), e);
        }
      }
    
      private void recurse(int level) {
        // We're going to reuse the stimuli array 3^steps times by overwriting it
        // in a recursive loop.  Sneaky.
        if (level == stimuli.length) {
          // We've filled the array.
          compareResultsForThisListOfStimuli();
        } else {
          // Keep recursing to fill the array.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  3. src/runtime/mpallocbits.go

    // in the pallocBits and returns the index.
    //
    // See find for an explanation of the searchIdx parameter.
    func (b *pallocBits) find1(searchIdx uint) uint {
    	_ = b[0] // lift nil check out of loop
    	for i := searchIdx / 64; i < uint(len(b)); i++ {
    		x := b[i]
    		if ^x == 0 {
    			continue
    		}
    		return i*64 + uint(sys.TrailingZeros64(^x))
    	}
    	return ^uint(0)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 18 15:13:43 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  4. internal/grid/muxclient.go

    				if !m.closed {
    					gridLogIf(m.ctx, m.sendLocked(message{Op: OpUnblockSrvMux, MuxID: m.MuxID}))
    				}
    				m.respMu.Unlock()
    			case <-m.ctx.Done():
    				// Client canceled. Don't block.
    				// Next loop will catch it.
    			case <-pingTimer:
    				if !m.doPing(respHandler) {
    					return
    				}
    				goto sendResp
    			}
    		case <-pingTimer:
    			if !m.doPing(respHandler) {
    				return
    			}
    		}
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/ssa/func.go

    	cachedPostorder  []*Block   // cached postorder traversal
    	cachedIdom       []*Block   // cached immediate dominators
    	cachedSdom       SparseTree // cached dominator tree
    	cachedLoopnest   *loopnest  // cached loop nest information
    	cachedLineStarts *xposmap   // cached map/set of xpos to integers
    
    	auxmap    auxmap             // map from aux values to opaque ids used by CSE
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/CompactHashMap.java

          CompactHashing.tableSet(newTable, targetHash & newMask, targetEntryIndex + 1);
        }
    
        Object oldTable = requireTable();
        int[] entries = requireEntries();
    
        // Loop over `oldTable` to construct its replacement, ``newTable`. The entries do not move, so
        // the `keys` and `values` arrays do not need to change. But because the "short hash" now has a
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 28 18:11:09 UTC 2024
    - 35.8K bytes
    - Viewed (0)
  7. src/cmd/cover/cover.go

    		// add calls to AddUint32/StoreUint32, and we don't want to
    		// somehow create an infinite loop.
    		//
    		// Note that in the current implementation (Go 1.20) both
    		// routines are assembly stubs that forward calls to the
    		// internal/runtime/atomic equivalents, hence the infinite
    		// loop scenario is purely theoretical (maybe if in some
    		// future implementation one of these functions might be
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  8. pilot/pkg/model/sidecar.go

    func (hc hostClassification) Matches(h host.Name) bool {
    	// exact lookup is fast, so check that first
    	if hc.exactHosts.Contains(h) {
    		return true
    	}
    
    	// exactHosts not found, fallback to loop allHosts
    	hIsWildCarded := h.IsWildCarded()
    	for _, importedHost := range hc.allHosts {
    		// If both are exact hosts, then fallback is not needed.
    		// In this scenario it should be determined by exact lookup.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 20:32:23 UTC 2024
    - 38.4K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/compilation_test.go

    		},
    		{
    			name:                       "O(n^2) loop with numbers",
    			schemaGenerator:            genArrayWithRule("number", "self.all(x, self.all(y, true))"),
    			expectCalcCostExceedsLimit: costLimit,
    			setMaxElements:             10,
    			expectedSetCost:            352,
    		},
    		{
    			name:                       "O(n^3) loop with numbers",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 20:13:14 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  10. cmd/encryption-v1.go

    			partStart = i
    			break
    		}
    		cumulativeSum += size
    		encPartSize, _ := sio.EncryptedSize(uint64(size))
    		encCumulativeSum += int64(encPartSize)
    	}
    	// partStart is always found in the loop above,
    	// because off is validated.
    
    	sseDAREEncPackageBlockSize := int64(SSEDAREPackageBlockSize + SSEDAREPackageMetaSize)
    	startPkgNum := (off - cumulativeSum) / SSEDAREPackageBlockSize
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 37.1K bytes
    - Viewed (0)
Back to top