Utilisation du multicast - Revision history

Laurent Toutain at 08:47, 13 April 2006

2006-04-13T08:47:31Z

Laurent Toutain at 08:46, 13 April 2006

2006-04-13T08:46:08Z

Laurent Toutain at 08:44, 13 April 2006

2006-04-13T08:44:51Z

Bruno Stévant: /* in2multi6 */

2006-04-12T17:02:58Z

‎in2multi6

Bruno Stévant: /* multi2out6 */

2006-04-10T16:15:09Z

‎multi2out6

Bruno Deniaud at 11:05, 27 February 2006

2006-02-27T11:05:18Z

Laurent Toutain: /* multi2out6 */

2005-12-17T17:20:27Z

‎multi2out6

Laurent Toutain: /* multi2out6 */

2005-12-17T17:19:36Z

‎multi2out6

Laurent Toutain: /* in2multi6 */

2005-12-17T17:19:12Z

‎in2multi6

Laurent Toutain: /* in2multi6 */

2005-12-17T17:14:18Z

‎in2multi6

@@ Line 2: / Line 2: @@
 La programmation avec les groupes multicast n'est pas standardisée en IPv4. La nouvelle API "socket" propose un ensemble de structures et appels systèmes pour étendre l'interface de programmation sockets aux applications utilisant le multicast. Cet exemple va illustrer ce point.
-Le but des deux programmes est d'échanger des données par multicast. Le programme <tt>in2multi6</tt> diffuse les données lues en entrée ("standard input") vers un groupe multicast donné. Le programme <tt>[http://livre.point6.net/listings/multi2out6.c multi2out6]</tt> écoute les paquets transmis dans ce groupe et les copie sur la sortie standard ("stdout").
+Le but des deux programmes est d'échanger des données par multicast. Le programme <tt>[http://livre.point6.net/listings/in2multi6.c in2multi6]</tt> diffuse les données lues en entrée ("standard input") vers un groupe multicast donné. Le programme <tt>[http://livre.point6.net/listings/multi2out6.c multi2out6]</tt> écoute les paquets transmis dans ce groupe et les copie sur la sortie standard ("stdout").
-==multi2out6==
+==[http://livre.point6.net/listings/multi2out6.c multi2out6]==
 Pour ce faire <tt>[http://livre.point6.net/listings/multi2out6.c multi2out6]</tt> va faire des appels systèmes qui vont produire des paquets d'abonnement (et de désabonnement) à un groupe multicast. L'abonnement sera réalisé grâce à l'envoi de deux messages ICMPv6 successifs de type 131, c'est-à-dire des "rapports d'abonnement". Puis les messages émis dans le groupe sont reçus par le programme. Lorsque le programme s'arrête, le code de l'interface va automatiquement provoquer l'émission d'un message de réduction d'un groupe de multicast (132).
@@ Line 122: / Line 122: @@
 Lorsque le programme s'arrête, un <tt>close(s)</tt> implicite a lieu, et le code de l'interface va envoyer un message de réduction de groupe si elle est la dernière à avoir envoyé un rapport d'abonnement au groupe.
-==in2multi6==
+==[http://livre.point6.net/listings/in2multi6.c in2multi6]==
 Le programme est appelé de la manière suivante :

@@ Line 6: / Line 6: @@
 ==multi2out6==
-Pour ce faire <tt>multi2out6</tt> va faire des appels systèmes qui vont produire des paquets d'abonnement (et de désabonnement) à un groupe multicast. L'abonnement sera réalisé grâce à l'envoi de deux messages ICMPv6 successifs de type 131, c'est-à-dire des "rapports d'abonnement". Puis les messages émis dans le groupe sont reçus par le programme. Lorsque le programme s'arrête, le code de l'interface va automatiquement provoquer l'émission d'un message de réduction d'un groupe de multicast (132).
+Pour ce faire <tt>[http://livre.point6.net/listings/multi2out6.c multi2out6]</tt> va faire des appels systèmes qui vont produire des paquets d'abonnement (et de désabonnement) à un groupe multicast. L'abonnement sera réalisé grâce à l'envoi de deux messages ICMPv6 successifs de type 131, c'est-à-dire des "rapports d'abonnement". Puis les messages émis dans le groupe sont reçus par le programme. Lorsque le programme s'arrête, le code de l'interface va automatiquement provoquer l'émission d'un message de réduction d'un groupe de multicast (132).
-Le programme multi2out6 est appelé de la manière suivante :
+Le programme [http://livre.point6.net/listings/multi2out6.c multi2out6] est appelé de la manière suivante :
   '''multi2out6 [-i interface] <adresse de groupe multicast>'''

@@ Line 2: / Line 2: @@
 La programmation avec les groupes multicast n'est pas standardisée en IPv4. La nouvelle API "socket" propose un ensemble de structures et appels systèmes pour étendre l'interface de programmation sockets aux applications utilisant le multicast. Cet exemple va illustrer ce point.
-Le but des deux programmes est d'échanger des données par multicast. Le programme <tt>in2multi6</tt> diffuse les données lues en entrée ("standard input") vers un groupe multicast donné. Le programme <tt>multi2out6</tt> écoute les paquets transmis dans ce groupe et les copie sur la sortie standard ("stdout").
+Le but des deux programmes est d'échanger des données par multicast. Le programme <tt>in2multi6</tt> diffuse les données lues en entrée ("standard input") vers un groupe multicast donné. Le programme <tt>[http://livre.point6.net/listings/multi2out6.c multi2out6]</tt> écoute les paquets transmis dans ce groupe et les copie sur la sortie standard ("stdout").
 ==multi2out6==

@@ Line 158: / Line 158: @@
 | }
 |
-| main(int argc, char **argv)
+| int main(int argc, char **argv)
 | {
 | u_int hops = 1,       /* as defined in rfc2553 */

@@ Line 61: / Line 61: @@
-| main(int argc, char **argv)
+| int main(int argc, char **argv)
 | {
 | struct ipv6_mreq mreq;

@@ Line 1: / Line 1: @@
 La programmation avec les groupes multicast n'est pas standardisée en IPv4. La nouvelle API "socket" propose un ensemble de structures et appels systèmes pour étendre l'interface de programmation sockets aux applications utilisant le multicast. Cet exemple va illustrer ce point.
@@ Line 225: / Line 226: @@
 |    }
 | }

← Older revision		Revision as of 17:20, 17 December 2005
Line 12:		Line 12:

	Voici le code complet du programme. Le port utilisé (ligne 15) est quelconque mais ne doit bien sûr pas correspondre à un service déjà existant.		Voici le code complet du programme. Le port utilisé (ligne 15) est quelconque mais ne doit bien sûr pas correspondre à un service déjà existant.
−

	1\| #include <sys/types.h>		1\| #include <sys/types.h>

← Older revision		Revision as of 17:19, 17 December 2005
Line 11:		Line 11:
	'''multi2out6 [-i interface] <adresse de groupe multicast>'''		'''multi2out6 [-i interface] <adresse de groupe multicast>'''

−	Voici le code complet du programme. Le port utilisé (ligne ~~[[See]]~~ ) est quelconque mais ne doit bien sûr pas correspondre à un service déjà existant.	+	Voici le code complet du programme. Le port utilisé (ligne 15) est quelconque mais ne doit bien sûr pas correspondre à un service déjà existant.

@@ Line 160: / Line 160: @@
 | main(int argc, char **argv)
 | {
-| u_int hops = 1, /* as defined in rfc2553 */
+| u_int hops = 1,       /* as defined in rfc2553 */
-| loop = 1, /* as defined in rfc2553 */
+|       loop = 1,       /* as defined in rfc2553 */
-| ifi = 0;
+|       ifi = 0;
 | int s, cc, ch;
 | char buf[1024];
@@ Line 185: / Line 185: @@
 |             ifi = if_nametoindex(optarg);
 |             if (ifi == 0)
 |                Usage();
 |          }
 |          break;
 |       default:
 |          Usage();
 |    }
 |    argc -= optind;
 |    argv += optind;
 |    if (argc != 1 || inet_pton(AF_INET6, *argv, &addr6) <= 0)
 |       Usage();
 |    if (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_HOPS,
 |                   &hops, sizeof(hops)) < 0)
 |       Perror("setsockopt IPV6_MULTICAST_HOPS");
 |    if (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_LOOP,
 |                   &loop, sizeof(loop)) < 0)
 |       Perror("setsockopt IPV6_MULTICAST_LOOP");
 |    if (ifi && (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_IF,
 |                           &ifi, sizeof(u_int)) < 0))
 |       Perror("setsockopt IPV6_MULTICAST_IF");
 |
 | #ifdef SIN6_LEN
 |    sin6.sin6_len = sizeof(sin6);
 | #endif
 |    sin6.sin6_family = AF_INET6;
 |    sin6.sin6_addr = addr6;
 |    sin6.sin6_port = htons(54321);
 |
 |    for (;;) {
 |       cc = read(0, buf, 1024);
 |       if (cc < 0)
 |          Perror("read file");
 |       if (cc == 0) {
 |          fprintf(stderr, ".\n", cc);
 |          exit (0);
 |       }
 |       if (sendto(s, buf, cc, 0,
 |                  (struct sockaddr *)&sin6, sizeof(sin6)) < 0)
 |          Perror("sendto");
 |       fprintf(stderr, "-%d->\n", cc);
 |    }
 | }

@@ Line 132: / Line 132: @@
 Il y a quatre arguments, trois optionnels qui sont l'interface d'émission (nom ou index numérique), le "ttl" mis dans les paquets multicast (voir le manuel de la primitive <tt>readv</tt>), et un drapeau qui sert à dire si la machine émettrice reçoit ou non les paquet émis. Le dernier argument est l'adresse du groups sous forme numérique.
-Voici le code complet du programme. Le port utilisé (ligne [[See]] ) est naturellement celui de <tt>in2multi6</tt>.
+Voici le code complet du programme. Le port utilisé (ligne 10) est naturellement celui de <tt>in2multi6</tt>.
- #include <sys/types.h>
+| #include <sys/types.h>
- #include <sys/socket.h>
+| #include <sys/socket.h>
- #include <netinet/in.h>
+| #include <netinet/in.h>
- #include <arpa/inet.h>
+| #include <arpa/inet.h>
- #include <stdio.h>
+| #include <stdio.h>
- #include <unistd.h>
+| #include <unistd.h>
+|
-  struct sockaddr_in6 sin6;
+| struct sockaddr_in6 sin6;
+|
-  #define IPPORT 54321
+| #define IPPORT 54321
+|
-  void Perror(const char *c)
+| void Perror(const char *c)
+| {
-  perror(c);
+|    perror(c);
-  exit(1);
+|    exit(1);
+| }
+|
-  void Usage ()
+| void Usage ()
+| {
-  fprintf(stderr, "%s\n", "Usage: in2multi6 [-i interface][-h hop][-l loop] addr");
+|    fprintf(stderr, "%s\n", "Usage: in2multi6 [-i interface][-h hop][-l loop] addr");
-  exit(1);
+|    exit(1);
+| }
+|
-  main(int argc, char **argv)
+| main(int argc, char **argv)
+| {
-  u_int hops = 1, /* as defined in rfc2553 */
+| u_int hops = 1, /* as defined in rfc2553 */
-  loop = 1, /* as defined in rfc2553 */
+| loop = 1, /* as defined in rfc2553 */
-  ifi = 0;
+| ifi = 0;
-  int s, cc, ch;
+| int s, cc, ch;
-  char buf[1024];
+| char buf[1024];
-  struct in6_addr addr6;
+| struct in6_addr addr6;
-  extern char *optarg;
+| extern char *optarg;
-  extern int optind;
+| extern int optind;
+|
-  addr6 = in6addr_any;
+|    addr6 = in6addr_any;
-  if ((s = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP)) < 0)
+|    if ((s = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP)) < 0)
-  Perror("socket");
+|       Perror("socket");
-  while ((ch = getopt(argc, argv, "h:t:l:i:")) != -1)
+|    while ((ch = getopt(argc, argv, "h:t:l:i:")) != -1)
-  switch(ch) {
+|       switch(ch) {
-  case 'h':
+|       case 'h':
-  case 't':
+|       case 't':
-  hops = atoi(optarg);
+|          hops = atoi(optarg);
-  break;
+|          break;
-  case 'l':
+|       case 'l':
-  loop = atoi(optarg);
+|          loop = atoi(optarg);
-  break;
+|          break;
-  case 'i':
+|       case 'i':
-  if (sscanf(optarg, "%u\0", &ifi) != 1) {
+|          if (sscanf(optarg, "%u\0", &ifi) != 1) {
-  ifi = if_nametoindex(optarg);
+|             ifi = if_nametoindex(optarg);
-  if (ifi == 0)
+|             if (ifi == 0)
-  Usage();
+|                Usage();
+|          }
-  break;
+|          break;
-  default:
+|       default:
-  Usage();
+|          Usage();
+|    }
-  argc -= optind;
+|    argc -= optind;
-  argv += optind;
+|    argv += optind;
-  if (argc != 1 || inet_pton(AF_INET6, *argv, &addr6) <= 0)
+|    if (argc != 1 || inet_pton(AF_INET6, *argv, &addr6) <= 0)
-  Usage();
+|       Usage();
-  if (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_HOPS,
+|    if (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_HOPS,
-  &hops, sizeof(hops)) < 0)
+|                   &hops, sizeof(hops)) < 0)
-  Perror("setsockopt IPV6_MULTICAST_HOPS");
+|       Perror("setsockopt IPV6_MULTICAST_HOPS");
-  if (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_LOOP,
+|    if (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_LOOP,
-  &loop, sizeof(loop)) < 0)
+|                   &loop, sizeof(loop)) < 0)
-  Perror("setsockopt IPV6_MULTICAST_LOOP");
+|       Perror("setsockopt IPV6_MULTICAST_LOOP");
-  if (ifi && (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_IF,
+|    if (ifi && (setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_IF,
-  &ifi, sizeof(u_int)) < 0))
+|                           &ifi, sizeof(u_int)) < 0))
-  Perror("setsockopt IPV6_MULTICAST_IF");
+|       Perror("setsockopt IPV6_MULTICAST_IF");
+|
-  #ifdef SIN6_LEN
+| #ifdef SIN6_LEN
-  sin6.sin6_len = sizeof(sin6);
+|    sin6.sin6_len = sizeof(sin6);
-  #endif
+| #endif
-  sin6.sin6_family = AF_INET6;
+|    sin6.sin6_family = AF_INET6;
-  sin6.sin6_addr = addr6;
+|    sin6.sin6_addr = addr6;
-  sin6.sin6_port = htons(54321);
+|    sin6.sin6_port = htons(54321);
+|
-  for (;;) {
+|    for (;;) {
-  cc = read(0, buf, 1024);
+|       cc = read(0, buf, 1024);
-  if (cc < 0)
+|       if (cc < 0)
-  Perror("read file");
+|          Perror("read file");
-  if (cc == 0) {
+|       if (cc == 0) {
-  fprintf(stderr, ".\n", cc);
+|          fprintf(stderr, ".\n", cc);
-  exit (0);
+|          exit (0);
+|       }
-  if (sendto(s, buf, cc, 0,
+|       if (sendto(s, buf, cc, 0,
-  (struct sockaddr *)&sin6, sizeof(sin6)) < 0)
+|                  (struct sockaddr *)&sin6, sizeof(sin6)) < 0)
-  Perror("sendto");
+|          Perror("sendto");
-  fprintf(stderr, "-%d->\n", cc);
+|       fprintf(stderr, "-%d->\n", cc);
+|    }
+| }