Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 453 for ctx_ (0.1 sec)

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

    	dashboardCmd.AddCommand(istioDebug)
    
    	return dashboardCmd
    }
    
    func inferPodMeta(ctx cli.Context, client kube.CLIClient, labelSelector string) (name, namespace string, err error) {
    	for _, ns := range []string{ctx.IstioNamespace(), ctx.NamespaceOrDefault(ctx.Namespace())} {
    		pl, err := client.PodsForSelector(context.TODO(), ns, labelSelector)
    		if err != nil {
    			continue
    		}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. cmd/tier.go

    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-t.C:
    			err := config.Reload(ctx, objAPI)
    			if err != nil {
    				tierLogIf(ctx, err)
    			}
    		}
    		t.Reset(tierCfgRefresh + randInterval())
    	}
    }
    
    // loadTierConfig loads remote tier configuration from objAPI.
    func loadTierConfig(ctx context.Context, objAPI ObjectLayer) (*TierConfigMgr, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_remote_test_util.cc

      TFE_Context* ctx = TFE_NewContext(opts, status);
      EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TFE_ContextSetServerDef(ctx, 0, serialized.data(), serialized.size(), status);
      EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
    
      TFE_TensorHandle* h0_task0 = TestMatrixTensorHandle(ctx);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 9.1K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    	for i, fiv := range versions {
    		if contextCanceled(ctx) {
    			errs[i] = ctx.Err()
    			continue
    		}
    		errs[i] = s.deleteVersions(ctx, volume, fiv.Name, fiv.Versions...)
    		diskHealthCheckOK(ctx, errs[i])
    	}
    
    	return errs
    }
    
    func (s *xlStorage) cleanupTrashImmediateCallers(ctx context.Context) {
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case entry := <-s.immediatePurge:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  6. cmd/erasure-multipart.go

    	if write {
    		err = reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	} else {
    		err = reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, readQuorum)
    	}
    	if err != nil {
    		return fi, nil, err
    	}
    
    	// Pick one from the first valid metadata.
    	fi, err = pickValidFileInfo(ctx, partsMetadata, modTime, etag, quorum)
    	return fi, partsMetadata, err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  7. internal/event/target/elasticsearch.go

    		key,
    		c.Exists.WithContext(ctx),
    	)
    	if err != nil {
    		return false, err
    	}
    	xhttp.DrainBody(res.Body)
    	return !res.IsError(), nil
    }
    
    func (c *esClientV7) removeEntry(ctx context.Context, index string, key string) error {
    	exists, err := c.entryExists(ctx, index, key)
    	if err == nil && exists {
    		res, err := c.Delete(
    			index,
    			key,
    			c.Delete.WithContext(ctx),
    		)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  8. internal/grid/muxclient.go

    }
    
    // Response is a response from the server.
    type Response struct {
    	Msg []byte
    	Err error
    }
    
    func newMuxClient(ctx context.Context, muxID uint64, parent *Connection) *muxClient {
    	ctx, cancelFn := context.WithCancelCause(ctx)
    	return &muxClient{
    		MuxID:              muxID,
    		ctx:                ctx,
    		cancelFn:           cancelFn,
    		parent:             parent,
    		LastPong:           time.Now().UnixNano(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  9. cmd/iam-store.go

    	getUsersSysType() UsersSysType
    	loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error
    	loadPolicyDocWithRetry(ctx context.Context, policy string, m map[string]PolicyDoc, retries int) error
    	loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error
    	loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  10. cmd/data-scanner.go

    		internalLogIf(ctx, err)
    	}
    }
    
    // runDataScanner will start a data scanner.
    // The function will block until the context is canceled.
    // There should only ever be one scanner running per cluster.
    func runDataScanner(ctx context.Context, objAPI ObjectLayer) {
    	ctx, cancel := globalLeaderLock.GetLock(ctx)
    	defer cancel()
    
    	// Load current bloom cycle
    	var cycleInfo currentScannerCycle
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top