- Sort Score
- Result 10 results
- Languages All
Results 361 - 370 of 428 for foreach (0.04 sec)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java
.withEnv("MINIO_SECRET_KEY", SECRET_KEY)// .withExposedPorts(port)// .withCommand("server /data")// .waitingFor(new HttpWaitStrategy()// .forPath("/minio/health/ready")// .forPort(port)// .withStartupTimeout(Duration.ofSeconds(30))); logger.info("Starting {}", IMAGE_NAME); minioServer.start();
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 13.8K 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) -
README.md
- [日本語 (Japanese)](docs/ja/README.md) - [简体中文 (Simplified Chinese)](docs/zh-CN/README.md) - [Español (Spanish)](docs/es/README.md) - [Português (Brazilian Portuguese)](docs/pt-BR/README.md) - [Français (French)](docs/fr/README.md) - [Deutsch (German)](docs/de/README.md) - [한국어 (Korean)](docs/ko/README.md) ## Powered By * [Lasta Di](https://github.com/lastaflute/lasta-di "Lasta Di"): DI Container
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 10 06:34:32 UTC 2025 - 7.2K bytes - Viewed (2) -
docs/hotfixes.md
lead to conflicts and the patch will not cleanly apply. Conflicts might be trivial which can be resolved easily, when conflicts seem to be non-trivial or touches the part of the code-base the developer is not confident - to get additional clarity reach out to #hack on MinIOHQ slack channel. Hasty changes must be avoided, minor fixes and logs may be added to hotfix branches but this should not be followed as practice.* Once the **patch** is successfully applied, developer must run tests to...
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Feb 14 21:36:02 UTC 2024 - 5K 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) -
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) -
android/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.3K 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) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
} else { frameCallback.onReadMessage(messageFrameBuffer.readByteString()) } } /** Read headers and process any control frames until we reach a non-control frame. */ @Throws(IOException::class) private fun readUntilNonControlFrame() { while (!closed) { readHeader() if (!isControlFrame) { break }Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.9K bytes - Viewed (0)