Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 453 for ctx_ (0.02 sec)

  1. istioctl/pkg/proxystatus/proxystatus.go

    `,
    		Aliases: []string{"ps"},
    		RunE: func(c *cobra.Command, args []string) error {
    			kubeClient, err := ctx.CLIClientWithRevision(opts.Revision)
    			if err != nil {
    				return err
    			}
    			multiXdsOpts.MessageWriter = c.OutOrStdout()
    
    			if len(args) > 0 {
    				podName, ns, err := ctx.InferPodInfoFromTypedResource(args[0], ctx.Namespace())
    				if err != nil {
    					return err
    				}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_experimental.h

    // this context.
    TF_CAPI_EXPORT extern void TFE_ContextEnableGraphCollection(TFE_Context* ctx);
    
    // Disables only graph collection in RunMetadata on the functions executed from
    // this context.
    TF_CAPI_EXPORT extern void TFE_ContextDisableGraphCollection(TFE_Context* ctx);
    
    // TODO(fishx): Move these monitoring APIs into a separate file.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  3. cmd/auth-handler_test.go

    func TestIsReqAuthenticated(t *testing.T) {
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    		t.Fatalf("unable initialize config file, %s", err)
    	}
    
    	initAllSubsystems(ctx)
    
    	initConfigSubsystem(ctx, objLayer)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  4. tensorflow/c/eager/dlpack.cc

      int device_id = 0;
      if (parsed_name.has_id) {
        device_id = parsed_name.id;
      }
    
      ctx.device_id = device_id;
      if (device_type == "CPU") {
        ctx.device_type = DLDeviceType::kDLCPU;
      } else if (device_type == "GPU") {
    #if TENSORFLOW_USE_ROCM
        ctx.device_type = DLDeviceType::kDLROCM;
    #else
        ctx.device_type = DLDeviceType::kDLCUDA;
    #endif
      } else {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. internal/dsync/dsync_test.go

    	var wg sync.WaitGroup
    	wg.Add(1)
    
    	ctx, cl := context.WithCancel(context.Background())
    	cancel := func() {
    		cl()
    		wg.Done()
    	}
    
    	if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Wait until context is canceled
    	wg.Wait()
    	if ctx.Err() == nil {
    		t.Fatal("Unexpected error", ctx.Err())
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. cmd/warm-backend-azure.go

    		vid = *resp.VersionID
    	}
    	return remoteVersionID(vid), nil
    }
    
    func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	return az.PutWithMeta(ctx, object, r, length, map[string]string{})
    }
    
    func (az *warmBackendAzure) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) {
    	if opts.startOffset < 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  7. cmd/veeam-sos-api.go

    // isVeeamClient - returns true if the request is from Veeam client.
    func isVeeamClient(ctx context.Context) bool {
    	ri := logger.GetReqInfo(ctx)
    	return ri != nil && strings.Contains(ri.UserAgent, veeamAgentSubstr)
    }
    
    func veeamSOSAPIHeadObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) {
    	gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts)
    	if gr != nil {
    		gr.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. internal/bucket/bandwidth/reader.go

    // 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,
    		opts:     opts,
    		ctx:      ctx,
    	}
    	reader.m.init(opts.BucketOptions)
    	return &reader
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. istioctl/pkg/kubeinject/kubeinject.go

    func GetValuesFromConfigMap(ctx cli.Context, revision string) (string, error) {
    	client, err := ctx.CLIClient()
    	if err != nil {
    		return "", err
    	}
    
    	if revision != "" {
    		injectConfigMapName = fmt.Sprintf("%s-%s", defaultInjectConfigMapName, revision)
    	}
    	meshConfigMap, err := client.Kube().CoreV1().ConfigMaps(ctx.IstioNamespace()).Get(context.TODO(), injectConfigMapName, metav1.GetOptions{})
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  10. internal/config/lambda/parse.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top