aboutsummaryrefslogtreecommitdiffstats
path: root/lib/observer/src/etop_txt.erl
diff options
context:
space:
mode:
authorErlang/OTP <[email protected]>2009-11-20 14:54:40 +0000
committerErlang/OTP <[email protected]>2009-11-20 14:54:40 +0000
commit84adefa331c4159d432d22840663c38f155cd4c1 (patch)
treebff9a9c66adda4df2106dfd0e5c053ab182a12bd /lib/observer/src/etop_txt.erl
downloadotp-84adefa331c4159d432d22840663c38f155cd4c1.tar.gz
otp-84adefa331c4159d432d22840663c38f155cd4c1.tar.bz2
otp-84adefa331c4159d432d22840663c38f155cd4c1.zip
The R13B03 release.OTP_R13B03
Diffstat (limited to 'lib/observer/src/etop_txt.erl')
-rw-r--r--lib/observer/src/etop_txt.erl101
1 files changed, 101 insertions, 0 deletions
diff --git a/lib/observer/src/etop_txt.erl b/lib/observer/src/etop_txt.erl
new file mode 100644
index 0000000000..d0612f15b4
--- /dev/null
+++ b/lib/observer/src/etop_txt.erl
@@ -0,0 +1,101 @@
+%%
+%% %CopyrightBegin%
+%%
+%% Copyright Ericsson AB 2002-2009. All Rights Reserved.
+%%
+%% The contents of this file are subject to the Erlang Public License,
+%% Version 1.1, (the "License"); you may not use this file except in
+%% compliance with the License. You should have received a copy of the
+%% Erlang Public License along with this software. If not, it can be
+%% retrieved online at http://www.erlang.org/.
+%%
+%% Software distributed under the License is distributed on an "AS IS"
+%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+%% the License for the specific language governing rights and limitations
+%% under the License.
+%%
+%% %CopyrightEnd%
+%%
+-module(etop_txt).
+-author('[email protected]').
+
+%%-compile(export_all).
+-export([init/1,stop/1]).
+-export([do_update/3]).
+
+-include("etop.hrl").
+-include("etop_defs.hrl").
+
+-import(etop,[loadinfo/1,meminfo/2]).
+-import(etop_gui,[formatmfa/1,to_list/1]).
+
+-define(PROCFORM,"~-15w~-20s~8w~8w~8w~8w ~-20s~n").
+
+stop(Pid) -> Pid ! stop.
+
+init(Config) ->
+ loop(Config).
+
+loop(Config) ->
+ Info = do_update(Config),
+ receive
+ stop -> stopped;
+ {dump,Fd} -> do_update(Fd,Info,Config), loop(Config);
+ {config,_,Config1} -> loop(Config1)
+ after Config#opts.intv -> loop(Config)
+ end.
+
+do_update(Config) ->
+ Info = etop:update(Config),
+ do_update(standard_io,Info,Config).
+
+do_update(Fd,Info,Config) ->
+ {Cpu,NProcs,RQ,Clock} = loadinfo(Info),
+ io:nl(Fd),
+ writedoubleline(Fd),
+ case Info#etop_info.memi of
+ undefined ->
+ io:fwrite(Fd, " ~-72w~10s~n"
+ " Load: cpu ~8w~n"
+ " procs~8w~n"
+ " runq ~8w~n",
+ [Config#opts.node,Clock,
+ Cpu,NProcs,RQ]);
+ Memi ->
+ [Tot,Procs,Atom,Bin,Code,Ets] =
+ meminfo(Memi, [total,processes,atom,binary,code,ets]),
+ io:fwrite(Fd, ?SYSFORM,
+ [Config#opts.node,Clock,
+ Cpu,Tot,Bin,
+ NProcs,Procs,Code,
+ RQ,Atom,Ets])
+ end,
+ io:nl(Fd),
+ writepinfo_header(Fd),
+ writesingleline(Fd),
+ writepinfo(Fd,Info#etop_info.procinfo),
+ writedoubleline(Fd),
+ io:nl(Fd),
+ Info.
+
+writepinfo_header(Fd) ->
+ io:fwrite(Fd,"Pid Name or Initial Func Time Reds Memory MsgQ Current Function~n",[]).
+
+writesingleline(Fd) ->
+ io:fwrite(Fd,"----------------------------------------------------------------------------------------~n",[]).
+writedoubleline(Fd) ->
+ io:fwrite(Fd,"========================================================================================~n",[]).
+
+writepinfo(Fd,[#etop_proc_info{pid=Pid,
+ mem=Mem,
+ reds=Reds,
+ name=Name,
+ runtime=Time,
+ cf=MFA,
+ mq=MQ}
+ |T]) ->
+ io:fwrite(Fd,?PROCFORM,[Pid,to_list(Name),Time,Reds,Mem,MQ,formatmfa(MFA)]),
+ writepinfo(Fd,T);
+writepinfo(_Fd,[]) ->
+ ok.
+