Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for Intn (0.19 sec)

  1. internal/grid/benchmark_test.go

    					n := 0
    					var latency int64
    					managers := grid.Managers
    					hosts := grid.Hosts
    					for pb.Next() {
    						// Pick a random manager.
    						src, dst := rng.Intn(len(managers)), rng.Intn(len(managers))
    						if src == dst {
    							dst = (dst + 1) % len(managers)
    						}
    						local := managers[src]
    						conn := local.Connection(hosts[dst])
    						if conn == nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer_test.go

    			// TryRead
    			n, err = rb.TryRead(buf[:readRng.Intn(len(buf))])
    			readBytes += n
    			read.Write(buf[:n])
    			debugln("READ 3\t", n, readBytes)
    			if err != nil && err != ErrAcquireLock && err != ErrIsEmpty {
    				readErr = err
    				break
    			}
    			if doSleep && readRng.Intn(20) == 0 {
    				time.Sleep(time.Duration(readRng.Intn(maxSleep)))
    			}
    		}
    	}()
    
    	// Writer
    	{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  3. cmd/xl-storage-format_test.go

    					if err != nil {
    						b.Fatal(err)
    					}
    					// Update modtime for resorting...
    					fi.ModTime = fi.ModTime.Add(-time.Second)
    					// Update a random version.
    					fi.VersionID = ids[rng.Intn(size)]
    					// Update...
    					err = xl.UpdateObjectVersion(fi)
    					if err != nil {
    						b.Fatal(err)
    					}
    					// Save...
    					dump, err = xl.AppendTo(dump[:0])
    					if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  4. cmd/local-locker_test.go

    					}
    
    					// Expire 50%
    					expired := time.Now().Add(-time.Hour * 2)
    					for _, v := range l.lockMap {
    						for i := range v {
    							if rng.Intn(2) == 0 {
    								v[i].TimeLastRefresh = expired.UnixNano()
    							}
    						}
    					}
    					start = time.Now()
    					l.expireOldLocks(time.Hour)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  5. internal/s3select/select_benchmark_test.go

    func newRandString(length int) string {
    	randSrc := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	b := make([]byte, length)
    	for i := range b {
    		b[i] = charset[randSrc.Intn(len(charset))]
    	}
    	return string(b)
    }
    
    func genSampleCSVData(count int) []byte {
    	buf := &bytes.Buffer{}
    	csvWriter := csv.NewWriter(buf)
    	csvWriter.Write([]string{"id", "name", "age", "city"})
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5K bytes
    - Viewed (0)
  6. cmd/benchmark-utils_test.go

    	const letterBytes = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
    	// seeding the random number generator.
    	rand.Seed(UTCNow().UnixNano())
    	// pick a character randomly.
    	return []byte{letterBytes[rand.Intn(len(letterBytes))]}
    }
    
    // picks a random byte and repeats it to size bytes.
    func generateBytesData(size int) []byte {
    	// repeat the random character chosen size
    	return bytes.Repeat(getRandomByte(), size)
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  7. src/bytes/buffer_test.go

    	var buf Buffer
    	s := ""
    	for i := 0; i < 50; i++ {
    		wlen := rand.Intn(len(testString))
    		if i%2 == 0 {
    			s = fillString(t, "TestMixedReadsAndWrites (1)", &buf, s, 1, testString[0:wlen])
    		} else {
    			s = fillBytes(t, "TestMixedReadsAndWrites (1)", &buf, s, 1, testBytes[0:wlen])
    		}
    
    		rlen := rand.Intn(len(testString))
    		fub := make([]byte, rlen)
    		n, _ := buf.Read(fub)
    		s = s[n:]
    	}
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Nov 14 19:01:17 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    func getRandomRange(minN, maxN int, seed int64) int {
    	// special value -1 means no explicit seeding.
    	if seed == -1 {
    		return rand.New(rand.NewSource(time.Now().UnixNano())).Intn(maxN-minN) + minN
    	}
    	return rand.New(rand.NewSource(seed)).Intn(maxN-minN) + minN
    }
    
    // Randomizes the order of bytes in the byte array
    // using Knuth Fisher-Yates shuffle algorithm.
    func randomizeBytes(s []byte, seed int64) []byte {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  9. src/bytes/bytes_test.go

    }
    
    var makeFieldsInput = func() []byte {
    	x := make([]byte, 1<<20)
    	// Input is ~10% space, ~10% 2-byte UTF-8, rest ASCII non-space.
    	r := rand.New(rand.NewSource(99))
    	for i := range x {
    		switch r.Intn(10) {
    		case 0:
    			x[i] = ' '
    		case 1:
    			if i > 0 && x[i-1] == 'x' {
    				copy(x[i-1:], "χ")
    				break
    			}
    			fallthrough
    		default:
    			x[i] = 'x'
    		}
    	}
    	return x
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Dec 23 23:54:14 UTC 2025
    - 62.9K bytes
    - Viewed (0)
  10. cmd/object-api-multipart_test.go

    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    
    	erasureDisks := er.getDisks()
    	ridx := rand.Intn(len(erasureDisks))
    
    	z.serverPools[0].erasureDisksMu.Lock()
    	er.getDisks = func() []StorageAPI {
    		erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk)
    		return erasureDisks
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
Back to top