Erland - Code Search

cmd/callhome.go

func initCallhome(ctx context.Context, objAPI ObjectLayer) {
	if !globalCallhomeConfig.Enabled() {
		return
	}

	go func() {
		r := rand.New(rand.NewSource(time.Now().UnixNano()))
		// Leader node (that successfully acquires the lock inside runCallhome)
		// will keep performing the callhome. If the leader goes down for some reason,
		// the lock will be released and another node will acquire it and take over
		// because of this loop.
		for {

Go

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

- Last Modified: Thu Apr 04 12:04:40 GMT 2024

- 5.1K bytes

- Viewed (1)

github.com/minio/minio

cmd/bucket-metadata.go

	key, err := GlobalKMS.GenerateKey(ctx, "", kmsContext)
	if err != nil {
		return
	}

	outbuf := bytes.NewBuffer(nil)
	objectKey := crypto.GenerateKey(key.Plaintext, rand.Reader)
	sealedKey := objectKey.Seal(key.Plaintext, crypto.GenerateIV(rand.Reader), crypto.S3.String(), bucket, "")
	crypto.S3.CreateMetadata(metadata, key.KeyID, key.Ciphertext, sealedKey)

Go

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

- Last Modified: Thu Apr 04 12:04:40 GMT 2024

- 16.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/perf-tests.go

// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package cmd

import (
	"context"
	"encoding/gob"
	"errors"
	"fmt"
	"io"
	"math/rand"
	"net/http"
	"net/url"
	"sync"
	"sync/atomic"
	"time"

	"github.com/dustin/go-humanize"
	"github.com/minio/madmin-go/v3"
	"github.com/minio/minio-go/v7"
	xhttp "github.com/minio/minio/internal/http"

Go

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

- Last Modified: Sun Jan 28 18:04:17 GMT 2024

- 11.3K bytes

- Viewed (0)

github.com/minio/minio

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/tiangolo/fastapi

tests/test_tutorial/test_dataclasses/test_tutorial003.py

    assert response.status_code == 200
    assert response.json() == [
        {
            "name": "Breaters",
            "items": [
                {
                    "name": "Island In The Moon",
                    "description": "A place to be be playin' and havin' fun",
                },
                {"name": "Holy Buddies", "description": None},
            ],
        },
        {

Python

- Registered: Sun Apr 28 07:19:10 GMT 2024

- Last Modified: Thu Sep 28 04:14:40 GMT 2023

- 12.1K 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/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)

Search Options