anchor.diff:      {noreply, State}.
   
   
  -handle_info({nodeup, Node, _InfoList}, 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),
  +            set_port_buffers(Port, SendBufSz, RecBufSz),
               {noreply, State}
       end;
   handle_info({nodedown, _Node, _InfoList}, State) ->
  
positive.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]),
      DistCtrl = erlang:system_info(dist_ctrl),
      %% make sure that buffers are correct on existing connections.
      [set_port_buffers(Port)
       || {_Node, Port} <- DistCtrl],
      {ok, #state{}}.
  
  
  
  handle_call({set_dist_buf_sizes, SendSz, RecvSz}, _From, State) ->
      Reply = 
          [inet:setopts(Port, [{sndbuf, SendSz}, {recbuf, RecvSz}])
           || {_Node, Port} <- erlang:system_info(dist_ctrl)],
      {reply, Reply, State};
  handle_call(Msg, _From, State) ->
      lager:warning("unknown call message received: ~p", [Msg]),
      {noreply, State}.
  
negative.code: 
  %% private 
  
  set_port_buffers(Port, SendBufSz, RecBufSz) ->
      inet:setopts(Port, [{sndbuf, SendBufSz},
                          {recbuf, RecBufSz}]).
  