Skip to content

Commit 5f7cb5f

Browse files
committed
Fix node id checking in DTM.
1 parent 81a8461 commit 5f7cb5f

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

contrib/pg_xtm/dtmd/src/main.c

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ static char *onbegin(void *client, cmd_t *cmd) {
121121
int node = cmd->argv[i * 2 + 1];
122122
xid_t xid = cmd->argv[i * 2 + 2];
123123

124-
if (node > MAX_NODES) {
124+
if (node >= MAX_NODES) {
125125
shout(
126126
"[%d] BEGIN: wrong 'node'\n",
127127
CLIENT_ID(client)
@@ -171,9 +171,10 @@ static char *onvote(void *client, cmd_t *cmd, int vote) {
171171
);
172172
return strdup("-");
173173
}
174+
174175
int node = cmd->argv[0];
175176
xid_t xid = cmd->argv[1];
176-
if (node > MAX_NODES) {
177+
if (node >= MAX_NODES) {
177178
shout(
178179
"[%d] VOTE: voted about a wrong 'node' (%d)\n",
179180
CLIENT_ID(client), node

0 commit comments

Comments
 (0)