anchor.diff:      handle_info({tcp, Socket, Data}, State);
   handle_info(timeout, State) ->
               lager:error("Handoff receiver for partition ~p timed out after "
  -                                   "processing ~p objects.", [State#state.partition, State#state.count]),
  +                                   "processing ~p objects from ~p.", [State#state.partition, State#state.count, State#state.peer]),
       {stop, normal, State}.
   
  -process_message(?PT_MSG_INIT, MsgData, State=#state{vnode_mod=VNodeMod}) ->
  +process_message(?PT_MSG_INIT, MsgData, State=#state{vnode_mod=VNodeMod,
  +                                                    peer=Peer}) ->
       <<Partition:160/integer>> = MsgData,
  -    lager:info("Receiving handoff data for partition ~p:~p", [VNodeMod, Partition]),
  +    lager:info("Receiving handoff data for partition ~p:~p from ~p", [VNodeMod, Partition, Peer]),
       {ok, VNode} = riak_core_vnode_master:get_vnode_pid(Partition, VNodeMod),
       Data = [{mod_src_tgt, {VNodeMod, undefined, Partition}},
               {vnode_pid, VNode}],
  
positive.code: terminate(_Reason, _State) -> ok.
  
  code_change(_OldVsn, State, _Extra) -> {ok, State}.
  
negative.code:          terminate/2, code_change/3]).
  
  -record(state, {sock :: port(),
                  peer :: term(),
                  ssl_opts :: [] | list(),
                  tcp_mod :: atom(),
                  timeout_len :: non_neg_integer(),
  