Commit 164faae8 authored by Wayne Davison's avatar Wayne Davison

Improve handling of MSG_IO_ERROR message.

parent de6ab501
...@@ -1405,12 +1405,12 @@ static void read_a_msg(void) ...@@ -1405,12 +1405,12 @@ static void read_a_msg(void)
got_flist_entry_status(FES_REDO, val); got_flist_entry_status(FES_REDO, val);
break; break;
case MSG_IO_ERROR: case MSG_IO_ERROR:
if (msg_bytes != 4 || am_sender) if (msg_bytes != 4)
goto invalid_msg; goto invalid_msg;
val = raw_read_int(); val = raw_read_int();
iobuf.in_multiplexed = 1; iobuf.in_multiplexed = 1;
io_error |= val; io_error |= val;
if (!am_generator) if (am_receiver)
send_msg_int(MSG_IO_ERROR, val); send_msg_int(MSG_IO_ERROR, val);
break; break;
case MSG_IO_TIMEOUT: case MSG_IO_TIMEOUT:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment