anchor.diff:  
   setup_active_timeout_sink(Config, RNode, Timeout, AutoClose) ->
       Host = get_hostname(node()),
  -    ListenOpts =  [binary,{active,false},{packet,0},
  -		   {nodelay,true},{keepalive,true},
  -		   {send_timeout,Timeout},{send_timeout_close,AutoClose}],
  +    ListenOpts =  [binary,
  +		   {active,             false},
  +		   {packet,             0},
  +		   {nodelay,            true},
  +		   {keepalive,          true},
  +		   {send_timeout,       Timeout},
  +		   {send_timeout_close, AutoClose}],
       {ok, L} = ?LISTEN(Config, 0, ListenOpts),
       Fun = fun(F) ->
   		  receive
  
positive.code:     ?P("[sink] connect from remote node (~p)", [RNode]),
      {ok, C} = Remote(fun() ->
  			     ?CONNECT(Config, Host,Port,
  				      [{active,false},{packet,2}])
  		     end),
      ?P("[sink] accept"),
      {ok, A} = gen_tcp:accept(L),
  
negative.code:     {Pid, Mon} = spawn_monitor(
                     fun() ->
                             {A, _} = setup_timeout_sink(Config,
  						       RNode, 1000,
  						       true, SndBuf),
                             Send = fun() ->
                                            Res = gen_tcp:send(A, BinData),
                                            Self ! Res,
  