ACE/protocols/examples/TMCast/Member/member.cpp

   1 // file      : TMCast/Member/member.cpp
   2 // author    : Boris Kolpackov <boris@dre.vanderbilt.edu>
   3 #include "ace/Log_Msg.h"
   4 #include "ace/Time_Value.h"
   5 #include "ace/OS_NS_stdlib.h"
   6 #include "ace/OS_NS_unistd.h"
   7 #include "ace/OS_NS_stdio.h"
   8 #include "ace/OS_NS_time.h"
   9 #include "ace/OS_NS_string.h"
  10
  11 #include "ace/TMCast/Group.hpp"
  12
  13 class Args {};
  14
  15 int
  16 ACE_TMAIN (int argc, ACE_TCHAR* argv[])
  17 {
  18   int status = 0;
  19   try
  20   {
  21     if (argc < 4) throw Args ();
  22
  23     bool receiver (true);
  24
  25     if (argv[1][0] == 'r') receiver = true;
  26     else if (argv[1][0] == 's') receiver = false;
  27     else throw Args ();
  28
  29     if (!receiver) ACE_OS::srand ((u_int) ACE_OS::time ());
  30
  31     ACE_INET_Addr address (argv[3]);
  32
  33     ACE_TMCast::Group group (address, ACE_TEXT_ALWAYS_CHAR (argv[2]));
  34
  35     if (receiver)
  36     {
  37       for (char buffer[256];;)
  38       {
  39         group.recv (buffer, sizeof (buffer));
  40
  41         ACE_DEBUG ((LM_DEBUG, "%s\n", buffer));
  42       }
  43     }
  44     else
  45     {
  46       char buffer[256];
  47
  48       for (unsigned long i = 0; i < 1000; i++)
  49       {
  50         // Sleep some random time around 1 sec.
  51
  52         ACE_UINT64 tmpl = 1000000U;
  53         unsigned long t =
  54           static_cast<unsigned long> (((tmpl * ACE_OS::rand ()) / RAND_MAX));
  55
  56         // ACE_DEBUG ((LM_DEBUG, "sleeping for %u\n", t));
  57
  58         ACE_OS::sleep (ACE_Time_Value (0, t));
  59
  60         ACE_OS::sprintf (buffer, "message # %lu", i);
  61
  62         try
  63         {
  64           group.send (buffer, ACE_OS::strlen (buffer) + 1);
  65         }
  66         catch (ACE_TMCast::Group::Aborted const&)
  67         {
  68           ACE_ERROR ((LM_ERROR, "%s has been aborted\n", buffer));
  69         }
  70       }
  71     }
  72   }
  73   catch (Args const&)
  74   {
  75     ACE_ERROR ((LM_ERROR,
  76                 "Usage: member {r|s} <id> <IPv4 mcast address>:<port>\n"));
  77     status++;
  78   }
  79   catch (ACE_TMCast::Group::Failed const&)
  80   {
  81     ACE_ERROR ((LM_ERROR,
  82                 "Group failure. Perhaps I am alone in the group.\n"));
  83     status++;
  84   }
  85   catch (ACE_TMCast::Group::InsufficienSpace const&)
  86   {
  87     ACE_ERROR ((LM_ERROR, "Insufficient space in receive buffer.\n"));
  88     status++;
  89   }
  90   return status;
  91 }