Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/admin-handlers.go

    	return entry
    }
    
    func topLockEntries(peerLocks []*PeerLocks, stale bool) madmin.LockEntries {
    	now := time.Now().UTC()
    	entryMap := make(map[string]*madmin.LockEntry)
    	toEntry := func(lri lockRequesterInfo) string {
    		return fmt.Sprintf("%s/%s", lri.Name, lri.UID)
    	}
    	for _, peerLock := range peerLocks {
    		if peerLock == nil {
    			continue
    		}
    		for k, v := range peerLock.Locks {
    			for _, lockReqInfo := range v {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
Back to top