- Sort Score
- Result 10 results
- Languages All
Results 341 - 350 of 1,936 for contexts (0.42 sec)
-
cmd/erasure-server-pool-decom.go
} } } return nil } func (z *erasureServerPools) doDecommissionInRoutine(ctx context.Context, idx int) { z.poolMetaMutex.Lock() var dctx context.Context dctx, z.decommissionCancelers[idx] = context.WithCancel(GlobalContext) z.poolMetaMutex.Unlock() // Generate an empty request info so it can be directly modified later by audit
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 42.2K bytes - Viewed (1) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/DefaultProfileInjector.java
} } target.setPlugins(new ArrayList<>(merged.values())); } } @Override protected void mergeReportPlugin_ReportSets( ReportPlugin target, ReportPlugin source, boolean sourceDominant, Map<Object, Object> context) {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Feb 25 08:27:34 UTC 2025 - 8K bytes - Viewed (0) -
cmd/perf-tests.go
} // Read a single byte. n, err = f.r.Read(p[:1]) if n > 0 { t := time.Now() f.t = &t } return n, err } // Runs the speedtest on local MinIO process. func selfSpeedTest(ctx context.Context, opts speedTestOpts) (res SpeedTestResult, err error) { objAPI := newObjectLayerFn() if objAPI == nil { return SpeedTestResult{}, errServerNotInitialized } var wg sync.WaitGroup var errOnce sync.Once
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 11.8K bytes - Viewed (0) -
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 != "" {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 19.4K bytes - Viewed (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());
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Nov 18 18:03:26 UTC 2025 - 17.3K bytes - Viewed (0) -
src/archive/tar/example_test.go
if err != nil { log.Fatal(err) } fmt.Printf("Contents of %s:\n", hdr.Name) if _, err := io.Copy(os.Stdout, tr); err != nil { log.Fatal(err) } fmt.Println() } // Output: // Contents of readme.txt: // This archive contains some text files. // Contents of gopher.txt: // Gopher names: // George // Geoffrey // Gonzo // Contents of todo.txt: // Get animal handling license.Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Thu Nov 16 16:54:08 UTC 2017 - 1.4K bytes - Viewed (0) -
docs/en/docs/_llm-test.md
//// tab | Test This is a code snippet: `foo`. And this is another code snippet: `bar`. And another one: `baz quux`. //// //// tab | Info Content of code snippets should be left as is. See section `### Content of code snippets` in the general prompt in `scripts/translate.py`. //// ## Quotes { #quotes } //// tab | TestRegistered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Thu Dec 11 14:48:47 UTC 2025 - 11.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/persistent/DurableHandleV2Request.java
public int size() { // Context header (16) + name length (4) + padding to 8-byte alignment (4) + data (32) return 16 + 4 + 4 + STRUCTURE_SIZE; } @Override public int encode(byte[] dst, int dstIndex) { int start = dstIndex; // Write context header SMBUtil.writeInt4(0, dst, dstIndex); // Next (offset to next context, 0 for last) dstIndex += 4;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 04:51:33 UTC 2025 - 5.2K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
return types.TargetStats{} } func (t *testLogger) Init(ctx context.Context) error { return nil } func (t *testLogger) IsOnline(ctx context.Context) bool { return t.current.Load() != nil } func (t *testLogger) Cancel() { t.current.Store(nil) } func (t *testLogger) Send(ctx context.Context, entry any) error { tb := t.current.Load() var logf func(format string, args ...any)Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4K bytes - Viewed (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
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Mon Aug 07 09:39:17 UTC 2023 - 25.6K bytes - Viewed (0)