Skip to content

Commit

Permalink
Update frontend.c Fixes (#608)
Browse files Browse the repository at this point in the history
* Update frontend.c Fixes

* fix
  • Loading branch information
reshke authored Apr 29, 2024
1 parent 6519d71 commit e23fc56
Showing 1 changed file with 8 additions and 5 deletions.
13 changes: 8 additions & 5 deletions sources/frontend.c
Original file line number Diff line number Diff line change
Expand Up @@ -1670,17 +1670,18 @@ static od_frontend_status_t od_frontend_remote(od_client_t *client)
// are we requested to meet sync point?

if (sync_req) {
od_log(&instance->logger, "sync-point", client, server,
"process, %d", od_server_synchronized(server));
od_debug(&instance->logger, "sync-point", client,
server, "process, %d",
od_server_synchronized(server));

while (1) {
if (od_server_synchronized(server)) {
break;
}
// await here

od_log(&instance->logger, "sync-point", client,
server, "process await");
od_debug(&instance->logger, "sync-point-await",
client, server, "process await");
status = od_frontend_remote_process_server(
server, client, true);

Expand All @@ -1690,6 +1691,8 @@ static od_frontend_status_t od_frontend_remote(od_client_t *client)
}

if (status != OD_OK) {
od_log(&instance->logger, "sync-point", client,
server, "failed to meet sync point");
break;
}

Expand All @@ -1699,7 +1702,7 @@ static od_frontend_status_t od_frontend_remote(od_client_t *client)

/* fill internals structs in */
if (od_frontend_deploy_prepared_stmt_msg(
server, &server->relay, "sync-point",
server, &server->relay, "sync-point-deploy",
server->parse_msg) != OD_OK) {
status = OD_ESERVER_WRITE;
break;
Expand Down

0 comments on commit e23fc56

Please sign in to comment.