- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 359 for arrange (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/bucket-stats.go
return newReplLatency } // Get upload latency of each object size range func (rl ReplicationLatency) getUploadLatency() (ret map[string]uint64) { ret = make(map[string]uint64) avg := rl.UploadHistogram.GetAvgData() for k, v := range avg { // Convert nanoseconds to milliseconds ret[sizeTagToString(k)] = uint64(v.avg() / time.Millisecond) } return ret }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.5K bytes - Click Count (0) -
internal/dsync/drwmutex_test.go
cunlock := make(chan bool) cdone := make(chan bool) for range numReaders { go parallelReader(context.Background(), m, clocked, cunlock, cdone) } // Wait for all parallel RLock()s to succeed. for range numReaders { <-clocked } for range numReaders { cunlock <- true } // Wait for the goroutines to finish. for range numReaders { <-cdone } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.4K bytes - Click Count (0) -
clause/where.go
func (not NotConditions) Build(builder Builder) { anyNegationBuilder := false for _, c := range not.Exprs { if _, ok := c.(NegationExpressionBuilder); ok { anyNegationBuilder = true break } } if anyNegationBuilder { if len(not.Exprs) > 1 { builder.WriteByte('(') } for idx, c := range not.Exprs { if idx > 0 { builder.WriteString(AndWithSpace) }
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Thu Apr 25 12:22:53 GMT 2024 - 5.1K bytes - Click Count (0) -
cmd/speedtest.go
// Check if we have local disks per pool less than // the concurrency make sure we choose only the "start" // concurrency to be equal to the lowest number of // local disks per server. for _, localDiskCount := range globalEndpoints.NLocalDisksPathsPerPool() { if localDiskCount < concurrency { concurrency = localDiskCount } } // Any concurrency less than '4' just stick to '4' concurrent
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 9.2K bytes - Click Count (0) -
guava/src/com/google/common/base/CaseFormat.java
LOWER_CAMEL(CharMatcher.inRange('A', 'Z'), "") { @Override String normalizeWord(String word) { return firstCharOnlyToUpper(word); } @Override String normalizeFirstWord(String word) { return Ascii.toLowerCase(word); } }, /** Java and C++ class naming convention, e.g., "UpperCamel". */ UPPER_CAMEL(CharMatcher.inRange('A', 'Z'), "") { @Override
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Dec 03 18:46:33 GMT 2025 - 6.5K bytes - Click Count (0) -
cmd/xl-storage-format-utils_test.go
xhttp.AmzBucketReplicationStatus: "", xhttp.ContentType: "application/json", }, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { const n = 100 want := hashDeterministicString(tt.arg) m := tt.arg for range n { if got := hashDeterministicString(m); got != want { t.Errorf("hashDeterministicString() = %v, want %v", got, want) } }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.1K bytes - Click Count (0) -
internal/config/lambda/event/targetlist.go
sync.RWMutex targets map[TargetID]Target } // Add - adds unique target to target list. func (list *TargetList) Add(targets ...Target) error { list.Lock() defer list.Unlock() for _, target := range targets { if _, ok := list.targets[target.ID()]; ok { return fmt.Errorf("target %v already exists", target.ID()) } list.targets[target.ID()] = target } return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/BoundType.java
* the License. */ package com.google.common.collect; import com.google.common.annotations.GwtCompatible; /** * Indicates whether an endpoint of some range is contained in the range itself ("closed") or not * ("open"). If a range is unbounded on a side, it is neither open nor closed on that side; the * bound simply does not exist. * * @since 10.0 */ @GwtCompatible public enum BoundType {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.3K bytes - Click Count (0) -
internal/event/config_test.go
{config3, "", []ARN{{TargetID{"1", "webhook"}, ""}, {TargetID{"2", "amqp"}, ""}}}, } for i, testCase := range testCases { testCase.config.SetRegion(testCase.region) result := []ARN{} for _, queue := range testCase.config.QueueList { result = append(result, queue.ARN) } if !reflect.DeepEqual(result, testCase.expectedResult) {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 28.9K bytes - Click Count (0) -
internal/event/rules_test.go
{"images/*", "jpg", "images/*jpg"}, {"images/", "*jpg", "images/*jpg"}, {"images/*", "*jpg", "images/*jpg"}, {"201*/images/", "jpg", "201*/images/*jpg"}, } for i, testCase := range testCases { result := NewPattern(testCase.prefix, testCase.suffix) if result != testCase.expectedResult { t.Fatalf("test %v: result: expected: %v, got: %v", i+1, testCase.expectedResult, result) } } }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 8.8K bytes - Click Count (0)