Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 453 for ctx_ (0.07 sec)

  1. cmd/global-heal.go

    			retErr = err
    		}
    
    		if retErr != nil {
    			healingLogIf(ctx, fmt.Errorf("listing failed with: %v on bucket: %v", retErr, bucket))
    			continue
    		}
    
    		select {
    		// If context is canceled don't mark as done...
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			tracker.bucketDone(bucket)
    			healingLogIf(ctx, tracker.update(ctx))
    		}
    	}
    	if retErr != nil {
    		return retErr
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. istioctl/pkg/completion/completion.go

    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/pkg/kube"
    )
    
    func getPodsNameInDefaultNamespace(ctx cli.Context, toComplete string) ([]string, error) {
    	client, err := ctx.CLIClient()
    	if err != nil {
    		return nil, err
    	}
    	ns := ctx.NamespaceOrDefault(ctx.Namespace())
    	podList, err := client.Kube().CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions{})
    	if err != nil {
    		return nil, err
    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. cmd/erasure-server-pool.go

    			return ListObjectsInfo{}, err
    		}
    		if contextCanceled(ctx) {
    			return ListObjectsInfo{}, ctx.Err()
    		}
    	}
    	return listFn(ctx, opts, maxKeys)
    }
    
    func (z *erasureServerPools) ListMultipartUploads(ctx context.Context, bucket, prefix, keyMarker, uploadIDMarker, delimiter string, maxUploads int) (ListMultipartsInfo, error) {
    	if err := checkListMultipartArgs(ctx, bucket, prefix, keyMarker, uploadIDMarker, delimiter); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  4. cmd/callhome.go

    	}
    
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    	// Perform callhome once and then keep running it at regular intervals.
    	performCallhome(ctx)
    
    	callhomeTimer := time.NewTimer(globalCallhomeConfig.FrequencyDur())
    	defer callhomeTimer.Stop()
    
    	for {
    		if !globalCallhomeConfig.Enabled() {
    			// Stop the processing as callhome got disabled
    			return false
    		}
    
    		select {
    		case <-ctx.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  5. tensorflow/c/eager/c_api_test_util.cc

    using tensorflow::tstring;
    
    TFE_TensorHandle* TestScalarTensorHandle(TFE_Context* ctx, float value) {
      float data[] = {value};
      TF_Status* status = TF_NewStatus();
      TF_Tensor* t = TFE_AllocateHostTensor(ctx, TF_FLOAT, nullptr, 0, status);
      memcpy(TF_TensorData(t), &data[0], TF_TensorByteSize(t));
      TFE_TensorHandle* th = TFE_NewTensorHandleFromTensor(ctx, t, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  6. cmd/iam.go

    					sys.purgeExpiredCredentialsForLDAP(ctx)
    					sys.updateGroupMembershipsForLDAP(ctx)
    				}
    				if sys.OpenIDConfig.ProviderEnabled() {
    					sys.purgeExpiredCredentialsForExternalSSO(ctx)
    				}
    			}
    
    			timer.Reset(waitInterval())
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    func (sys *IAMSys) validateAndAddRolePolicyMappings(ctx context.Context, m map[arn.ARN]string) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  7. cmd/erasure-healing_test.go

    		_, err = objLayer.HealObject(ctx, bucket, object, "", hopts)
    		if err != nil {
    			t.Fatal(err)
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    		if countErrs(errs, nil) != len(fileInfos) {
    			t.Fatal("Expected all xl.meta healed, but partial heal detected")
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", minioMetaBucket, cfgFile, "", false, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  8. istioctl/pkg/metrics/metrics_test.go

    func (client mockPromAPI) CleanTombstones(ctx context.Context) error {
    	return nil
    }
    
    func (client mockPromAPI) Config(ctx context.Context) (promv1.ConfigResult, error) {
    	return promv1.ConfigResult{}, nil
    }
    
    func (client mockPromAPI) DeleteSeries(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) error {
    	return nil
    }
    
    func (client mockPromAPI) Flags(ctx context.Context) (promv1.FlagsResult, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 01:35:47 UTC 2024
    - 8K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom.go

    	})
    	return err
    }
    
    func (z *erasureServerPools) decommissionPool(ctx context.Context, idx int, pool *erasureSets, bi decomBucketInfo) error {
    	ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{})
    
    	const envDecomWorkers = "_MINIO_DECOMMISSION_WORKERS"
    	workerSize, err := env.GetInt(envDecomWorkers, len(pool.sets))
    	if err != nil {
    		decomLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  10. cmd/lock-rest-client.go

    func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRLock, &args)
    }
    
    // Lock calls lock REST API.
    func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCLock, &args)
    }
    
    // RUnlock calls read unlock REST API.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
Back to top