Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 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)
  3. cmd/peer-rest-server.go

    )
    
    // GetLocksHandler - returns list of lock from the server.
    func (s *peerRESTServer) GetLocksHandler(_ *grid.MSS) (*localLockMap, *grid.RemoteErr) {
    	res := globalLockServer.DupLockMap()
    	return &res, nil
    }
    
    // DeletePolicyHandler - deletes a policy on the server.
    func (s *peerRESTServer) DeletePolicyHandler(mss *grid.MSS) (np grid.NoPayload, nerr *grid.RemoteErr) {
    	objAPI := newObjectLayerFn()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top