Subversion Repositories planix.SVN

Rev

Rev 2 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
2 - 1 
// runtime library definitions
2 
if objtype=="mips2" then objtype="mips";
3 
 
4 
include("/sys/src/alef/lib/"+objtype+"/acid");
5 
 
6 
defn
7 
pchan(addr)
8 
{
9 
	local l, n;
10 
 
11 
	complex Chan addr;
12 
 
13 
	if addr.sva then
14 
		print("Sender waiting: buffer ", addr.sva, "\n");
15 
	else
16 
		print("No sender\n");
17 
 
18 
	if addr.rva then
19 
		print("Receiver waiting: buffer ", addr.rva, "\n");
20 
	else
21 
		print("No receiver\n");
22 
 
23 
	if addr.async then {
24 
		n = 0;
25 
		l = addr.qh;
26 
		while l do {
27 
			n = n+1;
28 
			l = l.next;
29 
		}
30 
		print("Async channel\n\t", n\D, " messsages queued\n\t");
31 
		l = addr.free;
32 
		while l do {
33 
			n = n+1;
34 
			l = l.next;
35 
		}
36 
		print(n\D, " free buffers\n");
37 
	}
38 
 
39 
	if addr.selt then {
40 
		l = "send";
41 
		if addr.selt then
42 
			l = "receive";
43 
		print("In select ", l, ": task ", addr.selt\X, "\n");
44 
		labstk(addr.selt);
45 
	}
46 
}
47 
 
48 
defn
49 
tdb()
50 
{
51 
	local ta, tq;
52 
 
53 
	// Private proc tdb pointer
54 
	ta = *{	0x7fffe000,
55 
		0x0ffdf000,
56 
		0xbfff5000 }[match(objtype, {"mips", "sparc", "386"})];
57 
 
58 
	complex Tdb ta;
59 
 
60 
	print("tdb ", ta.ntask, " tasks:");
61 
 	if *ta then
62 
		print("locked\n");
63 
	else
64 
		print("unlocked\n");
65 
 
66 
	if ta.ctask then {
67 
		print("current task ", ta.ctask, "\n");
68 
		Task(ta.ctask);
69 
	}
70 
	else
71 
		print("proc is idle\n");
72 
 
73 
	tq = (Task)ta.runhd;
74 
	if tq == 0 then
75 
		return {};
76 
 
77 
	print("Tasks ready to run:\n");
78 
	while tq != 0 do {
79 
		print("Task(", tq, ")\n");
80 
		tq = tq.link;
81 
	}
82 
}
83 
 
84 
defn
85 
lselect(addr)
86 
{
87 
	local c;
88 
 
89 
	complex Task addr;
90 
	complex Chan c;
91 
 
92 
	c = addr.slist;
93 
	if c == 0 then {
94 
		print("No select pending\n");
95 
		return {};
96 
	}
97 
	while c do {
98 
		print("pchan(", c\X, ")\n");
99 
		c = c.sellink;
100 
	}
101 
}
102 
 
103 
defn
104 
pqlock(addr)
105 
{
106 
	local t;
107 
 
108 
	complex QLock addr;
109 
 
110 
	if *addr then
111 
		print("QLock is under modification\n");
112 
	if addr.used == 0 then
113 
		return {};
114 
 
115 
	print("QLock is held\n");
116 
	t = addr.queue;
117 
	complex Task t;
118 
	if t == 0 then {
119 
		print("No tasks waiting\n");
120 
		return {};
121 
	}
122 
	print("Tasks waiting:\n");
123 
	while t do {
124 
		print("Task(", t, ")\n");
125 
		tq = tq.qlink;
126 
	}
127 
}
128 
 
129 
srcpath = {
130 
	"./",
131 
	"/sys/src/alef/lib/port/",
132 
	"/sys/src/alef/lib/p9/",
133 
	"/sys/src/alef/lib/"+objtype+"/"
134 
};
135 
 
136 
defn labstk(l)
137 
{
138 
	if objtype == "386" then
139 
		_stk(ALEF_switch, *l, linkreg(0), 0);
140 
	else
141 
		_stk(*(l+4), *l, linkreg(0), 0);
142 
}
143 
 
144 
print("/sys/lib/acid/alef");
145 
 
146 
include("/sys/src/alef/lib/port/acid."+objtype);
147 
include("/sys/src/alef/lib/p9/acid."+objtype);