anchor.diff:              {NewLen, NewBuf} =
                   if Buf =:= <<>> ->
                       << L:32, PayLoad/binary >> = Data,
  -                    ?TDebug(" term size ~p~n", [<< L:32 >>]),
  +                    ?TLog(" term size ~p~n", [<< L:32 >>]),
                       {L, PayLoad};
                   true -> {Len, <<Buf/binary, Data/binary>>}
               end,
  
positive.code:     loop(Socket, Transport, <<>>, 0).
  
  -define(TDebug(__F, __A), ok). 
  %-define(TDebug(__F, __A), ?Debug(__F, __A)). 
  loop(Socket, Transport, Buf, Len) ->
      {OK, Closed, Error} = Transport:messages(),
      Transport:setopts(Socket, [{active, once}]),   
  
negative.code: mfa({Ref, Mod, Fun, Args}, Transport) ->
      NewArgs = args(Ref,Fun,Args,Transport),
      ApplyRes = try
                     ?TLog("~p MFA -> R ~n ~p:~p(~p)~n", [Transport,Mod,Fun,NewArgs]),
                     apply(Mod,Fun,NewArgs)
                 catch 
                      _Class:Reason -> {error, {Reason, erlang:get_stacktrace()}}
                 end,
      ?TLog("~p MFA -> R ~n ~p:~p(~p) -> ~p~n", [Transport,Mod,Fun,NewArgs,ApplyRes]),
      ?TLog("~p MF -> R ~n ~p:~p -> ~p~n", [Transport,Mod,Fun,ApplyRes]),
      send_resp(ApplyRes, Transport),
      ok. % 'ok' returned for erlimem compatibility
  
  args(R, fetch_recs_async, A, {_,_,R} = T) ->
      Args = lists:sublist(A, length(A)-1) ++ [T],
      ?TLog("fetch_recs_async, Args for TCP~n ~p~n", [Args]),
      Args;
  args(R, fetch_recs_async, A, {_,R} = T) ->
      Args = lists:sublist(A, length(A)-1) ++ [T],
      ?TLog("fetch_recs_async, Args for direct~n ~p~n", [Args]),
      Args;
  args(_, _F, A, _) ->
      ?TLog("~p(~p)~n", [_F, A]),
      A.
  
  send_resp(Resp, {Transport, Socket, Ref}) ->
      RespBin = term_to_binary({Ref, Resp}),
      ?TLog("TX (~p)~n~p~n", [byte_size(RespBin), RespBin]),
      PayloadSize = byte_size(RespBin),
      Transport:send(Socket, << PayloadSize:32, RespBin/binary >>);
  send_resp(Resp, {Pid, Ref}) when is_pid(Pid) ->
  