- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,291 for time (0.06 sec)
-
internal/dsync/dsync_test.go
dm.Lock(id, source) time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond) dm.Unlock(context.Background()) dm.Lock(id, source) time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond) dm.Unlock(context.Background()) dm.Lock(id, source) time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond) dm.Unlock(context.Background()) }
Registered: 2024-11-03 19:28 - Last Modified: 2024-06-19 14:35 - 11.1K bytes - Viewed (0) -
cmd/object-api-options.go
var mtime time.Time if mtimeStr != "" { mtime, err = time.Parse(time.RFC3339Nano, mtimeStr) if err != nil { return opts, fmt.Errorf("Unable to parse %s, failed with %w", xhttp.MinIOSourceMTime, err) } } retaintimeStr := strings.TrimSpace(hdr.Get(xhttp.MinIOSourceObjectRetentionTimestamp)) var retaintimestmp time.Time if retaintimeStr != "" {
Registered: 2024-11-03 19:28 - Last Modified: 2024-08-21 21:13 - 14.4K bytes - Viewed (0) -
cmd/erasure-healing-common.go
maxima = count latest = etag } } // Return the collected common max time, with maxima return latest, maxima } // commonTime returns a maximally occurring time from a list of time. func commonTimeAndOccurrence(times []time.Time, group time.Duration) (maxTime time.Time, maxima int) { timeOccurrenceMap := make(map[int64]int, len(times)) groupNano := group.Nanoseconds() // Ignore the uuid sentinel and count the rest.
Registered: 2024-11-03 19:28 - Last Modified: 2024-10-31 22:10 - 12.7K bytes - Viewed (0) -
docs_src/custom_request_and_route/tutorial003.py
Registered: 2024-11-03 07:19 - Last Modified: 2020-03-26 19:09 - 1K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
func (sys *BucketMetadataSys) GetBucketPolicy(bucket string) (*policy.BucketPolicy, time.Time, error) { meta, _, err := sys.GetConfig(GlobalContext, bucket) if err != nil { if errors.Is(err, errConfigNotFound) { return nil, time.Time{}, BucketPolicyNotFound{Bucket: bucket} } return nil, time.Time{}, err } if meta.policyConfig == nil { return nil, time.Time{}, BucketPolicyNotFound{Bucket: bucket} }
Registered: 2024-11-03 19:28 - Last Modified: 2024-08-28 15:32 - 20.4K 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: 2024-11-03 19:28 - Last Modified: 2024-05-09 00:51 - 2.7K bytes - Viewed (0) -
cmd/api-datatypes.go
// DeleteMarkerMTime is an embedded type containing time.Time for XML marshal type DeleteMarkerMTime struct { time.Time } // MarshalXML encodes expiration date if it is non-zero and encodes // empty string otherwise func (t DeleteMarkerMTime) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error { if t.Time.IsZero() { return nil } return e.EncodeElement(t.Time.Format(time.RFC3339), startElement) }
Registered: 2024-11-03 19:28 - Last Modified: 2024-05-14 07:26 - 3K bytes - Viewed (0) -
internal/http/listener_test.go
Registered: 2024-11-03 19:28 - Last Modified: 2024-06-10 17:41 - 11.8K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
statsTime time.Time rttMsSum, maxRttMs float64 successRequestCount int64 failedRequestCount int64 } type metrics struct { sync.Mutex LastCheckSuccess time.Time LastCheckFailure time.Time lastFullMinute serviceRTTMinuteStats currentMinute serviceRTTMinuteStats } func (h *metrics) setConnSuccess(reqStartTime time.Time) { h.Lock() defer h.Unlock()
Registered: 2024-11-03 19:28 - Last Modified: 2024-05-24 23:05 - 13.3K 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: 2024-11-03 19:28 - Last Modified: 2024-02-15 01:09 - 6.3K bytes - Viewed (0)