anchor.diff:                              T1 = set_socket(State, NewSocket),
                               inc_s_msg_count(T1)
                       end;
  -                _ ->
  -                    case QL >= desired_bundle_size(State) orelse 0 =:= MQL of
  +                QL ->
  +                    DBS = desired_bundle_size(State),
  +                    MSBS = msgs_since_bundle_start(State),
  +                    case (QL + MSBS) >= DBS of
                           true ->
                               MQueue = [{DestPid, Message} | msg_queue(State)],
  +%%                            io:format("Bundle Size: ~p~n", [length(MQueue)]),
                               NewSocket =
                                   send({dest_ip(State), dest_port(State), Socket},
                                        unpack_msg_bundle, MQueue),
                               T1State = set_socket(State, NewSocket),
                               T2State = inc_s_msg_count(T1State),
                               T3State = set_msg_queue(T2State, []),
  -                            _T4State = set_msg_queue_len(T3State, 0);
  +                            T4State = set_msg_queue_len(T3State, 0),
  +                            _T5State = set_msgs_since_bundle_start(T4State,0);
                           false ->
                               %% add to message bundle
                               T1 = set_msg_queue(State, [{DestPid, Message}
  
positive.code: set_msg_queue_len(State, Val) -> setelement(9, State, Val).
  desired_bundle_size(State)    -> element(10, State).
  set_desired_bundle_size(State, Val) -> setelement(10, State, Val).
  
  status(State) ->
       case socket(State) of
  
negative.code:     {DestIP, DestPort, LocalListenPort, Socket,
       _StartTime = erlang:now(), _SentMsgCount = 0,
       _ReceivedMsgCount = 0, _MsgQueue = [], _Len = 0,
      _DesiredBundleSize = 0, _MsgsSinceBundleStart = 0}.
  
  dest_ip(State)                -> element(1, State).
  dest_port(State)              -> element(2, State).
  