Erland - Code Search

cmd/erasure-server-pool-rebalance.go

	// Save rebalance.bin periodically.
	go func() {
		// Update rebalance.bin periodically once every 5-10s, chosen randomly
		// to avoid multiple pool leaders herding to update around the same
		// time.
		r := rand.New(rand.NewSource(time.Now().UnixNano()))
		randSleepFor := func() time.Duration {
			return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64())
		}

		timer := time.NewTimer(randSleepFor())

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Fri Apr 26 19:29:28 GMT 2024

- 27.2K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

    }

    /** Returns the minimum child or {@code -1} if no child exists. */
    int findMinChild(int index) {
      return findMin(getLeftChildIndex(index), 2);
    }

    /** Returns the minimum grand child or -1 if no grand child exists. */
    int findMinGrandChild(int index) {
      int leftChildIndex = getLeftChildIndex(index);
      if (leftChildIndex < 0) {
        return -1;
      }

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Thu Feb 22 21:19:52 GMT 2024

- 34K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/advance.jsp

		<header>
			<nav class="navbar navbar-expand-md navbar-dark fixed-top bg-dark">
				<div class="container">
					<la:link styleClass="navbar-brand d-inline-flex" href="/">
						<img src="${fe:url('/images/logo-head.png')}"
							alt="<la:message key="labels.header_brand_name" />"
							class="align-items-center" />
					</la:link>

Others

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Fri Feb 17 12:13:41 GMT 2023

- 14.9K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/maintenance/admin_maintenance.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %><!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.maintenance_title_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

Others

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Mon Jan 16 12:54:35 GMT 2023

- 11.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-server-pool-decom.go

		go func() {
			// Resume decommissioning of pools, but wait 3 minutes for cluster to stabilize.
			if err := sleepContext(ctx, 3*time.Minute); err != nil {
				return
			}
			r := rand.New(rand.NewSource(time.Now().UnixNano()))
			for {
				if err := z.Decommission(ctx, poolIndices...); err != nil {
					if errors.Is(err, errDecommissionAlreadyRunning) {
						// A previous decommission running found restart it.

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Wed May 01 15:18:21 GMT 2024

- 41.5K bytes

- Viewed (1)

github.com/minio/minio

cmd/xl-storage-disk-id-check.go

		if skipIfSuccessBefore <= 0 {
			skipIfSuccessBefore = globalDriveConfig.GetMaxTimeout()
		}
	}

	t := time.NewTicker(checkEvery)
	defer t.Stop()
	fn := mustGetUUID()

	rng := rand.New(rand.NewSource(time.Now().UnixNano()))

	monitor := func() bool {
		if contextCanceled(ctx) {
			return false
		}

		if p.health.status.Load() != diskHealthOK {
			return true
		}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Sun Apr 28 17:53:50 GMT 2024

- 33K bytes

- Viewed (0)

github.com/golang/go

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:]
	}

Go

- Registered: Tue Apr 30 11:13:12 GMT 2024

- Last Modified: Fri Apr 26 13:31:36 GMT 2024

- 18.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/notification.go

//
// The first call to return a non-nil error will be
// collected in errs slice and returned by Wait().
func (g *NotificationGroup) Go(ctx context.Context, f func() error, index int, addr xnet.Host) {
	r := rand.New(rand.NewSource(time.Now().UnixNano()))

	g.workers.Take()

	go func() {
		defer g.workers.Give()

		g.errs[index] = NotificationPeerErr{
			Host: addr,
		}
		for i := 0; i < g.retryCount; i++ {

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Fri Apr 12 18:13:36 GMT 2024

- 44.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/data-scanner.go

	scannerExcessFolders                 = uatomic.NewInt64(50000)
)

// initDataScanner will start the scanner in the background.
func initDataScanner(ctx context.Context, objAPI ObjectLayer) {
	go func() {
		r := rand.New(rand.NewSource(time.Now().UnixNano()))
		// Run the data scanner in a loop
		for {
			runDataScanner(ctx, objAPI)
			duration := time.Duration(r.Float64() * float64(scannerCycle.Load()))
			if duration < time.Second {

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Fri May 03 11:18:58 GMT 2024

- 47.6K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/math/IntMathTest.java

    for (int i = 0; i < 100000; i++) {
      assertEquals(LongMath.isPrime(i), IntMath.isPrime(i));
    }

    // Then check 1000 deterministic pseudo-random int values.
    Random rand = new Random(1);
    for (int i = 0; i < 1000; i++) {
      int n = rand.nextInt(Integer.MAX_VALUE);
      assertEquals(LongMath.isPrime(n), IntMath.isPrime(n));
    }
  }

  private static int force32(int value) {

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Wed Feb 07 17:50:39 GMT 2024

- 24.5K bytes

- Viewed (0)

Search Options