2 551445b9 2004-04-21 devnull * Sun RPC client.
4 551445b9 2004-04-21 devnull #include <u.h>
5 551445b9 2004-04-21 devnull #include <libc.h>
6 551445b9 2004-04-21 devnull #include <thread.h>
7 551445b9 2004-04-21 devnull #include <sunrpc.h>
9 551445b9 2004-04-21 devnull typedef struct Out Out;
10 551445b9 2004-04-21 devnull struct Out
12 551445b9 2004-04-21 devnull char err[ERRMAX]; /* error string */
13 551445b9 2004-04-21 devnull Channel *creply; /* send to finish rpc */
14 551445b9 2004-04-21 devnull uchar *p; /* pending request packet */
15 551445b9 2004-04-21 devnull int n; /* size of request */
16 551445b9 2004-04-21 devnull ulong tag; /* flush tag of pending request */
17 551445b9 2004-04-21 devnull ulong xid; /* xid of pending request */
18 551445b9 2004-04-21 devnull ulong st; /* first send time */
19 551445b9 2004-04-21 devnull ulong t; /* resend time */
20 551445b9 2004-04-21 devnull int nresend; /* number of resends */
21 551445b9 2004-04-21 devnull SunRpc rpc; /* response rpc */
24 551445b9 2004-04-21 devnull static void
25 551445b9 2004-04-21 devnull udpThread(void *v)
27 551445b9 2004-04-21 devnull uchar *p, *buf;
28 551445b9 2004-04-21 devnull Ioproc *io;
30 551445b9 2004-04-21 devnull SunClient *cli;
31 551445b9 2004-04-21 devnull enum { BufSize = 65536 };
34 551445b9 2004-04-21 devnull buf = emalloc(BufSize);
35 551445b9 2004-04-21 devnull io = ioproc();
38 551445b9 2004-04-21 devnull n = ioread(io, cli->fd, buf, BufSize);
39 551445b9 2004-04-21 devnull if(n <= 0)
41 551445b9 2004-04-21 devnull p = emalloc(4+n);
42 551445b9 2004-04-21 devnull memmove(p+4, buf, n);
43 551445b9 2004-04-21 devnull p[0] = n>>24;
44 551445b9 2004-04-21 devnull p[1] = n>>16;
45 551445b9 2004-04-21 devnull p[2] = n>>8;
46 551445b9 2004-04-21 devnull p[3] = n;
47 551445b9 2004-04-21 devnull if(sendp(cli->readchan, p) == 0)
52 551445b9 2004-04-21 devnull closeioproc(io);
53 551445b9 2004-04-21 devnull while(send(cli->dying, nil) == -1)
57 551445b9 2004-04-21 devnull static void
58 551445b9 2004-04-21 devnull netThread(void *v)
60 551445b9 2004-04-21 devnull uchar *p, buf[4];
61 551445b9 2004-04-21 devnull Ioproc *io;
62 551445b9 2004-04-21 devnull uint n, tot;
63 551445b9 2004-04-21 devnull int done;
64 551445b9 2004-04-21 devnull SunClient *cli;
67 551445b9 2004-04-21 devnull io = ioproc();
71 551445b9 2004-04-21 devnull n = ioreadn(io, cli->fd, buf, 4);
72 551445b9 2004-04-21 devnull if(n != 4)
74 551445b9 2004-04-21 devnull n = (buf[0]<<24)|(buf[1]<<16)|(buf[2]<<8)|buf[3];
75 551445b9 2004-04-21 devnull if(cli->chatty)
76 551445b9 2004-04-21 devnull fprint(2, "%.8ux...", n);
77 551445b9 2004-04-21 devnull done = n&0x80000000;
78 551445b9 2004-04-21 devnull n &= ~0x80000000;
79 551445b9 2004-04-21 devnull if(tot == 0){
80 551445b9 2004-04-21 devnull p = emalloc(4+n);
83 551445b9 2004-04-21 devnull p = erealloc(p, tot+n);
84 551445b9 2004-04-21 devnull if(ioreadn(io, cli->fd, p+tot, n) != n)
86 551445b9 2004-04-21 devnull tot += n;
87 551445b9 2004-04-21 devnull if(done){
88 551445b9 2004-04-21 devnull p[0] = tot>>24;
89 551445b9 2004-04-21 devnull p[1] = tot>>16;
90 551445b9 2004-04-21 devnull p[2] = tot>>8;
91 551445b9 2004-04-21 devnull p[3] = tot;
92 551445b9 2004-04-21 devnull if(sendp(cli->readchan, p) == 0)
99 551445b9 2004-04-21 devnull closeioproc(io);
100 551445b9 2004-04-21 devnull while(send(cli->dying, 0) == -1)
104 551445b9 2004-04-21 devnull static void
105 551445b9 2004-04-21 devnull timerThread(void *v)
107 551445b9 2004-04-21 devnull Ioproc *io;
108 551445b9 2004-04-21 devnull SunClient *cli;
110 551445b9 2004-04-21 devnull cli = v;
111 551445b9 2004-04-21 devnull io = ioproc();
112 551445b9 2004-04-21 devnull for(;;){
113 551445b9 2004-04-21 devnull if(iosleep(io, 200) < 0)
115 551445b9 2004-04-21 devnull if(sendul(cli->timerchan, 0) == 0)
118 551445b9 2004-04-21 devnull closeioproc(io);
119 551445b9 2004-04-21 devnull while(send(cli->dying, 0) == -1)
123 551445b9 2004-04-21 devnull static ulong
124 551445b9 2004-04-21 devnull msec(void)
126 551445b9 2004-04-21 devnull return nsec()/1000000;
129 551445b9 2004-04-21 devnull static ulong
130 551445b9 2004-04-21 devnull twait(ulong rtt, int nresend)
132 551445b9 2004-04-21 devnull ulong t;
134 551445b9 2004-04-21 devnull t = rtt;
135 551445b9 2004-04-21 devnull if(nresend <= 1)
137 551445b9 2004-04-21 devnull else if(nresend <= 3)
139 551445b9 2004-04-21 devnull else if(nresend <= 18)
140 551445b9 2004-04-21 devnull t <<= nresend-2;
142 551445b9 2004-04-21 devnull t = 60*1000;
143 551445b9 2004-04-21 devnull if(t > 60*1000)
144 551445b9 2004-04-21 devnull t = 60*1000;
146 551445b9 2004-04-21 devnull return t;
149 551445b9 2004-04-21 devnull static void
150 551445b9 2004-04-21 devnull rpcMuxThread(void *v)
152 551445b9 2004-04-21 devnull uchar *buf, *p, *ep;
153 551445b9 2004-04-21 devnull int i, n, nout, mout;
154 551445b9 2004-04-21 devnull ulong t, xidgen, tag;
155 551445b9 2004-04-21 devnull Alt a[5];
156 551445b9 2004-04-21 devnull Out *o, **out;
157 551445b9 2004-04-21 devnull SunRpc rpc;
158 551445b9 2004-04-21 devnull SunClient *cli;
159 4c06b8ee 2005-05-19 devnull SunStatus ok;
161 551445b9 2004-04-21 devnull cli = v;
162 551445b9 2004-04-21 devnull mout = 16;
163 551445b9 2004-04-21 devnull nout = 0;
164 551445b9 2004-04-21 devnull out = emalloc(mout*sizeof(out[0]));
165 551445b9 2004-04-21 devnull xidgen = truerand();
167 551445b9 2004-04-21 devnull a[0].op = CHANRCV;
168 551445b9 2004-04-21 devnull a[0].c = cli->rpcchan;
169 551445b9 2004-04-21 devnull a[0].v = &o;
170 551445b9 2004-04-21 devnull a[1].op = CHANNOP;
171 551445b9 2004-04-21 devnull a[1].c = cli->timerchan;
172 551445b9 2004-04-21 devnull a[1].v = nil;
173 551445b9 2004-04-21 devnull a[2].op = CHANRCV;
174 551445b9 2004-04-21 devnull a[2].c = cli->flushchan;
175 551445b9 2004-04-21 devnull a[2].v = &tag;
176 551445b9 2004-04-21 devnull a[3].op = CHANRCV;
177 551445b9 2004-04-21 devnull a[3].c = cli->readchan;
178 551445b9 2004-04-21 devnull a[3].v = &buf;
179 551445b9 2004-04-21 devnull a[4].op = CHANEND;
181 551445b9 2004-04-21 devnull for(;;){
182 551445b9 2004-04-21 devnull switch(alt(a)){
183 551445b9 2004-04-21 devnull case 0: /* o = <-rpcchan */
184 551445b9 2004-04-21 devnull if(o == nil)
185 551445b9 2004-04-21 devnull goto Done;
186 551445b9 2004-04-21 devnull cli->nsend++;
187 551445b9 2004-04-21 devnull /* set xid */
188 551445b9 2004-04-21 devnull o->xid = ++xidgen;
189 551445b9 2004-04-21 devnull if(cli->needcount)
190 551445b9 2004-04-21 devnull p = o->p+4;
192 551445b9 2004-04-21 devnull p = o->p;
193 551445b9 2004-04-21 devnull p[0] = xidgen>>24;
194 551445b9 2004-04-21 devnull p[1] = xidgen>>16;
195 551445b9 2004-04-21 devnull p[2] = xidgen>>8;
196 551445b9 2004-04-21 devnull p[3] = xidgen;
197 551445b9 2004-04-21 devnull if(write(cli->fd, o->p, o->n) != o->n){
198 551445b9 2004-04-21 devnull free(o->p);
199 551445b9 2004-04-21 devnull o->p = nil;
200 551445b9 2004-04-21 devnull snprint(o->err, sizeof o->err, "write: %r");
201 551445b9 2004-04-21 devnull sendp(o->creply, 0);
204 551445b9 2004-04-21 devnull if(nout >= mout){
205 551445b9 2004-04-21 devnull mout *= 2;
206 551445b9 2004-04-21 devnull out = erealloc(out, mout*sizeof(out[0]));
208 551445b9 2004-04-21 devnull o->st = msec();
209 551445b9 2004-04-21 devnull o->nresend = 0;
210 551445b9 2004-04-21 devnull o->t = o->st + twait(cli->rtt.avg, 0);
211 551445b9 2004-04-21 devnull if(cli->chatty) fprint(2, "send %lux %lud %lud\n", o->xid, o->st, o->t);
212 551445b9 2004-04-21 devnull out[nout++] = o;
213 551445b9 2004-04-21 devnull a[1].op = CHANRCV;
216 551445b9 2004-04-21 devnull case 1: /* <-timerchan */
217 551445b9 2004-04-21 devnull t = msec();
218 551445b9 2004-04-21 devnull for(i=0; i<nout; i++){
219 551445b9 2004-04-21 devnull o = out[i];
220 551445b9 2004-04-21 devnull if((int)(t - o->t) > 0){
221 551445b9 2004-04-21 devnull if(cli->chatty) fprint(2, "resend %lux %lud %lud\n", o->xid, t, o->t);
222 551445b9 2004-04-21 devnull if(cli->maxwait && t - o->st >= cli->maxwait){
223 551445b9 2004-04-21 devnull free(o->p);
224 551445b9 2004-04-21 devnull o->p = nil;
225 551445b9 2004-04-21 devnull strcpy(o->err, "timeout");
226 551445b9 2004-04-21 devnull sendp(o->creply, 0);
227 551445b9 2004-04-21 devnull out[i--] = out[--nout];
228 551445b9 2004-04-21 devnull continue;
230 551445b9 2004-04-21 devnull cli->nresend++;
231 551445b9 2004-04-21 devnull o->nresend++;
232 551445b9 2004-04-21 devnull o->t = t + twait(cli->rtt.avg, o->nresend);
233 551445b9 2004-04-21 devnull if(write(cli->fd, o->p, o->n) != o->n){
234 551445b9 2004-04-21 devnull free(o->p);
235 551445b9 2004-04-21 devnull o->p = nil;
236 551445b9 2004-04-21 devnull snprint(o->err, sizeof o->err, "rewrite: %r");
237 551445b9 2004-04-21 devnull sendp(o->creply, 0);
238 551445b9 2004-04-21 devnull out[i--] = out[--nout];
239 551445b9 2004-04-21 devnull continue;
243 551445b9 2004-04-21 devnull /* stop ticking if no work; rpcchan will turn it back on */
244 551445b9 2004-04-21 devnull if(nout == 0)
245 551445b9 2004-04-21 devnull a[1].op = CHANNOP;
248 551445b9 2004-04-21 devnull case 2: /* tag = <-flushchan */
249 551445b9 2004-04-21 devnull for(i=0; i<nout; i++){
250 551445b9 2004-04-21 devnull o = out[i];
251 551445b9 2004-04-21 devnull if(o->tag == tag){
252 551445b9 2004-04-21 devnull out[i--] = out[--nout];
253 551445b9 2004-04-21 devnull strcpy(o->err, "flushed");
254 551445b9 2004-04-21 devnull free(o->p);
255 551445b9 2004-04-21 devnull o->p = nil;
256 551445b9 2004-04-21 devnull sendp(o->creply, 0);
261 551445b9 2004-04-21 devnull case 3: /* buf = <-readchan */
262 551445b9 2004-04-21 devnull p = buf;
263 551445b9 2004-04-21 devnull n = (p[0]<<24)|(p[1]<<16)|(p[2]<<8)|p[3];
265 551445b9 2004-04-21 devnull ep = p+n;
266 4c06b8ee 2005-05-19 devnull if((ok = sunrpcunpack(p, ep, &p, &rpc)) != SunSuccess){
267 551445b9 2004-04-21 devnull fprint(2, "%s: in: %.*H unpack failed\n", argv0, n, buf+4);
268 551445b9 2004-04-21 devnull free(buf);
271 551445b9 2004-04-21 devnull if(cli->chatty)
272 551445b9 2004-04-21 devnull fprint(2, "in: %B\n", &rpc);
273 551445b9 2004-04-21 devnull if(rpc.iscall){
274 551445b9 2004-04-21 devnull fprint(2, "did not get reply\n");
275 551445b9 2004-04-21 devnull free(buf);
278 551445b9 2004-04-21 devnull o = nil;
279 551445b9 2004-04-21 devnull for(i=0; i<nout; i++){
280 551445b9 2004-04-21 devnull o = out[i];
281 551445b9 2004-04-21 devnull if(o->xid == rpc.xid)
284 551445b9 2004-04-21 devnull if(i==nout){
285 551445b9 2004-04-21 devnull if(cli->chatty) fprint(2, "did not find waiting request\n");
286 551445b9 2004-04-21 devnull free(buf);
289 551445b9 2004-04-21 devnull out[i] = out[--nout];
290 551445b9 2004-04-21 devnull free(o->p);
291 551445b9 2004-04-21 devnull o->p = nil;
292 4c06b8ee 2005-05-19 devnull o->rpc = rpc;
293 551445b9 2004-04-21 devnull if(rpc.status == SunSuccess){
294 551445b9 2004-04-21 devnull o->p = buf;
296 551445b9 2004-04-21 devnull o->p = nil;
297 551445b9 2004-04-21 devnull free(buf);
298 551445b9 2004-04-21 devnull sunerrstr(rpc.status);
299 551445b9 2004-04-21 devnull rerrstr(o->err, sizeof o->err);
301 551445b9 2004-04-21 devnull sendp(o->creply, 0);
306 551445b9 2004-04-21 devnull free(out);
307 551445b9 2004-04-21 devnull sendp(cli->dying, 0);
310 551445b9 2004-04-21 devnull SunClient*
311 551445b9 2004-04-21 devnull sundial(char *address)
314 551445b9 2004-04-21 devnull SunClient *cli;
316 551445b9 2004-04-21 devnull if((fd = dial(address, 0, 0, 0)) < 0)
317 551445b9 2004-04-21 devnull return nil;
319 551445b9 2004-04-21 devnull cli = emalloc(sizeof(SunClient));
320 551445b9 2004-04-21 devnull cli->fd = fd;
321 551445b9 2004-04-21 devnull cli->maxwait = 15000;
322 551445b9 2004-04-21 devnull cli->rtt.avg = 1000;
323 551445b9 2004-04-21 devnull cli->dying = chancreate(sizeof(void*), 0);
324 551445b9 2004-04-21 devnull cli->rpcchan = chancreate(sizeof(Out*), 0);
325 551445b9 2004-04-21 devnull cli->timerchan = chancreate(sizeof(ulong), 0);
326 551445b9 2004-04-21 devnull cli->flushchan = chancreate(sizeof(ulong), 0);
327 551445b9 2004-04-21 devnull cli->readchan = chancreate(sizeof(uchar*), 0);
328 551445b9 2004-04-21 devnull if(strstr(address, "udp!")){
329 551445b9 2004-04-21 devnull cli->needcount = 0;
330 551445b9 2004-04-21 devnull cli->nettid = threadcreate(udpThread, cli, SunStackSize);
331 551445b9 2004-04-21 devnull cli->timertid = threadcreate(timerThread, cli, SunStackSize);
333 551445b9 2004-04-21 devnull cli->needcount = 1;
334 551445b9 2004-04-21 devnull cli->nettid = threadcreate(netThread, cli, SunStackSize);
335 551445b9 2004-04-21 devnull /* assume reliable: don't need timer */
336 551445b9 2004-04-21 devnull /* BUG: netThread should know how to redial */
338 551445b9 2004-04-21 devnull threadcreate(rpcMuxThread, cli, SunStackSize);
340 551445b9 2004-04-21 devnull return cli;
344 551445b9 2004-04-21 devnull sunclientclose(SunClient *cli)
349 551445b9 2004-04-21 devnull * Threadints get you out of any stuck system calls
350 551445b9 2004-04-21 devnull * or thread rendezvouses, but do nothing if the thread
351 551445b9 2004-04-21 devnull * is in the ready state. Keep interrupting until it takes.
354 551445b9 2004-04-21 devnull if(!cli->timertid)
356 551445b9 2004-04-21 devnull while(n < 2){
358 d7b202df 2005-07-13 devnull threadint(cli->nettid);
359 d7b202df 2005-07-13 devnull if(cli->timertid)
360 d7b202df 2005-07-13 devnull threadint(cli->timertid);
363 551445b9 2004-04-21 devnull yield();
364 551445b9 2004-04-21 devnull while(nbrecv(cli->dying, nil) == 1)
368 551445b9 2004-04-21 devnull sendp(cli->rpcchan, 0);
369 551445b9 2004-04-21 devnull recvp(cli->dying);
371 551445b9 2004-04-21 devnull /* everyone's gone: clean up */
372 551445b9 2004-04-21 devnull close(cli->fd);
373 551445b9 2004-04-21 devnull chanfree(cli->flushchan);
374 551445b9 2004-04-21 devnull chanfree(cli->readchan);
375 551445b9 2004-04-21 devnull chanfree(cli->timerchan);
376 551445b9 2004-04-21 devnull free(cli);
380 551445b9 2004-04-21 devnull sunclientflushrpc(SunClient *cli, ulong tag)
382 551445b9 2004-04-21 devnull sendul(cli->flushchan, tag);
386 551445b9 2004-04-21 devnull sunclientprog(SunClient *cli, SunProg *p)
388 551445b9 2004-04-21 devnull if(cli->nprog%16 == 0)
389 551445b9 2004-04-21 devnull cli->prog = erealloc(cli->prog, (cli->nprog+16)*sizeof(cli->prog[0]));
390 551445b9 2004-04-21 devnull cli->prog[cli->nprog++] = p;
394 551445b9 2004-04-21 devnull sunclientrpc(SunClient *cli, ulong tag, SunCall *tx, SunCall *rx, uchar **tofree)
396 551445b9 2004-04-21 devnull uchar *bp, *p, *ep;
397 551445b9 2004-04-21 devnull int i, n1, n2, n, nn;
399 551445b9 2004-04-21 devnull SunProg *prog;
400 551445b9 2004-04-21 devnull SunStatus ok;
402 551445b9 2004-04-21 devnull for(i=0; i<cli->nprog; i++)
403 551445b9 2004-04-21 devnull if(cli->prog[i]->prog == tx->rpc.prog && cli->prog[i]->vers == tx->rpc.vers)
405 551445b9 2004-04-21 devnull if(i==cli->nprog){
406 551445b9 2004-04-21 devnull werrstr("unknown sun rpc program %d version %d", tx->rpc.prog, tx->rpc.vers);
407 551445b9 2004-04-21 devnull return -1;
409 551445b9 2004-04-21 devnull prog = cli->prog[i];
411 551445b9 2004-04-21 devnull if(cli->chatty){
412 551445b9 2004-04-21 devnull fprint(2, "out: %B\n", &tx->rpc);
413 551445b9 2004-04-21 devnull fprint(2, "\t%C\n", tx);
416 551445b9 2004-04-21 devnull n1 = sunrpcsize(&tx->rpc);
417 551445b9 2004-04-21 devnull n2 = suncallsize(prog, tx);
419 551445b9 2004-04-21 devnull n = n1+n2;
420 551445b9 2004-04-21 devnull if(cli->needcount)
424 551445b9 2004-04-21 devnull * The dance with 100 is to leave some padding in case
425 551445b9 2004-04-21 devnull * suncallsize is slightly underestimating. If this happens,
426 551445b9 2004-04-21 devnull * the pack will succeed and then we can give a good size
427 551445b9 2004-04-21 devnull * mismatch error below. Otherwise the pack fails with
428 551445b9 2004-04-21 devnull * garbage args, which is less helpful.
430 551445b9 2004-04-21 devnull bp = emalloc(n+100);
431 551445b9 2004-04-21 devnull ep = bp+n+100;
433 551445b9 2004-04-21 devnull if(cli->needcount){
434 551445b9 2004-04-21 devnull nn = n-4;
435 551445b9 2004-04-21 devnull p[0] = (nn>>24)|0x80;
436 551445b9 2004-04-21 devnull p[1] = nn>>16;
437 551445b9 2004-04-21 devnull p[2] = nn>>8;
438 551445b9 2004-04-21 devnull p[3] = nn;
441 551445b9 2004-04-21 devnull if((ok = sunrpcpack(p, ep, &p, &tx->rpc)) != SunSuccess
442 551445b9 2004-04-21 devnull || (ok = suncallpack(prog, p, ep, &p, tx)) != SunSuccess){
443 551445b9 2004-04-21 devnull sunerrstr(ok);
444 551445b9 2004-04-21 devnull free(bp);
445 551445b9 2004-04-21 devnull return -1;
447 551445b9 2004-04-21 devnull ep -= 100;
448 551445b9 2004-04-21 devnull if(p != ep){
449 551445b9 2004-04-21 devnull werrstr("rpc: packet size mismatch %d %ld %ld", n, ep-bp, p-bp);
450 551445b9 2004-04-21 devnull free(bp);
451 551445b9 2004-04-21 devnull return -1;
454 551445b9 2004-04-21 devnull memset(&o, 0, sizeof o);
455 551445b9 2004-04-21 devnull o.creply = chancreate(sizeof(void*), 0);
456 551445b9 2004-04-21 devnull o.tag = tag;
457 551445b9 2004-04-21 devnull o.p = bp;
458 551445b9 2004-04-21 devnull o.n = n;
460 551445b9 2004-04-21 devnull sendp(cli->rpcchan, &o);
461 551445b9 2004-04-21 devnull recvp(o.creply);
462 551445b9 2004-04-21 devnull chanfree(o.creply);
464 551445b9 2004-04-21 devnull if(o.p == nil){
465 551445b9 2004-04-21 devnull werrstr("%s", o.err);
466 551445b9 2004-04-21 devnull return -1;
469 551445b9 2004-04-21 devnull p = o.rpc.data;
470 551445b9 2004-04-21 devnull ep = p+o.rpc.ndata;
471 551445b9 2004-04-21 devnull rx->rpc = o.rpc;
472 551445b9 2004-04-21 devnull rx->rpc.proc = tx->rpc.proc;
473 551445b9 2004-04-21 devnull rx->rpc.prog = tx->rpc.prog;
474 551445b9 2004-04-21 devnull rx->rpc.vers = tx->rpc.vers;
475 551445b9 2004-04-21 devnull rx->type = (rx->rpc.proc<<1)|1;
476 4c06b8ee 2005-05-19 devnull if(rx->rpc.status != SunSuccess){
477 4c06b8ee 2005-05-19 devnull sunerrstr(rx->rpc.status);
478 4c06b8ee 2005-05-19 devnull werrstr("unpack: %r");
479 4c06b8ee 2005-05-19 devnull free(o.p);
480 4c06b8ee 2005-05-19 devnull return -1;
483 551445b9 2004-04-21 devnull if((ok = suncallunpack(prog, p, ep, &p, rx)) != SunSuccess){
484 551445b9 2004-04-21 devnull sunerrstr(ok);
485 551445b9 2004-04-21 devnull werrstr("unpack: %r");
486 551445b9 2004-04-21 devnull free(o.p);
487 551445b9 2004-04-21 devnull return -1;
490 551445b9 2004-04-21 devnull if(cli->chatty){
491 551445b9 2004-04-21 devnull fprint(2, "in: %B\n", &rx->rpc);
492 551445b9 2004-04-21 devnull fprint(2, "in:\t%C\n", rx);
495 551445b9 2004-04-21 devnull if(tofree)
496 551445b9 2004-04-21 devnull *tofree = o.p;
498 551445b9 2004-04-21 devnull free(o.p);
500 551445b9 2004-04-21 devnull return 0;