Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 46 of 46 for timeCh (0.73 sec)

  1. src/runtime/metrics_test.go

    	// Spend this much time measuring latencies.
    	latencies := make([]time.Duration, 0, 1024)
    	_, samples := prepareAllMetricsSamples()
    
    	// Hit metrics.Read continuously and measure.
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		start := time.Now()
    		metrics.Read(samples)
    		latencies = append(latencies, time.Since(start))
    	}
    	// Make sure to stop the timer before we wait! The load created above
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:52:17 UTC 2024
    - 45K bytes
    - Viewed (0)
  2. src/runtime/pprof/pprof_test.go

    	r := regexp.MustCompile(re)
    
    	if deadline, ok := t.Deadline(); ok {
    		if d := time.Until(deadline); d > 1*time.Second {
    			timer := time.AfterFunc(d-1*time.Second, func() {
    				debug.SetTraceback("all")
    				panic(fmt.Sprintf("timed out waiting for %#q", re))
    			})
    			defer timer.Stop()
    		}
    	}
    
    	buf := make([]byte, 64<<10)
    	for {
    		runtime.Gosched()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  3. src/crypto/tls/handshake_server_test.go

    				if *fast {
    					clientConn.SetWriteDeadline(time.Now().Add(1 * time.Second))
    				} else {
    					clientConn.SetWriteDeadline(time.Now().Add(1 * time.Minute))
    				}
    				clientConn.Write(b)
    				continue
    			}
    			bb := make([]byte, len(b))
    			if *fast {
    				clientConn.SetReadDeadline(time.Now().Add(1 * time.Second))
    			} else {
    				clientConn.SetReadDeadline(time.Now().Add(1 * time.Minute))
    			}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    	return updatedPod
    }
    
    // LatestLoopEntryTime returns the last time in the sync loop monitor.
    func (kl *Kubelet) LatestLoopEntryTime() time.Time {
    	val := kl.syncLoopMonitor.Load()
    	if val == nil {
    		return time.Time{}
    	}
    	return val.(time.Time)
    }
    
    // updateRuntimeUp calls the container runtime status callback, initializing
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  5. CREDITS

    but in order to avoid inconsistency the Agreement is copyrighted and
    may only be modified in the following manner. The Agreement Steward
    reserves the right to publish new versions (including revisions) of
    this Agreement from time to time. No one other than the Agreement
    Steward has the right to modify this Agreement. The Eclipse Foundation
    is the initial Agreement Steward. The Eclipse Foundation may assign the
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 15:34:20 UTC 2024
    - 1.7M bytes
    - Viewed (0)
  6. src/net/http/h2_bundle.go

    	return err
    }
    
    // A timer is a time.Timer, as an interface which can be replaced in tests.
    type http2timer = interface {
    	C() <-chan time.Time
    	Reset(d time.Duration) bool
    	Stop() bool
    }
    
    // timeTimer adapts a time.Timer to the timer interface.
    type http2timeTimer struct {
    	*time.Timer
    }
    
    func (t http2timeTimer) C() <-chan time.Time { return t.Timer.C }
    
    const (
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
Back to top