- Sort Score
- Num 10 results
- Language All
Results 201 - 210 of 870 for context_b (0.06 seconds)
-
cmd/lock-rest-client_test.go
} // Attempt all calls. _, err = lkClient.RLock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") } _, err = lkClient.Lock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Lock to fail") } _, err = lkClient.RUnlock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for RUnlock to fail") }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 2K bytes - Click Count (0) -
internal/grid/connection.go
"github.com/tinylib/msgp/msgp" "github.com/zeebo/xxh3" ) func gridLogIf(ctx context.Context, err error, errKind ...any) { logger.LogIf(ctx, "grid", err, errKind...) } func gridLogIfNot(ctx context.Context, err error, ignored ...error) { logger.LogIfNot(ctx, "grid", err, ignored...) } func gridLogOnceIf(ctx context.Context, err error, id string, errKind ...any) { logger.LogOnceIf(ctx, "grid", err, id, errKind...) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/ProfileSelector.java
/** * Determines the profiles which are active in the specified activation context. Active profiles will eventually be * injected into the model. * * @param profiles The profiles whose activation status should be determined, must not be {@code null}. * @param context The environmental context used to determine the activation status of a profile, must not be * {@code null}.Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 1.9K bytes - Click Count (0) -
impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/GAVUtilsTest.java
.version("1.0.0") .build(); Document document = Document.of(pomXml); UpgradeContext context = createMockContext(); Coordinates gav = AbstractUpgradeStrategy.extractArtifactCoordinatesWithParentResolution(context, document); assertNotNull(gav); assertEquals("com.example", gav.groupId());
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Nov 18 18:03:26 GMT 2025 - 17.3K bytes - Click Count (0) -
cmd/peer-rest-server.go
go func() { err := globalTierConfigMgr.Reload(context.Background(), newObjectLayerFn()) if err != nil { peersLogIf(context.Background(), fmt.Errorf("Failed to reload remote tier config %s", err)) } }() return np, nerr } // ConsoleLogHandler sends console logs of this node back to peer rest client func (s *peerRESTServer) ConsoleLogHandler(ctx context.Context, params *grid.MSS, out chan<- *grid.Bytes) *grid.RemoteErr {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
cmd/warm-backend-s3.go
}) return remoteVersionID(res.VersionID), s3.ToObjectError(err, object) } func (s3 *warmBackendS3) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) { return s3.PutWithMeta(ctx, object, r, length, map[string]string{}) } func (s3 *warmBackendS3) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error) { gopts := minio.GetObjectOptions{}
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jun 08 16:13:30 GMT 2025 - 5.8K bytes - Click Count (0) -
api/go1.21.txt
pkg cmp, func Less[$0 Ordered]($0, $0) bool #59488 pkg cmp, type Ordered interface {} #59488 pkg context, func AfterFunc(Context, func()) func() bool #57928 pkg context, func WithDeadlineCause(Context, time.Time, error) (Context, CancelFunc) #56661 pkg context, func WithoutCancel(Context) Context #40221 pkg context, func WithTimeoutCause(Context, time.Duration, error) (Context, CancelFunc) #56661 pkg crypto/elliptic, func GenerateKey //deprecated #52221
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Aug 07 09:39:17 GMT 2023 - 25.6K bytes - Click Count (0) -
internal/logger/target/http/http.go
// Init validate and initialize the http target func (h *Target) Init(ctx context.Context) (err error) { if h.config.QueueDir != "" { return h.initQueueOnce.DoWithContext(ctx, h.initDiskStore) } return h.initQueueOnce.DoWithContext(ctx, h.initMemoryStore) } func (h *Target) initDiskStore(ctx context.Context) (err error) { ctx, cancel := context.WithCancel(ctx) h.storeCtxCancel = cancel h.lastStarted = time.Now()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
cmd/consolelogger.go
// the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8), console: console.New(w), logBuf: ring.New(defaultLogBufferCount), } } // IsOnline always true in case of console logger func (sys *HTTPConsoleLoggerSys) IsOnline(_ context.Context) bool { return true }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.4K bytes - Click Count (0) -
internal/config/lambda/parse.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6K bytes - Click Count (0)