Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 451 - 460 of 3,737 for Done (0.17 seconds)

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

  1. cmd/metrics-resource.go

    	resourceMetricsMapMu.Unlock()
    	metricsTimer := time.NewTimer(resourceMetricsCollectionInterval)
    	defer metricsTimer.Stop()
    
    	collectLocalResourceMetrics()
    
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    		case <-metricsTimer.C:
    			collectLocalResourceMetrics()
    
    			// Reset the timer for next cycle.
    			metricsTimer.Reset(resourceMetricsCollectionInterval)
    		}
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 17.2K bytes
    - Click Count (0)
  2. cmd/batch-handlers.go

    					if kv.Match(BatchJobKV{Key: k, Value: v}) {
    						return true
    					}
    				}
    			}
    
    			// None of the provided metadata filters match skip the object.
    			return false
    		}
    
    		// if one of source or target is non MinIO, just replicate the top most version like `mc mirror`
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  3. android/guava/src/com/google/common/base/Preconditions.java

          boolean expression,
          /*
           * TODO(cpovirk): Consider removing @Nullable here, as we've done with the other methods'
           * errorMessageTemplate parameters: It is unlikely that callers intend for their string
           * template to be null (though we do handle that case gracefully at runtime). I've left this
           * one as it is because one of our users has defined a wrapper API around Preconditions,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 08 18:10:02 GMT 2026
    - 53.5K bytes
    - Click Count (0)
  4. internal/s3select/json/preader.go

    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    		defer r.readerWg.Done()
    		for {
    			next, err := r.nextSplit(jsonSplitSize, r.bufferPool.Get())
    			q := queueItem{
    				input: next,
    				dst:   make(chan []jstream.KVS, 1),
    				err:   err,
    			}
    			select {
    			case <-r.close:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  5. src/cmd/api/api_test.go

    		}
    	}
    }
    
    var warmupCache = sync.OnceFunc(func() {
    	// Warm up the import cache in parallel.
    	var wg sync.WaitGroup
    	for _, context := range contexts {
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			_ = NewWalker(context, filepath.Join(testenv.GOROOT(nil), "src"))
    		}()
    	}
    	wg.Wait()
    })
    
    func TestIssue21181(t *testing.T) {
    	if testing.Short() {
    		t.Skip("skipping with -short")
    	}
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Mar 02 13:20:41 GMT 2026
    - 7.6K bytes
    - Click Count (0)
  6. internal/s3select/csv/reader.go

    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    	if r.args.FileHeaderInfo != none {
    		// Read column names
    		// Get one line.
    		b, err := r.nextSplit(0, nil)
    		if err != nil {
    			r.err = err
    			return err
    		}
    		if !utf8.Valid(b) {
    			return errInvalidTextEncodingError()
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/ImmutableSortedMap.java

              // there's a way around creating the separate sortedKeys array, and if we're allocating
              // one array of size n, we might as well allocate two -- to say nothing of the allocation
              // done in Arrays.sort.
              for (int i = 0; i < size; i++) {
                // We're careful to put only K instances in.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 08 18:10:02 GMT 2026
    - 54.7K bytes
    - Click Count (0)
  8. docs/ru/docs/_llm-test.md

    //// tab | Тест
    
    Вот некоторые элементы, обёрнутые в HTML-элементы "abbr" (часть выдумана):
    
    ### abbr даёт полную расшифровку { #the-abbr-gives-a-full-phrase }
    
    * <abbr title="Getting Things Done - Как привести дела в порядок">GTD</abbr>
    * <abbr title="less than - меньше чем"><code>lt</code></abbr>
    * <abbr title="XML Web Token - XML веб‑токен">XWT</abbr>
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:56:20 GMT 2026
    - 17.2K bytes
    - Click Count (0)
  9. lib/fips140/v1.0.0-c2097c7c.zip

    using the MGF1 function // specified in PKCS #1 v2.1. func mgf1XOR(out []byte, hash fips140.Hash, seed []byte) { var counter [4]byte var digest []byte done := 0 for done < len(out) { hash.Reset() hash.Write(seed) hash.Write(counter[0:4]) digest = hash.Sum(digest[:0]) for i := 0; i < len(digest) && done < len(out); i++ { out[done] ^= digest[i] done++ } incCounter(&counter) } } func emsaPSSEncode(mHash []byte, emBits int, salt []byte, hash fips140.Hash) ([]byte, error) { // See RFC 8017, Section 9.1.1....
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Sep 25 19:53:19 GMT 2025
    - 642.7K bytes
    - Click Count (0)
  10. cmd/site-replication-metrics.go

    	}
    	go s.trackEWMA()
    	return &s
    }
    
    func (sr *SRStats) trackEWMA() {
    	for {
    		select {
    		case <-sr.movingAvgTicker.C:
    			sr.updateMovingAvg()
    		case <-GlobalContext.Done():
    			return
    		}
    	}
    }
    
    func (sr *SRStats) updateMovingAvg() {
    	sr.lock.Lock()
    	defer sr.lock.Unlock()
    	for _, s := range sr.M {
    		s.XferRateLrg.measure.updateExponentialMovingAverage(time.Now())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
Back to Top