TAO/orbsvcs/tests/Notify/PluggableTopology/main.cpp

   1
   2 #include "orbsvcs/CosNotifyChannelAdminC.h"
   3 //#include <orbsvcs/CosNotifyCommS.h>
   4 //#include <orbsvcs/CosNotificationS.h>
   5 #include "tao/TimeBaseC.h"
   6
   7 #include "ace/ARGV.h"
   8 #include "ace/OS_NS_stdio.h"
   9
  10 using namespace CORBA;
  11 namespace CNCA = CosNotifyChannelAdmin;
  12 namespace CN = CosNotification;
  13 namespace CNC = CosNotifyComm;
  14
  15 const char* NOTIFY_IOR = "corbaloc::localhost:9050/NotifyEventChannelFactory";
  16
  17 ORB_var orb;
  18 CNCA::EventChannelFactory_var ecf;
  19
  20 namespace {
  21   void init_qos_props(CN::QoSProperties& qos, bool topology_persist) {
  22     qos.length(13);
  23     ULong i = 0;
  24     qos[i].name = "EventReliability";
  25     qos[i++].value <<= CN::BestEffort;
  26     if (topology_persist) {
  27       qos[i].name = "ConnectionReliability";
  28       qos[i++].value <<= CN::Persistent;
  29     }
  30     else
  31     {
  32       qos[i].name = "ConnectionReliability";
  33       qos[i++].value <<= CN::BestEffort;
  34     }
  35     qos[i].name = "Priority";
  36     qos[i++].value <<= (Short) 1234;
  37     qos[i].name = "Timeout";
  38     qos[i++].value <<= (TimeBase::TimeT) 55555; // 5.5555 ms
  39     qos[i].name = "MaximumBatchSize";
  40     qos[i++].value <<= (Long) 200;
  41     qos[i].name = "PacingInterval";
  42     qos[i++].value <<= (TimeBase::TimeT) 42000; // 4.2ms
  43     qos[i].name = "StopTimeSupported";
  44     qos[i++].value <<= Any::from_boolean(0);
  45     qos.length(i);
  46   }
  47   void init_admin_props(CN::AdminProperties& admin) {
  48     admin.length(13);
  49     ULong i = 0;
  50     admin[i].name = "MaxQueueLength";
  51     admin[i++].value <<= (Long) 200;
  52     admin[i].name = "MaxConsumers";
  53     admin[i++].value <<= (Long) 2;
  54     admin[i].name = "MaxSuppliers";
  55     admin[i++].value <<= (Long) 1;
  56     admin[i].name = "RejectNewEvents";
  57     admin[i++].value <<= Any::from_boolean(1);
  58   }
  59   void setUp()
  60   {
  61     ACE_ARGV av;
  62     int ac = 0;
  63     orb = ORB_init(ac, av.argv());
  64     ACE_ASSERT(! is_nil(orb.in()));
  65     Object_var obj = orb->string_to_object(NOTIFY_IOR);
  66     ACE_ASSERT(! is_nil(obj.in()));
  67     ecf = CNCA::EventChannelFactory::_narrow(obj.in());
  68     ACE_ASSERT(! is_nil(ecf.in()));
  69   }
  70
  71   void tearDown()
  72   {
  73     ecf = CNCA::EventChannelFactory::_nil();
  74     orb->destroy();
  75     orb = ORB::_nil();
  76   }
  77 }
  78
  79
  80 int ACE_TMAIN (int, ACE_TCHAR *[])
  81 {
  82   try
  83   {
  84     setUp();
  85
  86     CN::QoSProperties qos;
  87     CN::AdminProperties admin;
  88     init_qos_props(qos, true);
  89     init_admin_props(admin);
  90
  91     CNCA::ChannelID ecid;
  92     CNCA::EventChannel_var ec = ecf->create_channel(qos, admin, ecid);
  93
  94     ACE_OS::printf("Created channel id=\"%ld\"\n", static_cast<long>(ecid));
  95
  96     tearDown();
  97
  98     return 0;
  99   }
 100   catch (Exception& e)
 101   {
 102     ACE_OS::fputs(e._name (), stderr);
 103     ACE_OS::fputs("\n", stderr);
 104   }
 105   return 1;
 106 }