Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 453 for ctx_ (0.12 sec)

  1. tensorflow/c/eager/c_api_cluster_test.cc

      CheckRemoteMatMulExecutesOK(ctx, remote_device_name, local_device_name);
    
      TFE_ContextUpdateServerDef(ctx, 0, serialized.data(), serialized.size(),
                                 status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      CheckRemoteMatMulExecutesOK(ctx, remote_device_name, local_device_name);
    
      TFE_DeleteContext(ctx);
      TF_DeleteStatus(status);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  2. istioctl/pkg/tag/util.go

    // DeleteTagWebhooks deletes the given webhooks.
    func DeleteTagWebhooks(ctx context.Context, client kubernetes.Interface, tag string) error {
    	webhooks, err := GetWebhooksWithTag(ctx, client, tag)
    	if err != nil {
    		return err
    	}
    	var result error
    	for _, wh := range webhooks {
    		result = multierror.Append(result, client.AdmissionregistrationV1().MutatingWebhookConfigurations().Delete(ctx, wh.Name, metav1.DeleteOptions{})).ErrorOrNil()
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/config-common.go

    	}
    	return buf, r.ObjInfo, nil
    }
    
    func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) {
    	buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{})
    	return buf, err
    }
    
    type objectDeleter interface {
    	DeleteObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error)
    }
    
    func deleteConfig(ctx context.Context, objAPI objectDeleter, configFile string) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    		if err != nil {
    			return err
    		}
    
    		c.healBucket(ctx, objAPI, bucket, info)
    
    		if bi.Deleted.IsZero() || (!bi.Created.IsZero() && bi.Deleted.Before(bi.Created)) {
    			c.healVersioningMetadata(ctx, objAPI, bucket, info)
    			c.healOLockConfigMetadata(ctx, objAPI, bucket, info)
    			c.healSSEMetadata(ctx, objAPI, bucket, info)
    			c.healBucketReplicationConfig(ctx, objAPI, bucket, info, &opts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  5. cmd/admin-handler-utils.go

    	if entity == "" {
    		return toAPIError(ctx, fmt.Errorf("error exporting %s with: %w", fname, err))
    	}
    	return toAPIError(ctx, fmt.Errorf("error exporting %s from %s with: %w", entity, fname, err))
    }
    
    // wraps import error for more context
    func importError(ctx context.Context, err error, fname, entity string) APIError {
    	if entity == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. internal/logger/targets.go

    func UpdateHTTPWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) {
    	return updateHTTPTargets(ctx, cfgs, systemTargets)
    }
    
    // UpdateAuditWebhooks swaps audit webhook targets with newly loaded ones from the cfg
    func UpdateAuditWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) {
    	return updateHTTPTargets(ctx, cfgs, auditTargets)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. cmd/data-usage.go

    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (map[string]uint64, error) {
    			m := make(map[string]uint64)
    			for _, pool := range z.serverPools {
    				for _, er := range pool.sets {
    					// Load bucket usage prefixes
    					ctx, done := context.WithTimeout(ctx, 2*time.Second)
    					ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil
    					done()
    					if ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. cmd/batch-rotate.go

    	ri.Failed = failed || ri.ObjectsFailed > 0
    	globalBatchJobsMetrics.save(job.ID, ri)
    	// persist in-memory state to disk.
    	batchLogIf(ctx, ri.updateAfter(ctx, api, 0, job))
    
    	if err := r.Notify(ctx, ri); err != nil {
    		batchLogIf(ctx, fmt.Errorf("unable to notify %v", err))
    	}
    
    	cancel()
    	return nil
    }
    
    //msgp:ignore batchKeyRotationJobError
    type batchKeyRotationJobError struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  9. cmd/config.go

    	})
    	return err
    }
    
    func readServerConfigHistory(ctx context.Context, objAPI ObjectLayer, uuidKV string) ([]byte, error) {
    	historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV+kvPrefix)
    	data, err := readConfig(ctx, objAPI, historyFile)
    	if err != nil {
    		return nil, err
    	}
    
    	return decryptData(data, historyFile)
    }
    
    func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 6K bytes
    - Viewed (0)
  10. cmd/object-lambda-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	eventData, err := getLambdaEventData(bucket, object, cred, r)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	resp, err := target.Send(eventData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	defer resp.Body.Close()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 10.3K bytes
    - Viewed (0)
Back to top