anchor.diff:  
       client_keepalive_test,
       heartbeats_test,
  +    async_request_manager_memory_management_test,
   
   %%    socket_timeout_test,
       closing_last_connection_should_cancel_all_session_transfers_test
  
positive.code:     await_status_answer(ok, <<"fs2">>, 2).
  
  
  socket_timeout_test(Config) ->
      [Worker1 | _] = ?config(op_worker_nodes, Config),
      SID = ?config({session_id, {<<"user1">>, ?GET_DOMAIN(Worker1)}}, Config),
  
negative.code: %%%===================================================================
  %%% Test helper functions
  %%%===================================================================
  
  
  assert_empty_async_req_manager_state(AsyncReqManager) ->
      {state,
          _, PendingReqs, UnreportedReqs, WithheldHeartbeats, _
      } = get_gen_server_state(AsyncReqManager),
  
      ?assertMatch(0, maps:size(PendingReqs)),
      ?assertMatch(0, maps:size(UnreportedReqs)),
      ?assertMatch(0, maps:size(WithheldHeartbeats)).
  
  
  get_gen_server_state(Pid) ->
      {status, Pid, _, [_PDict, _PStatus, _PParent, _PDbg, PMisc]} = sys:get_status(Pid),
      [_Header, _Status, {data, [{"State", State}]}] = PMisc,
      State.
  
  
  await_status_answer(ExpStatus, MsgId) ->
  