Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 212 for copts (0.26 sec)

  1. tensorflow/c/eager/c_api_distributed_test.cc

      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(/*enable=*/true));
      TFE_ContextOptionsSetDevicePlacementPolicy(opts, TFE_DEVICE_PLACEMENT_SILENT);
      TFE_Context* ctx = TFE_NewContext(opts, status);
      EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		if err == nil && opts.CheckPrecondFn(obj) {
    			return nil, PreConditionFailed{}
    		}
    		if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !isErrReadQuorum(err) {
    			return nil, err
    		}
    	}
    
    	userDefined := cloneMSS(opts.UserDefined)
    	if opts.PreserveETag != "" {
    		userDefined["etag"] = opts.PreserveETag
    	}
    	onlineDisks := er.getDisks()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  3. docs/extensions/s3zip/examples/minio-go/main.go

    	})
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	var opts minio.GetObjectOptions
    
    	// Add extract header to request:
    	opts.Set("x-minio-extract", "true")
    
    	// Download API.md from the archive
    	rd, err := s3Client.GetObject(context.Background(), "your-bucket", "path/to/file.zip/data.csv", opts)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	_, err = io.Copy(os.Stdout, rd)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 14 18:04:14 UTC 2021
    - 694 bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_cluster_test.cc

      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(async));
      TFE_ContextOptionsSetDevicePlacementPolicy(opts, TFE_DEVICE_PLACEMENT_SILENT);
      TFE_Context* ctx = TFE_NewContext(opts, status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  5. internal/bucket/replication/rule_test.go

    package replication
    
    import (
    	"bytes"
    	"fmt"
    	"testing"
    )
    
    func TestMetadataReplicate(t *testing.T) {
    	testCases := []struct {
    		inputConfig    string
    		opts           ObjectOpts
    		expectedResult bool
    	}{
    		// case 1 - rule with replica modification enabled; not a replica
    		{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.6K bytes
    - Viewed (0)
  6. cmd/config-common.go

    )
    
    var errConfigNotFound = errors.New("config file not found")
    
    func readConfigWithMetadata(ctx context.Context, store objectIO, configFile string, opts ObjectOptions) ([]byte, ObjectInfo, error) {
    	r, err := store.GetObjectNInfo(ctx, minioMetaBucket, configFile, nil, http.Header{}, opts)
    	if err != nil {
    		if isErrObjectNotFound(err) {
    			return nil, ObjectInfo{}, errConfigNotFound
    		}
    
    		return nil, ObjectInfo{}, err
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  7. cmd/storage-interface.go

    	WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error
    
    	// Metadata operations
    	DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
    	DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
    	DeleteBulk(ctx context.Context, volume string, paths ...string) error
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. cmd/metacache-set.go

    			} else {
    				werr = d.WalkDir(ctx, WalkDirOptions{
    					Limit:          opts.perDiskLimit,
    					Bucket:         opts.bucket,
    					BaseDir:        opts.path,
    					Recursive:      opts.recursive,
    					ReportNotFound: opts.reportNotFound,
    					FilterPrefix:   opts.filterPrefix,
    					ForwardTo:      opts.forwardTo,
    				}, w)
    			}
    
    			// fallback only when set.
    			for {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  9. internal/http/listener.go

    		if e != nil {
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		if opts.Trace != nil {
    			opts.Trace(fmt.Sprint("adding listener to ", l.Addr()))
    		}
    
    		listeners = append(listeners, l)
    	}
    
    	if len(listeners) == 0 {
    		// No listeners initialized, no need to continue
    		return
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    func (s *erasureSets) DeleteObject(ctx context.Context, bucket string, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	if opts.DeletePrefix && !opts.DeletePrefixObject {
    		err := s.deletePrefix(ctx, bucket, object)
    		return ObjectInfo{}, err
    	}
    	set := s.getHashedSet(object)
    	return set.DeleteObject(ctx, bucket, object, opts)
    }
    
    // DeleteObjects - bulk delete of objects
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
Back to top