anchor.diff:              %%reconnect
               set_socket(State, notconnected);
           _ ->
  -            {_, MQL} = process_info(self(), message_queue_len),
  -            QL = msg_queue_len(State),
  -            case QL of
  +            case msg_queue_len(State) of
                   0 ->
  -                    if MQL > 4 ->
  +                    {_, MQL} = process_info(self(), message_queue_len),
  +                    if MQL > 5 ->
                               %% start message bundle for sending
                               %% io:format("MQL ~p~n", [MQL]),
                               T1 = set_msg_queue(State, [{DestPid, Message}]),
  -                            T2 = set_msg_queue_len(T1, QL + 1),
  +                            T2 = set_msg_queue_len(T1, 1),
                               set_desired_bundle_size(T2, util:min(MQL,200));
                          true ->
                               NewSocket =
  
positive.code:             fail
      end.
  
  -spec state_new(DestIP::inet:ip_address(), DestPort::comm_server:tcp_port(),
                  LocalListenPort::comm_server:tcp_port(),
                  Socket::inet:socket() | notconnected) -> state().
  
negative.code:                 ok = inet:setopts(Socket, [{active, once}]),
                  State
      end,
      send_bundle_if_ready(NewState);
  
  on({tcp_closed, Socket}, State) ->
      log:log(warn,"[ CC ] tcp closed info", []),
  