case MSG_BYTES: {
if (status == Status.MORE) {
status = StreamUtils.readWord(input, b);
final String sourceProcess = b.toString();
if (status == Status.MORE) {
<BUG>CheckedBytes cb = StreamUtils.readCheckedBytes(input);
try {</BUG>
handler.handleMessage(sourceProcess, 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) {
CheckedBytes cb = StreamUtils.readCheckedBytes(input);
status = cb.getStatus();
if (cb.getChecksum() != cb.getExpectedChecksum()) {
