anchor.diff:      if (_tryReleaseLock(requestId, callId, lockType, socket) ||
           _tryCancelRequestor(requestId, callId, lockType, socket)) {
         writeJSON(socket, {"result": "ok", "action": "cancel", "requestId": requestId});
  -      socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
       } else {
         writeJSON(socket, {"error": "Cannot cancel requestor when the socket does not own it nor waits for it", "action": "cancel", "requestId": requestId});
  -      socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
       }
  +    _flushAndCatchError(socket);
     }
   
     // Checks if someone can be given their requested lockType
  
positive.code:   _releaseLock(String requestId, String callId, String lockType, Socket socket) {
      if (_tryReleaseLock(requestId, callId, lockType, socket)) {
        writeJSON(socket, {"result":"ok", "action":"release", "requestId":requestId});
        socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
        checkLockRequestors();
      } else {
        writeJSON(socket, {"error": "Cannot release lock when the socket does not own it", "action":"release", "requestId":requestId});
        socket.flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
      }
    }
  
    _tryCancelRequestor(String requestId, String callId, String lockType, Socket socket) {
  
negative.code:   static Future<Locker> bind(url, port) =>
        ServerSocket.bind(url, port)
          .then((ServerSocket sSocket) {
            _logger.info('Locker running on $url, $port');
            Locker locker = new Locker.config(sSocket);
            locker.serverSocket.listen(locker.handleClient);
            return locker;
  