Erland - Code Search

internal/event/targetlist_test.go

//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package event

import (
	"context"
	"crypto/rand"
	"errors"
	"reflect"
	"testing"
	"time"

	"github.com/minio/minio/internal/store"
)

type ExampleTarget struct {
	id       TargetID
	sendErr  bool
	closeErr bool
}

Go

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

- Last Modified: Tue Dec 05 10:16:33 GMT 2023

- 6.1K bytes

- Viewed (0)

github.com/minio/minio

internal/rest/client.go

}

// computes the exponential backoff duration according to
// https://www.awsarchitectureblog.com/2015/03/backoff.html
func exponentialBackoffWait(r *rand.Rand, unit, cap time.Duration) func(uint) time.Duration {
	if unit > time.Hour {
		// Protect against integer overflow
		panic("unit cannot exceed one hour")
	}
	return func(attempt uint) time.Duration {

Go

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

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

- 14.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/local-locker_test.go

	}
	if len(l.lockUID) != 0 {
		t.Fatalf("lockUID len, got %d, want %d + %d", len(l.lockUID), 0, 0)
	}
}

func Test_localLocker_expireOldLocksExpire(t *testing.T) {
	rng := rand.New(rand.NewSource(0))
	// Numbers of unique locks
	for _, locks := range []int{100, 1000, 1e6} {
		if testing.Short() && locks > 100 {
			continue
		}
		t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) {

Go

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

- Last Modified: Sun Mar 05 04:57:35 GMT 2023

- 11.8K bytes

- Viewed (0)

github.com/minio/minio

cmd/benchmark-utils_test.go

func getRandomByte() []byte {
	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

Go

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

- Last Modified: Fri Dec 23 15:46:00 GMT 2022

- 8.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/xl-storage-format_test.go

			}
			// Encode all. This is used for benchmarking.
			enc, err := xl.AppendTo(nil)
			if err != nil {
				b.Fatal(err)
			}
			b.Logf("Serialized size: %d bytes", len(enc))
			rng := rand.New(rand.NewSource(0))
			dump := make([]byte, len(enc))
			b.Run("UpdateObjectVersion", func(b *testing.B) {
				b.SetBytes(int64(size))
				b.ResetTimer()
				b.ReportAllocs()
				for i := 0; i < b.N; i++ {

Go

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

- Last Modified: Thu Feb 22 06:26:06 GMT 2024

- 17.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/server-main.go

		return
	}

	globalTrace.Publish(info)
}

func initServerConfig(ctx context.Context, newObject ObjectLayer) error {
	t1 := time.Now()

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

	for {
		select {
		case <-ctx.Done():
			// Retry was canceled successfully.
			return fmt.Errorf("Initializing sub-systems stopped gracefully %w", ctx.Err())
		default:

Go

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

- Last Modified: Fri May 03 15:54:03 GMT 2024

- 34.9K bytes

- Viewed (2)

github.com/google/guava

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

    Random rand = new Random(1);
    for (int bits = 10; bits < 63; bits++) {
      for (int i = 0; i < 100; i++) {
        long p = BigInteger.probablePrime(bits, rand).longValue();
        assertTrue(LongMath.isPrime(p));
      }
    }
  }

  @GwtIncompatible // isPrime is GWT-incompatible
  public void testIsPrimeOnRandomComposites() {
    Random rand = new Random(1);

Java

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

- Last Modified: Mon Mar 04 20:15:57 GMT 2024

- 32.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/login/index.jsp

<![endif]-->
</head>
<body class="hold-transition login-page">
	<div class="login-box">
		<div class="login-logo">
			<la:link href="/">
				<img src="${fe:url('/images/logo-top.png')}"
					alt="<la:message key="labels.header_brand_name" />" />
			</la:link>
		</div>
		<div class="notification">${notification}</div>
		<div class="card">
			<div class="card-body login-card-body">
				<p class="login-box-msg">
					<la:message key="labels.login" />

Others

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

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

- 3K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/login/newpassword.jsp

<![endif]-->
</head>
<body class="hold-transition login-page">
	<div class="login-box">
		<div class="login-logo">
			<la:link href="/">
				<img src="${fe:url('/images/logo-top.png')}"
					alt="<la:message key="labels.header_brand_name" />" />
			</la:link>
		</div>
		<div class="card">
			<div class="card-body login-card-body">
				<p class="login-box-msg">
					<la:message key="labels.login.newpassword" />
				</p>
				<%-- Message --%>

Others

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

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

- 3K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure_test.go

//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package cmd

import (
	"bytes"
	"context"
	"crypto/rand"
	"io"
	"testing"
)

var erasureEncodeDecodeTests = []struct {
	dataBlocks, parityBlocks   int
	missingData, missingParity int
	reconstructParity          bool
	shouldFail                 bool
}{

Go

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

- Last Modified: Mon Jul 25 19:37:26 GMT 2022

- 4.8K bytes

- Viewed (0)

Search Options