Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for RLockHandler (0.07 sec)

  1. 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)
  2. 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)
Back to top