static int connections = 1;
static int message_size = 100;
static int message_count = 10;
+static uint16_t port = 7471;
static uint8_t set_tos = 0;
static uint8_t tos;
static uint8_t migrate = 0;
} else
test.src_in.sin_family = PF_INET;
- test.src_in.sin_port = 7471;
+ test.src_in.sin_port = port;
ret = rdma_bind_addr(listen_id, test.src_addr);
if (ret) {
printf("cmatose: bind address failed: %d\n", ret);
if (ret)
return ret;
- test.dst_in.sin_port = 7471;
+ test.dst_in.sin_port = port;
printf("cmatose: connecting\n");
for (i = 0; i < connections; i++) {
{
int op, ret;
- while ((op = getopt(argc, argv, "s:b:c:C:S:t:m")) != -1) {
+ while ((op = getopt(argc, argv, "s:b:c:C:S:t:p:m")) != -1) {
switch (op) {
case 's':
dst_addr = optarg;
set_tos = 1;
tos = (uint8_t) atoi(optarg);
break;
+ case 'p':
+ port = atoi(optarg);
+ break;
case 'm':
migrate = 1;
break;
printf("\t[-C message_count]\n");
printf("\t[-S message_size]\n");
printf("\t[-t type_of_service]\n");
+ printf("\t[-p port_number]\n");
printf("\t[-m(igrate)]\n");
exit(1);
}
static int connections = 1;
static int message_size = 100;
static int message_count = 10;
+static uint16_t port = 7174;
static uint8_t set_tos = 0;
static uint8_t tos;
static char *dst_addr;
} else
test.src_in.sin_family = PF_INET;
- test.src_in.sin_port = 7174;
+ test.src_in.sin_port = port;
ret = rdma_bind_addr(listen_id, test.src_addr);
if (ret) {
printf("udaddy: bind address failed: %d\n", ret);
if (ret)
return ret;
- test.dst_in.sin_port = 7174;
+ test.dst_in.sin_port = port;
printf("udaddy: connecting\n");
for (i = 0; i < connections; i++) {