- Sort Score
- Num 10 results
- Language All
Results 2751 - 2760 of 2,989 for onex (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/bucket-targets.go
ResetID: tcfg.ResetID, Endpoint: tcfg.Endpoint, Secure: tcfg.Secure, } return tc, nil } // getRemoteARN gets existing ARN for an endpoint or generates a new one. func (sys *BucketTargetSys) getRemoteARN(bucket string, target *madmin.BucketTarget, deplID string) (arn string, exists bool) { if target == nil { return arn, exists } sys.RLock() defer sys.RUnlock()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.9K bytes - Click Count (0) -
cmd/bucket-metadata-sys.go
internalLogIf(ctx, err, logger.WarningKind) wait() // wait to proceed to next entry. continue } sys.Lock() // Update if the bucket metadata in the memory is older than on-disk one if lu := sys.metadataMap[bucket].lastUpdate(); lu.Before(meta.lastUpdate()) { updated = true sys.metadataMap[bucket] = meta } sys.Unlock() if updated {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.4K bytes - Click Count (0) -
internal/grid/types.go
func (j *Array[T]) Value() []T { if j.val == nil { j.val = j.p.newA(10) } return j.val } // Append a value to the underlying array. // The returned Array is always the same as the one called. func (j *Array[T]) Append(v ...T) *Array[T] { if j.val == nil { j.val = j.p.newA(uint32(len(v))) } j.val = append(j.val, v...) return j } // Set the underlying value.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/util/GsaConfigParser.java
* Processes each line of the input text, filtering URLs based on web and file protocol support. * * @param text the raw text containing URL patterns, one per line * @param web true if web protocol URLs should be included * @param file true if file protocol URLs should be included * @return a newline-separated string of filtered URL patterns */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 21.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/ActivityHelperTest.java
assertEquals(100, result.length()); assertFalse(result.endsWith("...")); } @Test public void test_normalizeScript_lessThanMaxLength() { // Create a script of 99 characters (one less than default max length) StringBuilder sb = new StringBuilder(); for (int i = 0; i < 99; i++) { sb.append("c"); } String shortScript = sb.toString();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 11:45:43 GMT 2026 - 24.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/CertificatePinnerChainValidationTest.kt
platform.expectFailureOnConscryptPlatform() platform.expectFailureOnCorrettoPlatform() platform.expectFailureOnLoomPlatform() // Start with two root CA certificates, one is good and the other is compromised. val rootCa = HeldCertificate .Builder() .serialNumber(1L) .certificateAuthority(1) .commonName("root") .build()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 24.4K bytes - Click Count (2) -
src/main/java/jcifs/internal/smb2/create/Smb2CreateRequest.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 22.9K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/io/Smb2ReadRequestTest.java
assertEquals(0, SMBUtil.readInt2(buffer, 46)); // ReadChannelInfoLength // Buffer byte assertEquals(0, buffer[48]); // One byte in buffer must be zero // Verify total bytes written assertEquals(49, bytesWritten); } @Test @DisplayName("Should write default values correctly")
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 24.8K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/execution/DefaultMavenExecutionRequest.java
/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at *
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Dec 12 11:02:17 GMT 2024 - 32.1K bytes - Click Count (0) -
cmd/background-newdisks-heal-ops.go
// Add future tracking capabilities // Be sure that they are included in toHealingDisk } // loadHealingTracker will load the healing tracker from the supplied disk. // The disk ID will be validated against the loaded one. func loadHealingTracker(ctx context.Context, disk StorageAPI) (*healingTracker, error) { if disk == nil { return nil, errors.New("loadHealingTracker: nil drive given") } diskID, err := disk.GetDiskID()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 16.5K bytes - Click Count (0)