Message msg = DMT.createFNPRejectedOverload(uid, false);
source.sendAsync(msg, null, 0, null);
}
if((waitStatus & RequestSender.WAIT_TRANSFERRING_DATA) != 0) {
Message df = DMT.createFNPCHKDataFound(uid, rs.getHeaders());
<BUG>source.sendAsync(df, null, 0, null);
PartiallyReceivedBlock prb = rs.getPRB();</BUG>
BlockTransmitter bt =
new BlockTransmitter(node.usm, source, uid, prb, node.outputThrottle, this);
node.addTransferringRequestHandler(uid);

Message msg = DMT.createFNPRejectedOverload(uid, false);
source.sendAsync(msg, null, 0, null);
}
if((waitStatus & RequestSender.WAIT_TRANSFERRING_DATA) != 0) {
Message df = DMT.createFNPCHKDataFound(uid, rs.getHeaders());
source.send(df, null);
PartiallyReceivedBlock prb = rs.getPRB();
BlockTransmitter bt =
new BlockTransmitter(node.usm, source, uid, prb, node.outputThrottle, this);
node.addTransferringRequestHandler(uid);
