Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 87 for _milliseconds (0.31 sec)

  1. internal/lock/lock_test.go

    		locked <- struct{}{}
    		if blerr = bl.Close(); blerr != nil {
    			t.Error(blerr)
    			return
    		}
    	}()
    
    	select {
    	case <-locked:
    		t.Error("unexpected unblocking")
    	case <-time.After(100 * time.Millisecond):
    	}
    
    	// unlock
    	if err = dupl.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	// the previously blocked routine should be unblocked
    	select {
    	case <-locked:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  2. docs/metrics/v3.md

    | `minio_cluster_iam_last_sync_duration_millis`                   | Last successful IAM data sync duration in milliseconds. <br><br>Type: counter                                                                   |        |
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Aug 02 22:30:11 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  3. internal/deadlineconn/deadlineconn.go

    // Package deadlineconn implements net.Conn wrapper with configured deadlines.
    package deadlineconn
    
    import (
    	"net"
    	"time"
    )
    
    const updateInterval = 250 * time.Millisecond
    
    // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout.
    type DeadlineConn struct {
    	net.Conn
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

        @PostConstruct
        public void init() {
            statsLogger = LogManager.getLogger(loggerName);
            statsCache = CacheBuilder.newBuilder().maximumSize(maxCacheSize).expireAfterWrite(cacheExpireAfterWrite, TimeUnit.MILLISECONDS)
                    .build(new CacheLoader<String, StatsObject>() {
                        @Override
                        public StatsObject load(final String key) {
                            return new StatsObject();
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  5. internal/cachevalue/cache_test.go

    	t3, _ := cache.Get()
    
    	if t1.Equal(t3) {
    		t.Fatalf("expected time to be un-equal: %s == %s", t1, t3)
    	}
    }
    
    func BenchmarkCache(b *testing.B) {
    	cache := New[time.Time]()
    	cache.InitOnce(1*time.Millisecond, Opts{},
    		func(ctx context.Context) (time.Time, error) {
    			return time.Now(), nil
    		},
    	)
    
    	b.ReportAllocs()
    	b.ResetTimer()
    
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. internal/config/scanner/scanner.go

    	switch speed := env.Get(EnvSpeed, kvs.GetWithDefault(Speed, DefaultKVS)); speed {
    	case "fastest":
    		cfg.Delay, cfg.MaxWait, cfg.Cycle = 0, 0, time.Second
    	case "fast":
    		cfg.Delay, cfg.MaxWait, cfg.Cycle = 1, 100*time.Millisecond, time.Minute
    	case "default":
    		cfg.Delay, cfg.MaxWait, cfg.Cycle = 2, time.Second, time.Minute
    	case "slow":
    		cfg.Delay, cfg.MaxWait, cfg.Cycle = 10, 15*time.Second, time.Minute
    	case "slowest":
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. internal/grid/grid.go

    			return b, nil
    		}
    	}
    }
    
    // getDeadline will truncate the deadline so it is at least 1ms and at most MaxDeadline.
    func getDeadline(d time.Duration) time.Duration {
    	if d < time.Millisecond {
    		return 0
    	}
    	if d > MaxDeadline {
    		return MaxDeadline
    	}
    	return d
    }
    
    type writerWrapper struct {
    	ch  chan<- []byte
    	ctx context.Context
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. cmd/server-main.go

    	if serverDebugLog {
    		fmt.Println(time.Now().Round(time.Millisecond).Format(time.RFC3339), " bootstrap: ", msg)
    	}
    
    	noSubs := globalTrace.NumSubscribers(madmin.TraceBootstrap) == 0
    	if noSubs {
    		return
    	}
    
    	globalTrace.Publish(info)
    }
    
    func bootstrapTrace(msg string, worker func()) {
    	if serverDebugLog {
    		fmt.Println(time.Now().Round(time.Millisecond).Format(time.RFC3339), " bootstrap: ", msg)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (3)
  9. cmd/metrics-v3-bucket-replication.go

    		"Total number of objects which failed replication in the last full minute on a bucket",
    		bucketL)
    	bucketReplLatencyMsMD = NewGaugeMD(bucketReplLatencyMs,
    		"Replication latency on a bucket in milliseconds",
    		bucketL, operationL, rangeL, targetArnL)
    	bucketReplProxiedDeleteTaggingRequestsTotalMD = NewCounterMD(bucketReplProxiedDeleteTaggingRequestsTotal,
    		"Number of DELETE tagging requests proxied to replication target",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. logger/logger.go

    	Discard = New(log.New(io.Discard, "", log.LstdFlags), Config{})
    	// Default Default logger
    	Default = New(log.New(os.Stdout, "\r\n", log.LstdFlags), Config{
    		SlowThreshold:             200 * time.Millisecond,
    		LogLevel:                  Warn,
    		IgnoreRecordNotFoundError: false,
    		Colorful:                  true,
    	})
    	// Recorder logger records running SQL into a recorder instance
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Nov 07 02:19:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
Back to top