- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for DupLockMap (0.18 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12K bytes - Click Count (0) -
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) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
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()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0)