Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 391 for ctx_ (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. tensorflow/c/eager/c_api.cc

    }
    
    void TFE_DeleteContext(TFE_Context* ctx) {
      if (ctx == nullptr) {
        return;
      }
    
      // ctx->RefCountIsOne() should be true here.
      tensorflow::unwrap(ctx)->Release();
    }
    
    TF_DeviceList* TFE_ContextListDevices(TFE_Context* ctx, TF_Status* status) {
      TF_DeviceList* l = new TF_DeviceList;
      tensorflow::unwrap(ctx)->ListDevices(&l->response);
      return l;
    }
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 43.9K bytes
    - Viewed (0)
  5. cmd/object-api-interface.go

    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (bucketInfo BucketInfo, err error)
    	ListBuckets(ctx context.Context, opts BucketOptions) (buckets []BucketInfo, err error)
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  6. tensorflow/c/c_op_requires.h

    #define C_OPKERNELCONTEXT_REQUIRES_OK(CTX, C_STATUS, __VA_ARGS__) \
      do {                                                            \
        ::tensorflow::Status _s(__VA_ARGS__);                         \
        if (!TF_PREDICT_TRUE(_s.ok())) {                              \
          ::tensorflow::Set_TF_Status_from_Status(C_STATUS, _s);      \
          TF_OpKernelContext_Failure(CTX, C_STATUS);                  \
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Aug 02 21:35:06 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  7. 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)
  8. cmd/local-locker.go

    }
    
    // IsLocal - local locker returns true.
    func (l *localLocker) IsLocal() bool {
    	return true
    }
    
    func (l *localLocker) ForceUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	select {
    	case <-ctx.Done():
    		return false, ctx.Err()
    	default:
    		l.mutex.Lock()
    		defer l.mutex.Unlock()
    		if len(args.UID) == 0 {
    			for _, resource := range args.Resources {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. cmd/metacache-server-pool.go

    			if rpc != nil {
    				ctx, cancel := context.WithTimeout(GlobalContext, 5*time.Second)
    				defer cancel()
    				c, err := rpc.GetMetacacheListing(ctx, *o)
    				if err == nil {
    					c.error = "no longer used"
    					c.status = scanStateError
    					rpc.UpdateMetacacheListing(ctx, *c)
    				}
    			}
    		}()
    		o.ID = ""
    	}
    
    	if contextCanceled(ctx) {
    		return entries, ctx.Err()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. tests/test_path.py

                        "ctx": {"min_length": 2},
                    }
                ]
            }
        ) | IsDict(
            {
                "detail": [
                    {
                        "loc": ["path", "item_id"],
                        "msg": "ensure this value has at least 2 characters",
                        "type": "value_error.any_str.min_length",
                        "ctx": {"limit_value": 2},
                    }
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 34.4K bytes
    - Viewed (0)
Back to top