From fb33e6b84719746d22938e2e79c57b5954f63fa4 Mon Sep 17 00:00:00 2001 From: Ludovic Pouzenc Date: Sat, 25 Jun 2016 23:40:57 +0200 Subject: receive_data : use some ring buffer to batch recv, reorder, validate --- mcastseed/src/dgrambuf_test.c | 46 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 46 insertions(+) create mode 100644 mcastseed/src/dgrambuf_test.c (limited to 'mcastseed/src/dgrambuf_test.c') diff --git a/mcastseed/src/dgrambuf_test.c b/mcastseed/src/dgrambuf_test.c new file mode 100644 index 0000000..1b96e3d --- /dev/null +++ b/mcastseed/src/dgrambuf_test.c @@ -0,0 +1,46 @@ +#include "dgrambuf.h" + +#define _GNU_SOURCE +#include +#include +#include +#include +#include + +int open_test_socket(); + +/* + * Quick'n'dirty bash udp sender + * while true; do echo $RANDOM > /dev/udp/127.0.0.1/1234; sleep 0.25; done + */ + +int main() { + int res=1, sockfd=open_test_socket(); + dgrambuf_t dgb=dgrambuf_new(3, 50); + while (res > 0) { + res = dgrambuf_recvmmsg(dgb, sockfd); + printf("dgrambuf_recvmmsg() => %i\n", res); + printf("dgrambuf_free_count => %zi\n", dgrambuf_free_count(dgb)); + } + return 0; +} + +int open_test_socket() { + int sockfd; + struct sockaddr_in sa; + sockfd = socket(AF_INET, SOCK_DGRAM, 0); + if (sockfd == -1) { + perror("socket()"); + exit(EXIT_FAILURE); + } + + sa.sin_family = AF_INET; + sa.sin_addr.s_addr = htonl(INADDR_LOOPBACK); + sa.sin_port = htons(1234); + if (bind(sockfd, (struct sockaddr *) &sa, sizeof(sa)) == -1) { + perror("bind()"); + exit(EXIT_FAILURE); + } + + return sockfd; +} -- cgit v1.2.3