- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for RLockHandler (0.07 sec)
-
cmd/lock-rest-server.go
// Ignore the Unlock() "reply" return value because if err == nil, "reply" is always true // Consequently, if err != nil, reply is always false return l.makeResp(resp, err) } // RLockHandler - Acquires an RLock. func (l *lockRESTServer) RLockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { // Add a timeout similar to what we expect upstream. ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.Acquire)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jan 31 19:54:34 UTC 2025 - 6.3K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
if err != nil { lh.writeErrorResponse(w, err) return } } func (lh *lockServerHandler) HealthHandler(w http.ResponseWriter, r *http.Request) {} func (lh *lockServerHandler) RLockHandler(w http.ResponseWriter, r *http.Request) { args, err := getLockArgs(r) if err != nil { lh.writeErrorResponse(w, err) return } reply, err := lh.lsrv.RLock(&args) if err == nil && !reply {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.3K bytes - Viewed (0)