j3d1/tinc
1
0
Fork 0
Code Issues 1 Pull requests Releases Wiki Activity

Allow testing the replay window with sptps_test.

Browse source
This commit is contained in:
Guus Sliepen 2013-08-30 14:23:02 +02:00
parent ccbf70b66f
commit d01ab07f78
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/sptps_test.c
View file

@ -54,6 +54,7 @@ static bool receive_record(void *handle, uint8_t type, const char *data, uint16_
static struct option const long_options[] = { static struct option const long_options[] = {
{"datagram", no_argument, NULL, 'd'}, {"datagram", no_argument, NULL, 'd'},
{"packet-loss", required_argument, NULL, 'l'}, {"packet-loss", required_argument, NULL, 'l'},
{"replay-window", required_argument, NULL, 'r'},
{"help", no_argument, NULL, 1}, {"help", no_argument, NULL, 1},
{NULL, 0, NULL, 0} {NULL, 0, NULL, 0}
}; };
@ -65,6 +66,7 @@ static void usage() {
fprintf(stderr, "Valid options are:\n" fprintf(stderr, "Valid options are:\n"
" -d, --datagram Enable datagram mode.\n" " -d, --datagram Enable datagram mode.\n"
" -l, --packet-loss RATE Fake packet loss of RATE percent.\n" " -l, --packet-loss RATE Fake packet loss of RATE percent.\n"
" -r, --replay-window N Set replay window to N bytes.\n"
"\n"); "\n");
fprintf(stderr, "Report bugs to tinc@tinc-vpn.org.\n"); fprintf(stderr, "Report bugs to tinc@tinc-vpn.org.\n");
} }
@ -77,7 +79,7 @@ int main(int argc, char *argv[]) {
int r; int r;
int option_index = 0; int option_index = 0;
while((r = getopt_long(argc, argv, "dl:", long_options, &option_index)) != EOF) { while((r = getopt_long(argc, argv, "dl:r:", long_options, &option_index)) != EOF) {
switch (r) { switch (r) {
case 0: /* long option */ case 0: /* long option */
break; break;
@ -90,6 +92,10 @@ int main(int argc, char *argv[]) {
packetloss = atoi(optarg); packetloss = atoi(optarg);
break; break;
case 'r': /* replay window size */
sptps_replaywin = atoi(optarg);
break;
case '?': /* wrong options */ case '?': /* wrong options */
usage(); usage();
return 1; return 1;
@ -228,6 +234,8 @@ int main(int argc, char *argv[]) {
} }
if(len == 0) if(len == 0)
break; break;
if(buf[0] == '#')
s.outseqno = atoi(buf + 1);
if(buf[0] == '^') if(buf[0] == '^')
sptps_send_record(&s, SPTPS_HANDSHAKE, NULL, 0); sptps_send_record(&s, SPTPS_HANDSHAKE, NULL, 0);
else if(buf[0] == '$') { else if(buf[0] == '$') {
@ -256,7 +264,7 @@ int main(int argc, char *argv[]) {
fprintf(stderr, "Dropped.\n"); fprintf(stderr, "Dropped.\n");
continue; continue;
} }
if(!sptps_receive_data(&s, buf, len)) if(!sptps_receive_data(&s, buf, len) && !datagram)
return 1; return 1;
} }
} }