Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 1,215 for hand (0.1 seconds)

  1. cmd/erasure-server-pool.go

    	// so various tasks will be useful
    	bootstrapTrace("initAutoHeal", func() {
    		initAutoHeal(GlobalContext, z)
    	})
    
    	// initialize the object layer.
    	defer setObjectLayer(z)
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	attempt := 1
    	for {
    		var err error
    		bootstrapTrace(fmt.Sprintf("poolMeta.Init: loading pool metadata, attempt: %d", attempt), func() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. cmd/site-replication-utils.go

    		peerResyncMap: make(map[string]resyncState),
    	}
    	go s.save(ctx)
    	go s.init(ctx)
    	return &s
    }
    
    // init site resync metrics
    func (sm *siteResyncMetrics) init(ctx context.Context) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	// Run the site resync metrics load in a loop
    	for {
    		if err := sm.load(ctx, newObjectLayerFn()); err == nil {
    			<-ctx.Done()
    			return
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  3. cmd/erasure-healing.go

    	}
    
    	cleanFileInfo := func(fi FileInfo) FileInfo {
    		// Returns a copy of the 'fi' with erasure index, checksums and inline data niled.
    		nfi := fi
    		if !nfi.IsRemote() {
    			nfi.Data = nil
    			nfi.Erasure.Index = 0
    			nfi.Erasure.Checksums = nil
    		}
    		return nfi
    	}
    
    	// We write at temporary location and then rename to final location.
    	tmpID := mustGetUUID()
    	migrateDataDir := mustGetUUID()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  4. docs/bucket/replication/README.md

    dedicated tutorials for configuring one-way "Active-Passive" and two-way "Active-Active" bucket replication.
    
    To replicate objects in a bucket to a destination bucket on a target site either in the same cluster or a different cluster, start by enabling [versioning](https://docs.min.io/community/minio-object-store/administration/object-management/object-versioning.html) for both source and destination buckets. Finally, the target site and the destination bucket need to be configured on the source...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 18.3K bytes
    - Click Count (0)
  5. docs/sts/web-identity.md

    URL is set to `https://console.minio.example.org/oauth_callback` and the login process should work correctly.
    
    For deployments employing DNS round-robin on a single domain to all the MinIO servers, it is possible that after redirection the browser may land on a different MinIO server. For example, the domain `console.minio.example.org` may resolve to `console-X.minio.example.org`, where `X` is `1`, `2`, `3` or `4`. For the login to work, if the user first landed on `console-1.minio.example.org`,...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  6. cmd/object-api-utils_test.go

    		b.ResetTimer()
    		b.ReportAllocs()
    		for b.Loop() {
    			concat(data...)
    		}
    	})
    }
    
    func BenchmarkConcatImplementation(b *testing.B) {
    	data := make([]string, 2)
    	rng := rand.New(rand.NewSource(0))
    	for i := range 2 {
    		var tmp [16]byte
    		rng.Read(tmp[:])
    		data[i] = hex.EncodeToString(tmp[:])
    	}
    	b.ResetTimer()
    	benchmark(b, data)
    }
    
    func BenchmarkPathJoinOld(b *testing.B) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 24.1K bytes
    - Click Count (0)
  7. cmd/iam-etcd-store_test.go

    // Copyright (c) 2015-2021 MinIO, Inc.
    //
    // This file is part of MinIO Object Storage stack
    //
    // This program is free software: you can redistribute it and/or modify
    // it under the terms of the GNU Affero General Public License as published by
    // the Free Software Foundation, either version 3 of the License, or
    // (at your option) any later version.
    //
    // This program is distributed in the hope that it will be useful
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 1.5K bytes
    - Click Count (0)
  8. 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:]
    	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  9. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  10. 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))
    	quorum := 0
    	// Numbers of unique locks
    	for _, locks := range []int{100, 1000, 1e6} {
    		if testing.Short() && locks > 100 {
    			continue
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
Back to Top