ACE/protocols/tests/RMCast/Sender.cpp

   1 // file      : Sender.cpp
   2 // author    : Boris Kolpackov <boris@kolpackov.net>
   3 #include "ace/Log_Msg.h"
   4 #include "ace/OS_NS_unistd.h"
   5
   6 #include "ace/RMCast/Socket.h"
   7
   8 #include "Protocol.h"
   9
  10 class args {};
  11
  12 int
  13 ACE_TMAIN (int argc, ACE_TCHAR* argv[])
  14 {
  15   try
  16   {
  17     if (argc < 2) throw args ();
  18
  19     ACE_INET_Addr addr (argv[1]);
  20
  21     //FUZZ: disable check_for_lack_ACE_OS
  22     // Turn on message loss and reordering simulation.
  23     //
  24     ACE_RMCast::Socket socket (addr, false, true);
  25     //FUZZ: enable check_for_lack_ACE_OS
  26
  27     Message msg;
  28     msg.sn = 0;
  29
  30     for (unsigned short i = 0; i < payload_size; i++)
  31     {
  32       msg.payload[i] = i;
  33     }
  34
  35     for (; msg.sn < message_count; msg.sn++)
  36     {
  37       socket.send (&msg, sizeof (msg));
  38     }
  39
  40     // Keep running in case retransmissions are needed.
  41     //
  42     ACE_OS::sleep (ACE_Time_Value (60, 0));
  43
  44     return 0;
  45   }
  46   catch (args const&)
  47   {
  48     ACE_ERROR ((LM_ERROR,
  49                 "usage: %s <IPv4 multicast address>:<port>\n", argv[0]));
  50   }
  51
  52   return 1;
  53 }