anchor.diff:  
   %% private 
   
  -set_port_buffers(Port, SendBufSz, RecBufSz) ->
  -    inet:setopts(Port, [{sndbuf, SendBufSz},
  -                        {recbuf, RecBufSz}]).
  +set_port_buffers(Port, SndBuf, RecBuf) ->
  +    inet:setopts(Port, [{sndbuf, SndBuf},
  +                        {recbuf, RecBuf}]).
  
positive.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) ->
  
negative.code:          }).
  
  %% provided for testing convenience and debugging.
  set_dist_buf_sizes(SndBuf, RecBuf) 
    when (is_integer(SndBuf) andalso SndBuf > 0) andalso
         (is_integer(RecBuf) andalso RecBuf > 0) ->
      gen_server:call(?MODULE, {set_dist_buf_sizes, SndBuf, RecBuf}).
  
  
  start_link() ->
  