Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 183 for dopts (0.05 sec)

  1. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/notification.go

    		if report == nil || report.BucketStats == nil {
    			continue
    		}
    		for opts := range report.BucketStats {
    			d, ok := consolidatedReport.BucketStats[opts]
    			if !ok {
    				d = bandwidth.Details{
    					LimitInBytesPerSecond: report.BucketStats[opts].LimitInBytesPerSecond,
    				}
    			}
    			dt, ok := report.BucketStats[opts]
    			if ok {
    				d.CurrentBandwidthInBytesPerSecond += dt.CurrentBandwidthInBytesPerSecond
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. tensorflow/c/BUILD

        srcs = ["tf_shape.cc"],
        hdrs = ["tf_shape.h"],
        copts = tf_copts(),
        visibility = ["//visibility:public"],
        deps = [
            ":c_api_macros",
            ":tf_shape_internal",
            "//tensorflow/core:framework",
        ],
    )
    
    cc_library(
        name = "tf_shape_internal",
        hdrs = ["tf_shape_internal.h"],
        copts = tf_copts(),
        visibility = ["//tensorflow:internal"],
        deps = [
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Oct 24 19:09:45 UTC 2024
    - 30.4K bytes
    - Viewed (0)
  4. cmd/object-api-options.go

    	opts, err = getDefaultOpts(hdr, false, metadata)
    	if err != nil {
    		return opts, err
    	}
    
    	opts.MTime = mtime
    	opts.ReplicationSourceLegalholdTimestamp = lholdtimestmp
    	opts.ReplicationSourceRetentionTimestamp = retaintimestmp
    	opts.ReplicationSourceTaggingTimestamp = taggingtimestmp
    	opts.PreserveETag = etag
    	opts.WantChecksum = wantCRC
    
    	return opts, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  5. cmd/metacache-walk.go

    		}
    		return nil
    	}
    
    	// Stream output.
    	return scanDir(opts.BaseDir)
    }
    
    func (p *xlStorageDiskIDCheck) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) {
    	if err := p.checkID(opts.DiskID); err != nil {
    		return err
    	}
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir)
    	if err != nil {
    		return err
    	}
    	defer done(0, &err)
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. internal/event/target/nats_contrib_test.go

    	defer con.Close()
    }
    
    func TestNatsConnUserPass(t *testing.T) {
    	opts := natsserver.DefaultTestOptions
    	opts.Port = 14223
    	opts.Username = "testminio"
    	opts.Password = "miniotest"
    	s := natsserver.RunServer(&opts)
    	defer s.Shutdown()
    
    	clientConfig := &NATSArgs{
    		Enable: true,
    		Address: xnet.Host{
    			Name:      "localhost",
    			Port:      (xnet.Port(opts.Port)),
    			IsPortSet: true,
    		},
    		Subject:  "test",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  7. internal/http/dial_linux.go

    			// Enable custom socket send/recv buffers.
    			if opts.SendBufSize > 0 {
    				_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_SNDBUF, opts.SendBufSize)
    			}
    
    			if opts.RecvBufSize > 0 {
    				_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_RCVBUF, opts.RecvBufSize)
    			}
    
    			if opts.NoDelay {
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_NODELAY, 1)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (3)
  8. internal/cachevalue/cache.go

    func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] {
    	return &Cache[T]{
    		ttl:      ttl,
    		updateFn: update,
    		opts:     opts,
    	}
    }
    
    // InitOnce initializes the cache with a TTL and an update function. It is
    // guaranteed to be called only once.
    func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. internal/bucket/bandwidth/reader.go

    		return
    	}
    	r.m.updateMeasurement(r.opts.BucketOptions, uint64(tokens))
    	return
    }
    
    // NewMonitoredReader returns reference to a monitored reader that throttles reads to configured bandwidth for the
    // bucket.
    func NewMonitoredReader(ctx context.Context, m *Monitor, r io.Reader, opts *MonitorReaderOptions) *MonitoredReader {
    	reader := MonitoredReader{
    		r:        r,
    		throttle: m.throttle(opts.BucketOptions),
    		m:        m,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. 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 Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Aug 03 20:50:20 UTC 2023
    - 94.6K bytes
    - Viewed (0)
Back to top