/cygdrive/d/src/svn/vrut/trunk/modules/tracking/psender/psender.c

Go to the documentation of this file.

#include <netdb.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/ioctl.h>
#include <errno.h>
#include <stdio.h>
#include <time.h>

// Packet sender
// Upraveny program domaci ulohy na X36PKO
// program spoustejte s parametry: ip-adresa port protokol kofiguracni_soubor
// ip-adresa - muzete pouzit platny nazev serveru - program uziva DNS
// port - zvolte port vetsi nez 1024
// protokol - VZDY zadejte "udp"
// konfiguracni soubor - obsahuje seznam souborù s pakety a jejich délka v bytech.
//                                    - kazdy soubor obsahuje jeden ulozeny paket
void wait_for_ms(int ms)
{
       double sec = (double)ms / 1000;
       sec *= CLOCKS_PER_SEC;
       clock_t wait = clock() + sec;
       while(clock() < wait){}
       return;
}

main(int argc, char *argv[])
{
       if (argc != 5) 
       {
              printf("Parametry: -ip_adresa/hostname port protokol(zadejte udp) konfiguracni_soubor");
              return;
       }
   struct sockaddr_in my_addr, rem_addr;
   int                sockfd;
   struct hostent     *ph;
   struct servent     *ps;
   struct protoent    *pp;
   unsigned int       inaddr;

   int    i,iii, len, rem_addr_length;
   char   s[80];
   char   *p;
   char   sbuf[80], rbuf[80];
   FILE * input;
   FILE * config;

   if ((inaddr=inet_addr(argv[1]))!=INADDR_NONE)
      ph=gethostbyaddr((char *)&inaddr, sizeof(unsigned int), AF_INET);
   else
      ph=gethostbyname(argv[1]);

   if (ph)
   {
      printf("\nHostname: %s\n",ph->h_name);
      for (i=0; ph->h_aliases[i]; i++)
         printf("          %s\n", ph->h_aliases[i]);

      printf("Type: %i\nLen:  %i\n", ph->h_addrtype, ph->h_length);
      for (i=0; ph->h_addr_list[i]; i++)
         printf("Addr: %i.%i.%i.%i\n",
         (unsigned char)(ph->h_addr_list[i])[0],
         (unsigned char)(ph->h_addr_list[i])[1],
         (unsigned char)(ph->h_addr_list[i])[2],
         (unsigned char)(ph->h_addr_list[i])[3]);
   }
   else
   {
      herror("Chyba pri zjisteni adresy - neni registrovano ve jmenne sluzbe");
      exit(10);
   }

   //-----------------------------------------------------------------
   // Zjisteni protokolu

   if (isdigit(argv[3][0]))
      pp=getprotobynumber(atoi(argv[3]));
   else
      pp=getprotobyname(argv[3]);

   if (pp)
   {
      printf("\nProtocol: %s\n", pp->p_name);
      for (i=0; pp->p_aliases[i]; i++)
         printf("          %s\n", pp->p_aliases[i]);
      printf("Num:  %i\n", pp->p_proto);
   }
   else
   {
      printf("Chyba pri zjisteni protokulu\n");
      exit(11);
   }

   //-----------------------------------------------------------------
   // Zjisteni sluzby

   if (isdigit(argv[2][0]))
      ps=getservbyport(htons((u_short)atoi(argv[2])), pp->p_name);
   else
      ps=getservbyname(argv[2], pp->p_name);

   if (ps)
   {
      printf("\nServname: %s\n",ps->s_name);
      for (i=0; ps->s_aliases[i]; i++)
         printf("          %s\n", ps->s_aliases[i]);

      printf("Port:  %hi\nProto: %s\n", ntohs((u_short)ps->s_port), ps->s_proto);
   }
   else
   {
      if (isdigit(argv[2][0])&&((u_short)atoi(argv[2]) > 1024))
         printf("Cislo portu vetsi nez 1024\n");
      else
      {   
         printf("Chyba pri zjisteni sluzby\n");
         exit(12);
      }   
   }



   //------------------------------------------------------------------

   printf("\n");

   if ((sockfd = socket(PF_INET, SOCK_DGRAM, pp->p_proto))<0)
   {
      perror("Socket nelze otevrit");
      exit(1);
   }
   //------------------------------------------------------------------
   bzero((char *) &my_addr, sizeof(my_addr));
   my_addr.sin_family = AF_INET;
   my_addr.sin_addr.s_addr = INADDR_ANY;
   my_addr.sin_port = 0;
   if (bind(sockfd, (struct sockaddr *) &my_addr, sizeof(my_addr)) < 0)
   {
      perror("Chyba v bind");
      close(sockfd); exit(2);
   }
   //------------------------------------------------------------------
   bzero ((char *) &rem_addr, sizeof(rem_addr));
   rem_addr.sin_family = AF_INET;
   if (isdigit(argv[2][0])&&((u_short)atoi(argv[2]) > 1024))
      rem_addr.sin_port = htons((u_short)atoi(argv[2]));
   else
      rem_addr.sin_port = ps->s_port;                   // service port
   bcopy(ph->h_addr, (char *) &rem_addr.sin_addr, ph->h_length);
   char packet[9000];
   char chunk;

  // printf("budeme otvirat...%s \n", argv[4]);
   //flush(printf);

       config = fopen(argv[4], "r");
       if (config == 0) {printf("config nejde otevrit\n"); return 0   ;}
       else   printf("soubor otevren \n");
       char filename[256];
       int aa;
while(1)
{
       if ( 2 != fscanf(config, "%s %i", &filename, &aa)) return 0;
       printf("%s %i", filename, aa);
       iii = 0;
              input = fopen(filename, "r");
       if (input == 0) printf("nefunguje");
       while (iii < aa)
   {
          chunk = getc(input);
          packet[iii] = chunk;
          iii++;
          printf("%c",chunk);
   }
       fclose(input);

   strcpy(sbuf,argv[4]);
   len = strlen(sbuf);
   printf("Odesilana zprava(%i): %s\n", len, sbuf);

   if ((len = sendto(sockfd, packet, iii, 0, (struct sockaddr *) &rem_addr, sizeof(rem_addr))) < 0)
   {
      perror("Chyba ve vysilani");
      close(sockfd); exit(3);
   }
   printf("Odeslano %i\n", len);
       wait_for_ms(50);
}
   close(sockfd);
}

---