anchor.diff:                           true                          -> inet
                         end,
               InetMod:setopts(Socket, [{active, once}]),
  -            {noreply, NewState, State#state.timeout_len}
  +            {noreply, NewState, State#state.recv_timeout_len}
       end;
   handle_info({ssl_closed, Socket}, State) ->
       handle_info({tcp_closed, Socket}, State);
  
positive.code:                 tcp_mod  = if SslOpts /= [] -> ssl;
                                true          -> gen_tcp
                             end,
                  timeout_len = app_helper:get_env(riak_core, handoff_receive_timeout, ?RECV_TIMEOUT)}}.
  
  handle_call({set_socket, Socket0}, _From, State = #state{ssl_opts = SslOpts}) ->
      SockOpts = [{active, once}, {packet, 4}, {header, 1}],
  
negative.code:     State#state{partition=Partition, vnode=VNode};
  
  process_message(?PT_MSG_BATCH, MsgData, State) ->
      lists:foldl(fun(Obj, StateAcc) -> process_message(?PT_MSG_OBJ, Obj, StateAcc) end,
                  State,
                  binary_to_term(MsgData));
  
  process_message(?PT_MSG_OBJ, MsgData, State=#state{vnode=VNode, count=Count,
                                                     vnode_timeout_len=VNodeTimeout}) ->
      Msg = {handoff_data, MsgData},
      case catch gen_fsm:sync_send_all_state_event(VNode, Msg, VNodeTimeout) of
          ok ->
              State#state{count=Count+1};
          {'EXIT', {timeout, _}} ->
              exit({error, {vnode_timeout, VNodeTimeout, size(MsgData),
                            binary:part(MsgData, {0,min(size(MsgData),128)})}});
          E={error, _} ->
              exit(E)
      end;
  