Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 212 for copts (0.07 sec)

  1. 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)
  2. 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)
  3. istioctl/pkg/tag/generate.go

    func Generate(ctx context.Context, client kube.Client, opts *GenerateOptions, istioNS string) (string, error) {
    	// abort if there exists a revision with the target tag name
    	revWebhookCollisions, err := GetWebhooksWithRevision(ctx, client.Kube(), opts.Tag)
    	if err != nil {
    		return "", err
    	}
    	if !opts.Generate && !opts.Overwrite &&
    		len(revWebhookCollisions) > 0 && opts.Tag != DefaultRevisionName {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. 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)
  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 Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Aug 03 20:50:20 UTC 2023
    - 94.6K bytes
    - Viewed (0)
  6. internal/bucket/bandwidth/monitor.go

    	}
    }
    
    func (m *Monitor) init(opts BucketOptions) {
    	m.mlock.Lock()
    	defer m.mlock.Unlock()
    
    	_, ok := m.bucketsMeasurement[opts]
    	if !ok {
    		m.bucketsMeasurement[opts] = newBucketMeasurement(time.Now())
    	}
    }
    
    // DeleteBucket deletes monitoring the 'bucket'
    func (m *Monitor) DeleteBucket(bucket string) {
    	m.tlock.Lock()
    	for opts := range m.bucketsThrottle {
    		if opts.Name == bucket {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc

      std::unique_ptr<TFE_ContextOptions, decltype(&TFE_DeleteContextOptions)> opts(
          TFE_NewContextOptions(), TFE_DeleteContextOptions);
      std::unique_ptr<TF_Buffer, decltype(&TF_DeleteBuffer)> config(
          TF_CreateConfig(
              /*xla*/ false,
              /* gpu_memory_allow_growth */ true, /* num_cpu_devices */
              2),
          TF_DeleteBuffer);
      TFE_ContextOptionsSetConfig(opts.get(), config->data, config->length,
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. cmd/object_api_suite_test.go

    	}
    
    	var bytesBuffer1 bytes.Buffer
    	var opts ObjectOptions
    	_, err = obj.PutObject(context.Background(), "bucket", "object", mustGetPutObjReader(t, readerEOF, length, "", ""), opts)
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	err = GetObject(context.Background(), obj, "bucket", "object", 0, length, &bytesBuffer1, "", opts)
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  9. tensorflow/c/eager/c_api_debug_test.cc

    #include "tensorflow/core/platform/test.h"
    
    TEST(CApiDebug, ScalarCPU) {
      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_Context* ctx = TFE_NewContext(opts, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TFE_TensorHandle* h = TestScalarTensorHandle(ctx, 1.0f);
      TFE_TensorDebugInfo* debug_info = TFE_TensorHandleTensorDebugInfo(h, status);
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Mon Apr 06 22:10:09 UTC 2020
    - 2.3K bytes
    - Viewed (0)
  10. cmd/naughty-disk_test.go

    func (d *naughtyDisk) UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.UpdateMetadata(ctx, volume, path, fi, opts)
    }
    
    func (d *naughtyDisk) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top