observer: cdv add scheduler information

New info in 18.

1 files changed, 111 insertions, 7 deletions

diff --git a/lib/observer/src/crashdump_viewer.erl b/lib/observer/src/crashdump_viewer.erl
index 0d7ad47ef4..007fc74279 100644
--- a/lib/observer/src/crashdump_viewer.erl
+++ b/lib/observer/src/crashdump_viewer.erl
@@ -63,6 +63,7 @@
 	 allocator_info/0,
 	 hash_tables/0,
 	 index_tables/0,
+	 schedulers/0,
 	 expand_binary/1]).
 
 %% Library function
@@ -114,6 +115,7 @@
 -define(proc_heap,proc_heap).
 -define(proc_messages,proc_messages).
 -define(proc_stack,proc_stack).
+-define(scheduler,scheduler).
 -define(timer,timer).
 -define(visible_node,visible_node).
 
@@ -267,6 +269,8 @@ hash_tables() ->
     call(hash_tables).
 index_tables() ->
     call(index_tables).
+schedulers() ->
+    call(schedulers).
 
 %%%-----------------------------------------------------------------
 %%% Called when a link to a process (Pid) is clicked.
@@ -431,7 +435,11 @@ handle_call(hash_tables,_From,State=#state{file=File}) ->
 handle_call(index_tables,_From,State=#state{file=File}) ->
     IndexTables=index_tables(File),
     TW = truncated_warning([?hash_table,?index_table]),
-    {reply,{ok,IndexTables,TW},State}.
+    {reply,{ok,IndexTables,TW},State};
+handle_call(schedulers,_From,State=#state{file=File}) ->
+    Schedulers=schedulers(File),
+    TW = truncated_warning([?scheduler]),
+    {reply,{ok,Schedulers,TW},State}.
 
 
 
@@ -677,9 +685,11 @@ skip(Fd,<<>>) ->
 
 
 val(Fd) ->
+    val(Fd, "-1").
+val(Fd, NoExist) ->
     case get_rest_of_line(Fd) of
-	{eof,[]} -> "-1";
-	[] -> "-1";
+	{eof,[]} -> NoExist;
+	[] -> NoExist;
 	{eof,Val} -> Val;
 	Val -> Val
     end.
@@ -967,6 +977,8 @@ get_general_info(Fd,GenInfo) ->
 	    get_general_info(Fd,GenInfo#general_info{taints=Val});
 	"Atoms" ->
 	    get_general_info(Fd,GenInfo#general_info{num_atoms=val(Fd)});
+	"Calling Thread" ->
+	    get_general_info(Fd,GenInfo#general_info{thread=val(Fd)});
 	"=" ++ _next_tag ->
 	    GenInfo;
 	Other ->
@@ -1135,6 +1147,8 @@ all_procinfo(Fd,Fun,Proc,WS,LineHead) ->
 	    get_procinfo(Fd,Fun,Proc#proc{arity=Arity--"\r\n"},WS);
 	"Run queue" ->
 	    get_procinfo(Fd,Fun,Proc#proc{run_queue=val(Fd)},WS);
+	"Internal State" ->
+	    get_procinfo(Fd,Fun,Proc#proc{int_state=val(Fd)},WS);
 	"=" ++ _next_tag ->
 	    Proc;
 	Other ->
@@ -1238,17 +1252,23 @@ maybe_other_node(Id) ->
 	    {"<" ++ N, _Rest} ->
 		N;
 	    {"#Port<" ++ N, _Rest} ->
-		N
+		N;
+	    {_, []} ->
+		not_found
 	end,
+    maybe_other_node2(Channel).
+
+maybe_other_node2(not_found) -> not_found;
+maybe_other_node2(Channel) ->
     Ms = ets:fun2ms(
-	   fun({{Tag,Start},Ch}) when Tag=:=?visible_node, Ch=:=Channel -> 
+	   fun({{Tag,Start},Ch}) when Tag=:=?visible_node, Ch=:=Channel ->
 		   {"Visible Node",Start};
 	      ({{Tag,Start},Ch}) when Tag=:=?hidden_node, Ch=:=Channel ->
 		   {"Hidden Node",Start};
-	      ({{Tag,Start},Ch}) when Tag=:=?not_connected, Ch=:=Channel -> 
+	      ({{Tag,Start},Ch}) when Tag=:=?not_connected, Ch=:=Channel ->
 		   {"Not Connected Node",Start}
 	   end),
-    
+
     case ets:select(cdv_dump_index_table,Ms) of
 	[] ->
 	    not_found;
@@ -2303,6 +2323,89 @@ get_indextableinfo1(Fd,IndexTable) ->
 	    IndexTable
     end.
 
+
+%%-----------------------------------------------------------------
+%% Page with scheduler table information
+schedulers(File) ->
+    case lookup_index(?scheduler) of
+	[] ->
+	    [];
+	Schedulers ->
+	    Fd = open(File),
+	    R = lists:map(fun({Name,Start}) ->
+				  get_schedulerinfo(Fd,Name,Start)
+			  end,
+			  Schedulers),
+	    close(Fd),
+	    R
+    end.
+
+get_schedulerinfo(Fd,Name,Start) ->
+    pos_bof(Fd,Start),
+    get_schedulerinfo1(Fd,#sched{name=Name}).
+
+get_schedulerinfo1(Fd,Sched=#sched{details=Ds}) ->
+    case line_head(Fd) of
+	"Current Process" ->
+	    get_schedulerinfo1(Fd,Sched#sched{process=val(Fd, "None")});
+	"Current Port" ->
+	    get_schedulerinfo1(Fd,Sched#sched{port=val(Fd, "None")});
+	"Run Queue Max Length" ->
+	    RQMax = list_to_integer(val(Fd)),
+	    RQ = RQMax + Sched#sched.run_q,
+	    get_schedulerinfo1(Fd,Sched#sched{run_q=RQ, details=Ds#{runq_max=>RQMax}});
+	"Run Queue High Length" ->
+	    RQHigh = list_to_integer(val(Fd)),
+	    RQ = RQHigh + Sched#sched.run_q,
+	    get_schedulerinfo1(Fd,Sched#sched{run_q=RQ, details=Ds#{runq_high=>RQHigh}});
+	"Run Queue Normal Length" ->
+	    RQNorm = list_to_integer(val(Fd)),
+	    RQ = RQNorm + Sched#sched.run_q,
+	    get_schedulerinfo1(Fd,Sched#sched{run_q=RQ, details=Ds#{runq_norm=>RQNorm}});
+	"Run Queue Low Length" ->
+	    RQLow = list_to_integer(val(Fd)),
+	    RQ = RQLow + Sched#sched.run_q,
+	    get_schedulerinfo1(Fd,Sched#sched{run_q=RQ, details=Ds#{runq_low=>RQLow}});
+	"Run Queue Port Length" ->
+	    RQ = list_to_integer(val(Fd)),
+	    get_schedulerinfo1(Fd,Sched#sched{port_q=RQ});
+
+	"Scheduler Sleep Info Flags" ->
+	    get_schedulerinfo1(Fd,Sched#sched{details=Ds#{sleep_info=>val(Fd, "None")}});
+	"Scheduler Sleep Info Aux Work" ->
+	    get_schedulerinfo1(Fd,Sched#sched{details=Ds#{sleep_aux=>val(Fd, "None")}});
+
+	"Run Queue Flags" ->
+	    get_schedulerinfo1(Fd,Sched#sched{details=Ds#{runq_flags=>val(Fd, "None")}});
+
+	"Current Process State" ->
+	    get_schedulerinfo1(Fd,Sched#sched{details=Ds#{currp_state=>val(Fd)}});
+	"Current Process Internal State" ->
+	    get_schedulerinfo1(Fd,Sched#sched{details=Ds#{currp_int_state=>val(Fd)}});
+	"Current Process Program counter" ->
+	    get_schedulerinfo1(Fd,Sched#sched{details=Ds#{currp_prg_cnt=>val(Fd)}});
+	"Current Process CP" ->
+	    get_schedulerinfo1(Fd,Sched#sched{details=Ds#{currp_cp=>val(Fd)}});
+	"Current Process Limited Stack Trace" ->
+	    %% If there shall be last in scheduler information block
+	    Sched#sched{details=get_limited_stack(Fd, 0, Ds)};
+	"=" ++ _next_tag ->
+	    Sched;
+	Other ->
+	    unexpected(Fd,Other,"scheduler information"),
+	    Sched
+    end.
+
+get_limited_stack(Fd, N, Ds) ->
+    case val(Fd) of
+	Addr = "0x" ++ _ ->
+	    get_limited_stack(Fd, N+1, Ds#{{currp_stack, N} => Addr});
+	"=" ++ _next_tag ->
+	    Ds;
+	Line ->
+	    get_limited_stack(Fd, N+1, Ds#{{currp_stack, N} => Line})
+    end.
+
 %%%-----------------------------------------------------------------
 %%% Parse memory in crashdump version 0.1 and newer
 %%%
@@ -2605,6 +2708,7 @@ tag_to_atom("proc_dictionary") -> ?proc_dictionary;
 tag_to_atom("proc_heap") -> ?proc_heap;
 tag_to_atom("proc_messages") -> ?proc_messages;
 tag_to_atom("proc_stack") -> ?proc_stack;
+tag_to_atom("scheduler") -> ?scheduler;
 tag_to_atom("timer") -> ?timer;
 tag_to_atom("visible_node") -> ?visible_node;
 tag_to_atom(UnknownTag) ->