- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for lockNotFound (0.12 sec)
-
internal/dsync/dsync-server_test.go
lockMap map[string]int64 // Refresh returns lock not found if set to true lockNotFound bool // Set to true if you want peers servers to do not respond responseDelay int64 } func (l *lockServer) setRefreshReply(refreshed bool) { l.mutex.Lock() defer l.mutex.Unlock() l.lockNotFound = !refreshed } func (l *lockServer) setResponseDelay(responseDelay time.Duration) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// c) timed out // lockNotFound, lockRefreshed := 0, 0 done := false for i := 0; i < len(restClnts); i++ { select { case refreshResult := <-ch: if refreshResult.offline { continue } if refreshResult.refreshed { lockRefreshed++ } else { lockNotFound++ } if lockRefreshed >= quorum || lockNotFound > len(restClnts)-quorum { done = true }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0)