TAO/orbsvcs/tests/Notify/Bug_3646d_Regression/server.cpp

   1 #include "ace/Service_Config.h"
   2 #include "orbsvcs/Notify_Service/Notify_Service.h"
   3 #include "orbsvcs/CosNotifyChannelAdminC.h"
   4 #include "orbsvcs/CosNamingC.h"
   5
   6 #include "DllORB.h"
   7
   8 ACE_TCHAR const * const scpc_loadOrb = ACE_DYNAMIC_VERSIONED_SERVICE_DIRECTIVE(
   9   "testDllOrb",
  10   "bug3646d",
  11   TAO_VERSION,
  12   "_make_DllORB",
  13   "testDllOrb -ORBDebugLevel 0 -ORBId testDllOrb -ORBDottedDecimalAddresses 1 -ORBInitRef NameService=file://naming.ior"
  14 );
  15
  16 ACE_TCHAR const * const scpc_unloadOrb = ACE_REMOVE_SERVICE_DIRECTIVE("testDllOrb");
  17
  18 ACE_TCHAR const * const scpc_loadNotifyService = ACE_DYNAMIC_VERSIONED_SERVICE_DIRECTIVE(
  19   "testNotifyService",
  20   "TAO_Notify_Service",
  21   TAO_VERSION,
  22   "_make_TAO_Notify_Service_Driver",
  23   "-Channel -ChannelName Channel1 -ChannelName Channel2 -RunThreads 10 -ORBInitRef NameService=file://naming.ior -IORoutput notify.ior"
  24 );
  25
  26 ACE_TCHAR const * const scpc_unloadNotifyService = ACE_REMOVE_SERVICE_DIRECTIVE("testNotifyService");
  27
  28 ACE_TCHAR const * const scpc_loadNameService = ACE_DYNAMIC_VERSIONED_SERVICE_DIRECTIVE(
  29   "testNamingService",
  30   "TAO_CosNaming_Serv",
  31   TAO_VERSION,
  32   "_make_TAO_Naming_Loader",
  33   "testNameService testNameService -ORBId testDllOrb -m 0 -o naming.ior"
  34 );
  35
  36 ACE_TCHAR const * const scpc_unloadNameService = ACE_REMOVE_SERVICE_DIRECTIVE("testNamingService");
  37
  38 void loadunloadcycle()
  39 {
  40   ACE_DEBUG((
  41     LM_DEBUG,
  42     ACE_TEXT ("(%P|%t) loadunloadcycle - loading\n")
  43   ));
  44
  45   int result = ACE_Service_Config::process_directive(scpc_loadOrb);
  46   ACE_DEBUG((
  47     LM_DEBUG,
  48     ACE_TEXT ("(%P|%t) loadunloadcycle - loading ORB done. Result: <%d>\n"),
  49     result
  50   ));
  51
  52   DllORB * p_orb =
  53     ACE_Dynamic_Service<DllORB>::instance("testDllOrb");
  54
  55   CORBA::ORB_var v_orb = p_orb->orb();
  56     ACE_DEBUG((
  57     LM_DEBUG,
  58     ACE_TEXT ("(%P|%t) loadunloadcycle - v_orb OK\n")
  59   ));
  60
  61   CORBA::Object_var v_poa =
  62     v_orb->resolve_initial_references("RootPOA");
  63   ACE_DEBUG((
  64     LM_DEBUG,
  65     ACE_TEXT ("(%P|%t) loadunloadcycle - v_poa OK\n")
  66   ));
  67
  68   PortableServer::POA_var v_rootPOA =
  69     PortableServer::POA::_narrow(v_poa.in ());
  70   ACE_DEBUG((
  71     LM_DEBUG,
  72     ACE_TEXT ("(%P|%t) loadunloadcycle - v_rootPOA OK\n")
  73   ));
  74
  75   result = ACE_Service_Config::process_directive(scpc_loadNameService);
  76   ACE_DEBUG((
  77     LM_DEBUG,
  78     ACE_TEXT ("(%P|%t) loadunloadcycle - loading NamingService done. Result: <%d>\n"),
  79     result
  80   ));
  81
  82   result = ACE_Service_Config::process_directive(scpc_loadNotifyService);
  83   ACE_DEBUG((
  84     LM_DEBUG,
  85     ACE_TEXT ("(%P|%t) loadunloadcycle - loading NotifyService done. Result: <%d>\n"),
  86     result
  87   ));
  88
  89   ACE_DEBUG((
  90     LM_DEBUG,
  91     ACE_TEXT ("(%P|%t) loadunloadcycle - unloading\n")
  92   ));
  93
  94   ACE_DEBUG((
  95     LM_DEBUG,
  96     ACE_TEXT ("(%P|%t) loadunloadcycle - unloading NotifyService ...\n")
  97   ));
  98   result = ACE_Service_Config::process_directive(scpc_unloadNotifyService);
  99   ACE_DEBUG((
 100     LM_DEBUG,
 101     ACE_TEXT ("(%P|%t) loadunloadcycle - unloading NotifyService done. Result: <%d>\n"),
 102     result
 103   ));
 104
 105   ACE_DEBUG((
 106     LM_DEBUG,
 107     ACE_TEXT ("(%P|%t) loadunloadcycle - unloading NameService ...\n")
 108   ));
 109   result = ACE_Service_Config::process_directive(scpc_unloadNameService);
 110   ACE_DEBUG((
 111     LM_DEBUG,
 112     ACE_TEXT ("(%P|%t) loadunloadcycle - unloading NameService done. Result: <%d>\n"),
 113     result
 114   ));
 115
 116   ACE_DEBUG((
 117     LM_DEBUG,
 118     ACE_TEXT ("(%P|%t) loadunloadcycle - unloading ORB ...\n")
 119   ));
 120   result = ACE_Service_Config::process_directive(scpc_unloadOrb);
 121   ACE_DEBUG((
 122     LM_DEBUG,
 123     ACE_TEXT ("(%P|%t) loadunloadcycle - unloading ORB done. Result: <%d>\n"),
 124     result
 125   ));
 126 }
 127
 128 int ACE_TMAIN (int , ACE_TCHAR **)
 129 {
 130   ACE_DEBUG((
 131     LM_DEBUG,
 132     ACE_TEXT ("(%P|%t) main - entered\n")
 133   ));
 134
 135   for (int cnt = 0, max = 10; cnt < max; ++cnt)
 136     {
 137       ACE_DEBUG((
 138         LM_DEBUG,
 139         ACE_TEXT ("(%P|%t) main - cycle %d ...\n"), cnt
 140       ));
 141       loadunloadcycle();
 142       ACE_DEBUG((
 143         LM_DEBUG,
 144         ACE_TEXT ("(%P|%t) main - cycle %d done\n"), cnt
 145       ));
 146     }
 147
 148   ACE_DEBUG((
 149     LM_DEBUG,
 150     ACE_TEXT ("(%P|%t) main - leaving\n")
 151   ));
 152
 153   return 0;
 154 }