anchor.diff:  
   %% private 
   
  -set_port_buffers(Port) ->
  -    {ok, SndBufSz} = application:get_env(riak_core, dist_send_buf_size),
  -    {ok, RecBufSz} = application:get_env(riak_core, dist_recv_buf_size),
  -    inet:setopts(Port, [{sndbuf, SndBufSz},
  +set_port_buffers(Port, SendBufSz, RecBufSz) ->
  +    inet:setopts(Port, [{sndbuf, SendBufSz},
                           {recbuf, RecBufSz}]).
  
positive.code: 
  -module(riak_core_dist_mon).
  
  -export([start_link/0, set_dist_buf_sizes/2]).
  
  %% gen_server callbacks
  -behavior(gen_server).
  -export([init/1, handle_call/3, handle_cast/2, handle_info/2,
           terminate/2, code_change/3]).
  
  -record(state, {}).
  
  %% provided for testing convenience and debugging.
  set_dist_buf_sizes(SendSz, RecvSz) 
  
negative.code:     {noreply, State}.
  
  
  handle_info({nodeup, Node, _InfoList}, #state{sndbuf=SendBufSz,
                                                recbuf=RecBufSz} = 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),
              {noreply, State}
      end;
  handle_info({nodedown, _Node, _InfoList}, State) ->
  