Commit 13c7bcbb authored by Wayne Davison's avatar Wayne Davison

Output an error before we die if we get a wacko message from the receiver.

parent d48c8065
...@@ -208,13 +208,17 @@ static void read_msg_fd(void) ...@@ -208,13 +208,17 @@ static void read_msg_fd(void)
switch (tag) { switch (tag) {
case MSG_DONE: case MSG_DONE:
if (len != 0) if (len != 0) {
rprintf(FERROR, "invalid message %d:%d\n", tag, len);
exit_cleanup(RERR_STREAMIO); exit_cleanup(RERR_STREAMIO);
}
redo_list_add(-1); redo_list_add(-1);
break; break;
case MSG_REDO: case MSG_REDO:
if (len != 4) if (len != 4) {
rprintf(FERROR, "invalid message %d:%d\n", tag, len);
exit_cleanup(RERR_STREAMIO); exit_cleanup(RERR_STREAMIO);
}
read_loop(fd, buf, 4); read_loop(fd, buf, 4);
redo_list_add(IVAL(buf,0)); redo_list_add(IVAL(buf,0));
break; break;
...@@ -231,6 +235,7 @@ static void read_msg_fd(void) ...@@ -231,6 +235,7 @@ static void read_msg_fd(void)
} }
break; break;
default: default:
rprintf(FERROR, "unknown message %d:%d\n", tag, len);
exit_cleanup(RERR_STREAMIO); exit_cleanup(RERR_STREAMIO);
} }
......
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