Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 1,152 for timer (0.04 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

       * timeouts (due to a problem with the transport). When a stream times out we don't know whether
       * the problem impacts just one stream or the entire connection.
       *
       * To differentiate the two cases we ping the server when a stream times out. If the overall
       * connection is fine the ping will receive a pong; otherwise it won't.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  2. internal/cachevalue/cache_test.go

    		func(ctx context.Context) (time.Time, error) {
    			return time.Now(), nil
    		},
    	)
    
    	t1, _ := cache.Get()
    
    	t2, _ := cache.Get()
    
    	if !t1.Equal(t2) {
    		t.Fatalf("expected time to be equal: %s != %s", t1, t2)
    	}
    
    	time.Sleep(3 * time.Second)
    	t3, _ := cache.Get()
    
    	if t1.Equal(t3) {
    		t.Fatalf("expected time to be un-equal: %s == %s", t1, t3)
    	}
    }
    
    func BenchmarkCache(b *testing.B) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. internal/http/listener_test.go

    		{[]string{"unknown-host:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{true}},                            // 4
    		{[]string{"localhost:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{false}},                              // 5
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. cmd/os-instrumented.go

    }
    
    // time an os action.
    func (o *osMetrics) time(s osMetric) func() {
    	startTime := time.Now()
    	return func() {
    		duration := time.Since(startTime)
    
    		atomic.AddUint64(&o.operations[s], 1)
    		o.latency[s].add(duration)
    	}
    }
    
    // incTime will increment time on metric s with a specific duration.
    func (o *osMetrics) incTime(s osMetric, d time.Duration) {
    	atomic.AddUint64(&o.operations[s], 1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. istioctl/pkg/metrics/metrics_test.go

    	return nil, nil
    }
    
    func (client mockPromAPI) LabelNames(
    	ctx context.Context, matches []string, startTime time.Time, endTime time.Time, options ...promv1.Option,
    ) ([]string, promv1.Warnings, error) {
    	return nil, nil, nil
    }
    
    func (client mockPromAPI) LabelValues(context.Context, string, []string, time.Time, time.Time, ...promv1.Option,
    ) (prometheus_model.LabelValues, promv1.Warnings, error) {
    	return nil, nil, nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 01:35:47 UTC 2024
    - 8K bytes
    - Viewed (0)
  6. internal/s3select/parquet/reader.go

    				var duration time.Duration
    				// Only support UTC normalized timestamps.
    				if ts.IsAdjustedToUTC {
    					switch {
    					case ts.Unit.IsSetNANOS():
    						duration = time.Duration(val) * time.Nanosecond
    					case ts.Unit.IsSetMILLIS():
    						duration = time.Duration(val) * time.Millisecond
    					case ts.Unit.IsSetMICROS():
    						duration = time.Duration(val) * time.Microsecond
    					default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/execution/BuildSummary.java

         * @param time The build time of the project in milliseconds.
         */
        protected BuildSummary(MavenProject project, long time) {
            this(project, time, time);
        }
    
        /**
         * Creates a new build summary for the specified project.
         *
         * @param project The project being summarized, must not be {@code null}.
         * @param execTime The exec time of the project in milliseconds.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. tests/non_std_test.go

    package tests_test
    
    import (
    	"testing"
    	"time"
    )
    
    type Animal struct {
    	Counter    uint64 `gorm:"primary_key:yes"`
    	Name       string `gorm:"DEFAULT:'galeone'"`
    	From       string // test reserved sql keyword as field name
    	Age        *time.Time
    	unexported string // unexported value
    	CreatedAt  time.Time
    	UpdatedAt  time.Time
    }
    
    func TestNonStdPrimaryKeyAndDefaultValues(t *testing.T) {
    	DB.Migrator().DropTable(&Animal{})
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  9. cmd/perf-tests.go

    // This is to improve the RX throughput accuracy.
    type netPerfRX struct {
    	RX                uint64    // RX bytes
    	lastToConnect     time.Time // time at which last peer to connect to us
    	firstToDisconnect time.Time // time at which the first peer disconnects from us
    	RXSample          uint64    // RX bytes between lastToConnect and firstToDisconnect
    	activeConnections uint64
    	sync.RWMutex
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  10. cmd/update_test.go

    		data                string
    		expectedResult      time.Time
    		expectedSha256hex   string
    		expectedReleaseInfo string
    		expectedErr         bool
    	}{
    		{"more than two fields", time.Time{}, "", "", true},
    		{"more than", time.Time{}, "", "", true},
    		{"more than.two.fields", time.Time{}, "", "", true},
    		{"more minio.RELEASE.fields", time.Time{}, "", "", true},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 10.4K bytes
    - Viewed (0)
Back to top