Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 87 for _milliseconds (0.23 sec)

  1. cmd/metrics-v2_test.go

    		},
    		{
    			val:   0.31,
    			label: labels[1],
    		},
    		{
    			val:   0.61,
    			label: labels[3],
    		},
    		{
    			val:   0.79,
    			label: labels[2],
    		},
    	}
    	ticker := time.NewTicker(1 * time.Millisecond)
    	defer ticker.Stop()
    	for _, obs := range observations {
    		// Send observations once every 1ms, to simulate delay between
    		// observations. This is to test the channel based
    		// synchronization used internally.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Mar 04 18:05:56 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. cmd/globals.go

    	// dynamic sleeper to avoid thundering herd for trash folder expunge routine
    	deleteCleanupSleeper = newDynamicSleeper(5, 25*time.Millisecond, false)
    
    	// dynamic sleeper for multipart expiration routine
    	deleteMultipartCleanupSleeper = newDynamicSleeper(5, 25*time.Millisecond, false)
    
    	// Is MINIO_SYNC_BOOT set?
    	globalEnableSyncBoot bool
    
    	// Contains NIC interface name used for internode communication
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. cmd/peer-rest-common.go

    	peerRESTListenBucket = "bucket"
    	peerRESTListenPrefix = "prefix"
    	peerRESTListenSuffix = "suffix"
    	peerRESTListenEvents = "events"
    	peerRESTLogMask      = "log-mask"
    )
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. internal/amztime/iso8601_time.go

    package amztime
    
    import (
    	"strings"
    	"time"
    )
    
    // RFC3339 a subset of the ISO8601 timestamp format. e.g 2014-04-29T18:30:38Z
    const (
    	iso8601TimeFormat     = "2006-01-02T15:04:05.000Z"    // Reply date format with millisecond precision.
    	iso8601TimeFormatLong = "2006-01-02T15:04:05.000000Z" // Reply date format with nanosecond precision.
    )
    
    // ISO8601Format converts time 't' into ISO8601 time format expected in AWS S3 spec.
    //
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jan 16 23:38:33 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  5. internal/grid/msg.go

    //
    //msgp:tuple message
    type message struct {
    	MuxID      uint64    // Mux to receive message if any.
    	Seq        uint32    // Sequence number.
    	DeadlineMS uint32    // If non-zero, milliseconds until deadline (max 1193h2m47.295s, ~49 days)
    	Handler    HandlerID // ID of handler if invoking a remote handler.
    	Op         Op        // Operation. Other fields change based on this value.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. internal/http/listener.go

    	}
    
    	return addrs
    }
    
    // TCPOptions specify customizable TCP optimizations on raw socket
    type TCPOptions struct {
    	UserTimeout int // this value is expected to be in milliseconds
    
    	// When the net.Conn is a remote drive this value is honored, we close the connection to remote peer proactively.
    	DriveOPTimeout func() time.Duration
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. internal/handlers/forwarder.go

    package handlers
    
    import (
    	"context"
    	"net"
    	"net/http"
    	"net/http/httputil"
    	"net/url"
    	"strings"
    	"sync"
    	"time"
    )
    
    const defaultFlushInterval = time.Duration(100) * time.Millisecond
    
    // Forwarder forwards all incoming HTTP requests to configured transport.
    type Forwarder struct {
    	RoundTripper http.RoundTripper
    	PassHost     bool
    	Logger       func(error)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  8. cmd/bootstrap-peer-server.go

    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    			retries++
    			// after 20 retries start logging that servers are not reachable yet
    			if retries >= 20 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  9. cmd/background-heal-ops.go

    }
    
    func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) {
    	// No need to wait run at full speed.
    	if maxIO <= 0 {
    		return
    	}
    
    	const waitTick = 100 * time.Millisecond
    
    	tmpMaxWait := maxWait
    
    	for currentIO() >= maxIO {
    		if tmpMaxWait > 0 {
    			if tmpMaxWait < waitTick {
    				time.Sleep(tmpMaxWait)
    				return
    			}
    			time.Sleep(waitTick)
    			tmpMaxWait -= waitTick
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  10. internal/dsync/drwmutex.go

    	lockRetryMinInterval = 250 * time.Millisecond
    	if lri := env.Get("_MINIO_LOCK_RETRY_INTERVAL", ""); lri != "" {
    		v, err := strconv.Atoi(lri)
    		if err != nil {
    			panic(err)
    		}
    		lockRetryMinInterval = time.Duration(v) * time.Millisecond
    	}
    
    	lockRetryBackOff = backoffWait(
    		lockRetryMinInterval,
    		100*time.Millisecond,
    		5*time.Second,
    	)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
Back to top