@@ -1195,7 +1195,7 @@ void MtmUpdateNodeConnStr(int nodeId, char const* connStr)
1195
1195
elog (ERROR , "Host not specified in connection string: '%s'" , connStr );
1196
1196
}
1197
1197
host += 5 ;
1198
- for (end = host ; * end != ' ' && * end != ',' && * end != ' \0' ; end ++ );
1198
+ for (end = host ; * end != ' ' && * end != '\0' ; end ++ );
1199
1199
hostLen = end - host ;
1200
1200
if (hostLen >= MULTIMASTER_MAX_HOST_NAME_SIZE ) {
1201
1201
elog (ERROR , "Too long (%d) host name '%.*s' for node %d, limit is %d" ,
@@ -1229,7 +1229,7 @@ static void MtmSplitConnStrs(void)
1229
1229
elog (ERROR , "Database not specified in connection string: '%s'" , connStr );
1230
1230
}
1231
1231
dbName += 7 ;
1232
- for (end = dbName ; * end != ' ' && * end != ',' && * end != ' \0' ; end ++ );
1232
+ for (end = dbName ; * end != ' ' && * end != '\0' ; end ++ );
1233
1233
len = end - dbName ;
1234
1234
MtmDatabaseName = (char * )malloc (len + 1 );
1235
1235
memcpy (MtmDatabaseName , dbName , len );
@@ -1242,6 +1242,9 @@ static void MtmSplitConnStrs(void)
1242
1242
elog (ERROR , "Multimaster should have at least two nodes" );
1243
1243
}
1244
1244
MtmNodes = i ;
1245
+ if (MtmNodeId > MtmNodes ) {
1246
+ elog (ERROR , "Invalid node id %d for specified nubmer of nodes %d" , MtmNodeId , MtmNodes );
1247
+ }
1245
1248
}
1246
1249
1247
1250
void
@@ -1353,7 +1356,7 @@ _PG_init(void)
1353
1356
"Multimaster node ID" ,
1354
1357
NULL ,
1355
1358
& MtmNodeId ,
1356
- 1 ,
1359
+ INT_MAX ,
1357
1360
1 ,
1358
1361
INT_MAX ,
1359
1362
PGC_BACKEND ,
0 commit comments