Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,291 for time (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. docs_src/custom_request_and_route/tutorial003.py

    
    @router.get("/timed")
    async def timed():
        return {"message": "It's the time of my life"}
    
    
    Registered: 2024-11-03 07:19
    - Last Modified: 2020-03-26 19:09
    - 1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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: 2024-11-03 19:28
    - Last Modified: 2024-06-10 17:41
    - 11.8K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top