ex9-send.c

/*---------------------------------------------------------------------------
 * Programmazione di rete
 *
 * Semplicissimo sender UDP.
 * Questo programma si aspetta in ingresso i parametri indicati qui di seguito:
 *
 * ./send indirizzoIP numero porta
 *
 * Questa nuova versione trasmette in multicast e l'indirizzo IP fornito in riga
 * di comando DEVE appartenere alla classe degli indirizzi IP multicast.
 *
 * Ing. Alessio Palma
 *
 * $Id$
 *
 */


#include<stdio.h>
#include<sys/types.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<netdb.h>
#include<sys/socket.h>
/* contiene la struttura comune ai due moduli */
#include"esempi.h"


void initialize_socket( char *, int );
void read_message( void );
void send_message( void );
void ask_usrname( void );

/*------------------------------------------------------------------------
 *
 * Dichiarazioni variabili
 *
 */

int socket_descriptor;
struct sockaddr_in socket_address, remote_address;
struct in_addr ipaddr;

/* prestate attenzione che il pacchetto che invia è della versione 2 */
struct type_pacchetto_v2 pacchetto;

/* vale 1 se l'utente vuole terminare */
int user_quit=0;

/*----------------------------------------------------------------------
 parametri per l'impostazione multicast
 uchar_ttl = 1 significa che il pacchetto rimane nella LAN

 I pacchetti inviati sono ricevuti anche dal mittente
 uchar_loop = 1;
*/

u_char uchar_ttl = 1;
u_char uchar_loop = 1;


/*----------------------------------------------------------------------
 * Initialize_socket( void )
 *
 * inizializza il socket e lo collega alla porta ed indirizzo IP voluti
 *
 */

void initialize_socket(char *IPaddress, int port)
{

/*
 * Per trasmettere in multicast serve un indirizzo appropriato
 */

    if(!IN_MULTICAST(htonl(inet_addr(IPaddress)))) {
      printf("L'Indirizzo IP fornito deve appartenere alla classe MULTICAST\n");
      exit(1);
    }

     if ( (socket_descriptor = socket(AF_INET, SOCK_DGRAM,0)) < 0 ) {
          printf("non posso aprire il socket\n");
          exit(1);
     }

 /*
  * socket che il programma alloca ed userà
  *
  */

     socket_address.sin_family = AF_INET;
     socket_address.sin_addr.s_addr = htonl(INADDR_ANY);
     socket_address.sin_port = htons( 0 );

 /*
  * socket ed indirizzo IP verso cui spedire i dati
  *
  */

     remote_address.sin_family = AF_INET;
     remote_address.sin_port = htons( port );
     inet_aton( IPaddress, &remote_address.sin_addr );
     memset(&remote_address.sin_zero, 0x00, 8);

  /*
   * attiva le opzioni per il multicasting
   */

     if (setsockopt( socket_descriptor, IPPROTO_IP, IP_MULTICAST_TTL,
                     &uchar_ttl, sizeof(uchar_ttl)) ) {
      printf("Non posso impostare \n");
      exit(1);
     }

     if ( bind( socket_descriptor, (struct sockaddr *)&socket_address,
                sizeof(socket_address) ) ) {
          printf("non posso collegare il socket\n");
          exit(1);
     }

}


/*----------------------------------------------------------------------
 * Initialize_socket( void )
 *
 * carica la struttura pacchetto.
 *
 */

void read_message()
{
     printf("messaggio:");
     fflush(stdin);
     fgets((char *)pacchetto.messaggio, MAXLEN_MSG, stdin );
     user_quit = ( strncmp( pacchetto.messaggio , QUIT_STRING, 4) == 0 );
}


/*----------------------------------------------------------------------
 * send_messagge( void )
 *
 * Invia la struttura pacchetto in rete.
 *
 */

void send_message()
{
     sendto( socket_descriptor, (void *)&pacchetto,
             sizeof(pacchetto)/sizeof(char),0,
             (struct sockaddr *)&remote_address,sizeof(remote_address));
}


/*----------------------------------------------------------------------
 * ask_username( void )
 *
 * inizializza la struttura pacchetto con il nome dell'utente
 *
 */
void ask_username()
{
    fflush(stdin);
    printf("Inserisci il tuo nickname:");
    fgets((char *)&pacchetto.nome, MAXLEN_USRNAME, stdin);
    printf("ok\n");
}


main(int argc, char **argv )
{
     initialize_socket( argv[1], atoi(argv[2]));
     ask_username();

      while( ! user_quit ) {
         read_message();
         send_message();
      }

    close(socket_descriptor);
}