Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,140 for rsync (0.03 sec)

  1. internal/dsync/drwmutex.go

    }
    
    func (g *Granted) isLocked() bool {
    	return isLocked(g.lockUID)
    }
    
    func isLocked(uid string) bool {
    	return len(uid) > 0
    }
    
    // NewDRWMutex - initializes a new dsync RW mutex.
    func NewDRWMutex(clnt *Dsync, names ...string) *DRWMutex {
    	restClnts, _ := clnt.GetLockers()
    	sort.Strings(names)
    	return &DRWMutex{
    		writeLocks:           make([]string, len(restClnts)),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. cmd/namespace-lock.go

    // volume, path and operation ID.
    func (n *nsLockMap) NewNSLock(lockers func() ([]dsync.NetLocker, string), volume string, paths ...string) RWLocker {
    	sort.Strings(paths)
    	opsID := mustGetUUID()
    	if n.isDistErasure {
    		drwmutex := dsync.NewDRWMutex(&dsync.Dsync{
    			GetLockers: lockers,
    			Timeouts:   dsync.DefaultTimeouts,
    		}, pathsJoinPrefix(volume, paths...)...)
    		return &distLockInstance{drwmutex, opsID}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. docs/bucket/replication/DESIGN.md

    replicate objects one at a time so as not to impede server load. Ideally, resync should not be initiated for multiple buckets simultaneously - progress of the syncing can be monitored by looking at `mc replicate resync status alias/bucket --remote-bucket <arn>`. In the event that resync operation failed to replicate some versions, they would be picked up by the healing mechanism in-built as part of the scanner. If the resync operation reports a failed status or in the event of a cluster restart while...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  4. tests/test_dependency_contextmanager.py

    class OtherDependencyError(Exception):
        pass
    
    
    async def asyncgen_state(state: Dict[str, str] = Depends(get_state)):
        state["/async"] = "asyncgen started"
        yield state["/async"]
        state["/async"] = "asyncgen completed"
    
    
    def generator_state(state: Dict[str, str] = Depends(get_state)):
        state["/sync"] = "generator started"
        yield state["/sync"]
        state["/sync"] = "generator completed"
    
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 17 04:13:50 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. cmd/erasure.go

    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"math/rand"
    	"os"
    	"runtime"
    	"sort"
    	"sync"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/dsync"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    // list all errors that can be ignore in a bucket operation.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  6. docs/bucket/replication/README.md

    replicated objects to the DR cluster need to be re-replicated, `mc replicate resync start alias/bucket --remote-bucket <arn>` can be used to initiate a reset. This would initiate a re-sync between the two clusters by walking the bucket namespace and replicating eligible objects that satisfy the existing objects replication rule specified in the replication config. The status of the resync operation can be viewed with `mc replicate resync status alias/bucket --remote-bucket <arn>`.
    
    Note that Ex...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 24 23:46:33 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  7. cmd/site-replication-utils.go

    const (
    	siteResyncPrefix = bucketMetaPrefix + "/site-replication/resync"
    )
    
    type resyncState struct {
    	resyncID  string
    	LastSaved time.Time
    }
    
    //msgp:ignore siteResyncMetrics
    type siteResyncMetrics struct {
    	sync.RWMutex
    	// resyncStatus maps resync ID to resync status for peer
    	resyncStatus map[string]SiteResyncStatus
    	// map peer deployment ID to resync ID
    	peerResyncMap map[string]resyncState
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  8. cmd/lock-rest-server-common_test.go

    		lockRequesterInfo2,
    	}
    
    	lri := locker.ll.lockMap["name"]
    
    	// test unknown uid
    	if locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "unknown-uid",
    	}, &lri) {
    		t.Errorf("Expected %#v, got %#v", false, true)
    	}
    
    	if !locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "0123-4567",
    	}, &lri) {
    		t.Errorf("Expected %#v, got %#v", true, false)
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. cmd/bucket-replication-utils.go

    }
    
    // ResyncStatusType status of resync operation
    type ResyncStatusType int
    
    const (
    	// NoResync - no resync in progress
    	NoResync ResyncStatusType = iota
    	// ResyncPending - resync pending
    	ResyncPending
    	// ResyncCanceled - resync canceled
    	ResyncCanceled
    	// ResyncStarted -  resync in progress
    	ResyncStarted
    	// ResyncCompleted -  resync finished
    	ResyncCompleted
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  10. cmd/site-replication.go

    		}
    	}
    	return pi, true
    }
    
    // startResync initiates resync of data to peerSite specified. The overall site resync status
    // is maintained in .minio.sys/buckets/site-replication/resync/<deployment-id.meta>, while collecting
    // individual bucket resync status in .minio.sys/buckets/<bucket-name>/replication/resync.bin
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
Back to top