Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for dopts (0.02 sec)

  1. cmd/batch-handlers.go

    			return err
    		}
    		return r.copyWithMultipartfromSource(ctx, api, core, srcObjInfo, opts, partsCount)
    	}
    	gopts := miniogo.GetObjectOptions{
    		VersionID: srcObjInfo.VersionID,
    	}
    	if err := gopts.SetMatchETag(srcObjInfo.ETag); err != nil {
    		return err
    	}
    	rd, objInfo, _, err := core.GetObject(ctx, srcBucket, srcObject, gopts)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    		return ObjectInfo{}, err
    	}
    	ctx = lkctx.Context()
    	defer lk.Unlock(lkctx)
    
    	if opts.DeletePrefix {
    		return ObjectInfo{}, z.deletePrefix(ctx, bucket, object)
    	}
    
    	gopts := opts
    	gopts.NoLock = true
    
    	pinfo, noReadQuorumPools, err := z.getPoolInfoExistingWithOpts(ctx, bucket, object, gopts)
    	if err != nil {
    		if _, ok := err.(InsufficientReadQuorum); ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		if dsc.ReplicateAny() {
    			opts.SetDeleteReplicationState(dsc, opts.VersionID)
    			goi.replicationDecision = opts.DeleteReplication.ReplicateDecisionStr
    		}
    	}
    
    	if opts.EvalRetentionBypassFn != nil {
    		if err := opts.EvalRetentionBypassFn(goi, gerr); err != nil {
    			return ObjectInfo{}, err
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    	data := bytes.Repeat([]byte("a"), 5*1024*1024)
    	var opts ObjectOptions
    
    	err = objLayer.MakeBucket(ctx, bucket, MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("Failed to make a bucket - %v", err)
    	}
    
    	// Create an object with multiple parts uploaded in decreasing
    	// part number.
    	res, err := objLayer.NewMultipartUpload(ctx, bucket, object, opts)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  5. tensorflow/c/eager/c_api_test.cc

      return;
    #else
      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_ContextOptionsSetTfrt(opts, tfrt);
      TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(async));
      TFE_Context* ctx = TFE_NewContext(opts, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TFE_TensorHandle* n = TestMatrixTensorHandle100x100(ctx);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 03 20:50:20 UTC 2023
    - 94.6K bytes
    - Viewed (0)
  6. cmd/object-api-multipart_test.go

    func testObjectNewMultipartUpload(obj ObjectLayer, instanceType string, t TestErrHandler) {
    	bucket := "minio-bucket"
    	object := "minio-object"
    	opts := ObjectOptions{}
    	_, err := obj.NewMultipartUpload(context.Background(), "--", object, opts)
    	if err == nil {
    		t.Fatalf("%s: Expected to fail since bucket name is invalid.", instanceType)
    	}
    
    	errMsg := "Bucket not found: minio-bucket"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  7. tensorflow/c/c_api_test.cc

    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 97K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/lifecycle_test.go

    				t.Fatalf("Got unexpected error: %v", err)
    			}
    			opts := ObjectOpts{
    				Name:             tc.objectName,
    				UserTags:         tc.objectTags,
    				ModTime:          tc.objectModTime,
    				DeleteMarker:     tc.isDelMarker,
    				IsLatest:         !tc.isNoncurrent,
    				SuccessorModTime: tc.objectSuccessorModTime,
    				VersionID:        tc.versionID,
    			}
    			opts.NumVersions = 1
    			if tc.hasManyVersions {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    		}
    
    		if !globalTierConfigMgr.Empty() {
    			oss[index] = newObjSweeper(bucket, object.ObjectName).WithVersion(opts.VersionID).WithVersioning(opts.Versioned, opts.VersionSuspended)
    			oss[index].SetTransitionState(goi.TransitionedObject)
    		}
    
    		// All deletes on directory objects needs to be for `nullVersionID`
    		if isDirObject(object.ObjectName) && object.VersionID == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  10. cmd/iam.go

    	}
    	if len(opts.secretKey) > 0 && len(opts.accessKey) == 0 {
    		return auth.Credentials{}, time.Time{}, auth.ErrNoAccessKeyWithSecretKey
    	}
    
    	var policyBuf []byte
    	if opts.sessionPolicy != nil {
    		err := opts.sessionPolicy.Validate()
    		if err != nil {
    			return auth.Credentials{}, time.Time{}, err
    		}
    		policyBuf, err = json.Marshal(opts.sessionPolicy)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
Back to top