Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for DupLockMap (0.05 sec)

  1. cmd/local-locker.go

    		entry := v[0]
    		if entry.Writer {
    			st.Writes++
    		} else {
    			st.Reads += len(v)
    		}
    	}
    	return st
    }
    
    type localLockMap map[string][]lockRequesterInfo
    
    func (l *localLocker) DupLockMap() localLockMap {
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    
    	lockCopy := make(map[string][]lockRequesterInfo, len(l.lockMap))
    	for k, v := range l.lockMap {
    		if len(v) == 0 {
    			delete(l.lockMap, k)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. cmd/notification.go

    		ctx := logger.SetReqInfo(ctx, reqInfo)
    		peersLogOnceIf(ctx, err, sys.peerClients[index].host.String())
    	}
    	locksResp = append(locksResp, &PeerLocks{
    		Addr:  getHostName(r),
    		Locks: globalLockServer.DupLockMap(),
    	})
    	return locksResp
    }
    
    // LoadBucketMetadata - calls LoadBucketMetadata call on all peers
    func (sys *NotificationSys) LoadBucketMetadata(ctx context.Context, bucketName string) {
    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