From 671f4a60e5306f13fc58310d05efa3b10c88586c Mon Sep 17 00:00:00 2001 From: Sean Hefty Date: Thu, 22 Aug 2013 11:54:56 -0700 Subject: [PATCH] cmtime: Allow user to specify timeout values --- examples/cmtime.c | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/examples/cmtime.c b/examples/cmtime.c index fb6bb192..7342666e 100644 --- a/examples/cmtime.c +++ b/examples/cmtime.c @@ -51,6 +51,7 @@ static struct rdma_event_channel *channel; static char *port = "7471"; static char *dst_addr; static char *src_addr; +static int timeout = 2000; enum step { STEP_CREATE_ID, @@ -374,7 +375,7 @@ static int run_client(void) for (i = 0; i < connections; i++) { start_perf(&nodes[i], STEP_RESOLVE_ADDR); ret = rdma_resolve_addr(nodes[i].id, rai->ai_src_addr, - rai->ai_dst_addr, 2000); + rai->ai_dst_addr, timeout); if (ret) { perror("failure getting addr"); nodes[i].error = 1; @@ -393,7 +394,7 @@ static int run_client(void) if (nodes[i].error) continue; start_perf(&nodes[i], STEP_RESOLVE_ROUTE); - ret = rdma_resolve_route(nodes[i].id, 2000); + ret = rdma_resolve_route(nodes[i].id, timeout); if (ret) { perror("failure resolving route"); nodes[i].error = 1; @@ -464,7 +465,7 @@ int main(int argc, char **argv) hints.ai_port_space = RDMA_PS_TCP; hints.ai_qp_type = IBV_QPT_RC; - while ((op = getopt(argc, argv, "s:b:c:p:")) != -1) { + while ((op = getopt(argc, argv, "s:b:c:p:t:")) != -1) { switch (op) { case 's': dst_addr = optarg; @@ -478,12 +479,16 @@ int main(int argc, char **argv) case 'p': port = optarg; break; + case 't': + timeout = atoi(optarg); + break; default: printf("usage: %s\n", argv[0]); printf("\t[-s server_address]\n"); printf("\t[-b bind_address]\n"); printf("\t[-c connections]\n"); printf("\t[-p port_number]\n"); + printf("\t[-t timeout_ms]\n"); exit(1); } } -- 2.46.0