case MSG_BYTES: {
if (status == Status.MORE) {
status = StreamUtils.readWord(input, b);
final String sourceProcess = b.toString();
if (status == Status.MORE) {
<BUG>StreamUtils.CheckedBytes cb = StreamUtils.readCheckedBytes(input);
try {</BUG>
handler.handleMessage(cb.getBytes());
<BUG>} catch (Throwable t) {
}</BUG>
}

case MSG_BYTES: {
if (status == Status.MORE) {
status = StreamUtils.readWord(input, b);
final String sourceProcess = b.toString();
if (status == Status.MORE) {
StreamUtils.CheckedBytes cb = StreamUtils.readCheckedBytes(input);
status = cb.getStatus();
if (cb.getChecksum() != cb.getExpectedChecksum()) {
logger.error("Incorrect checksum from process " + sourceProcess);
