Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 19 for Opts (0.02 seconds)

  1. cmd/erasure-server-pool.go

    		unlockOnDefer = true
    	}
    
    	checkPrecondFn := opts.CheckPrecondFn
    	opts.CheckPrecondFn = nil // do not need to apply pre-conditions at lower layer.
    	opts.NoLock = true        // no locks needed at lower levels for getObjectInfo()
    	objInfo, zIdx, err := z.getLatestObjectInfoWithIdx(ctx, bucket, object, opts)
    	if err != nil {
    		if objInfo.DeleteMarker {
    			if opts.VersionID == "" {
    				return &GetObjectReader{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. 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
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  3. 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);
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Oct 09 05:56:18 GMT 2025
    - 94.6K bytes
    - Click Count (0)
  4. tensorflow/c/c_api_test.cc

    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Wed Jan 07 04:56:09 GMT 2026
    - 97.3K bytes
    - Click Count (0)
  5. 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"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 89.4K bytes
    - Click Count (0)
  6. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 55.5K bytes
    - Click Count (0)
  7. cmd/batch-handlers.go

    			ReplicationRequest: true,
    		})
    		return err
    	}
    
    	opts := ObjectOptions{
    		VersionID:    srcObjInfo.VersionID,
    		MTime:        srcObjInfo.ModTime,
    		PreserveETag: srcObjInfo.ETag,
    		UserDefined:  srcObjInfo.UserDefined,
    	}
    	if r.Target.Type == BatchJobReplicateResourceS3 || r.Source.Type == BatchJobReplicateResourceS3 {
    		opts.VersionID = ""
    	}
    	if crypto.S3.IsEncrypted(srcObjInfo.UserDefined) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  8. 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 == "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  9. tensorflow/c/c_api.h

    TF_CAPI_EXPORT extern void TF_DeleteImportGraphDefOptions(
        TF_ImportGraphDefOptions* opts);
    
    // Set the prefix to be prepended to the names of nodes in `graph_def` that will
    // be imported into `graph`. `prefix` is copied and has no lifetime
    // requirements.
    TF_CAPI_EXPORT extern void TF_ImportGraphDefOptionsSetPrefix(
        TF_ImportGraphDefOptions* opts, const char* prefix);
    
    // Set the execution device for nodes in `graph_def`.
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Oct 26 21:08:15 GMT 2023
    - 82.3K bytes
    - Click Count (0)
  10. cmd/peer-rest-server.go

    	}
    
    	return np, nerr
    }
    
    func (s *peerRESTServer) GetMetacacheListingHandler(opts *listPathOptions) (*metacache, *grid.RemoteErr) {
    	resp := localMetacacheMgr.getBucket(context.Background(), opts.Bucket).findCache(*opts)
    	return &resp, nil
    }
    
    func (s *peerRESTServer) UpdateMetacacheListingHandler(req *metacache) (*metacache, *grid.RemoteErr) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
Back to Top