Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newDynamicTimeout (0.09 sec)

  1. cmd/globals.go

    	globalDomainIPs   set.StringSet // Root domain IP address(s) for a distributed MinIO deployment
    
    	globalOperationTimeout       = newDynamicTimeout(10*time.Minute, 5*time.Minute) // default timeout for general ops
    	globalDeleteOperationTimeout = newDynamicTimeout(5*time.Minute, 1*time.Minute)  // default time for delete ops
    
    	globalBucketObjectLockSys *BucketObjectLockSys
    	globalBucketQuotaSys      *BucketQuotaSys
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. cmd/callhome.go

    import (
    	"bytes"
    	"compress/gzip"
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"math/rand"
    	"net/url"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second)
    
    // initCallhome will start the callhome task in the background.
    func initCallhome(ctx context.Context, objAPI ObjectLayer) {
    	if !globalCallhomeConfig.Enabled() {
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    		// When all disks == all command line endpoints
    		// this is a fresh setup, no need to trigger healing.
    		return Endpoints{}
    	}
    	return disksToHeal
    }
    
    var newDiskHealingTimeout = newDynamicTimeout(30*time.Second, 10*time.Second)
    
    var errRetryHealing = errors.New("some items failed to heal, we will retry healing this drive again")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    		if err != nil {
    			errResp(err)
    			return
    		}
    	}
    
    	nsLock := objectAPI.NewNSLock(minioMetaBucket, "health-check-in-progress")
    	lkctx, err := nsLock.GetLock(ctx, newDynamicTimeout(deadline, deadline))
    	if err != nil { // returns a locked lock
    		errResp(err)
    		return
    	}
    
    	defer nsLock.Unlock(lkctx)
    	healthCtx, healthCancel := context.WithTimeout(lkctx.Context(), deadline)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
Back to top