RepoMirrors
/
haproxy
mirror of http://git.haproxy.org/git/haproxy.git/
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DEV: tcploop: add minimal UDP support 

Passing "-u" turns to SOCK_DGRAM + IPPROTO_UDP, which still allows
bind/connect()/recv()/send() and can be convenient for experimentation
purposes.
This commit is contained in:
Willy Tarreau 2022-06-07 12:09:55 +02:00
parent d493331d47
commit 2d7cd3e4ca
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dev/tcploop/tcploop.c
View File

@ -72,6 +72,8 @@ static struct timeval start_time;
static int showtime; static int showtime;
static int verbose; static int verbose;
static int pid; static int pid;
static int sock_type = SOCK_STREAM;
static int sock_proto = IPPROTO_TCP;
/* display the message and exit with the code */ /* display the message and exit with the code */
@ -95,6 +97,7 @@ __attribute__((noreturn)) void usage(int code, const char *arg0)
"\n" "\n"
"options :\n" "options :\n"
" -v : verbose\n" " -v : verbose\n"
" -u : use UDP instead of TCP (limited)\n"
" -t|-tt|-ttt : show time (msec / relative / absolute)\n" " -t|-tt|-ttt : show time (msec / relative / absolute)\n"
"actions :\n" "actions :\n"
" A[<count>] : Accepts <count> incoming sockets and closes count-1\n" " A[<count>] : Accepts <count> incoming sockets and closes count-1\n"
@ -338,7 +341,7 @@ int tcp_socket()
{ {
int sock; int sock;
sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); sock = socket(AF_INET, sock_type, sock_proto);
if (sock < 0) { if (sock < 0) {
perror("socket()"); perror("socket()");
return -1; return -1;
@ -806,6 +809,10 @@ int main(int argc, char **argv)
showtime += 3; showtime += 3;
else if (strcmp(argv[0], "-v") == 0) else if (strcmp(argv[0], "-v") == 0)
verbose ++; verbose ++;
else if (strcmp(argv[0], "-u") == 0) {
sock_type = SOCK_DGRAM;
sock_proto = IPPROTO_UDP;
}
else if (strcmp(argv[0], "--") == 0) else if (strcmp(argv[0], "--") == 0)
break; break;
else else