Merge pull request #170 from klacke/klacke/conn_controlling_process

Bug with controlling_process for Connection

test/example/p_connect.lux

@@ -0,0 +1,19 @@
+
+[global fail_pattern=[Ee][Rr][Rr][Oo][Rr]]
+[global eprompt=\(s|c@.*\)\d*>]
+
+[shell server]
+    !erl -sname s -pa ../../_build/default/lib/quicer/ebin -s qt s
+    ?$eprompt
+
+
+[shell client]
+    !erl -sname c -pa ../../_build/default/lib/quicer/ebin
+    ?$eprompt
+    !qt:c().
+    ?-->
+    !p_connect.
+    ?Connection \# 1
+    ?-->
+    !{stream, 1}.
+    ?Stream

test/example/qt.erl

@@ -202,6 +202,31 @@ client(Conns, Streams, CNo, SNo) ->
              end, lists:seq(CNo, CNo+N-1)),
       client(CC ++ Conns, Streams, CNo+N, SNo);
 
+    {ok, p_connect} ->
+      %% Use controlling process
+      Self = self(),
+      _P = proc_lib:spawn_link(
+            fun() ->
+                case quicer:connect("localhost", Port, c_opts(), 5000) of
+                  {ok, Conn} ->
+                    ok = quicer:controlling_process(Conn, Self),
+                    timer:sleep(400),
+                    Self ! {connection, Conn};
+                  Err ->
+                    Self ! {connection_err, Err}
+                end
+            end),
+      receive
+        {connection, Conn} ->
+          io:format("Connection # ~p~n", [CNo]),
+          client([{Conn, CNo} | Conns], Streams, CNo+1, SNo);
+
+        {connection_err, Err} ->
+          io:format("Failed to connect ~p~n", [Err]),
+          client(Conns, Streams, CNo, SNo)
+      end;
+
+
     {ok, {connect_stream, N}} ->
       %% Create N connections, with a stream associated to each conn
       L = lists:map(