- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 114 for aurons (0.04 sec)
-
src/main/java/org/codelibs/fess/dict/DictionaryFile.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 11.2K bytes - Viewed (0) -
cmd/peer-s3-client.go
res.After.Drives = append(res.After.Drives, healBucketResults[i].After.Drives...) } } return res, nil } // ListBuckets lists buckets across all nodes and returns a consistent view: // - Return an error when a pool cannot return N/2+1 valid bucket information // - For each pool, check if the bucket exists in N/2+1 nodes before including it in the final result
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/erasure.go
ep := disksInfo[i].Endpoint if disksInfo[i].RootDisk { offlineDisks[ep]++ onlineDisks[ep]-- } } return onlineDisks, offlineDisks } // getDisksInfo - fetch disks info across all other storage API. func getDisksInfo(disks []StorageAPI, endpoints []Endpoint, metrics bool) (disksInfo []madmin.Disk) { disksInfo = make([]madmin.Disk, len(disks)) g := errgroup.WithNErrs(len(disks))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.1K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_cluster_objects_size_distribution` | Distribution of object sizes across a cluster | | `minio_cluster_objects_version_distribution` | Distribution of object versions across a cluster | | `minio_cluster_usage_object_total` | Total number of objects in a cluster |
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 43.4K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
var zero T for x, count := range c { if count >= quorum { return x, true } } return zero, false } // figure out the most commonVersions across disk that satisfies // the 'writeQuorum' this function returns "" if quorum cannot // be achieved and disks have too many inconsistent versions. func reduceCommonVersions(diskVersions [][]byte, writeQuorum int) (versions []byte) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* suggested that listeners are added before the service starts. * * <p>{@code addListener} guarantees execution ordering across calls to a given listener but not * across calls to multiple listeners. Specifically, a given listener will have its callbacks * invoked in the same order as the underlying service enters those states. Additionally, at most
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 10.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
executorService.shutdownNow(); } } } /** * Performs a search operation using rank fusion across available searchers. * If only one searcher is available, uses the main searcher. Otherwise, performs * concurrent searches across multiple searchers and fuses the results. * * @param query the search query string
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 24.8K bytes - Viewed (0) -
src/test/java/jcifs/EmptyIteratorTest.java
assertDoesNotThrow(() -> { emptyIterator.remove(); }, "remove() should not throw any exception"); } @Test @DisplayName("EmptyIterator should behave consistently across multiple calls") void testConsistentBehavior() { // When & Then - test multiple sequential calls for (int i = 0; i < 10; i++) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12K bytes - Viewed (0) -
cmd/global-heal.go
madmin.HealOpts{ ScanMode: scanMode, Remove: healDeleteDangling, }) if err != nil { if isErrObjectNotFound(err) || isErrVersionNotFound(err) { // queueing happens across namespace, ignore // objects that are not found. return } result = healEntryFailure(0) bgSeq.countFailed(madmin.HealItemObject)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 04 13:49:12 UTC 2025 - 16.2K bytes - Viewed (0) -
cmd/notification.go
if i < retryCount-1 { time.Sleep(100*time.Millisecond + time.Duration(r.Float64()*float64(time.Second))) continue } } break } }() } // DeletePolicy - deletes policy across all peers. func (sys *NotificationSys) DeletePolicy(ctx context.Context, policyName string) []NotificationPeerErr { ng := WithNPeers(len(sys.peerClients)).WithRetries(1) for idx, client := range sys.peerClients {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.9K bytes - Viewed (0)