o5r/plan9port
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

better errors

Browse source
This commit is contained in:
rsc 2005-07-13 10:51:30 +00:00
parent 2d70c581f4
commit a28c0548f4
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/libmux/mux.c
View file

@ -35,8 +35,10 @@ muxrpc(Mux *mux, void *tx)
/* must malloc because stack could be private */ /* must malloc because stack could be private */
r = mallocz(sizeof(Muxrpc), 1); r = mallocz(sizeof(Muxrpc), 1);
if(r == nil) if(r == nil){
werrstr("mallocz: %r");
return nil; return nil;
}
r->r.l = &mux->lk; r->r.l = &mux->lk;
/* assign the tag, add selves to response queue */ /* assign the tag, add selves to response queue */
@ -48,6 +50,8 @@ muxrpc(Mux *mux, void *tx)
/* actually send the packet */ /* actually send the packet */
if(tag < 0 || mux->settag(mux, tx, tag) < 0 || _muxsend(mux, tx) < 0){ if(tag < 0 || mux->settag(mux, tx, tag) < 0 || _muxsend(mux, tx) < 0){
werrstr("settag/send tag %d: %r", tag);
fprint(2, "%r\n");
qlock(&mux->lk); qlock(&mux->lk);
dequeue(mux, r); dequeue(mux, r);
puttag(mux, r); puttag(mux, r);
@ -105,6 +109,8 @@ muxrpc(Mux *mux, void *tx)
p = r->p; p = r->p;
puttag(mux, r); puttag(mux, r);
qunlock(&mux->lk); qunlock(&mux->lk);
if(p == nil)
werrstr("unexpected eof");
return p; return p;
} }