commit - 7e19561a6c511205d64667bb3bf89842678c6f96
commit + d165fa680cba59b60cbe1fe4a0fa8aac92fdef67
blob - a3ea6722b11cb223b5f8d23938696125a1fc6c29
blob + c225d86bff61bc070d0455407a074977fe7370b6
--- src/libmux/mux.c
+++ src/libmux/mux.c
/* actually send the packet */
if(tag < 0 || mux->settag(mux, tx, tag) < 0 || _muxsend(mux, tx) < 0){
qlock(&mux->lk);
+ dequeue(mux, r);
puttag(mux, r);
qunlock(&mux->lk);
return nil;
continue;
}
r2 = mux->wait[tag];
- if(r2 == nil){
+ if(r2 == nil || r2->prev == nil){
fprint(2, "%s: bad rpc tag %ux (no one waiting on that tag)\n", argv0, tag);
/* must leak packet! don't know how to free it! */
continue;
}
r2->p = p;
dequeue(mux, r2);
- puttag(mux, r2);
rwakeup(&r2->r);
}
mux->muxer = 0;
}
//print("finished %p\n", r);
p = r->p;
+ puttag(mux, r);
qunlock(&mux->lk);
return p;
}