RepoMirrors/mars
1
0
Fork 0
mirror of https://github.com/schoebel/mars synced 2024-12-26 00:22:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

client: fix communication protocol error

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2014-11-25 17:10:48 +01:00 committed by Thomas Schoebel-Theuer
parent 5c7a3c95cc
commit e4d2567eed
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
kernel/mars_client.c
View File

@ -300,9 +300,20 @@ int receiver_thread(void *data)
struct mref_object *mref = NULL;
unsigned long flags;
if (output->recv_error) {
/* The protocol may be out of sync.
* Consume some data to avoid distributed deadlocks.
*/
(void)mars_recv_raw(&output->socket, &cmd, 0, sizeof(cmd));
wake_up_interruptible(&output->event);
brick_msleep(100);
status = output->recv_error;
continue;
}
status = mars_recv_struct(&output->socket, &cmd, mars_cmd_meta);
MARS_IO("got cmd = %d status = %d\n", cmd.cmd_code, status);
if (status < 0)
if (status <= 0)
goto done;
switch (cmd.cmd_code & CMD_FLAG_MASK) {