public void sendToken(LoopFactory lf) { inAddrWrite.peer.sendToken(lf); }
public void recvWord(LoopFactory lf) { lf.recvWord(); }
public int getTokensToAbsorb() { return 0; }
+ public int reset(CodeBag ctx, int phase, Destination ackDestination) {
+ // ugly-ass hack
+ if (phase!=0)
+ return DoneNode.doReset(ctx, phase, dock, this, peer, ackDestination, true);
+ return 0;
+ }
protected void build(CodeBag ctx, LoopFactory lf) {
lf = lf.makeNext(0);
lf.abortLoopIfTorpedoPresent();