- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,051 for reach (0.02 sec)
-
PULL_REQUESTS_ETIQUETTE.md
- Is small, focused, and easy to review—ideally one commit, unless multiple commits better narrate complex work. - Adheres to MinIO’s coding standards (e.g., Go style, error handling, testing). PRs must flow smoothly through review to reach production. Large PRs should be split into smaller, manageable ones. ## Submitting PRs 1. **Title and Summary**:
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun May 25 16:32:03 UTC 2025 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Strings.java
return Platform.stringIsNullOrEmpty(string); } /** * Returns a string, of length at least {@code minLength}, consisting of {@code string} prepended * with as many copies of {@code padChar} as are necessary to reach that length. For example, * * <ul> * <li>{@code padStart("7", 3, '0')} returns {@code "007"} * <li>{@code padStart("2010", 3, '0')} returns {@code "2010"} * </ul> *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Aug 27 17:53:41 UTC 2025 - 12.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
// even check the guard. I don't think we care too much about this use case but it could lead // to a confusing error message. throw new TimeoutException("Timed out waiting for " + this + " to reach the RUNNING state."); } } @Override public final void awaitTerminated() { monitor.enterWhenUninterruptibly(isStopped); try { checkCurrentState(TERMINATED); } finally {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
config.QueueList = append(config.QueueList[:i], config.QueueList[i+1:]...) } // This is a one time activity we shall do this // here and allow stale ARN to be removed. We shall // never reach a stage where we will have stale // notification configs. } } else { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } } configData, err := xml.Marshal(config)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.1K bytes - Viewed (0) -
docs/kms/README.md
### Verify auto-encryption > Note that auto-encryption only affects requests without S3 encryption headers. So, if a S3 client sends > e.g. SSE-C headers, MinIO will encrypt the object with the key sent by the client and won't reach out to > the configured KMS. To verify auto-encryption, use the following `mc` command: ``` mc cp test.file myminio/bucket/
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 7.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Route.kt
* limitations under the License. */ package okhttp3 import java.net.InetSocketAddress import java.net.Proxy import okhttp3.internal.toCanonicalHost /** * The concrete route used by a connection to reach an abstract origin server. When creating a * connection the client has many options: * * * **HTTP proxy:** a proxy server may be explicitly configured for the client. Otherwise, the
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.2K bytes - Viewed (0) -
cmd/service.go
} globalServiceFreezeMu.Unlock() } // unfreezeServices will unfreeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func unfreezeServices() { // We need a lock since we need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock() // Close when we reach 0 globalServiceFreezeCnt-- if globalServiceFreezeCnt <= 0 { // Set to a nil channel. var _ch chan struct{}
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Feb 28 07:02:14 UTC 2024 - 3.8K bytes - Viewed (0) -
src/test/java/jcifs/context/SingletonContextTest.java
log.error("Failed to get SingletonContext instance via reflection", e); fail("Failed to get SingletonContext instance via reflection: " + e.getMessage()); return null; // Should not reach here } }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java
currentWeight += channel.getScore(); if (random < currentWeight) { return channel; } } // Should not reach here return channels.iterator().next(); } private ChannelInfo selectWithAffinity(CommonServerMessageBlock message, Collection<ChannelInfo> channels) { // Use file handle or tree ID for affinity
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 8.2K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Striped64.java
* free slot. * * The table size is capped because, when there are more threads * than CPUs, supposing that each thread were bound to a CPU, * there would exist a perfect hash function mapping threads to * slots that eliminates collisions. When we reach capacity, we * search for this mapping by randomly varying the hash codes of * colliding threads. Because search is random, and collisions
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jan 15 22:17:15 UTC 2025 - 11.4K bytes - Viewed (0)