anchor.diff:              State2 = State
       end,
   
  +    Mailbox2 = case Mailbox =< Threshold of
  +                   true ->
  +                       Pid ! Msg,
  +                       Mailbox + 1;
  +                   false ->
  +                       handle_overload(Msg, State),
  +                       Mailbox
  +               end,
  +
       Counter2 = Counter + 1,
       case Counter2 of
           RequestInterval ->
  
positive.code:              exit(ProxyPid, kill)
       end,
       [
        %% TODO: Fix after refactoring
        %% fun({_VnodePid, ProxyPid}) ->
        %%         {"should not discard in normal operation", timeout, 60,
        %%          fun() ->
        %%                  ToSend = ?DEFAULT_OVERLOAD_THRESHOLD-2,
        %%                  [ProxyPid ! hello || _ <- lists:seq(1, ToSend)],
        %%                  %% synchronize on the mailbox
        %%                  ProxyPid ! {get_count, self()},
        %%                  receive
        %%                      {count, Count} ->
        %%                          %% ToSend messages + 1 unanswered vnode_proxy_ping
        %%                          ?assertEqual(ToSend+1, Count)
        %%                  end
        %%          end
        %%         }
        %% end,
        fun({VnodePid, ProxyPid}) ->
                {"should discard during overflow", timeout, 60,
                 fun() ->
                         VnodePid ! block,
                         [ProxyPid ! hello || _ <- lists:seq(1, 50000)],
                         %% synchronize on the mailbox
                         Reply = gen:call(ProxyPid, '$vnode_proxy_call', sync, infinity),
                         ?assertEqual({ok, ok}, Reply),
                         VnodePid ! unblock,
  
negative.code:                fun() ->
                         VnodePid ! slow,
                         [ProxyPid ! hello || _ <- lists:seq(1, 50000)],
                         %% synchronize on the mailbox - no-op that hits msg catchall
                         Reply = gen:call(ProxyPid, '$vnode_proxy_call', sync, infinity),
                         ?assertEqual({ok, ok}, Reply),
                         %% check that the outstanding message count is
  