anchor.diff:  -export([t_lttng_list/1,
            t_carrier_pool/1,
            t_memory_carrier/1,
  -         t_async_io_pool/1,
  -         t_driver_control_ready_async/1,
  +         t_driver_control/1,
            t_driver_start_stop/1,
            t_driver_ready_input_output/1,
            t_driver_timeout/1,
  
positive.code: t_scheduler_poll(Config) ->
      ok = lttng_start_event("org_erlang_otp:scheduler_poll", Config),
  
      ok = memory_load(),
  
      Res = lttng_stop_and_view(Config),
      ok = check_tracepoint("org_erlang_otp:scheduler_poll", Res),
  
negative.code:         passive_no_read ->
              receive die -> ok end;
          active ->
              inet:setopts(Sock, [{active, 2}, {packet,2}]),
              receive Msg1 -> io:format("msg1: ~p~n", [Msg1]) end,
              receive Msg2 -> io:format("msg2: ~p~n", [Msg2]) end,
              ok = gen_tcp:close(Sock);
          timeout ->
              Res = gen_tcp:recv(Sock, 2000, 1000),
              io:format("res ~p~n", [Res]);
          {active, Number} when is_number(Number) ->
              inet:setopts(Sock, [{active, Number}, {packet,2}]),
              [begin
                   receive _Msg1 -> Pid ! ok, io:format("msg ~p~n", [I]) end
               end || I <- lists:seq(1,Number)],
              ok = gen_tcp:close(Sock)
      end,
      Pid ! {self(), done},
      ok.
  