- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,357 for makeT (0.02 sec)
-
internal/bucket/bandwidth/monitor_test.go
m0.incrementBytes(0) m1MiBPS := newBucketMeasurement(start) m1MiBPS.incrementBytes(oneMiB) test1Want := make(map[BucketOptions]Details) test1Want[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{LimitInBytesPerSecond: 1024 * 1024, CurrentBandwidthInBytesPerSecond: 0} test1Want2 := make(map[BucketOptions]Details) test1Want2[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.3K bytes - Viewed (0) -
src/bytes/compare_test.go
func TestCompareBytes(t *testing.T) { lengths := make([]int, 0) // lengths to test in ascending order for i := 0; i <= 128; i++ { lengths = append(lengths, i) } lengths = append(lengths, 256, 512, 1024, 1333, 4095, 4096, 4097) if !testing.Short() { lengths = append(lengths, 65535, 65536, 65537, 99999) } n := lengths[len(lengths)-1] a := make([]byte, n+1) b := make([]byte, n+1) for _, len := range lengths {
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Thu Jul 13 23:11:42 UTC 2023 - 6.8K bytes - Viewed (0) -
internal/s3select/csv/reader.go
} // Create queue r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.input = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.readerWg.Add(1) // Start splitter go func() { defer close(r.input) defer close(r.queue) defer r.readerWg.Done() for { q := queueItem{ input: next, dst: make(chan [][]string, 1), err: nextErr, } select {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 8.8K bytes - Viewed (0) -
cmd/peer-s3-server.go
globalLocalDrivesMu.RUnlock() // Initialize sync waitgroup. g := errgroup.WithNErrs(len(localDrives)) // Disk states slices beforeState := make([]string, len(localDrives)) afterState := make([]string, len(localDrives)) // Make a volume entry on all underlying storage disks. for index := range localDrives { g.Go(func() (serr error) { if localDrives[index] == nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.2K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
return errors.New("cannot combine --data and --combine") } // file / version / file filemap := make(map[string]map[string]string) foundData := make(map[string][]byte) partDataToVerID := make(map[string][2]string) var baseName string // versionID -> combineFiles := make(map[string][]string) decode := func(r io.Reader, file string) ([]byte, error) { file = strings.ReplaceAll(file, ":", "_")
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 40.4K bytes - Viewed (0) -
cmd/metacache-bucket.go
func (b *bucketMetacache) cloneCaches() (map[string]metacache, map[string][]string) { b.mu.RLock() defer b.mu.RUnlock() dst := make(map[string]metacache, len(b.caches)) maps.Copy(dst, b.caches) // Copy indexes dst2 := make(map[string][]string, len(b.cachesRoot)) for k, v := range b.cachesRoot { tmp := make([]string, len(v)) copy(tmp, v) dst2[k] = tmp } return dst, dst2 }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.6K bytes - Viewed (0) -
cmd/erasure-metadata_test.go
} } return fis } commonSuccModTime := time.Date(2023, time.August, 25, 0, 0, 0, 0, time.UTC) succModTimesInQuorum := make([]time.Time, 16) succModTimesNoQuorum := make([]time.Time, 16) commonNumVersions := 2 numVersionsInQuorum := make([]int, 16) numVersionsNoQuorum := make([]int, 16) for i := range 16 { if i < 4 { continue } succModTimesInQuorum[i] = commonSuccModTime
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.4K bytes - Viewed (0) -
scripts/translate.py
translate or explain an English word to the human readers of the translation. These additional abbr elements would not make sense in the English text, but they do make sense in the translation. So keep them in the translation, even though they are not part of the English text. This rule only applies to abbr elements. 5) Apply above rules also when there is an existing translation! Make sure that all title attributes in abbr elements get properly translated or updated, using the schemes given above....
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 19:05:53 UTC 2025 - 34.1K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
func (x *xlMetaInlineData) remove(keys ...string) bool { in := x.afterVersion() sz, buf, _ := msgp.ReadMapHeaderBytes(in) newKeys := make([][]byte, 0, sz) newVals := make([][]byte, 0, sz) var removeKey func(s []byte) bool // Copy if big number of compares... if len(keys) > 5 && sz > 5 { mKeys := make(map[string]struct{}, len(keys)) for _, key := range keys { mKeys[key] = struct{}{} }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.4K bytes - Viewed (0) -
cmd/api-router.go
host, _, err := net.SplitHostPort(getHost(r)) if err != nil { host = r.Host } // Make sure to skip matching minio.<domain>` this is // specifically meant for operator/k8s deployment // The reason we need to skip this is for a special // usecase where we need to make sure that // minio.<namespace>.svc.<cluster_domain> is ignored // by the bucketDNS style to ensure that path style
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:19 UTC 2025 - 23.3K bytes - Viewed (0)