Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 1,339 for contextos (0.18 sec)

  1. 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)
    		},
    	)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. istioctl/pkg/completion/completion.go

    	}
    
    	return nsNameList, nil
    }
    
    func getNamespaces(ctx context.Context, client kube.CLIClient) ([]corev1.Namespace, error) {
    	nslist, err := client.Kube().CoreV1().Namespaces().List(ctx, metav1.ListOptions{})
    	if err != nil {
    		return []corev1.Namespace{}, err
    	}
    	return nslist.Items, nil
    }
    
    func ValidNamespaceArgs(_ *cobra.Command, ctx cli.Context, args []string, toComplete string) ([]string, cobra.ShellCompDirective) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. tensorflow/c/eager/parallel_device/parallel_device_test.cc

                                  status.get());
      std::unique_ptr<TFE_Context, decltype(&TFE_DeleteContext)> context(
          TFE_NewContext(opts.get(), status.get()), TFE_DeleteContext);
      ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());
      BasicTestsForTwoDevices(context.get(),
                              "/job:localhost/replica:0/task:0/device:CPU:0",
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Aug 06 23:56:17 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  4. internal/s3select/jstream/scratch.go

    package jstream
    
    import (
    	"unicode/utf8"
    )
    
    type scratch struct {
    	data []byte
    	fill int
    }
    
    // reset scratch buffer
    func (s *scratch) reset() { s.fill = 0 }
    
    // bytes returns the written contents of scratch buffer
    func (s *scratch) bytes() []byte { return s.data[0:s.fill] }
    
    // grow scratch buffer
    func (s *scratch) grow() {
    	ndata := make([]byte, cap(s.data)*2)
    	copy(ndata, s.data)
    	s.data = ndata
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 758 bytes
    - Viewed (0)
  5. cmd/local-locker.go

    	for _, resource := range resources {
    		_, lockTaken := l.lockMap[resource]
    		if lockTaken {
    			return false
    		}
    	}
    	return true
    }
    
    func (l *localLocker) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	if len(args.Resources) > maxDeleteList {
    		return false, fmt.Errorf("internal error: localLocker.Lock called with more than %d resources", maxDeleteList)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    			}
    		}
    	}
    
    	return nil
    }
    
    func (z *erasureServerPools) doDecommissionInRoutine(ctx context.Context, idx int) {
    	z.poolMetaMutex.Lock()
    	var dctx context.Context
    	dctx, z.decommissionCancelers[idx] = context.WithCancel(GlobalContext)
    	z.poolMetaMutex.Unlock()
    
    	// Generate an empty request info so it can be directly modified later by audit
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  7. compat/maven-model-builder/src/test/java/org/apache/maven/model/building/BuildModelSourceTransformerTest.java

                    .groupId("GROUPID")
                    .artifactId("ARTIFACTID")
                    .version("1.0-SNAPSHOT")
                    .build());
            Mockito.when(context.getRawModel(pomFile, root.resolve("pom.xml"))).thenReturn(parent);
            Mockito.when(context.locate(root)).thenReturn(root.resolve("pom.xml"));
            Model initial = new Model(org.apache.maven.api.model.Model.newBuilder()
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. cmd/metrics-v3-system-process.go

    	processVirtualMemoryMaxBytesMD    = NewGaugeMD(processVirtualMemoryMaxBytes, "Maximum virtual memory size in bytes")
    )
    
    func loadProcStatMetrics(ctx context.Context, stat procfs.ProcStat, m MetricValues) {
    	if stat.CPUTime() > 0 {
    		m.Set(processCPUTotalSeconds, float64(stat.CPUTime()))
    	}
    
    	if stat.ResidentMemory() > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    func (er erasureObjects) newMultipartUpload(ctx context.Context, bucket string, object string, opts ObjectOptions) (*NewMultipartUploadResult, error) {
    	if opts.CheckPrecondFn != nil {
    		if !opts.NoLock {
    			ns := er.NewNSLock(bucket, object)
    			lkctx, err := ns.GetLock(ctx, globalOperationTimeout)
    			if err != nil {
    				return nil, err
    			}
    			ctx = lkctx.Context()
    			defer ns.Unlock(lkctx)
    			opts.NoLock = true
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  10. 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
    	loadSecretKey(ctx context.Context, user string, userType IAMUserType) (string, 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)
Back to top