stv0g/Criterion
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

protocol: Loop on FSM errors

Browse source
This commit is contained in:
Snaipe 2016-04-25 22:45:39 +02:00
parent 7c8c38d983
commit 33d4d3c9f1
1 changed files with 11 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/protocol/messages.c
View file

@ -91,12 +91,18 @@ void cr_send_to_runner(const criterion_protocol_msg *message) {
}
unsigned char *buf = NULL;
int read = nn_recv(g_client_socket, &buf, NN_MSG, 0);
int read = 0;
if (read <= 0) {
criterion_perror("Could not read ack: %s.\n", nn_strerror(errno));
abort();
}
do {
read = nn_recv(g_client_socket, &buf, NN_MSG, 0);
if (read <= 0) {
if (read == -1 && errno == EFSM)
continue;
criterion_perror("Could not read ack: %s.\n", nn_strerror(errno));
abort();
}
} while (read > 0);
criterion_protocol_ack ack;
pb_istream_t stream = pb_istream_from_buffer(buf, read);