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:                 peer :: term(),
                  ssl_opts :: [] | list(),
                  tcp_mod :: atom(),
                  timeout_len :: non_neg_integer(),
                  partition :: non_neg_integer(),
                  vnode_mod = riak_kv_vnode:: module(),
                  vnode :: pid(),
                  count = 0 :: non_neg_integer()}).
  
  %% set the timeout to five minutes to be conservative.
  -define(RECV_TIMEOUT, 300000).
  
  start_link() ->
      start_link([]).
  
negative.code:                 tcp_mod  = if SslOpts /= [] -> ssl;
                                true          -> gen_tcp
                             end,
                  recv_timeout_len = app_helper:get_env(riak_core, handoff_receive_timeout, ?RECV_TIMEOUT),
                  vnode_timeout_len = app_helper:get_env(riak_core, handoff_receive_vnode_timeout, ?VNODE_TIMEOUT)}}.
  
  handle_call({set_socket, Socket0}, _From, State = #state{ssl_opts = SslOpts}) ->
      SockOpts = [{active, once}, {packet, 4}, {header, 1}],
  