2 d89ce51a 2005-02-11 devnull // pthread-specific access functions
3 d89ce51a 2005-02-11 devnull // avoid complicated libthread_db interface
6 2a931b72 2005-02-11 devnull include("pthread-"+systype+"-"+objtype);
8 d89ce51a 2005-02-11 devnull // pick apart system mcontext_t structures
9 d89ce51a 2005-02-11 devnull defn mcontext(m)
11 d89ce51a 2005-02-11 devnull complex mcontext_t m;
13 d89ce51a 2005-02-11 devnull if systype == "linux" then {
15 d89ce51a 2005-02-11 devnull return {"PC", m[14], "SP", m[7], "BP", m[6]};
16 d89ce51a 2005-02-11 devnull } else if systype == "freebsd" then {
17 d89ce51a 2005-02-11 devnull return {"PC", m.mc_eip, "SP", m.mc_esp, "BP", m.mc_ebp};
19 d89ce51a 2005-02-11 devnull error("do not know how to read mcontext_t on system "+systype);
23 d89ce51a 2005-02-11 devnull // plan 9 thread library support
25 d89ce51a 2005-02-11 devnull defn context(c)
27 d89ce51a 2005-02-11 devnull c = (Context)c;
28 d89ce51a 2005-02-11 devnull return mcontext(c.uc.uc_mcontext);
31 d89ce51a 2005-02-11 devnull defn contextstk(c)
33 d89ce51a 2005-02-11 devnull _stk(context(c), 0);
36 d89ce51a 2005-02-11 devnull defn contextlstk(c)
38 d89ce51a 2005-02-11 devnull _stk(context(c), 1);
41 0a61c07d 2004-04-19 devnull defn altfmt(A){
42 0a61c07d 2004-04-19 devnull local i, s, yes;
43 0a61c07d 2004-04-19 devnull complex Alt A;
45 0a61c07d 2004-04-19 devnull s = "alt(";
46 2a931b72 2005-02-11 devnull s = s + "tag(*" + itoa(A.tag, "%#x") + "=" + itoa(*A.tag, "%#x") + ") ";
49 0a61c07d 2004-04-19 devnull while A.op != CHANEND && A.op != CHANNOBLK do{
50 0a61c07d 2004-04-19 devnull if A.op != CHANNOP then{
51 0a61c07d 2004-04-19 devnull if yes then s = s + " ";
52 0a61c07d 2004-04-19 devnull s = s + itoa(i, "%d");
53 0a61c07d 2004-04-19 devnull s = s + ":";
54 0a61c07d 2004-04-19 devnull if A.op == CHANSND then s = s + "send";
55 0a61c07d 2004-04-19 devnull if A.op == CHANRCV then s = s + "recv";
56 0a61c07d 2004-04-19 devnull s = s + "(channel(";
57 2a931b72 2005-02-11 devnull s = s + itoa(A.c, "%#x");
58 0a61c07d 2004-04-19 devnull s = s + "))";
61 0a61c07d 2004-04-19 devnull i = i + 1;
62 0a61c07d 2004-04-19 devnull A = (Alt)(A + sizeofAlt);
64 0a61c07d 2004-04-19 devnull if A.op==CHANNOBLK then{
65 0a61c07d 2004-04-19 devnull if yes then s = s + " ";
66 0a61c07d 2004-04-19 devnull s = s + "noblock";
68 0a61c07d 2004-04-19 devnull s = s + ")";
69 0a61c07d 2004-04-19 devnull return s;
72 0a61c07d 2004-04-19 devnull defn alt(A){
73 0a61c07d 2004-04-19 devnull print(altfmt(A), "\n");
76 d89ce51a 2005-02-11 devnull defn channel(C) {
77 d89ce51a 2005-02-11 devnull complex Channel C;
78 d89ce51a 2005-02-11 devnull local i, p;
80 d89ce51a 2005-02-11 devnull print("channel ", C\X, " // ", *(C.name\s));
81 d89ce51a 2005-02-11 devnull if C.freed then {
82 d89ce51a 2005-02-11 devnull print(" (moribund)");
84 d89ce51a 2005-02-11 devnull print("\n");
85 d89ce51a 2005-02-11 devnull print("\telemsize=", C.elemsize\D, " bufsize=", C.bufsize, "\n");
86 d89ce51a 2005-02-11 devnull if C.bufsize then {
87 d89ce51a 2005-02-11 devnull print("\t", C.nbuf\D, " values in channel:\n");
88 d89ce51a 2005-02-11 devnull print("\t");
89 d89ce51a 2005-02-11 devnull p = C.buf+C.off*C.elemsize;
90 d89ce51a 2005-02-11 devnull loop 1,C.nbuf do {
91 d89ce51a 2005-02-11 devnull if C.elemsize==4 then {
92 d89ce51a 2005-02-11 devnull print(*p\X, " ");
94 d89ce51a 2005-02-11 devnull print("data(", p\X, ") ");
96 d89ce51a 2005-02-11 devnull p = p+C.elemsize;
97 d89ce51a 2005-02-11 devnull if p == C.buf+C.bufsize*C.elemsize then {
98 d89ce51a 2005-02-11 devnull p = C.buf;
102 d89ce51a 2005-02-11 devnull print("\n");
103 d89ce51a 2005-02-11 devnull print(" senders:\n");
104 d89ce51a 2005-02-11 devnull _altarray(C.asend);
105 d89ce51a 2005-02-11 devnull print(" recvers:\n");
106 d89ce51a 2005-02-11 devnull _altarray(C.arecv);
109 d89ce51a 2005-02-11 devnull defn _altarray(aa)
111 d89ce51a 2005-02-11 devnull local i, a, t;
114 d89ce51a 2005-02-11 devnull aa = (_Altarray)aa;
115 d89ce51a 2005-02-11 devnull while i < aa.n do {
116 d89ce51a 2005-02-11 devnull a = (Alt)aa.a[i];
117 d89ce51a 2005-02-11 devnull print("\t"+threadstkline(a.thread)+"\n");
122 0a61c07d 2004-04-19 devnull defn fnname(a){
123 0a61c07d 2004-04-19 devnull local sym, s;
125 0a61c07d 2004-04-19 devnull s = symbols;
126 0a61c07d 2004-04-19 devnull while s do {
127 0a61c07d 2004-04-19 devnull sym = head s;
128 0a61c07d 2004-04-19 devnull if sym[2] == a then
129 0a61c07d 2004-04-19 devnull return sym[0];
130 0a61c07d 2004-04-19 devnull s = tail s;
132 2a931b72 2005-02-11 devnull return itoa(a, "%#x");
135 0a61c07d 2004-04-19 devnull stkignorelist = {};
136 0a61c07d 2004-04-19 devnull defn stkignore(s){
137 0a61c07d 2004-04-19 devnull append stkignorelist, s;
140 0a61c07d 2004-04-19 devnull defn threadstkline(T){
141 c9896e2e 2004-05-23 devnull local stk, frame, pc, pc0, file, s, sym, i, stop, P, mainpid;
143 d89ce51a 2005-02-11 devnull T = (_Thread)T;
144 d89ce51a 2005-02-11 devnull P = (Proc)T.proc;
145 d89ce51a 2005-02-11 devnull if P.thread == T then {
146 c9896e2e 2004-05-23 devnull mainpid = pid;
147 2a931b72 2005-02-11 devnull setproc(pthread2tid(P.osprocid));
148 7284df18 2004-04-19 devnull stk = strace({});
149 d89ce51a 2005-02-11 devnull setproc(mainpid);
151 d89ce51a 2005-02-11 devnull stk = strace(context(T.context));
153 0a61c07d 2004-04-19 devnull stop = 0;
154 0a61c07d 2004-04-19 devnull while stk && !stop do {
155 7284df18 2004-04-19 devnull frame = head stk;
156 7284df18 2004-04-19 devnull stk = tail stk;
157 7284df18 2004-04-19 devnull pc = frame[2];
158 7284df18 2004-04-19 devnull pc0 = frame[0];
159 0a61c07d 2004-04-19 devnull file = pcfile(pc);
160 2e965b33 2004-05-05 devnull if !regexp("plan9/src/lib9/", file)
161 7284df18 2004-04-19 devnull && !regexp("plan9/src/libthread/", file)
162 d89ce51a 2005-02-11 devnull && file != "?file?"
163 0a61c07d 2004-04-19 devnull && match(file, stkignore)==-1 then
164 0a61c07d 2004-04-19 devnull stop = 1;
166 0a61c07d 2004-04-19 devnull file = pcfile(pc);
167 0a61c07d 2004-04-19 devnull s = file+":"+itoa(pcline(pc), "%d");
168 0a61c07d 2004-04-19 devnull if pc0 != 0 then
169 0a61c07d 2004-04-19 devnull s = s + " "+fnname(pc0);
170 0a61c07d 2004-04-19 devnull return s;
173 0a61c07d 2004-04-19 devnull defn threadfmt(T){
174 d89ce51a 2005-02-11 devnull complex _Thread T;
175 d89ce51a 2005-02-11 devnull local P, s, name;
177 0a61c07d 2004-04-19 devnull P = (Proc)T.proc;
178 2a931b72 2005-02-11 devnull s = "t=(_Thread)"+itoa(T, "%#-10x")+" // ";
180 d89ce51a 2005-02-11 devnull if P.thread == T then
181 0a61c07d 2004-04-19 devnull s = s + "Running ";
183 d89ce51a 2005-02-11 devnull s = s + "Sleeping ";
184 d89ce51a 2005-02-11 devnull s = s + threadstkline(T);
186 d89ce51a 2005-02-11 devnull name = T+392; // T+offsetof(_Thread, name);
187 d89ce51a 2005-02-11 devnull if *(name\b) != 0 then
188 d89ce51a 2005-02-11 devnull s = s + " ["+*(name\s)+"]";
189 0a61c07d 2004-04-19 devnull return s;
192 0a61c07d 2004-04-19 devnull defn thread(T){
193 0a61c07d 2004-04-19 devnull print(threadfmt(T), "\n");
196 d89ce51a 2005-02-11 devnull defn procthreads(P){
197 0a61c07d 2004-04-19 devnull complex Proc P;
198 d89ce51a 2005-02-11 devnull local T;
200 d89ce51a 2005-02-11 devnull T = (_Thread)P.allthreads.$head;
201 0a61c07d 2004-04-19 devnull while T != 0 do{
202 0a61c07d 2004-04-19 devnull print("\t");
203 0a61c07d 2004-04-19 devnull thread(T);
204 d89ce51a 2005-02-11 devnull T = (_Thread)T.allnext;
208 d89ce51a 2005-02-11 devnull defn prociter(x) {
209 0a61c07d 2004-04-19 devnull local P;
211 d89ce51a 2005-02-11 devnull P = (Proc)*_threadprocs;
212 0a61c07d 2004-04-19 devnull while P != 0 do{
213 d89ce51a 2005-02-11 devnull if P != (Proc)*_threadprocs then print("\n");
214 d89ce51a 2005-02-11 devnull proc(P);
215 d89ce51a 2005-02-11 devnull if x == 1 then
216 d89ce51a 2005-02-11 devnull procthreads(P);
217 d89ce51a 2005-02-11 devnull if x == 2 then
218 d89ce51a 2005-02-11 devnull threadstks(P);
219 c73e7cf5 2004-04-20 devnull P = (Proc)P.next;
223 d89ce51a 2005-02-11 devnull defn procs() {
224 d89ce51a 2005-02-11 devnull prociter(0);
227 d89ce51a 2005-02-11 devnull defn threads() {
228 d89ce51a 2005-02-11 devnull prociter(1);
231 d89ce51a 2005-02-11 devnull defn stacks() {
232 d89ce51a 2005-02-11 devnull prociter(2);
235 c73e7cf5 2004-04-20 devnull threadstkignore = {
236 c73e7cf5 2004-04-20 devnull "plan9/src/libthread/",
237 2e965b33 2004-05-05 devnull "plan9/src/lib9/",
238 2e965b33 2004-05-05 devnull "plan9/src/lib9/(fmt|utf)/",
240 0a61c07d 2004-04-19 devnull defn threadstks(P){
241 0a61c07d 2004-04-19 devnull complex Proc P;
242 d89ce51a 2005-02-11 devnull local T, mainpid, pref, ign;
244 0a61c07d 2004-04-19 devnull pref = stkprefix;
245 0a61c07d 2004-04-19 devnull stkprefix = pref+"\t\t";
246 0a61c07d 2004-04-19 devnull ign = stkignore;
247 c73e7cf5 2004-04-20 devnull stkignore = threadstkignore;
248 d89ce51a 2005-02-11 devnull T = (_Thread)P.allthreads.$head;
249 0a61c07d 2004-04-19 devnull while T != 0 do{
250 0a61c07d 2004-04-19 devnull print("\t");
251 0a61c07d 2004-04-19 devnull thread(T);
252 0a61c07d 2004-04-19 devnull threadstk(T);
253 d89ce51a 2005-02-11 devnull T = (_Thread)T.allnext;
254 0a61c07d 2004-04-19 devnull print("\n");
256 0a61c07d 2004-04-19 devnull stkprefix = pref;
257 0a61c07d 2004-04-19 devnull stkignore = ign;
260 0a61c07d 2004-04-19 devnull defn proc(P){
261 0a61c07d 2004-04-19 devnull complex Proc P;
263 2a931b72 2005-02-11 devnull print("p=(Proc)", itoa(P, "%#-10x"), " // pthread ", P.osprocid\X, " pid ", pthread2tid(P.osprocid)\D, " ");
264 0a61c07d 2004-04-19 devnull if P.thread==0 then
265 0a61c07d 2004-04-19 devnull print(" Sched");
267 0a61c07d 2004-04-19 devnull print(" Running");
268 0a61c07d 2004-04-19 devnull print("\n");
271 0a61c07d 2004-04-19 devnull defn threadlstk(T){
272 d89ce51a 2005-02-11 devnull complex _Thread T;
273 0a61c07d 2004-04-19 devnull local P, mainpid;
275 0a61c07d 2004-04-19 devnull P = (Proc)T.proc;
276 d89ce51a 2005-02-11 devnull mainpid = pid;
277 2a931b72 2005-02-11 devnull setproc(pthread2tid(P.osprocid));
279 d89ce51a 2005-02-11 devnull if P.thread == T then
282 d89ce51a 2005-02-11 devnull contextlstk(T.context);
283 d89ce51a 2005-02-11 devnull setproc(mainpid);
286 0a61c07d 2004-04-19 devnull defn threadstk(T){
287 d89ce51a 2005-02-11 devnull complex _Thread T;
288 0a61c07d 2004-04-19 devnull local P, mainpid;
290 0a61c07d 2004-04-19 devnull P = (Proc)T.proc;
291 0a61c07d 2004-04-19 devnull mainpid = pid;
292 2a931b72 2005-02-11 devnull setproc(pthread2tid(P.osprocid));
294 d89ce51a 2005-02-11 devnull if P.thread == T then
297 d89ce51a 2005-02-11 devnull contextstk(T.context);
299 d89ce51a 2005-02-11 devnull setproc(mainpid);
302 0a61c07d 2004-04-19 devnull print(acidfile);