anchor.diff:          currentLock[lockType]['timestamp'] = new DateTime.now();
           _logger.fine('Lock type $lockType acquired');
           writeJSON(currentLock[lockType]["socket"], {"result":"ok", "action":"get", "requestId": currentLock[lockType]["requestId"]});
  +        currentLock[lockType]["socket"].flush().catchError((e, s) => _logger.warning("error when flushing in socket ${s.hashCode} $e $s"));
         }
       });
   
  
positive.code:   }
  
    handleClient(Socket socket) {
      clientSockets.add(socket);
      toJsonStream(socket).listen((Map data) {
        if (data["type"] == "lock") handleLockRequest(data["data"], socket);
        if (data["type"] == "info") handleInfoRequest(socket);
      }, onDone: () => _disposeOfSocket(socket));
    }
  
    handleInfoRequest(Socket socket) {
  
negative.code:     if (requestors[lockType] == null) requestors[lockType] = [];
      requestors[lockType].add({
        "socket" : socket,
        "socketHashCode" : socket.hashCode,
        "requestId": requestId,
        "callId": callId,
        "author": author,
  