anchor.diff:  
   start_fold(TargetNode, Module, {Type, Opts}, ParentPid, SslOpts) ->
       SrcNode = node(),
  +    SrcPartition = get_src_partition(Opts),
  +    TargetPartition = get_target_partition(Opts),
   
        try
  -         SrcPartition = get_src_partition(Opts),
  -         TargetPartition = get_target_partition(Opts),
            Filter = get_filter(Opts),
            [_Name,Host] = string:tokens(atom_to_list(TargetNode), "@"),
            {ok, Port} = get_handoff_port(TargetNode),
  
positive.code:          exit:{shutdown, timeout} ->
               %% A receive timeout during handoff
               riak_core_stat:update(handoff_timeouts),
               log_fail(Module, {Type, Opts}, SrcNode, TargetNode,
                        " because of TCP recv timeout");
           Err:Reason ->
               ReasonStr3 = io_lib:format(" because of ~p:~p ~p",
                                          [Err, Reason, erlang:get_stacktrace()]),
               log_fail(Module, {Type, Opts}, SrcNode, TargetNode, ReasonStr3),
               gen_fsm:send_event(ParentPid, {handoff_error, Err, Reason})
       end.
  
  
negative.code: get_status_interval() ->
      app_helper:get_env(riak_core, handoff_status_interval, ?STATUS_INTERVAL).
  
  get_src_partition(Opts) ->
      proplists:get_value(src_partition, Opts).
  
  