Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 453 for ctx_ (0.06 sec)

  1. cmd/local-locker_test.go

    	rResources := make([]string, 1000)
    	quorum := 0
    	l := newLocker()
    	ctx := context.Background()
    	for i := range wResources {
    		arg := dsync.LockArgs{
    			UID:       mustGetUUID(),
    			Resources: []string{mustGetUUID()},
    			Source:    t.Name(),
    			Owner:     "owner",
    			Quorum:    &quorum,
    		}
    		ok, err := l.Lock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/lock-rest-server-common_test.go

    	"reflect"
    	"sync"
    	"testing"
    
    	"github.com/minio/minio/internal/dsync"
    )
    
    // Helper function to create a lock server for testing
    func createLockTestServer(ctx context.Context, t *testing.T) (string, *lockRESTServer, string) {
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatalf("unable initialize config file, %s", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. cmd/metacache-bucket.go

    		// Recursively delete all caches.
    		objAPI := newObjectLayerFn()
    		if objAPI != nil {
    			ez, ok := objAPI.(deleteAllStorager)
    			if ok {
    				ctx := context.Background()
    				ez.deleteAll(ctx, minioMetaBucket, metacachePrefixForID(bucket, slashSeparator))
    			}
    		}
    	}
    	return &bucketMetacache{
    		bucket:     bucket,
    		caches:     make(map[string]metacache, 10),
    		cachesRoot: make(map[string][]string, 10),
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. internal/crypto/sse-kms.go

    	if k == nil {
    		return key, Errorf("KMS not configured")
    	}
    
    	keyID, kmsKey, sealedKey, ctx, err := s3.ParseMetadata(metadata)
    	if err != nil {
    		return key, err
    	}
    	if ctx == nil {
    		ctx = kms.Context{bucket: path.Join(bucket, object)}
    	} else if _, ok := ctx[bucket]; !ok {
    		ctx[bucket] = path.Join(bucket, object)
    	}
    	unsealKey, err := k.Decrypt(context.TODO(), &kms.DecryptRequest{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. internal/http/dial_others.go

    }
    
    // DialContext is a function to make custom Dial for internode communications
    type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
    
    // NewInternodeDialContext configures a custom dialer for internode communications
    func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext {
    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    			Timeout: dialTimeout,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  6. internal/rest/client.go

    	u := *c.url
    	u.Path = path.Join(u.Path, rpcMethod)
    	u.RawQuery = values.Encode()
    
    	req, err := c.newRequest(ctx, httpMethod, u, body)
    	if err != nil {
    		return nil, &NetworkError{Err: err}
    	}
    	if length > 0 {
    		req.ContentLength = length
    	}
    
    	_, expectTimeouts := ctx.Deadline()
    
    	req, update := setupReqStatsUpdate(req)
    	defer update()
    
    	resp, err := c.httpClient.Do(req)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    func (z *erasureServerPools) loadRebalanceMeta(ctx context.Context) error {
    	r := &rebalanceMeta{}
    	if err := r.load(ctx, z.serverPools[0]); err == nil {
    		z.rebalMu.Lock()
    		z.rebalMeta = r
    		z.updateRebalanceStats(ctx)
    		z.rebalMu.Unlock()
    	} else if !errors.Is(err, errConfigNotFound) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  8. internal/bucket/bandwidth/monitor.go

    	bucketMovingAvgTicker *time.Ticker    // Ticker for calculating moving averages
    	ctx                   context.Context // Context for generate
    	NodeCount             uint64
    }
    
    // NewMonitor returns a monitor with defaults.
    func NewMonitor(ctx context.Context, numNodes uint64) *Monitor {
    	m := &Monitor{
    		bucketsMeasurement:    make(map[BucketOptions]*bucketMeasurement),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    	if err != nil {
    		replLogOnceIf(ctx, err, bucket)
    		return nil, err
    	}
    	tgts, err := globalBucketTargetSys.ListBucketTargets(ctx, bucket)
    	if err != nil {
    		replLogIf(ctx, err)
    		return nil, err
    	}
    
    	objInfoCh := make(chan itemOrErr[ObjectInfo], 10)
    	if err := objAPI.Walk(ctx, bucket, opts.Prefix, objInfoCh, WalkOptions{}); err != nil {
    		replLogIf(ctx, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  10. cmd/erasure-metadata-utils.go

    func reduceReadQuorumErrs(ctx context.Context, errs []error, ignoredErrs []error, readQuorum int) (maxErr error) {
    	return reduceQuorumErrs(ctx, errs, ignoredErrs, readQuorum, errErasureReadQuorum)
    }
    
    // reduceWriteQuorumErrs behaves like reduceErrs but only for returning
    // values of maximally occurring errors validated against writeQuorum.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top