From: maxim Date: Mon, 12 Nov 2007 13:10:47 +0000 (+0000) Subject: b=14127 X-Git-Tag: v1_7_0_51~513 X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=commitdiff_plain;h=f1c11f6d982b9c60f2c917059acaa12bcb15dde6 b=14127 i=isaac i=liang Minor enhancement allowing lstclient to accept incoming connections. --- diff --git a/lnet/selftest/rpc.c b/lnet/selftest/rpc.c index dcd3b49..2b17e55 100644 --- a/lnet/selftest/rpc.c +++ b/lnet/selftest/rpc.c @@ -1587,7 +1587,10 @@ srpc_startup (void) #ifdef __KERNEL__ rc = LNetNIInit(LUSTRE_SRV_LNET_PID); #else - rc = LNetNIInit(getpid() | LNET_PID_USERFLAG); + if (the_lnet.ln_server_mode_flag) + rc = LNetNIInit(LUSTRE_SRV_LNET_PID); + else + rc = LNetNIInit(getpid() | LNET_PID_USERFLAG); #endif if (rc < 0) { CERROR ("LNetNIInit() has failed: %d\n", rc); diff --git a/lnet/utils/lstclient.c b/lnet/utils/lstclient.c index 5ab4dcd..ec52175 100644 --- a/lnet/utils/lstclient.c +++ b/lnet/utils/lstclient.c @@ -23,9 +23,10 @@ unsigned int libcfs_debug = 0; static struct option lstjn_options[] = { - {"sesid", required_argument, 0, 's' }, - {"group", required_argument, 0, 'g' }, - {0, 0, 0, 0 } + {"sesid", required_argument, 0, 's' }, + {"group", required_argument, 0, 'g' }, + {"server_mode", no_argument, 0, 'm' }, + {0, 0, 0, 0 } }; void @@ -126,12 +127,16 @@ main(int argc, char **argv) { char *ses = NULL; char *grp = NULL; + int server_mode_flag = 0; int optidx; int c; int rc; + const char *usage_string = + "Usage: lstclient --sesid ID --group GROUP [--server_mode]\n"; + while (1) { - c = getopt_long(argc, argv, "s:g:", + c = getopt_long(argc, argv, "s:g:m", lstjn_options, &optidx); if (c == -1) @@ -144,15 +149,17 @@ main(int argc, char **argv) case 'g': grp = optarg; break; + case 'm': + server_mode_flag = 1; + break; default: - fprintf(stderr, - "Usage: lstclient --sesid ID --group GROUP\n"); + fprintf(stderr, usage_string); return -1; } } if (optind != argc || grp == NULL || ses == NULL) { - fprintf(stderr, "Usage: lstclient --sesid ID --group GROUP\n"); + fprintf(stderr, usage_string); return -1; } @@ -169,6 +176,9 @@ main(int argc, char **argv) return -1; } + if (server_mode_flag) + lnet_server_mode(); + rc = lnet_selftest_init(); if (rc != 0) { fprintf(stderr, "Can't startup selftest\n");