Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for peerLocks (0.21 sec)

  1. cmd/admin-handlers_test.go

    		lri.UID = mustGetUUID()
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    	}
    
    	var peerLocks []*PeerLocks
    	for _, owner := range owners {
    		peerLocks = append(peerLocks, &PeerLocks{
    			Addr:  owner,
    			Locks: locksHeld,
    		})
    	}
    	var exp madmin.LockEntries
    	for _, lri := range lris {
    		lockType := func(lri lockRequesterInfo) string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  2. cmd/notification.go

    }
    
    var errPeerNotReachable = errors.New("peer is not reachable")
    
    // GetLocks - makes GetLocks RPC call on all peers.
    func (sys *NotificationSys) GetLocks(ctx context.Context, r *http.Request) []*PeerLocks {
    	locksResp := make([]*PeerLocks, len(sys.peerClients))
    	g := errgroup.WithNErrs(len(sys.peerClients))
    	for index, client := range sys.peerClients {
    		index := index
    		client := client
    		g.Go(func() error {
    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)
Back to top