- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 453 for ctx_ (0.02 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)