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.");
+	}
+
+}