Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 453 for ctx_ (0.04 sec)

  1. internal/grid/connection.go

    	"github.com/zeebo/xxh3"
    )
    
    func gridLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "grid", err, errKind...)
    }
    
    func gridLogIfNot(ctx context.Context, err error, ignored ...error) {
    	logger.LogIfNot(ctx, "grid", err, ignored...)
    }
    
    func gridLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, "grid", err, id, errKind...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. cmd/background-newdisks-heal-ops.go

    		return err
    	}
    	globalBackgroundHealState.updateHealStatus(h)
    	return h.disk.WriteAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		htrackerBytes)
    }
    
    // delete the tracker on disk.
    func (h *healingTracker) delete(ctx context.Context) error {
    	return h.disk.Delete(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		DeleteOptions{
    			Recursive: false,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. tensorflow/c/eager/c_api_distributed_test.cc

      // Create one variable per task.
      TFE_TensorHandle* h0 = TestVariable(ctx, 1.0, task1_name);
      TFE_TensorHandle* h1 = TestVariable(ctx, 2.0, task2_name);
      TFE_TensorHandle* h2 = TestVariable(ctx, 3.0, task0_name);
    
      // Add a sync point to make sure that variables have been initialized
      // before the function execution starts.
      TFE_ContextAsyncWait(ctx, status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/cni-watcher_test.go

    	fs.On("AddPodToMesh",
    		ctx,
    		mock.IsType(pod),
    		util.GetPodIPsIfPresent(pod),
    		valid.Netns,
    	).Return(nil)
    
    	dpServer := getFakeDP(fs, client.Kube())
    
    	handlers := setupHandlers(ctx, client, dpServer, "istio-system")
    
    	// We are not going to start the server, so the sockpath is irrelevant
    	pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net_test.go

    	podIPs := []netip.Addr{podIP}
    
    	err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "fakenetns")
    	assert.NoError(t, err)
    	assert.Equal(t, 1, ztunnelServer.addedPods.Load())
    }
    
    func TestServerRemovePod(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	setupLogging()
    	fixture := getTestFixure(ctx)
    	netServer := fixture.netServer
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. cmd/erasure.go

    					continue
    				}
    				scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-cache-update")
    				updates <- cache.clone()
    
    				lastSave = cache.Info.LastUpdate
    			case v, ok := <-bucketResults:
    				if !ok {
    					// Save final state...
    					cache.Info.NextCycle = wantCycle
    					cache.Info.LastUpdate = time.Now()
    					scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-channel-closed")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  7. cmd/bucket-quota.go

    	bucketStorageCache.InitOnce(10*time.Second,
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (DataUsageInfo, error) {
    			if objAPI == nil {
    				return DataUsageInfo{}, errServerNotInitialized
    			}
    			ctx, done := context.WithTimeout(ctx, 2*time.Second)
    			defer done()
    
    			return loadDataUsageFromBackend(ctx, objAPI)
    		},
    	)
    }
    
    // GetBucketUsageInfo return bucket usage info for a given bucket
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. internal/kms/kms.go

    // for multiple KMS/KES servers.
    func (k *KMS) Version(ctx context.Context) (string, error) {
    	return k.conn.Version(ctx)
    }
    
    // APIs returns a list of KMS server APIs.
    //
    // TODO(aead): remove this API since it's hardly useful.
    func (k *KMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return k.conn.APIs(ctx)
    }
    
    // Metrics returns a current snapshot of the KMS metrics.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  9. internal/kms/kes.go

    )
    
    type kesConn struct {
    	defaultKeyID string
    	client       *kes.Client
    }
    
    func (c *kesConn) Version(ctx context.Context) (string, error) {
    	return c.client.Version(ctx)
    }
    
    func (c *kesConn) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	APIs, err := c.client.APIs(ctx)
    	if err != nil {
    		if errors.Is(err, kes.ErrNotAllowed) {
    			return nil, ErrPermission
    		}
    		return nil, Error{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  10. tensorflow/c/eager/c_api_experimental.cc

    }
    
    void TFE_ContextEnableGraphCollection(TFE_Context* ctx) {
      tensorflow::unwrap(ctx)->SetShouldStoreGraphs(true);
    }
    
    void TFE_ContextDisableGraphCollection(TFE_Context* ctx) {
      tensorflow::unwrap(ctx)->SetShouldStoreGraphs(false);
    }
    
    uint64_t TFE_GetContextId(TFE_Context* ctx) {
      tensorflow::EagerContext* context =
          tensorflow::ContextFromInterface(tensorflow::unwrap(ctx));
      return context->GetContextId();
    }
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 35.9K bytes
    - Viewed (0)
Back to top