Skip to content

Commit e960b9c

Browse files
committed
Fix sockhub_main
1 parent a68fabf commit e960b9c

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

contrib/pg_dtm/sockhub/sockhub_main.c

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,7 @@ int main(int argc, char* argv[])
1414
if (argv[i][0] == '-') {
1515
switch (argv[i][1]) {
1616
case 'h':
17-
params.host = argv[++i];
18-
continue;
19-
case 'p':
20-
params.port = atoi(argv[++i]);
17+
ShubParamsSetHosts(&params, argv[++i]);
2118
continue;
2219
case 'f':
2320
params.file = argv[++i];
@@ -36,8 +33,7 @@ int main(int argc, char* argv[])
3633
Usage:
3734
fprintf(stderr, "sockhub: combine several local unix socket connections into one inet socket\n"
3835
"Options:\n"
39-
"\t-h HOST\tremote host name\n"
40-
"\t-p PORT\tremote port\n"
36+
"\t-h HOST:PORT\tremote address\n"
4137
"\t-f FILE\tunix socket file name\n"
4238
"\t-d DELAY\tdelay for waiting income requests (milliseconds)\n"
4339
"\t-b SIZE\tbuffer size\n"
@@ -47,7 +43,7 @@ int main(int argc, char* argv[])
4743

4844
return 1;
4945
}
50-
if (params.host == NULL || params.file == NULL || i != argc) {
46+
if (params.leader == NULL || params.file == NULL || i != argc) {
5147
goto Usage;
5248
}
5349

0 commit comments

Comments
 (0)