anchor.diff:      Reply =  [I || {M, I} <- ordsets:to_list(Excl), M =:= Module],
       {reply, {ok, Reply}, State};
   handle_call({add_outbound,Mod,Idx,Node,Pid},_From,State=#state{handoffs=HS}) ->
  -    ShouldStart=enqueue_handoff(Mod,Idx,Node,Pid,HS),
  -    case ShouldStart andalso send_handoff(Mod,Idx,Node,Pid) of
  +    case send_handoff(Mod,Idx,Node,Pid,HS) of
           {ok,Handoff=#handoff_status{transport_pid=Sender}} ->
               {reply,{ok,Sender},State#state{handoffs=HS ++ [Handoff]}};
           Error ->
  
positive.code:                     normal ->
                          false;
                      max_concurrency ->
                          lager:info("An ~w handoff of partition ~w ~w was terminated for reason: ~w~n", [Dir,Mod,Index,Reason]),
                          true;
                      _ ->
                          lager:error("An ~w handoff of partition ~w ~w was terminated for reason: ~w~n", [Dir,Mod,Index,Reason]),
                          true
                  end,
  
              %% if we have the vnode process pid, tell the vnode why the
              %% handoff stopped so it can clean up its state
              case WarnVnode andalso H#handoff_status.vnode_pid of
                  Vnode when is_pid(Vnode) ->
                      riak_core_vnode:handoff_error(Vnode,'DOWN',Reason);
                  _ ->
                      ok
  
negative.code: 
  -type mod()   :: atom().
  -type index() :: integer().
  
  -record(handoff_status,
          { modindex      :: {mod(),index()},
            node          :: atom(),
            direction     :: inbound | outbound,
            transport_pid :: pid(),
            timestamp     :: tuple(),
  