TAO/orbsvcs/examples/Notify/Federation/SpaceCraft/SpaceCraft.cpp

   1 // file      : SpaceCraft.cpp
   2 // author    : Boris Kolpackov <boris@dre.vanderbilt.edu>
   3 #include "tao/corba.h"
   4
   5 #include "orbsvcs/CosNotificationC.h"
   6 #include "orbsvcs/CosNotifyChannelAdminC.h"
   7 #include "orbsvcs/CosNotifyCommC.h"
   8 #include "orbsvcs/CosNotifyCommS.h"
   9
  10 // For in-process Notification Service.
  11 //
  12 #include "orbsvcs/Notify/Service.h"
  13 #include "orbsvcs/Notify/CosNotify_Initializer.h" // NS static link helper.
  14
  15
  16 #include "Gate/Gate.h"
  17
  18 #include <iostream>
  19 #include <sstream>
  20
  21 using std::cerr;
  22 using std::endl;
  23
  24 using namespace CORBA;
  25 using namespace CosNotifyComm;
  26 using namespace CosNotifyFilter;
  27 using namespace CosNotification;
  28 using namespace CosNotifyChannelAdmin;
  29
  30 int
  31 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  32 {
  33   try
  34   {
  35     ORB_var orb (ORB_init (argc, argv));
  36
  37     if (argc < 2)
  38     {
  39       ACE_ERROR ((LM_ERROR,
  40                   "Usage: %s <space-craft-name>={a, b, c}\n",
  41                   argv[0]));
  42       return 1;
  43     }
  44
  45     // Activate the root POA.
  46     //
  47     CORBA::Object_var obj (
  48       orb->resolve_initial_references ("RootPOA"));
  49
  50     PortableServer::POA_var root_poa (PortableServer::POA::_narrow (obj.in ()));
  51
  52     PortableServer::POAManager_var poa_manager (root_poa->the_POAManager ());
  53
  54     poa_manager->activate ();
  55
  56
  57     // Initialize Notification Service.
  58     //
  59     TAO_Notify_Service* ns = TAO_Notify_Service::load_default ();
  60
  61     if (ns == 0)
  62     {
  63       ACE_ERROR ((LM_ERROR,
  64                   "Notification Service not found! check svc.conf\n"));
  65       return -1;
  66     }
  67
  68
  69     ns->init_service (orb.in ());
  70
  71     // Create the channel factory.
  72     //
  73     EventChannelFactory_var factory (ns->create (root_poa.in ()));
  74
  75     if (is_nil (factory.in ()))
  76     {
  77       ACE_ERROR ((LM_ERROR,
  78                   "Unable to create channel factory\n"));
  79       return 1;
  80     }
  81
  82     // Create the channel.
  83     //
  84     QoSProperties qosp;
  85     AdminProperties ap;
  86     ChannelID id;
  87
  88     EventChannel_var channel (factory->create_channel (qosp, ap, id));
  89
  90     // Create and install the filter. We want to reduce the amount
  91     // of dicovery messages that are propagated between space crafts.
  92     //
  93     FilterFactory_var filter_factory (channel->default_filter_factory ());
  94     Filter_var filter (filter_factory->create_filter ("EXTENDED_TCL"));
  95
  96     ConstraintExpSeq constraints (1);
  97     constraints.length (1);
  98
  99     constraints[0].event_types.length (0);
 100     constraints[0].constraint_expr = string_dup (
 101       "$domain_name == 'Aerospace' and "
 102       "$type_name == 'AgentDiscovery' and "
 103       "($.counter - 3 * ($.counter / 3)) == 0");// ETCL (or TAO) doesn't have %?
 104
 105     filter->add_constraints (constraints);
 106
 107     AdminID admin_id = 0;
 108     ConsumerAdmin_var consumer_admin (
 109       channel->new_for_consumers (AND_OP, admin_id));
 110
 111     consumer_admin->add_filter (filter.in ());
 112
 113     // Find which space craft we are.
 114     //
 115     ACE_INET_Addr space_craft_addr;
 116     const ACE_TCHAR *space_craft_name = argv[1];
 117
 118     // Do a quick mapping to mcast addresses.
 119     //
 120     switch (space_craft_name[0])
 121     {
 122     case 'a':
 123       {
 124         space_craft_addr = ACE_INET_Addr ("224.1.0.1:10000");
 125         break;
 126       }
 127     case 'b':
 128       {
 129         space_craft_addr = ACE_INET_Addr ("224.1.0.2:10000");
 130         break;
 131       }
 132     case 'c':
 133       {
 134         space_craft_addr = ACE_INET_Addr ("224.1.0.3:10000");
 135         break;
 136       }
 137     default:
 138       {
 139         ACE_ERROR ((LM_ERROR,
 140                     "Space craft name should be either 'a', 'b', or 'c'.\n"));
 141         return 1;
 142       }
 143     }
 144
 145     // Create the SpaceCraft <=> Channel gate.
 146     //
 147     Gate space_craft_gate (space_craft_addr,
 148                            consumer_admin.in (),
 149                            channel->default_supplier_admin ());
 150
 151
 152     // Create the Channel <=> Constellation gate.
 153     //
 154     ACE_INET_Addr constellation_addr ("224.1.1.1:10000");
 155     Gate constellation_gate (constellation_addr, channel.in ());
 156
 157     orb->run ();
 158
 159     return 0;
 160   }
 161   catch (const CORBA::UserException& ue)
 162   {
 163     ue._tao_print_exception ("User exception: ");
 164     return 1;
 165   }
 166   catch (const CORBA::SystemException& se)
 167   {
 168     se._tao_print_exception ("System exception: ");
 169     return 1;
 170   }
 171
 172   return 1;
 173 }