- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 699 for context_b (0.32 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/server-main.go
} } func initConfigSubsystem(ctx context.Context, newObject ObjectLayer) error { // %w is used by all error returns here to make sure // we wrap the underlying error, make sure when you // are modifying this code that you do so, if and when // you want to add extra context to your error. This // ensures top level retry works accordingly. // Initialize config system.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:18:36 GMT 2025 - 35.9K bytes - Click Count (4) -
cmd/admin-handlers-site-replication.go
writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } } func parseJSONBody(ctx context.Context, body io.Reader, v any, encryptionKey string) error { data, err := io.ReadAll(body) if err != nil { return SRError{ Cause: err, Code: ErrSiteReplicationInvalidRequest, } } if encryptionKey != "" {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.4K bytes - Click Count (0) -
cmd/bootstrap-peer-server.go
} // client to talk to bootstrap NEndpoints. type bootstrapRESTClient struct { gridConn *grid.Connection } // Verify function verifies the server config. func (client *bootstrapRESTClient) Verify(ctx context.Context, srcCfg *ServerSystemConfig) (err error) { if newObjectLayerFn() != nil { return nil } recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS()) if err != nil { return errCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 01 22:13:18 GMT 2024 - 8.4K bytes - Click Count (0) -
android/guava/src/com/google/common/eventbus/SubscriberExceptionContext.java
* the License. */ package com.google.common.eventbus; import static com.google.common.base.Preconditions.checkNotNull; import java.lang.reflect.Method; /** * Context for an exception thrown by a subscriber. * * @since 16.0 */ public class SubscriberExceptionContext { private final EventBus eventBus; private final Object event; private final Object subscriber;Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 17:06:34 GMT 2025 - 2.2K bytes - Click Count (0) -
internal/crypto/sse-kms.go
// and the KMS context on success. func (ssekms) ParseHTTP(h http.Header) (string, kms.Context, error) { if h == nil { return "", nil, ErrInvalidEncryptionMethod } algorithm := h.Get(xhttp.AmzServerSideEncryption) if algorithm != xhttp.AmzEncryptionKMS { return "", nil, ErrInvalidEncryptionMethod } var ctx kms.Context if context, ok := h[xhttp.AmzServerSideEncryptionKmsContext]; ok {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 07 23:55:37 GMT 2024 - 8.5K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/DefaultProfileActivationContext.java
* * @param projectDirectory The base directory of the current project, may be {@code null} if profile activation * happens in the context of metadata retrieval rather than project building. * @return This context, never {@code null}. */ public DefaultProfileActivationContext setProjectDirectory(File projectDirectory) { this.projectDirectory = projectDirectory;Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 7.4K bytes - Click Count (0) -
cmd/erasure-metadata-utils_test.go
}, nil, nil, }, // Checks if wrapped context cancellation errors are grouped as one. {canceledErrs, nil, context.Canceled}, } // Validates list of all the testcases for returning valid errors. for i, testCase := range testCases { gotErr := reduceReadQuorumErrs(t.Context(), testCase.errs, testCase.ignoredErrs, 5) if gotErr != testCase.err {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.3K bytes - Click Count (0) -
cmd/erasure_test.go
buffer := make([]byte, len(data), 2*len(data)) copy(buffer, data) erasure, err := NewErasure(t.Context(), test.dataBlocks, test.parityBlocks, blockSizeV2) if err != nil { t.Fatalf("Test %d: failed to create erasure: %v", i, err) } encoded, err := erasure.EncodeData(t.Context(), buffer) if err != nil { t.Fatalf("Test %d: failed to encode data: %v", i, err) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 4.8K bytes - Click Count (0) -
cmd/metrics-v3-cluster-usage.go
"Cluster object version count distribution", "range") ) // loadClusterUsageObjectMetrics - reads cluster usage metrics. // // This is a `MetricsLoaderFn`. func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { dataUsageInfo, err := c.dataUsageInfo.Get() if err != nil { metricsLogIf(ctx, err) return nil } // data usage has not captured any data yet.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6.5K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance.go
ps.RebalancedBuckets = append(ps.RebalancedBuckets, bucket) break } } } func (r *rebalanceMeta) load(ctx context.Context, store objectIO) error { return r.loadWithOpts(ctx, store, ObjectOptions{}) } func (r *rebalanceMeta) loadWithOpts(ctx context.Context, store objectIO, opts ObjectOptions) error { data, _, err := readConfigWithMetadata(ctx, store, rebalMetaName, opts) if err != nil { return err
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 28.7K bytes - Click Count (0)