anchor.diff:      
   setup_timeout_sink(RNode, Timeout, AutoClose) ->
       Host = get_hostname(node()),
  +    ?P("[sink] create listen socket"),
       {ok, L} = gen_tcp:listen(0, [{active,             false},
                                    {packet,             2},
   				 {send_timeout,       Timeout},
  
positive.code: 			{error,Error} = timeout_sink_loop(Send),
  			Self ! {error,Error}
  		end,
      spawn_link(SenderFun),
      spawn_link(SenderFun),
  
      receive
  	{error, timeout} -> ok
      after 10000 ->
              ?P("UNEXPECTED timeout(1,~w)", [AutoClose]),
  	    exit({timeout, AutoClose})
      end,
  
      receive
  	{error, Error_1} ->
              after_send_timeout(AutoClose, Error_1)
      after 10000 ->
              ?P("UNEXPECTED timeout(2,~w)", [AutoClose]),
  	    exit({timeout, AutoClose})
      end,
  
      {error,Error_2} = gen_tcp:send(A, <<"Hej">>),
      after_send_timeout(AutoClose, Error_2),
      ok.
  
  
  
negative.code: 		     receive {Pid,X} -> X
  		     end
  	     end,
      ?P("[sink] connect from remote node (~p)", [RNode]),
      {ok, C} = Remote(fun() ->
  			     gen_tcp:connect(Host,Port,
  					     [{active,false},{packet,2}])
  		     end),
      ?P("[sink] accept"),
      {ok, A} = gen_tcp:accept(L),
      ?P("[sink] send message"),
      gen_tcp:send(A,"Hello"),
      ?P("[sink] recv message on remote node (~p)", [RNode]),
      {ok, "Hello"} = Remote(fun() -> gen_tcp:recv(C,0) end),
      ?P("[sink] done"),
      A.
  
  setup_active_timeout_sink(RNode, Timeout, AutoClose) ->
  