Blame


1 0a61c07d 2004-04-19 devnull
2 0a61c07d 2004-04-19 devnull defn labpc(l)
3 0a61c07d 2004-04-19 devnull {
4 7284df18 2004-04-19 devnull complex Label l;
5 7284df18 2004-04-19 devnull
6 7284df18 2004-04-19 devnull return l.pc;
7 0a61c07d 2004-04-19 devnull }
8 0a61c07d 2004-04-19 devnull
9 7284df18 2004-04-19 devnull defn label(l)
10 0a61c07d 2004-04-19 devnull {
11 7284df18 2004-04-19 devnull complex Label l;
12 7284df18 2004-04-19 devnull
13 7284df18 2004-04-19 devnull if objtype == "386" then
14 7284df18 2004-04-19 devnull return {"PC", l.pc, "BX", l.bx, "SP", l.sp, "BP", l.bp, "SI", l.si, "DI", l.di};
15 7284df18 2004-04-19 devnull return {};
16 0a61c07d 2004-04-19 devnull }
17 0a61c07d 2004-04-19 devnull
18 7284df18 2004-04-19 devnull
19 0a61c07d 2004-04-19 devnull defn labstk(l)
20 0a61c07d 2004-04-19 devnull {
21 7284df18 2004-04-19 devnull _stk(label(l), 0);
22 0a61c07d 2004-04-19 devnull }
23 0a61c07d 2004-04-19 devnull
24 0a61c07d 2004-04-19 devnull defn lablstk(l)
25 0a61c07d 2004-04-19 devnull {
26 7284df18 2004-04-19 devnull _stk(label(l), 1);
27 0a61c07d 2004-04-19 devnull }
28 0a61c07d 2004-04-19 devnull
29 0a61c07d 2004-04-19 devnull defn altfmt(A){
30 0a61c07d 2004-04-19 devnull local i, s, yes;
31 0a61c07d 2004-04-19 devnull complex Alt A;
32 0a61c07d 2004-04-19 devnull
33 0a61c07d 2004-04-19 devnull s = "alt(";
34 0a61c07d 2004-04-19 devnull s = s + "tag(*" + itoa(A.tag, "%x") + "=" + itoa(*A.tag, "%x") + ") ";
35 0a61c07d 2004-04-19 devnull i = 0;
36 0a61c07d 2004-04-19 devnull yes = 0;
37 0a61c07d 2004-04-19 devnull while A.op != CHANEND && A.op != CHANNOBLK do{
38 0a61c07d 2004-04-19 devnull if A.op != CHANNOP then{
39 0a61c07d 2004-04-19 devnull if yes then s = s + " ";
40 0a61c07d 2004-04-19 devnull s = s + itoa(i, "%d");
41 0a61c07d 2004-04-19 devnull s = s + ":";
42 0a61c07d 2004-04-19 devnull if A.op == CHANSND then s = s + "send";
43 0a61c07d 2004-04-19 devnull if A.op == CHANRCV then s = s + "recv";
44 0a61c07d 2004-04-19 devnull s = s + "(channel(";
45 0a61c07d 2004-04-19 devnull s = s + itoa(A.c, "%x");
46 0a61c07d 2004-04-19 devnull s = s + "))";
47 0a61c07d 2004-04-19 devnull yes = 1;
48 0a61c07d 2004-04-19 devnull }
49 0a61c07d 2004-04-19 devnull i = i + 1;
50 0a61c07d 2004-04-19 devnull A = (Alt)(A + sizeofAlt);
51 0a61c07d 2004-04-19 devnull }
52 0a61c07d 2004-04-19 devnull if A.op==CHANNOBLK then{
53 0a61c07d 2004-04-19 devnull if yes then s = s + " ";
54 0a61c07d 2004-04-19 devnull s = s + "noblock";
55 0a61c07d 2004-04-19 devnull }
56 0a61c07d 2004-04-19 devnull s = s + ")";
57 0a61c07d 2004-04-19 devnull return s;
58 0a61c07d 2004-04-19 devnull }
59 0a61c07d 2004-04-19 devnull
60 0a61c07d 2004-04-19 devnull defn alt(A){
61 0a61c07d 2004-04-19 devnull print(altfmt(A), "\n");
62 0a61c07d 2004-04-19 devnull }
63 0a61c07d 2004-04-19 devnull
64 0a61c07d 2004-04-19 devnull defn fnname(a){
65 0a61c07d 2004-04-19 devnull local sym, s;
66 0a61c07d 2004-04-19 devnull
67 0a61c07d 2004-04-19 devnull s = symbols;
68 0a61c07d 2004-04-19 devnull while s do {
69 0a61c07d 2004-04-19 devnull sym = head s;
70 0a61c07d 2004-04-19 devnull if sym[2] == a then
71 0a61c07d 2004-04-19 devnull return sym[0];
72 0a61c07d 2004-04-19 devnull s = tail s;
73 0a61c07d 2004-04-19 devnull }
74 0a61c07d 2004-04-19 devnull return itoa(a, "%x");
75 0a61c07d 2004-04-19 devnull }
76 0a61c07d 2004-04-19 devnull
77 0a61c07d 2004-04-19 devnull stkignorelist = {};
78 0a61c07d 2004-04-19 devnull
79 0a61c07d 2004-04-19 devnull defn stkignore(s){
80 0a61c07d 2004-04-19 devnull append stkignorelist, s;
81 0a61c07d 2004-04-19 devnull }
82 0a61c07d 2004-04-19 devnull
83 0a61c07d 2004-04-19 devnull defn threadstkline(T){
84 c9896e2e 2004-05-23 devnull local stk, frame, pc, pc0, file, s, sym, i, stop, P, mainpid;
85 0a61c07d 2004-04-19 devnull
86 c9896e2e 2004-05-23 devnull if T.state == Running then {
87 c9896e2e 2004-05-23 devnull P = (Proc)T.proc;
88 c9896e2e 2004-05-23 devnull mainpid = pid;
89 c9896e2e 2004-05-23 devnull if mainpid != P.pid then setproc(P.pid);
90 7284df18 2004-04-19 devnull stk = strace({});
91 c9896e2e 2004-05-23 devnull if mainpid != P.pid then setproc(mainpid);
92 c9896e2e 2004-05-23 devnull } else
93 7284df18 2004-04-19 devnull stk = strace(label(T.sched));
94 7284df18 2004-04-19 devnull
95 0a61c07d 2004-04-19 devnull stop = 0;
96 0a61c07d 2004-04-19 devnull while stk && !stop do {
97 7284df18 2004-04-19 devnull frame = head stk;
98 7284df18 2004-04-19 devnull stk = tail stk;
99 7284df18 2004-04-19 devnull pc = frame[2];
100 7284df18 2004-04-19 devnull pc0 = frame[0];
101 0a61c07d 2004-04-19 devnull file = pcfile(pc);
102 2e965b33 2004-05-05 devnull if !regexp("plan9/src/lib9/", file)
103 7284df18 2004-04-19 devnull && !regexp("plan9/src/libthread/", file)
104 0a61c07d 2004-04-19 devnull && match(file, stkignore)==-1 then
105 0a61c07d 2004-04-19 devnull stop = 1;
106 0a61c07d 2004-04-19 devnull }
107 0a61c07d 2004-04-19 devnull file = pcfile(pc);
108 0a61c07d 2004-04-19 devnull s = file+":"+itoa(pcline(pc), "%d");
109 0a61c07d 2004-04-19 devnull if pc0 != 0 then
110 0a61c07d 2004-04-19 devnull s = s + " "+fnname(pc0);
111 0a61c07d 2004-04-19 devnull return s;
112 0a61c07d 2004-04-19 devnull }
113 0a61c07d 2004-04-19 devnull
114 0a61c07d 2004-04-19 devnull defn threadfmt(T){
115 0a61c07d 2004-04-19 devnull complex Thread T;
116 0a61c07d 2004-04-19 devnull local A, yes, i, P, s;
117 0a61c07d 2004-04-19 devnull
118 0a61c07d 2004-04-19 devnull P = (Proc)T.proc;
119 4fbe07e1 2004-09-23 devnull s = "t=(Thread)"+itoa(T, "%-10x")+" // ";
120 0a61c07d 2004-04-19 devnull
121 0a61c07d 2004-04-19 devnull if T.state == Running then
122 0a61c07d 2004-04-19 devnull s = s + "Running ";
123 0a61c07d 2004-04-19 devnull else if T.state == Ready then
124 0a61c07d 2004-04-19 devnull s = s + "Ready ";
125 0a61c07d 2004-04-19 devnull else if T.state == Rendezvous then
126 0a61c07d 2004-04-19 devnull s = s + "Rendez ";
127 0a61c07d 2004-04-19 devnull else
128 0a61c07d 2004-04-19 devnull s = s + "Bad state "+itoa(T.state, "%x")+" ";
129 0a61c07d 2004-04-19 devnull
130 0a61c07d 2004-04-19 devnull A = (Alt)T.alt;
131 0a61c07d 2004-04-19 devnull if 1 then
132 0a61c07d 2004-04-19 devnull s = s + threadstkline(T);
133 0a61c07d 2004-04-19 devnull else if T.chan == Chanalt then
134 0a61c07d 2004-04-19 devnull s = s + altfmt(T.alt);
135 0a61c07d 2004-04-19 devnull else if T.chan == Chansend then
136 0a61c07d 2004-04-19 devnull s = s + "send(Channel("+itoa(A.c, "%x")+"))";
137 0a61c07d 2004-04-19 devnull else if T.chan == Chanrecv then
138 0a61c07d 2004-04-19 devnull s = s + "recv(Channel("+itoa(A.c, "%x")+"))";
139 0a61c07d 2004-04-19 devnull else
140 0a61c07d 2004-04-19 devnull s = s + threadstkline(T);
141 0a61c07d 2004-04-19 devnull
142 0a61c07d 2004-04-19 devnull if T.moribund == 1 then
143 0a61c07d 2004-04-19 devnull s = s + " Moribund";
144 0a61c07d 2004-04-19 devnull if T.cmdname != 0 then
145 0a61c07d 2004-04-19 devnull s = s + " ["+*(T.cmdname\s)+"]";
146 0a61c07d 2004-04-19 devnull return s;
147 0a61c07d 2004-04-19 devnull }
148 0a61c07d 2004-04-19 devnull
149 0a61c07d 2004-04-19 devnull defn thread(T){
150 0a61c07d 2004-04-19 devnull print(threadfmt(T), "\n");
151 0a61c07d 2004-04-19 devnull }
152 0a61c07d 2004-04-19 devnull
153 0a61c07d 2004-04-19 devnull defn pthreads(P){
154 0a61c07d 2004-04-19 devnull complex Proc P;
155 0a61c07d 2004-04-19 devnull local T, Tq, mainpid;
156 0a61c07d 2004-04-19 devnull
157 0a61c07d 2004-04-19 devnull mainpid = pid;
158 0a61c07d 2004-04-19 devnull Tq = (Tqueue)P.threads;
159 0a61c07d 2004-04-19 devnull T = (Thread)Tq.$head;
160 0a61c07d 2004-04-19 devnull while T != 0 do{
161 0a61c07d 2004-04-19 devnull print("\t");
162 0a61c07d 2004-04-19 devnull thread(T);
163 7284df18 2004-04-19 devnull T = (Thread)T.nextt;
164 0a61c07d 2004-04-19 devnull }
165 0a61c07d 2004-04-19 devnull }
166 0a61c07d 2004-04-19 devnull
167 0a61c07d 2004-04-19 devnull defn threads(){
168 0a61c07d 2004-04-19 devnull local P;
169 7284df18 2004-04-19 devnull complex Pqueue _threadpq;
170 c73e7cf5 2004-04-20 devnull
171 0a61c07d 2004-04-19 devnull P = (Proc)_threadpq.$head;
172 0a61c07d 2004-04-19 devnull while P != 0 do{
173 0a61c07d 2004-04-19 devnull if P != (Proc)_threadpq.$head then print("\n");
174 0a61c07d 2004-04-19 devnull lproc(P);
175 c73e7cf5 2004-04-20 devnull P = (Proc)P.next;
176 0a61c07d 2004-04-19 devnull }
177 0a61c07d 2004-04-19 devnull }
178 0a61c07d 2004-04-19 devnull
179 0a61c07d 2004-04-19 devnull defn stacks(){
180 0a61c07d 2004-04-19 devnull local P, mainpid;
181 c73e7cf5 2004-04-20 devnull complex Pqueue _threadpq;
182 0a61c07d 2004-04-19 devnull
183 7284df18 2004-04-19 devnull stkprefix = "";
184 0a61c07d 2004-04-19 devnull mainpid = pid;
185 0a61c07d 2004-04-19 devnull P = (Proc)_threadpq.$head;
186 0a61c07d 2004-04-19 devnull while P != 0 do{
187 0a61c07d 2004-04-19 devnull proc(P);
188 80e841ab 2004-09-17 devnull if mainpid != P.pid then setproc(P.pid);
189 0a61c07d 2004-04-19 devnull // setproc(P.pid);
190 0a61c07d 2004-04-19 devnull // if P.thread==0 then{
191 0a61c07d 2004-04-19 devnull // print("=== thread scheduler stack\n");
192 0a61c07d 2004-04-19 devnull // stk();
193 0a61c07d 2004-04-19 devnull // }
194 0a61c07d 2004-04-19 devnull // print("threadstks(", P\X, ")\n");
195 0a61c07d 2004-04-19 devnull threadstks(P);
196 80e841ab 2004-09-17 devnull if mainpid != P.pid then setproc(mainpid);
197 7284df18 2004-04-19 devnull P = (Proc)P.next;
198 0a61c07d 2004-04-19 devnull print("\n");
199 0a61c07d 2004-04-19 devnull }
200 a796abef 2004-05-12 devnull // setproc(mainpid);
201 0a61c07d 2004-04-19 devnull }
202 0a61c07d 2004-04-19 devnull
203 0a61c07d 2004-04-19 devnull defn stacksizes(){
204 0a61c07d 2004-04-19 devnull local P, T, Tq, top, sp, mainpid;
205 c73e7cf5 2004-04-20 devnull complex Pqueue _threadpq;
206 0a61c07d 2004-04-19 devnull
207 0a61c07d 2004-04-19 devnull mainpid = pid;
208 0a61c07d 2004-04-19 devnull P = (Proc)_threadpq.$head;
209 0a61c07d 2004-04-19 devnull while P != 0 do{
210 0a61c07d 2004-04-19 devnull P = (Proc)P;
211 80e841ab 2004-09-17 devnull if mainpid != P.pid then setproc(P.pid);
212 0a61c07d 2004-04-19 devnull Tq = (Tqueue)P.threads;
213 0a61c07d 2004-04-19 devnull T = (Thread)Tq.$head;
214 0a61c07d 2004-04-19 devnull while T != 0 do{
215 0a61c07d 2004-04-19 devnull top = T.stk+T.stksize;
216 0a61c07d 2004-04-19 devnull if T.state==Running then {
217 0a61c07d 2004-04-19 devnull sp = *SP;
218 0a61c07d 2004-04-19 devnull }else{
219 80e841ab 2004-09-17 devnull sp = T.sched.sp;
220 0a61c07d 2004-04-19 devnull }
221 80e841ab 2004-09-17 devnull print(top-sp\D, " of ", T.stksize\D, " - 0x", top\X, " 0x", sp\X, " ", *T.stk\X, "\n");
222 7284df18 2004-04-19 devnull T = (Thread)T.nextt;
223 0a61c07d 2004-04-19 devnull }
224 80e841ab 2004-09-17 devnull if mainpid != P.pid then setproc(mainpid);
225 0a61c07d 2004-04-19 devnull P = P.next;
226 0a61c07d 2004-04-19 devnull }
227 a796abef 2004-05-12 devnull // setproc(mainpid);
228 0a61c07d 2004-04-19 devnull }
229 0a61c07d 2004-04-19 devnull
230 0a61c07d 2004-04-19 devnull defn lproc(P){
231 0a61c07d 2004-04-19 devnull proc(P);
232 0a61c07d 2004-04-19 devnull pthreads(P);
233 0a61c07d 2004-04-19 devnull }
234 0a61c07d 2004-04-19 devnull
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)/",
239 c73e7cf5 2004-04-20 devnull };
240 0a61c07d 2004-04-19 devnull defn threadstks(P){
241 0a61c07d 2004-04-19 devnull complex Proc P;
242 0a61c07d 2004-04-19 devnull local T, Tq, mainpid, pref, ign;
243 0a61c07d 2004-04-19 devnull
244 0a61c07d 2004-04-19 devnull mainpid = pid;
245 0a61c07d 2004-04-19 devnull pref = stkprefix;
246 0a61c07d 2004-04-19 devnull stkprefix = pref+"\t\t";
247 0a61c07d 2004-04-19 devnull ign = stkignore;
248 c73e7cf5 2004-04-20 devnull stkignore = threadstkignore;
249 a796abef 2004-05-12 devnull // setproc(P.pid);
250 0a61c07d 2004-04-19 devnull Tq = (Tqueue)P.threads;
251 0a61c07d 2004-04-19 devnull T = (Thread)Tq.$head;
252 0a61c07d 2004-04-19 devnull while T != 0 do{
253 0a61c07d 2004-04-19 devnull // print("=============================\n");
254 0a61c07d 2004-04-19 devnull // print(" thread(", T\X, ")\n");
255 0a61c07d 2004-04-19 devnull print("\t");
256 0a61c07d 2004-04-19 devnull thread(T);
257 0a61c07d 2004-04-19 devnull threadstk(T);
258 7284df18 2004-04-19 devnull T = (Thread)T.nextt;
259 0a61c07d 2004-04-19 devnull print("\n");
260 0a61c07d 2004-04-19 devnull }
261 a796abef 2004-05-12 devnull // setproc(mainpid);
262 0a61c07d 2004-04-19 devnull stkprefix = pref;
263 0a61c07d 2004-04-19 devnull stkignore = ign;
264 0a61c07d 2004-04-19 devnull }
265 0a61c07d 2004-04-19 devnull
266 0a61c07d 2004-04-19 devnull defn proc(P){
267 0a61c07d 2004-04-19 devnull complex Proc P;
268 0a61c07d 2004-04-19 devnull
269 0a61c07d 2004-04-19 devnull print("p=(Proc)", itoa(P, "%-10x"), " pid ", P.pid\D, " ");
270 0a61c07d 2004-04-19 devnull if P.thread==0 then
271 0a61c07d 2004-04-19 devnull print(" Sched");
272 0a61c07d 2004-04-19 devnull else
273 0a61c07d 2004-04-19 devnull print(" Running");
274 0a61c07d 2004-04-19 devnull print("\n");
275 0a61c07d 2004-04-19 devnull }
276 0a61c07d 2004-04-19 devnull
277 0a61c07d 2004-04-19 devnull defn procs(){
278 0a61c07d 2004-04-19 devnull local P;
279 c73e7cf5 2004-04-20 devnull complex Pqueue _threadpq;
280 0a61c07d 2004-04-19 devnull
281 0a61c07d 2004-04-19 devnull P = (Proc)_threadpq.$head;
282 0a61c07d 2004-04-19 devnull while P != 0 do{
283 0a61c07d 2004-04-19 devnull proc(P);
284 0a61c07d 2004-04-19 devnull P = P.next;
285 0a61c07d 2004-04-19 devnull }
286 0a61c07d 2004-04-19 devnull }
287 0a61c07d 2004-04-19 devnull
288 0a61c07d 2004-04-19 devnull defn threadlstk(T){
289 0a61c07d 2004-04-19 devnull complex Thread T;
290 0a61c07d 2004-04-19 devnull local P, mainpid;
291 0a61c07d 2004-04-19 devnull
292 0a61c07d 2004-04-19 devnull P = (Proc)T.proc;
293 a796abef 2004-05-12 devnull // mainpid = pid;
294 a796abef 2004-05-12 devnull // setproc(P.pid);
295 0a61c07d 2004-04-19 devnull
296 0a61c07d 2004-04-19 devnull if T.state == Running then{
297 0a61c07d 2004-04-19 devnull lstk();
298 0a61c07d 2004-04-19 devnull } else {
299 0a61c07d 2004-04-19 devnull lablstk(T.sched);
300 0a61c07d 2004-04-19 devnull }
301 a796abef 2004-05-12 devnull // setproc(mainpid);
302 0a61c07d 2004-04-19 devnull }
303 0a61c07d 2004-04-19 devnull
304 0a61c07d 2004-04-19 devnull defn threadstk(T){
305 0a61c07d 2004-04-19 devnull complex Thread T;
306 0a61c07d 2004-04-19 devnull local P, mainpid;
307 0a61c07d 2004-04-19 devnull
308 0a61c07d 2004-04-19 devnull P = (Proc)T.proc;
309 0a61c07d 2004-04-19 devnull mainpid = pid;
310 a796abef 2004-05-12 devnull // setproc(P.pid);
311 0a61c07d 2004-04-19 devnull
312 0a61c07d 2004-04-19 devnull if T.state == Running then{
313 c9896e2e 2004-05-23 devnull if P.pid != mainpid then
314 c9896e2e 2004-05-23 devnull setproc(P.pid);
315 0a61c07d 2004-04-19 devnull stk();
316 c9896e2e 2004-05-23 devnull if P.pid != mainpid then
317 c9896e2e 2004-05-23 devnull setproc(mainpid);
318 0a61c07d 2004-04-19 devnull } else {
319 0a61c07d 2004-04-19 devnull labstk(T.sched);
320 0a61c07d 2004-04-19 devnull }
321 a796abef 2004-05-12 devnull // setproc(mainpid);
322 0a61c07d 2004-04-19 devnull }
323 0a61c07d 2004-04-19 devnull
324 0a61c07d 2004-04-19 devnull defn tqueue(Q) {
325 0a61c07d 2004-04-19 devnull complex Tqueue Q;
326 0a61c07d 2004-04-19 devnull
327 0a61c07d 2004-04-19 devnull while Q != 0 do {
328 0a61c07d 2004-04-19 devnull print(Q.$head\X, " ");
329 0a61c07d 2004-04-19 devnull Q = *(Q.$tail);
330 0a61c07d 2004-04-19 devnull
331 0a61c07d 2004-04-19 devnull }
332 0a61c07d 2004-04-19 devnull print("#\n");
333 0a61c07d 2004-04-19 devnull }
334 0a61c07d 2004-04-19 devnull
335 0a61c07d 2004-04-19 devnull defn channel(C) {
336 0a61c07d 2004-04-19 devnull complex Channel C;
337 0a61c07d 2004-04-19 devnull local i, p;
338 0a61c07d 2004-04-19 devnull
339 0a61c07d 2004-04-19 devnull print("channel ", C\X);
340 0a61c07d 2004-04-19 devnull if C.freed then {
341 0a61c07d 2004-04-19 devnull print(" (moribund)");
342 0a61c07d 2004-04-19 devnull }
343 0a61c07d 2004-04-19 devnull print("\n");
344 0a61c07d 2004-04-19 devnull print("\telementsize=", C.e\D, " buffersize=", C.s, "\n");
345 0a61c07d 2004-04-19 devnull if C.s then {
346 0a61c07d 2004-04-19 devnull print("\t", C.n\D, " values in channel:\n");
347 0a61c07d 2004-04-19 devnull print("\t");
348 0a61c07d 2004-04-19 devnull p = C.v+C.e*(C.f%C.s);
349 0a61c07d 2004-04-19 devnull loop 1,C.n do {
350 0a61c07d 2004-04-19 devnull if C.e==4 then {
351 0a61c07d 2004-04-19 devnull print((*p)\X, " ");
352 0a61c07d 2004-04-19 devnull }else {
353 0a61c07d 2004-04-19 devnull print("data(", (*p)\X, ") ");
354 0a61c07d 2004-04-19 devnull }
355 0a61c07d 2004-04-19 devnull p = p+C.e;
356 0a61c07d 2004-04-19 devnull if p == C.v+C.s*C.e then {
357 0a61c07d 2004-04-19 devnull p = C.v;
358 0a61c07d 2004-04-19 devnull }
359 0a61c07d 2004-04-19 devnull }
360 0a61c07d 2004-04-19 devnull }
361 0a61c07d 2004-04-19 devnull print("\n");
362 0a61c07d 2004-04-19 devnull print(C.nentry\D, " queue slots:\n");
363 0a61c07d 2004-04-19 devnull i=0;
364 0a61c07d 2004-04-19 devnull loop 1,C.nentry do {
365 0a61c07d 2004-04-19 devnull if C.qentry[i] then
366 0a61c07d 2004-04-19 devnull print("\t", altfmt(C.qentry[i]), "\n");
367 0a61c07d 2004-04-19 devnull else
368 0a61c07d 2004-04-19 devnull print("\t<empty>\n");
369 0a61c07d 2004-04-19 devnull i=i+1;
370 0a61c07d 2004-04-19 devnull }
371 0a61c07d 2004-04-19 devnull }
372 0a61c07d 2004-04-19 devnull
373 c73e7cf5 2004-04-20 devnull defn polling() {
374 c73e7cf5 2004-04-20 devnull local i, c, t, p, pf;
375 c73e7cf5 2004-04-20 devnull
376 c73e7cf5 2004-04-20 devnull p=(Poll)polls; pf=(struct_pollfd)pfd; loop 1,*npoll do {
377 c73e7cf5 2004-04-20 devnull print("\tfd ", pf.fd\D, " ");
378 c73e7cf5 2004-04-20 devnull if pf.events & 1 then
379 c73e7cf5 2004-04-20 devnull print("r");
380 c73e7cf5 2004-04-20 devnull else if pf.events & 2 then
381 c73e7cf5 2004-04-20 devnull print("w");
382 c73e7cf5 2004-04-20 devnull else
383 c73e7cf5 2004-04-20 devnull print(pf.events\D);
384 c73e7cf5 2004-04-20 devnull print(" chan Channel(", p.c\X, ")\n");
385 c73e7cf5 2004-04-20 devnull p = (Poll)(p+sizeofPoll);
386 c73e7cf5 2004-04-20 devnull pf = (struct_pollfd)(pf+sizeofstruct_pollfd);
387 c73e7cf5 2004-04-20 devnull }
388 c73e7cf5 2004-04-20 devnull
389 c73e7cf5 2004-04-20 devnull c=sleepchan; t=sleeptime; loop 1,*nsleep do {
390 c73e7cf5 2004-04-20 devnull print("\tsleep ", *t\D, " Channel(", *c\X, ")\n");
391 c73e7cf5 2004-04-20 devnull c++;
392 c73e7cf5 2004-04-20 devnull t++;
393 c73e7cf5 2004-04-20 devnull }
394 c73e7cf5 2004-04-20 devnull }
395 c73e7cf5 2004-04-20 devnull
396 0a61c07d 2004-04-19 devnull print(acidfile);