diff --git a/examples/5_recovery/bob.c b/examples/5_recovery/bob.c index 0de10465504bc3fc136cb1ee3411d508a2b4df8d..7a74479040060ade4aa184cd7ae04436f646ae45 100644 --- a/examples/5_recovery/bob.c +++ b/examples/5_recovery/bob.c @@ -34,22 +34,20 @@ int main() { printf("Receiving messages [%c, %c]\n", yn[0], yn[1]); if (yn[0] == 'y') check("get first ", connector_get(c, 0)); if (yn[1] == 'y') check("get second ", connector_get(c, 1)); - code = connector_sync(c, 1000); - if (code == 0) printf("sync succeeded!\n"); - else if (code == -1) { - printf("sync failed; state recovered!\n"); - continue; - } else { - printf("Unrecoverable error! code %d\n", code); - connector_dump_log(c); - } - - for (i = 0; i < 2; i++) { - if (yn[i] == 'y') { + if(code >= 0) { + for (i = 0; i < 2; i++) { + if (yn[i] == 'y') { check("read ", connector_gotten(c, i, &msg, &msg_len)); - printf("Got %s msg `%.*s`\n", nth[i], msg_len, msg); + printf("Got %s msg `%.*s`\n", nth[i], msg_len, msg); + } } + } else if(code == -1) { + printf("No interaction! Recovered state.\n"); + } else { + printf("Unrecoverable error!\n"); + connector_dump_log(c); + break; } }