- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 219 for cout (0.22 sec)
-
docs/distributed/decom-encrypted-sse-s3.sh
pid_2=$! sleep 30 expanded_user_count=$(./mc admin user list myminio/ | wc -l) expanded_policy_count=$(./mc admin policy list myminio/ | wc -l) if [ $user_count -ne $expanded_user_count ]; then echo "BUG: original user count differs from expanded setup" exit 1 fi if [ $policy_count -ne $expanded_policy_count ]; then echo "BUG: original policy count differs from expanded setup" exit 1 fi
Shell Script - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Mar 14 15:54:11 GMT 2024 - 4.5K bytes - Viewed (0) -
internal/dsync/drwmutex.go
} // checkQuorumLocked determines whether we have locked the required quorum of underlying locks or not func checkQuorumLocked(locks *[]string, quorum int) bool { count := 0 for _, uid := range *locks { if isLocked(uid) { count++ } } return count >= quorum } // releaseAll releases all locks that are marked as locked
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
count := len(testCases) for i := 4; i < len(testCases); i++ { tc := testCases[i] dataDir, err := xl.DeleteVersion(fileInfos[i]) failOnErr(count+1, err) if dataDir != tc.expectedDataDir { t.Fatalf("Expected %s but got %s", tc.expectedDataDir, dataDir) } count++ } } func Benchmark_mergeXLV2Versions(b *testing.B) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
cmd/admin-handlers.go
peerLocks := globalNotificationSys.GetLocks(ctx, r) topLocks := topLockEntries(peerLocks, stale) // Marshal API response upto requested count. if len(topLocks) > count && count > 0 { topLocks = topLocks[:count] } jsonBytes, err := json.Marshal(topLocks) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
internal/s3select/sql/parser.go
ArgsList []*Expression `parser:"\"(\" (@@ (\",\" @@)*)?\")\""` } // CountFunc represents the COUNT sql function type CountFunc struct { StarArg bool `parser:" \"COUNT\" \"(\" ( @\"*\"?"` ExprArg *Expression `parser:" @@? )! \")\""` } // CastFunc represents CAST sql function type CastFunc struct {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/metacache-set.go
filter := func(list []uint64) (commonCount uint64) { max := 0 signatureMap := map[uint64]int{} for _, v := range list { signatureMap[v]++ } for ops, count := range signatureMap { if max < count && commonCount < ops { max = count commonCount = ops } } if max < readQuorum { return 0 } return commonCount } commonWrite = filter(writes)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 18 04:42:11 GMT 2024 - 30.4K bytes - Viewed (0) -
.github/workflows/multipart/migrate.sh
## upgrading to master, healing and being able to recover ## the last version. if [ $failed_count_site1 -ne 0 ]; then echo "failed with multipart on site1 uploads ${failed_count_site1}" fi if [ $failed_count_site2 -ne 0 ]; then echo "failed with multipart on site2 uploads ${failed_count_site2}" fi export RELEASE=${1} docker-compose -f docker-compose-site1.yaml up -d
Shell Script - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Feb 17 01:15:57 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/data-usage-cache.go
// appear earlier in this array of intervals, see // ObjectsHistogramIntervals splCount += count fallthrough default: res[szInt.name] = count } } return res } // add a version count to the histogram. func (h *versionsHistogram) add(versions uint64) { // Fetch the histogram interval corresponding // to the passed object size.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 41.3K bytes - Viewed (1) -
cmd/os_other.go
maxEntries := 1000 if opts.count > 0 && opts.count < maxEntries { maxEntries = opts.count } done := false remaining := opts.count for !done { // Read up to max number of entries. fis, err := d.Readdir(maxEntries) if err != nil { if err == io.EOF { break } return nil, osErrToFileErr(err) } if opts.count > -1 { if remaining <= len(fis) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Sep 13 15:14:36 GMT 2023 - 4K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
driveAPILatencyMicros = "api_latency_micros" driveHealing = "healing" driveOnline = "online" driveOfflineCount = "offline_count" driveOnlineCount = "online_count" driveCount = "count" // iostat related driveReadsPerSec = "reads_per_sec" driveReadsKBPerSec = "reads_kb_per_sec" driveReadsAwait = "reads_await" driveWritesPerSec = "writes_per_sec"
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 11 21:22:15 GMT 2024 - 7.5K bytes - Viewed (0)