diff options
Diffstat (limited to 'tests/virtsock/virtsock_server_mcast_bidir.c')
-rw-r--r-- | tests/virtsock/virtsock_server_mcast_bidir.c | 54 |
1 files changed, 54 insertions, 0 deletions
diff --git a/tests/virtsock/virtsock_server_mcast_bidir.c b/tests/virtsock/virtsock_server_mcast_bidir.c new file mode 100644 index 00000000..b3366315 --- /dev/null +++ b/tests/virtsock/virtsock_server_mcast_bidir.c @@ -0,0 +1,54 @@ +/* client.c */ +#include <stdio.h> +#include <sys/types.h> +#include <sys/socket.h> +#include <netinet/in.h> +#include <arpa/inet.h> +#include <netdb.h> +#include <stdlib.h> +#include <unistd.h> +#include <string.h> +#include <errno.h> +#include <fcntl.h> +#include <strings.h> + +#include "mcast_sock.h" + +static char *rx_mcast_group = "224.0.0.1"; +static int rx_mcast_port = 6666; +static char *tx_mcast_group = "225.0.0.1"; +static int tx_mcast_port = 6667; + +// main prog for a server program sending continuously some data to a multicast socket and receiving answers on another +int main(void) +{ + int i = 0; + char rx_buf[256], tx_buf[256]; + struct mcast_bidir_sock *sock = mcast_bidir_sock_setup(tx_mcast_group, tx_mcast_port, rx_mcast_group, rx_mcast_port); + if (!sock) { + perror("Error initializing bidirectional sock"); + } + + while (++i) { + char *ibuf; + strcpy(tx_buf, "MSG NR."); + asprintf(&ibuf, "%d", i); + strcat(tx_buf, ibuf); + if (mcast_bidir_sock_tx(sock, tx_buf, sizeof(tx_buf)) + < 0) { + perror("Error transmitting message to server"); + } + printf("Sent MSG to client: \"%s\"\n", tx_buf); + if (mcast_bidir_sock_rx(sock, rx_buf, sizeof(rx_buf)) + < 0) { + perror("Error receiving message from server"); + } + printf("Received ACK from client: \"%s\"\n", rx_buf); + + sleep(1); + } + if(mcast_bidir_sock_close(sock)) { + perror("Error closing sockets."); + } + +} |