blob: a2fd46c5e933e3d54a4fa4e098a2f53ab0967455 [file] [log] [blame]
//
// pthread-specific access functions
// avoid complicated libthread_db interface
//
include("pthread-"+systype+"-"+objtype);
// pick apart system mcontext_t structures
defn mcontext(m)
{
complex mcontext_t m;
if systype == "linux" then {
m = m\X;
return {"PC", m[14], "SP", m[7], "BP", m[6]};
} else if systype == "freebsd" then {
return {"PC", m.mc_eip, "SP", m.mc_esp, "BP", m.mc_ebp};
} else
error("do not know how to read mcontext_t on system "+systype);
}
//
// plan 9 thread library support
//
defn context(c)
{
c = (Context)c;
return mcontext(c.uc.uc_mcontext);
}
defn contextstk(c)
{
_stk(context(c), 0);
}
defn contextlstk(c)
{
_stk(context(c), 1);
}
defn altfmt(A){
local i, s, yes;
complex Alt A;
s = "alt(";
s = s + "tag(*" + itoa(A.tag, "%#x") + "=" + itoa(*A.tag, "%#x") + ") ";
i = 0;
yes = 0;
while A.op != CHANEND && A.op != CHANNOBLK do{
if A.op != CHANNOP then{
if yes then s = s + " ";
s = s + itoa(i, "%d");
s = s + ":";
if A.op == CHANSND then s = s + "send";
if A.op == CHANRCV then s = s + "recv";
s = s + "(channel(";
s = s + itoa(A.c, "%#x");
s = s + "))";
yes = 1;
}
i = i + 1;
A = (Alt)(A + sizeofAlt);
}
if A.op==CHANNOBLK then{
if yes then s = s + " ";
s = s + "noblock";
}
s = s + ")";
return s;
}
defn alt(A){
print(altfmt(A), "\n");
}
defn channel(C) {
complex Channel C;
local i, p;
print("channel ", C\X, " // ", *(C.name\s));
if C.freed then {
print(" (moribund)");
}
print("\n");
print("\telemsize=", C.elemsize\D, " bufsize=", C.bufsize, "\n");
if C.bufsize then {
print("\t", C.nbuf\D, " values in channel:\n");
print("\t");
p = C.buf+C.off*C.elemsize;
loop 1,C.nbuf do {
if C.elemsize==4 then {
print(*p\X, " ");
}else {
print("data(", p\X, ") ");
}
p = p+C.elemsize;
if p == C.buf+C.bufsize*C.elemsize then {
p = C.buf;
}
}
}
print("\n");
print(" senders:\n");
_altarray(C.asend);
print(" recvers:\n");
_altarray(C.arecv);
}
defn _altarray(aa)
{
local i, a, t;
i = 0;
aa = (_Altarray)aa;
while i < aa.n do {
a = (Alt)aa.a[i];
print("\t"+threadstkline(a.thread)+"\n");
i++;
}
}
defn fnname(a){
local sym, s;
s = symbols;
while s do {
sym = head s;
if sym[2] == a then
return sym[0];
s = tail s;
}
return itoa(a, "%#x");
}
stkignorelist = {};
defn stkignore(s){
append stkignorelist, s;
}
defn threadstkline(T){
local stk, frame, pc, pc0, file, s, sym, i, stop, P, mainpid;
T = (_Thread)T;
P = (Proc)T.proc;
if P.thread == T then {
mainpid = pid;
setproc(pthread2tid(P.osprocid));
stk = strace({});
setproc(mainpid);
} else
stk = strace(context(T.context));
stop = 0;
while stk && !stop do {
frame = head stk;
stk = tail stk;
pc = frame[2];
pc0 = frame[0];
file = pcfile(pc);
if !regexp("plan9/src/lib9/", file)
&& !regexp("plan9/src/libthread/", file)
&& file != "?file?"
&& match(file, stkignore)==-1 then
stop = 1;
}
file = pcfile(pc);
s = file+":"+itoa(pcline(pc), "%d");
if pc0 != 0 then
s = s + " "+fnname(pc0);
return s;
}
defn threadfmt(T){
complex _Thread T;
local P, s, name;
P = (Proc)T.proc;
s = "t=(_Thread)"+itoa(T, "%#-10x")+" // ";
if P.thread == T then
s = s + "Running ";
else
s = s + "Sleeping ";
s = s + threadstkline(T);
name = T+392; // T+offsetof(_Thread, name);
if *(name\b) != 0 then
s = s + " ["+*(name\s)+"]";
return s;
}
defn thread(T){
print(threadfmt(T), "\n");
}
defn procthreads(P){
complex Proc P;
local T;
T = (_Thread)P.allthreads.$head;
while T != 0 do{
print("\t");
thread(T);
T = (_Thread)T.allnext;
}
}
defn prociter(x) {
local P;
P = (Proc)*_threadprocs;
while P != 0 do{
if P != (Proc)*_threadprocs then print("\n");
proc(P);
if x == 1 then
procthreads(P);
if x == 2 then
threadstks(P);
P = (Proc)P.next;
}
}
defn procs() {
prociter(0);
}
defn threads() {
prociter(1);
}
defn stacks() {
prociter(2);
}
threadstkignore = {
"plan9/src/libthread/",
"plan9/src/lib9/",
"plan9/src/lib9/(fmt|utf)/",
};
defn threadstks(P){
complex Proc P;
local T, mainpid, pref, ign;
pref = stkprefix;
stkprefix = pref+"\t\t";
ign = stkignore;
stkignore = threadstkignore;
T = (_Thread)P.allthreads.$head;
while T != 0 do{
print("\t");
thread(T);
threadstk(T);
T = (_Thread)T.allnext;
print("\n");
}
stkprefix = pref;
stkignore = ign;
}
defn proc(P){
complex Proc P;
print("p=(Proc)", itoa(P, "%#-10x"), " // pthread ", P.osprocid\X, " pid ", pthread2tid(P.osprocid)\D, " ");
if P.thread==0 then
print(" Sched");
else
print(" Running");
print("\n");
}
defn threadlstk(T){
complex _Thread T;
local P, mainpid;
P = (Proc)T.proc;
mainpid = pid;
setproc(pthread2tid(P.osprocid));
if P.thread == T then
lstk();
else
contextlstk(T.context);
setproc(mainpid);
}
defn threadstk(T){
complex _Thread T;
local P, mainpid;
P = (Proc)T.proc;
mainpid = pid;
setproc(pthread2tid(P.osprocid));
if P.thread == T then
stk();
else
contextstk(T.context);
setproc(mainpid);
}
print(acidfile);