1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
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.");
}
}
|
