Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 87 for _milliseconds (0.14 sec)

  1. cmd/admin-handlers.go

    	go func() {
    		<-ctx.Done()
    		globalNotificationSys.ServiceFreeze(ctx, false)
    	}()
    
    	keepAliveTicker := time.NewTicker(500 * time.Millisecond)
    	defer keepAliveTicker.Stop()
    
    	enc := json.NewEncoder(w)
    	ch := objectSpeedTest(ctx, speedTestOpts{
    		objectSize:       size,
    		concurrencyStart: concurrent,
    		duration:         duration,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. cmd/batch-rotate.go

    	batchKeyRotateVersion              = batchKeyRotateVersionV1
    	batchKeyRotateAPIVersion           = "v1"
    	batchKeyRotateJobDefaultRetries    = 3
    	batchKeyRotateJobDefaultRetryDelay = 25 * time.Millisecond
    )
    
    // Start the batch key rottion job, resumes if there was a pending job via "job.ID"
    func (r *BatchJobKeyRotateV1) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error {
    	ri := &batchJobInfo{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  3. cmd/batch-expire.go

    	batchExpireVersionV1            = 1
    	batchExpireVersion              = batchExpireVersionV1
    	batchExpireAPIVersion           = "v1"
    	batchExpireJobDefaultRetries    = 3
    	batchExpireJobDefaultRetryDelay = 250 * time.Millisecond
    )
    
    type objInfoCache map[string]*ObjectInfo
    
    func newObjInfoCache() objInfoCache {
    	return objInfoCache(make(map[string]*ObjectInfo))
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  4. internal/s3select/message.go

    	var progressTickerC <-chan time.Time
    	if writer.getProgressFunc != nil {
    		progressTicker = time.NewTicker(1 * time.Minute)
    		progressTickerC = progressTicker.C
    	}
    	recordStagingTicker := time.NewTicker(500 * time.Millisecond)
    
    	// Exit conditions:
    	//
    	// 1. If a writer.write() returns false, select loop below exits and
    	// closes `doneCh` to indicate to caller to also exit.
    	//
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  5. cmd/peer-rest-client.go

    	sent := time.Now()
    	resp, err := getSysConfigRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	info = resp.ValueOrZero()
    	if ti, ok := info.Config["time-info"].(madmin.TimeInfo); ok {
    		rt := int32(time.Since(sent).Milliseconds())
    		ti.RoundtripDuration = rt
    		info.Config["time-info"] = ti
    	}
    	return info, err
    }
    
    // GetSysErrors - fetch sys errors for a remote node.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    			case <-dctx.Done():
    				if !timeout.Stop() {
    					<-timeout.C
    				}
    			case <-timeout.C:
    				spent := time.Since(started)
    				goOffline(fmt.Errorf("unable to write+read for %v", spent.Round(time.Millisecond)), spent)
    			}
    		}()
    
    		func() {
    			defer dcancel()
    
    			err := p.storage.WriteAll(ctx, minioMetaTmpBucket, fn, toWrite)
    			if err != nil {
    				if osErrToFileErr(err) == errFaultyDisk {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  7. cmd/endpoint.go

    	var epsResolved int
    	var foundLocal bool
    	resolvedList := make([]bool, len(endpoints))
    	// Mark the starting time
    	startTime := time.Now()
    	keepAliveTicker := time.NewTicker(500 * time.Millisecond)
    	defer keepAliveTicker.Stop()
    	for {
    		// Break if the local endpoint is found already Or all the endpoints are resolved.
    		if foundLocal || (epsResolved == len(endpoints)) {
    			break
    		}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  8. cmd/data-scanner.go

    	"github.com/minio/minio/internal/event"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v3/console"
    	uatomic "go.uber.org/atomic"
    )
    
    const (
    	dataScannerSleepPerFolder        = time.Millisecond                 // Time to wait between folders.
    	dataUsageUpdateDirCycles         = 16                               // Visit all folders every n cycles.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  9. cmd/iam-store.go

    	Policy     policy.Policy
    	CreateDate time.Time `json:",omitempty"`
    	UpdateDate time.Time `json:",omitempty"`
    }
    
    func newPolicyDoc(p policy.Policy) PolicyDoc {
    	now := UTCNow().Round(time.Millisecond)
    	return PolicyDoc{
    		Version:    1,
    		Policy:     p,
    		CreateDate: now,
    		UpdateDate: now,
    	}
    }
    
    // defaultPolicyDoc - used to wrap a default policy as PolicyDoc.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  10. cmd/object-api-utils.go

    	hosts := getHostsSlice(records)
    	rng := rand.New(rand.NewSource(time.Now().UTC().UnixNano()))
    	var d net.Dialer
    	var retry int
    	for retry < len(hosts) {
    		ctx, cancel := context.WithTimeout(GlobalContext, 300*time.Millisecond)
    
    		host = hosts[rng.Intn(len(hosts))]
    		conn, err := d.DialContext(ctx, "tcp", host)
    		cancel()
    		if err != nil {
    			retry++
    			continue
    		}
    		conn.Close()
    		break
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
Back to top