- Sort Score
- Result 10 results
- Languages All
Results 611 - 620 of 771 for ensure (0.2 sec)
-
cmd/post-policy_test.go
if err := newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatalf("Initializing config.json failed") } // Register the API end points with Erasure/FS object layer. apiRouter := initTestAPIEndPoints(obj, []string{"PostPolicy"}) credentials := globalActiveCred bucketName := minioMetaBucket objectName := "config/x"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/CharMappingService.java
}).orElse(Collections.emptyList()); } /** * Retrieves the character mapping file for the specified dictionary ID. * <p> * This method looks up the dictionary file and ensures it is a character mapping file * before returning it wrapped in an OptionalEntity. * </p> * * @param dictId the dictionary ID to retrieve the character mapping file for
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 6.1K bytes - Viewed (0) -
docs/logging/README.md
NOTE: - `timeToFirstByte` and `timeToResponse` will be expressed in Nanoseconds. - Additionally in the case of the erasure coded setup `tags.objectLocation` provides per object details about - Pool number the object operation was performed on. - Set number the object operation was performed on.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 10.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
timeoutFuture.timer = null; // Don't include already elapsed delay in delegate.toString() String message = "Timed out"; // This try-finally block ensures that we complete the timeout future, even if attempting // to produce the message throws (probably StackOverflowError from delegate.toString()) try { if (timer != null) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8K bytes - Viewed (0) -
cmd/server-main_test.go
t.Fatal("Unexpected object layer initialization error", err) } _, ok := obj.(*erasureServerPools) if !ok { t.Fatal("Unexpected object layer detected", reflect.TypeOf(obj)) } // Tests for Erasure object layer initialization. // Create temporary backend for the test server. nDisks = 16 disks, err = getRandomDisks(nDisks) if err != nil { t.Fatal("Failed to create drives for the backend") }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 3.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
* * <p>The job supports selective crawling by specifying configuration IDs for different * types of crawlers (web, file, data). It manages the crawler process lifecycle, * handles timeout scenarios, and ensures proper cleanup of resources.</p> * * <p>Key features:</p> * <ul> * <li>Concurrent crawler process management with configurable limits</li> * <li>Selective crawling based on configuration IDs</li>
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
throw new IOException("Failed to create new transport"); } // Reconnect channel.setState(ChannelState.CONNECTING); // Connection would be ensured through proper transport interface // Re-establish channel binding manager.performChannelBinding(channel); // Update channel with new transport
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 11.6K bytes - Viewed (0) -
cmd/bitrot-whole.go
"io" ) // Implementation to calculate bitrot for the whole file. type wholeBitrotWriter struct { disk StorageAPI volume string filePath string shardSize int64 // This is the shard size of the erasure logic hash.Hash // For bitrot hash } func (b *wholeBitrotWriter) Write(p []byte) (int, error) { err := b.disk.AppendFile(context.TODO(), b.volume, b.filePath, p) if err != nil { return 0, err }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 2.7K bytes - Viewed (0) -
docs/fr/docs/index.md
* Cliquez sur le bouton "Try it out", il vous permet de renseigner les paramètres et d'interagir directement avec l'API :  * Cliquez ensuite sur le bouton "Execute", l'interface utilisateur communiquera avec votre API, enverra les paramètres, obtiendra les résultats et les affichera à l'écran :
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:49:48 UTC 2025 - 22K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
} } return target; } /** * Commits any remaining documents in the cache to the index. * This method ensures all pending documents are processed. */ @Override public void commit() { synchronized (docList) { if (!docList.isEmpty()) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 10.3K bytes - Viewed (0)