- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for DupLockMap (0.05 sec)
-
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) -
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)