Skip to content

Commit

Permalink
Fix parse complete msgs order in pipeline mode
Browse files Browse the repository at this point in the history
  • Loading branch information
reshke committed Jan 19, 2024
1 parent 360f52d commit b460820
Showing 1 changed file with 2 additions and 11 deletions.
13 changes: 2 additions & 11 deletions sources/frontend.c
Original file line number Diff line number Diff line change
Expand Up @@ -729,7 +729,7 @@ static od_frontend_status_t od_frontend_remote_server(od_relay_t *relay,

kiwi_be_type_t type = *data;
if (instance->config.log_debug)
od_debug(&instance->logger, "main", client, server, "%s",
od_debug(&instance->logger, "main", client, server, "sending to client %s",
kiwi_be_type_to_string(type));

int is_deploy = od_server_in_deploy(server);
Expand Down Expand Up @@ -784,10 +784,7 @@ static od_frontend_status_t od_frontend_remote_server(od_relay_t *relay,
break;
}
case KIWI_BE_PARSE_COMPLETE:
if (route->rule->pool->reserve_prepared_statement) {
// skip msg
is_deploy = 1;
}
break;
default:
break;
}
Expand Down Expand Up @@ -1302,12 +1299,6 @@ static od_frontend_status_t od_frontend_remote_client(od_relay_t *relay,
machine_msg_free(msg);
}

machine_msg_t *pmsg;
pmsg = kiwi_be_write_parse_complete(NULL);
if (pmsg == NULL) {
return OD_ESERVER_WRITE;
}
rc = od_write(&client->io, pmsg);
forwarded = 1;

if (rc == -1) {
Expand Down

0 comments on commit b460820

Please sign in to comment.