10 _vtsend(VtConn *z, Packet *p)  in _vtsend()  argument
16 	if(z->state != VtStateConnected) {  in _vtsend()
39 		if(write(z->outfd, ioc.addr, ioc.len) < ioc.len){  in _vtsend()
40 			vtlog(VtServerLog, "<font size=-1>%T %s:</font> sending packet %p: %r<br>\n", z->addr, p);  in _vtsend()
47 	vtlog(VtServerLog, "<font size=-1>%T %s:</font> sent packet %p (%d bytes)<br>\n", z->addr, p, tot);  in _vtsend()
63 _vtrecv(VtConn *z)  in _vtrecv()  argument
70 	if(z->state != VtStateConnected) {  in _vtrecv()
75 	p = z->part;  in _vtrecv()
82 		n = read(z->infd, b, 2);  in _vtrecv()
101 		n = read(z->infd, b, n);  in _vtrecv()
112 	vtlog(VtServerLog, "<font size=-1>%T %s:</font> read packet %p len %d<br>\n", z->addr, p, len);  in _vtrecv()
115 	vtlog(VtServerLog, "<font size=-1>%T %s:</font> error reading packet: %r<br>\n", z->addr);  in _vtrecv()
128 	VtConn *z;  in vtrecvproc()  local
131 	z = v;  in vtrecvproc()
134 	qlock(&z->lk);  in vtrecvproc()
135 	z->readq = q;  in vtrecvproc()
136 	qlock(&z->inlk);  in vtrecvproc()
137 	rwakeup(&z->rpcfork);  in vtrecvproc()
138 	qunlock(&z->lk);  in vtrecvproc()
140 	while((p = _vtrecv(z)) != nil)  in vtrecvproc()
145 	qunlock(&z->inlk);  in vtrecvproc()
146 	qlock(&z->lk);  in vtrecvproc()
151 	z->readq = nil;  in vtrecvproc()
152 	rwakeup(&z->rpcfork);  in vtrecvproc()
153 	qunlock(&z->lk);  in vtrecvproc()
154 	vthangup(z);  in vtrecvproc()
162 	VtConn *z;  in vtsendproc()  local
164 	z = v;  in vtsendproc()
167 	qlock(&z->lk);  in vtsendproc()
168 	z->writeq = q;  in vtsendproc()
169 	qlock(&z->outlk);  in vtsendproc()
170 	rwakeup(&z->rpcfork);  in vtsendproc()
171 	qunlock(&z->lk);  in vtsendproc()
174 		if(_vtsend(z, p) < 0)  in vtsendproc()
176 	qunlock(&z->outlk);  in vtsendproc()
177 	qlock(&z->lk);  in vtsendproc()
182 	z->writeq = nil;  in vtsendproc()
183 	rwakeup(&z->rpcfork);  in vtsendproc()
184 	qunlock(&z->lk);  in vtsendproc()
189 vtrecv(VtConn *z)  in vtrecv()  argument
194 	qlock(&z->lk);  in vtrecv()
195 	if(z->state != VtStateConnected){  in vtrecv()
197 		qunlock(&z->lk);  in vtrecv()
200 	if(z->readq){  in vtrecv()
201 		q = _vtqincref(z->readq);  in vtrecv()
202 		qunlock(&z->lk);  in vtrecv()
208 	qlock(&z->inlk);  in vtrecv()
209 	qunlock(&z->lk);  in vtrecv()
210 	p = _vtrecv(z);  in vtrecv()
211 	qunlock(&z->inlk);  in vtrecv()
213 		vthangup(z);  in vtrecv()
218 vtsend(VtConn *z, Packet *p)  in vtsend()  argument
222 	qlock(&z->lk);  in vtsend()
223 	if(z->state != VtStateConnected){  in vtsend()
226 		qunlock(&z->lk);  in vtsend()
229 	if(z->writeq){  in vtsend()
230 		q = _vtqincref(z->writeq);  in vtsend()
231 		qunlock(&z->lk);  in vtsend()
241 	qlock(&z->outlk);  in vtsend()
242 	qunlock(&z->lk);  in vtsend()
243 	if(_vtsend(z, p) < 0){  in vtsend()
244 		qunlock(&z->outlk);  in vtsend()
245 		vthangup(z);  in vtsend()
248 	qunlock(&z->outlk);  in vtsend()