diff options
| author | Siri Hansen <[email protected]> | 2016-09-27 10:56:19 +0200 |
|---|---|---|
| committer | Siri Hansen <[email protected]> | 2016-09-27 10:56:19 +0200 |
| commit | be58aad8ef594f08b4cbe8da876a7977abb3ab3f (patch) | |
| tree | 1dfa6e5c87a151e56da23b8e8454f8396f45ca24 /lib/observer/src/ttb.erl | |
| parent | 504e93b8c7bfd5d59aa14beaee380c32545b5de1 (diff) | |
| parent | cf7220cd933a7b7efbb79c2b8458b21ff047d863 (diff) | |
| download | otp-be58aad8ef594f08b4cbe8da876a7977abb3ab3f.tar.gz otp-be58aad8ef594f08b4cbe8da876a7977abb3ab3f.tar.bz2 otp-be58aad8ef594f08b4cbe8da876a7977abb3ab3f.zip | |
Merge branch 'maint'
Diffstat (limited to 'lib/observer/src/ttb.erl')
| -rw-r--r-- | lib/observer/src/ttb.erl | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/lib/observer/src/ttb.erl b/lib/observer/src/ttb.erl index ac6c4572eb..87a50e046b 100644 --- a/lib/observer/src/ttb.erl +++ b/lib/observer/src/ttb.erl @@ -78,6 +78,11 @@ do_tracer(Nodes0,PI,Client,Traci) -> do_tracer(Clients,PI,Traci) -> Shell = proplists:get_value(shell, Traci, false), + IpPortSpec = + case proplists:get_value(queue_size, Traci) of + undefined -> 0; + QS -> {0,QS} + end, DefShell = fun(Trace) -> dbg:dhandler(Trace, standard_io) end, {ClientSucc,Succ} = lists:foldl( @@ -98,7 +103,7 @@ do_tracer(Clients,PI,Traci) -> [_,H] = string:tokens(atom_to_list(N),"@"), H end, - case catch dbg:tracer(N,port,dbg:trace_port(ip,0)) of + case catch dbg:tracer(N,port,dbg:trace_port(ip,IpPortSpec)) of {ok,N} -> {ok,Port} = dbg:trace_port_control(N,get_listen_port), {ok,T} = dbg:get_tracer(N), @@ -160,6 +165,8 @@ opt([{resume,MSec}|O],{PI,Client,Traci}) -> opt(O,{PI,Client,[{resume, {true, MSec}}|Traci]}); opt([{flush,MSec}|O],{PI,Client,Traci}) -> opt(O,{PI,Client,[{flush, MSec}|Traci]}); +opt([{queue_size,QueueSize}|O],{PI,Client,Traci}) -> + opt(O,{PI,Client,[{queue_size,QueueSize}|Traci]}); opt([],Opt) -> ensure_opt(Opt). |