Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/local-locker.go

    		Writes:      int(l.writers.Load()),
    		LockQueue:   int(l.waitMutex.Load()),
    		LastCleanup: l.lastCleanup.Load(),
    	}
    }
    
    type localLockMap map[string][]lockRequesterInfo
    
    func (l *localLocker) DupLockMap() localLockMap {
    	defer l.getMutex()()
    
    	lockCopy := make(map[string][]lockRequesterInfo, len(l.lockMap))
    	for k, v := range l.lockMap {
    		if len(v) == 0 {
    			delete(l.lockMap, k)
    			continue
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
Back to top