- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 453 for ctx_ (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)