- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for Lange (0.92 sec)
-
src/bytes/bytes_test.go
for i := 0; i <= 2*maxWnd; i++ { for _, window := range windows { if window > len(b[i:]) { window = len(b[i:]) } testCountWindow(i, window) for j := 0; j < window; j++ { b[i+j] = byte(0) } } } for i := 4096 - (maxWnd + 1); i < len(b); i++ { for _, window := range windows { if window > len(b[i:]) { window = len(b[i:]) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Jan 24 16:07:25 GMT 2024 - 56.2K bytes - Viewed (0) -
cmd/test-utils_test.go
return nil, nil, err } // Wait up to 10 seconds for disks to come online. pools := obj.(*erasureServerPools) t := time.Now() for _, pool := range pools.serverPools { for _, sets := range pool.erasureDisks { for _, s := range sets { if !s.IsLocal() { for { if s.IsOnline() { break } time.Sleep(100 * time.Millisecond)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
globalProfiler = make(map[string]minioProfiler, 10) } // Stop profiler of all types if already running for k, v := range globalProfiler { for _, p := range profiles { if p == k { v.Stop() delete(globalProfiler, k) } } } for _, profiler := range profiles { prof, err := startProfiler(profiler) if err != nil { s.writeErrorResponse(w, err) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/iam-store.go
policies := make(map[string]MappedPolicy, m.Size()) m.Range(func(k string, v MappedPolicy) bool { policies[k] = v return true }) return policies } // converts a mapped policy into a slice of distinct policies func (mp MappedPolicy) toSlice() []string { var policies []string for _, policy := range strings.Split(mp.Policies, ",") { if strings.TrimSpace(policy) == "" { continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/bucket-stats_gen.go
if err != nil { err = msgp.WrapError(err, "Stats") return } if z.Stats == nil { z.Stats = make(map[string]*BucketReplicationStat, zb0002) } else if len(z.Stats) > 0 { for key := range z.Stats { delete(z.Stats, key) } } for zb0002 > 0 { zb0002-- var za0001 string var za0002 *BucketReplicationStat za0001, err = dc.ReadString() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 57.5K bytes - Viewed (0) -
cmd/xl-storage.go
if err != nil { return err } // Clear and repopulate for k := range foundDirs { delete(foundDirs, k) } // Populate into map for _, k := range dirs { foundDirs[k] = struct{}{} } // Delete all directories we expect to be there. for _, dir := range wantDirs { delete(foundDirs, dir) } // Nothing to delete if len(foundDirs) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
testBuckets := []string{ // This bucket is used for testing ListObject operations. "test-bucket-folders", // This bucket has file delete marker. "test-bucket-files", } for _, bucket := range testBuckets { err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{ VersioningEnabled: true, }) if err != nil { t.Fatalf("%s : %s", instanceType, err.Error()) } } var err error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
uploadID string expectedErrType error }{bucket, "\\", uploadID, InvalidUploadID{}}) } // Iterating over creatPartCases to generate multipart chunks. for i, testCase := range abortTestCases { err = obj.AbortMultipartUpload(context.Background(), testCase.bucketName, testCase.objName, testCase.uploadID, opts) if testCase.expectedErrType == nil && err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
internal/s3select/select_test.go
<JSON> </JSON> </OutputSerialization> <RequestProgress> <Enabled>FALSE</Enabled> </RequestProgress> </SelectObjectContentRequest>` for _, testCase := range testTable { t.Run(testCase.name, func(t *testing.T) { // Hack cpuid to the CPU doesn't appear to support AVX2. // Restore whatever happens. if cpuid.CPU.Supports(cpuid.AVX2) { cpuid.CPU.Disable(cpuid.AVX2)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 76.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
func (z *erasureServerPools) GetDisksID(ids ...string) []StorageAPI { idMap := make(map[string]struct{}) for _, id := range ids { idMap[id] = struct{}{} } res := make([]StorageAPI, 0, len(idMap)) for _, s := range z.serverPools { for _, set := range s.sets { for _, disk := range set.getDisks() { if disk == OfflineDisk { continue } if id, _ := disk.GetDiskID(); id != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0)