anchor.diff:      {noreply, State}.
   
   
  -handle_info({nodeup, Node, _InfoList}, #state{sndbuf=SendBufSz,
  -                                              recbuf=RecBufSz} = State) ->
  +handle_info({nodeup, Node, _InfoList}, #state{sndbuf=SndBuf,
  +                                              recbuf=RecBuf} = State) ->
       DistCtrl = erlang:system_info(dist_ctrl),
       case proplists:get_value(Node, DistCtrl) of
           undefined ->
               lager:error("Could not get dist for ~p\n~p\n", [Node, DistCtrl]),
               {noreply, State};
           Port ->
  -            set_port_buffers(Port, SendBufSz, RecBufSz),
  +            set_port_buffers(Port, SndBuf, RecBuf),
               {noreply, State}
       end;
   handle_info({nodedown, _Node, _InfoList}, State) ->
  
positive.code: 
  %% private 
  
  set_port_buffers(Port, SendBufSz, RecBufSz) ->
      inet:setopts(Port, [{sndbuf, SendBufSz},
                          {recbuf, RecBufSz}]).
  
negative.code:     %% register for monitor events so we can adjust buffers on 
      %% new connections when they're started.
      ok = net_kernel:monitor_nodes(true, [{node_type, visible}, nodedown_reason]),
      {SndBuf, RecBuf} = get_riak_env_vars(),
      DistCtrl = erlang:system_info(dist_ctrl),
      %% make sure that buffers are correct on existing connections.
      [set_port_buffers(Port, SndBuf, RecBuf)
       || {_Node, Port} <- DistCtrl],
      {ok, #state{sndbuf=SndBuf, recbuf=RecBuf}}.
  
  get_riak_env_vars() ->
      {ok, SndBuf} = application:get_env(riak_core, dist_send_buf_size),
      {ok, RecBuf} = application:get_env(riak_core, dist_recv_buf_size),
      {SndBuf, RecBuf}.
  
  handle_call({set_dist_buf_sizes, SndBuf, RecBuf}, _From, State) ->
      [set_port_buffers(Port, SndBuf, RecBuf)
       || {_Node, Port} <- erlang:system_info(dist_ctrl)],
      {reply, ok, State#state{sndbuf=SndBuf, recbuf=RecBuf}};
  handle_call(Msg, _From, State) ->
      lager:warning("unknown call message received: ~p", [Msg]),
      {noreply, State}.
  