Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 453 for ctx_ (0.14 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. cmd/config-current.go

    			}
    			loggerCfg.HTTP[n] = l
    		}
    		if errs := logger.UpdateHTTPWebhooks(ctx, loggerCfg.HTTP); len(errs) > 0 {
    			configLogIf(ctx, fmt.Errorf("Unable to update logger webhook config: %v", errs))
    		}
    	case config.AuditWebhookSubSys:
    		loggerCfg, err := logger.LookupConfigForSubSys(ctx, s, config.AuditWebhookSubSys)
    		if err != nil {
    			configLogIf(ctx, fmt.Errorf("Unable to load audit webhook config: %w", err))
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  10. tests/connpool_test.go

    func (c *wrapperConnPool) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) {
    	c.got = append(c.got, query)
    	return c.db.PrepareContext(ctx, query)
    }
    
    func (c *wrapperConnPool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) {
    	c.got = append(c.got, query)
    	return c.db.ExecContext(ctx, query, args...)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top