- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 1,152 for timer (0.03 sec)
-
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) -
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) -
internal/http/listener_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 17:41:02 UTC 2024 - 11.8K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)