diff options
author | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2000-03-08 16:33:47 +0000 |
---|---|---|
committer | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2000-03-08 16:33:47 +0000 |
commit | f5887395f7fc4657f98370f718d8033d4a65e95e (patch) | |
tree | ffe8e894c4d31a65cdd30167fba99d8b663e3790 | |
parent | 61acc9114fe583e2c989157c76befc08a42c4ad0 (diff) | |
download | ATCD-f5887395f7fc4657f98370f718d8033d4a65e95e.tar.gz |
ChangeLogTag:Tue Mar 7 17:50:12 2000 Carlos O'Ryan <coryan@uci.edu>
-rw-r--r-- | TAO/ChangeLogs/ChangeLog-02a | 378 | ||||
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_ObserverStrategy.cpp | 2 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/Event/Basic/Basic.dsw | 12 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/Event/Basic/Gateway.cpp | 239 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/Event/Basic/Gateway.dsp | 99 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/Event/Basic/Makefile | 644 | ||||
-rwxr-xr-x | TAO/orbsvcs/tests/Event/Basic/run_test.pl | 8 |
7 files changed, 1078 insertions, 304 deletions
diff --git a/TAO/ChangeLogs/ChangeLog-02a b/TAO/ChangeLogs/ChangeLog-02a index 6af0537c582..b8b26cc6e02 100644 --- a/TAO/ChangeLogs/ChangeLog-02a +++ b/TAO/ChangeLogs/ChangeLog-02a @@ -1,3 +1,19 @@ +Wed Mar 8 08:31:25 2000 Carlos O'Ryan <coryan@uci.edu> + + * orbsvcs/orbsvcs/Event/EC_ObserverStrategy.cpp: + Fixed problems with gateway re-connections. After a consumer + changed its subscription no more events are received from the + remote supplier. + Thanks to Harald Finster <finster@ave.ac.agit.de> for reporting + this bug. + + * orbsvcs/tests/Event/Basic/Makefile: + * orbsvcs/tests/Event/Basic/run_test.pl: + * orbsvcs/tests/Event/Basic/Basic.dsw: + * orbsvcs/tests/Event/Basic/Gateway.cpp: + * orbsvcs/tests/Event/Basic/Gateway.dsp: + Add a new regression test to the event service. + Wed Mar 8 08:59:47 2000 Jeff Parsons <parsons@cs.wustl.edu> * tao/InterfaceC.cpp: @@ -14,8 +30,8 @@ Wed Mar 8 01:33:21 2000 Christopher Kohlhoff <chris@kohlhoff.com> Tue Mar 07 15:42:41 2000 Nanbor Wang <nanbor@cs.wustl.edu> - * docs/interceptors.html: Fixed some html tag problems. Thanks to - Chanaka Liyanaarachchi <chanaka@ociweb.com> for reporting this. + * docs/interceptors.html: Fixed some html tag problems. Thanks to + Chanaka Liyanaarachchi <chanaka@ociweb.com> for reporting this. Tue Mar 07 10:30:06 2000 bala <bala@cs.wustl.edu> @@ -23,34 +39,34 @@ Tue Mar 07 10:30:06 2000 bala <bala@cs.wustl.edu> Tue Mar 7 09:33:21 2000 Jeff Parsons <parsons@cs.wustl.edu> - * tao/deep_free.cpp: - In TAO_Marshal_Union, the type of 'discrim_tc' was changed - to a _var, but I neglected to change its form when used as - an argument to discrim_tc.in (). + * tao/deep_free.cpp: + In TAO_Marshal_Union, the type of 'discrim_tc' was changed + to a _var, but I neglected to change its form when used as + an argument to discrim_tc.in (). Mon Mar 6 22:49:45 2000 Pradeep Gore <pradeep@flamenco.cs.wustl.edu> - * orbsvcs/orbsvcs/Notify/Notify_EventChannelFactory_i.cpp: + * orbsvcs/orbsvcs/Notify/Notify_EventChannelFactory_i.cpp: removed ACE_CHECK_RETURN from the get_channel method to - fix compile warning with kai3.3e + fix compile warning with kai3.3e Mon Mar 6 19:43:00 2000 Pradeep Gore <pradeep@flamenco.cs.wustl.edu> - * orbsvcs/orbsvcs/Notify/Notify_EventChannelFactory_i.cpp: - fixed compile warning in create method. + * orbsvcs/orbsvcs/Notify/Notify_EventChannelFactory_i.cpp: + fixed compile warning in create method. * orbsvcs/tests/CosEC_Basic/CosEC_Basic.cpp: fix for IRIX compile error: used ServantBase_var instead of auto_ptr Mon Mar 6 16:49:44 2000 Jeff Parsons <parsons@cs.wustl.edu> - * tao/deep_free.cpp: - Plugged a memory leak in TAO_Marshal_Union. When the - typecode of the union's discriminator is fetched, a - duplicate is returned, but the return value was not - disposed of after use. Thanks to - Lothar Werzinger <werzinger.lothar@krones.de> for - sending in the IDL file and test code that revealed - this bug. + * tao/deep_free.cpp: + Plugged a memory leak in TAO_Marshal_Union. When the + typecode of the union's discriminator is fetched, a + duplicate is returned, but the return value was not + disposed of after use. Thanks to + Lothar Werzinger <werzinger.lothar@krones.de> for + sending in the IDL file and test code that revealed + this bug. Sun Mar 5 18:36:34 2000 Darrell Brunsch <brunsch@uci.edu> @@ -70,220 +86,220 @@ Sun Mar 5 18:36:34 2000 Darrell Brunsch <brunsch@uci.edu> Sun Mar 5 16:36:25 2000 Pradeep Gore <pradeep@flamenco.cs.wustl.edu> - * orbsvcs/orbsvcs/Notify/Notify_EventChannelFactory_i.cpp: - dereference via .in in method MyFactory. - * orbsvcs/orbsvcs/Notify/Notify_EventChannel_i.cpp: - get_event_channel: translate any exception to ChannelNotFound. - * orbsvcs/orbsvcs/Notify/Notify_ProxySupplier_T.cpp: - corrected spelling mistake. - * orbsvcs/orbsvcs/Notify/Notify_PushConsumer.cpp: - * orbsvcs/orbsvcs/Notify/Notify_PushSupplier.cpp: - added missing ACE_THROW_SPEC + * orbsvcs/orbsvcs/Notify/Notify_EventChannelFactory_i.cpp: + dereference via .in in method MyFactory. + * orbsvcs/orbsvcs/Notify/Notify_EventChannel_i.cpp: + get_event_channel: translate any exception to ChannelNotFound. + * orbsvcs/orbsvcs/Notify/Notify_ProxySupplier_T.cpp: + corrected spelling mistake. + * orbsvcs/orbsvcs/Notify/Notify_PushConsumer.cpp: + * orbsvcs/orbsvcs/Notify/Notify_PushSupplier.cpp: + added missing ACE_THROW_SPEC Sun Mar 5 15:34:36 2000 Balachandran Natarajan <bala@cs.wustl.edu> - * tests/IORManipulation/IORTest.cpp (main): Added a work around - for a compiler bug in IRIX CC. + * tests/IORManipulation/IORTest.cpp (main): Added a work around + for a compiler bug in IRIX CC. Sun Mar 5 12:45:50 2000 Jeff Parsons <parsons@cs.wustl.edu> - * tao/MessagingC.h: - * tao/MessagingC.cpp: - Removed Any operators for ExceptionHolder, which is a - valuetype, not an interface. + * tao/MessagingC.h: + * tao/MessagingC.cpp: + Removed Any operators for ExceptionHolder, which is a + valuetype, not an interface. - * POAC.h: - Added #if !defined (TAO_HAS_MINIMUM_CORBA) guards to - declaration of Any operators for ForwardRequest. The - operator bodies are already guarded. + * POAC.h: + Added #if !defined (TAO_HAS_MINIMUM_CORBA) guards to + declaration of Any operators for ForwardRequest. The + operator bodies are already guarded. Sat Mar 4 18:11:28 2000 Pradeep Gore <pradeep@flamenco.cs.wustl.edu> - * Modified the following files: - * orbsvcs/Notify/Notify_Constraint_Interpreter.h: - * orbsvcs/Notify/Notify_FilterAdmin_i.{h,cpp}: - * orbsvcs/Notify/Notify_FilterFactory_i.h: - * orbsvcs/Notify/Notify_Filter_i.{h,cpp}: - * orbsvcs/Notify/Notify_QoSAdmin_i.h : - minor changes to header file inclusions. - * orbsvcs/Notify/Notify_ConsumerAdmin_i.{h,cpp}: - * orbsvcs/Notify/Notify_SupplierAdmin_i.{h,cpp}: - * orbsvcs/Notify/Notify_EventChannelFactory_i.{h,cpp}: - * orbsvcs/Notify/Notify_EventChannel_i.{h,cpp}: - Changed the design for looking up children objects from being - ACE_Hash_Map_Manager based to the POA.Each Object factory in Notify - creates a child POA to activate created objects in.This cleanly - decouples object lookup functionality from the working of the - Event Channel.The unique ID's generated for each object created is - converted to Object Id's for activation and reference lookup. - * orbsvcs/Notify/Notify_ProxyPushConsumer_i.{h,cpp}: - * orbsvcs/Notify/Notify_ProxyPushSupplier_i.{h,cpp}: - * orbsvcs/Notify/Notify_StructuredProxyPushConsumer_i.{h,cpp}: - * orbsvcs/Notify/Notify_StructuredProxyPushSupplier_i.{h,cpp}: - Added 'push' implementations. - * orbsvcs/Notify/Notify_StructuredPushConsumer.{h,cpp}: - * orbsvcs/Notify/Notify_StructuredPushSupplier.{h,cpp}: + * Modified the following files: + * orbsvcs/Notify/Notify_Constraint_Interpreter.h: + * orbsvcs/Notify/Notify_FilterAdmin_i.{h,cpp}: + * orbsvcs/Notify/Notify_FilterFactory_i.h: + * orbsvcs/Notify/Notify_Filter_i.{h,cpp}: + * orbsvcs/Notify/Notify_QoSAdmin_i.h : + minor changes to header file inclusions. + * orbsvcs/Notify/Notify_ConsumerAdmin_i.{h,cpp}: + * orbsvcs/Notify/Notify_SupplierAdmin_i.{h,cpp}: + * orbsvcs/Notify/Notify_EventChannelFactory_i.{h,cpp}: + * orbsvcs/Notify/Notify_EventChannel_i.{h,cpp}: + Changed the design for looking up children objects from being + ACE_Hash_Map_Manager based to the POA.Each Object factory in Notify + creates a child POA to activate created objects in.This cleanly + decouples object lookup functionality from the working of the + Event Channel.The unique ID's generated for each object created is + converted to Object Id's for activation and reference lookup. + * orbsvcs/Notify/Notify_ProxyPushConsumer_i.{h,cpp}: + * orbsvcs/Notify/Notify_ProxyPushSupplier_i.{h,cpp}: + * orbsvcs/Notify/Notify_StructuredProxyPushConsumer_i.{h,cpp}: + * orbsvcs/Notify/Notify_StructuredProxyPushSupplier_i.{h,cpp}: + Added 'push' implementations. + * orbsvcs/Notify/Notify_StructuredPushConsumer.{h,cpp}: + * orbsvcs/Notify/Notify_StructuredPushSupplier.{h,cpp}: Removed <open> and close methods from helper classes. * orbsvcs/orbsvcs/Makefile: - Added new files to Notify, updated dependencies. + Added new files to Notify, updated dependencies. * orbsvcs/Notify_Service/Notify_Service.{h,cpp}: - Changed to use the TAO_Notify_EventChannelFactory::create method. - * orbsvcs/examples/Notify/Filter.cpp: - Changed to use the new TAO_Notify_StructuredPushConsumer methods. - - New files: - * orbsvcs/Notify/Notify_Event_Manager.{h,cpp}: - The <TAO_Notify_Event_Manager> class controls all aspects of event - propogation from suppliers to consumers, provides methods to handle - subscription and publication lists logic.It also contains the - <recipient_map_> which is the central storage for subscription - lists and is accessed to decide where events should go. - * orbsvcs/Notify/Notify_ID_Pool_T.{h,cpp,i}: - The <TAO_Notify_ID_Pool> template class generates Ids for all object - factories in Notify.Id's can be returned to the pool for recyling. - * orbsvcs/Notify/Notify_Listeners.h: - Defines the <TAO_Notify_Event_Listener> and - <TAO_Notify_Update_Listener> internal interfaces for Notify. - * orbsvcs/Notify/Notify_ProxyConsumer_T.{h,cpp}: - Template Base classes for the Proxy Consumers. - * orbsvcs/Notify/Notify_ProxySupplier_T.{h,cpp}: - Template Base classes for the Proxy Suppliers. - * orbsvcs/Notify/Notify_PushConsumer.{h,cpp}: - Helper servant implementation for PushConsumers. - * orbsvcs/Notify/Notify_PushSupplier.cpp.{h,cpp}: - Helper servant implementation for PushSuppliers. - * orbsvcs/Notify/Notify_Resource_Manager.{h,cpp}: - All object creations are done here. - * orbsvcs/Notify/Notify_Types.{h,cpp}: + Changed to use the TAO_Notify_EventChannelFactory::create method. + * orbsvcs/examples/Notify/Filter.cpp: + Changed to use the new TAO_Notify_StructuredPushConsumer methods. + + New files: + * orbsvcs/Notify/Notify_Event_Manager.{h,cpp}: + The <TAO_Notify_Event_Manager> class controls all aspects of event + propogation from suppliers to consumers, provides methods to handle + subscription and publication lists logic.It also contains the + <recipient_map_> which is the central storage for subscription + lists and is accessed to decide where events should go. + * orbsvcs/Notify/Notify_ID_Pool_T.{h,cpp,i}: + The <TAO_Notify_ID_Pool> template class generates Ids for all object + factories in Notify.Id's can be returned to the pool for recyling. + * orbsvcs/Notify/Notify_Listeners.h: + Defines the <TAO_Notify_Event_Listener> and + <TAO_Notify_Update_Listener> internal interfaces for Notify. + * orbsvcs/Notify/Notify_ProxyConsumer_T.{h,cpp}: + Template Base classes for the Proxy Consumers. + * orbsvcs/Notify/Notify_ProxySupplier_T.{h,cpp}: + Template Base classes for the Proxy Suppliers. + * orbsvcs/Notify/Notify_PushConsumer.{h,cpp}: + Helper servant implementation for PushConsumers. + * orbsvcs/Notify/Notify_PushSupplier.cpp.{h,cpp}: + Helper servant implementation for PushSuppliers. + * orbsvcs/Notify/Notify_Resource_Manager.{h,cpp}: + All object creations are done here. + * orbsvcs/Notify/Notify_Types.{h,cpp}: Defines the <TAO_Notify_EventType> and Subscription and Publication - list types. - * orbsvcs/examples/Notify/Subscribe/Subscribe{.h,.cpp}: - * orbsvcs/examples/Notify/Subscribe/main.cpp: - * orbsvcs/examples/Notify/Subscribe/Makefile: + list types. + * orbsvcs/examples/Notify/Subscribe/Subscribe{.h,.cpp}: + * orbsvcs/examples/Notify/Subscribe/main.cpp: + * orbsvcs/examples/Notify/Subscribe/Makefile: New example to show how to use subscription (under construction). Sat Mar 4 16:09:42 2000 Jeff Parsons <parsons@cs.wustl.edu> - * tao/MessagingC.h: - * tao/MessagingC.i: - * tao/MessagingC.cpp: - * tao/POAC.h: - * tao/POAC.i: - * tao/POAC.cpp: - * tao/PolicyC.h: - * tao/PolicyC.i: - * tao/PolicyC.cpp: - Replaced all Any insertion/extraction operators with the new - versions that use compiled marshaling. Also added many missing - Any and CDR stream insertion/extraction operators. This - completes the job for all the generated files in TAO/tao. + * tao/MessagingC.h: + * tao/MessagingC.i: + * tao/MessagingC.cpp: + * tao/POAC.h: + * tao/POAC.i: + * tao/POAC.cpp: + * tao/PolicyC.h: + * tao/PolicyC.i: + * tao/PolicyC.cpp: + Replaced all Any insertion/extraction operators with the new + versions that use compiled marshaling. Also added many missing + Any and CDR stream insertion/extraction operators. This + completes the job for all the generated files in TAO/tao. Fri Mar 3 14:41:42 2000 Balachandran Natarajan <bala@cs.wustl.edu> - * tao/Sequence.cpp (allocbuf): - * tao/Typecode.cpp: Removed the use of "naked new" - operators. + * tao/Sequence.cpp (allocbuf): + * tao/Typecode.cpp: Removed the use of "naked new" + operators. Fri Mar 3 13:41:12 2000 Balachandran Natarajan <bala@cs.wustl.edu> - * tao/IIOP_Profile.cpp: - * tao/SHMIOP_Profile.cpp: - * tao/UIOP_Profile.cpp: Added error checking. The error checking - was needed for the ACE_Inet_Addr::set () method that was getting - called. This is for bug #474 reported by Chris Cleeland - <cleeland_c@ociweb.com>. + * tao/IIOP_Profile.cpp: + * tao/SHMIOP_Profile.cpp: + * tao/UIOP_Profile.cpp: Added error checking. The error checking + was needed for the ACE_Inet_Addr::set () method that was getting + called. This is for bug #474 reported by Chris Cleeland + <cleeland_c@ociweb.com>. Fri Mar 3 11:15:06 2000 Ossama Othman <ossama@uci.edu> - * tao/SHMIOP_Profile.cpp (decode): + * tao/SHMIOP_Profile.cpp (decode): - Corrected "IIOP" to be "SHMIOP" in debugging output. Minor - cosmetic changes. + Corrected "IIOP" to be "SHMIOP" in debugging output. Minor + cosmetic changes. Fri Mar 3 11:01:32 2000 Krishnakumar Elakkara Pathayapura <krish@polka.cs.wustl.edu> - * orbsvcs/orbsvcs/Log/Log_i.cpp (my_factory): fixed a bug. The - constructor was not making a duplicate when assigning to a - _var. Thanks to Rob Ruff <rruff@scires.com> and Sandro Doro - <doro.s@flashnet.it> for reporting it. + * orbsvcs/orbsvcs/Log/Log_i.cpp (my_factory): fixed a bug. The + constructor was not making a duplicate when assigning to a + _var. Thanks to Rob Ruff <rruff@scires.com> and Sandro Doro + <doro.s@flashnet.it> for reporting it. Fri Mar 3 01:06:49 2000 Nagarajan Surendran <naga@cs.wustl.edu> - * docs/releasenotes/index.html: Fixed a missing link ~naga/av.html - to ~schmidt/av.html. Thanks to Keith Nicewarner - <knicewar@erg.sri.com> for reporting this. + * docs/releasenotes/index.html: Fixed a missing link ~naga/av.html + to ~schmidt/av.html. Thanks to Keith Nicewarner + <knicewar@erg.sri.com> for reporting this. Thu Mar 2 22:29:17 2000 Jeff Parsons <parsons@cs.wustl.edu> - * tao/TAO.dsp: - Added TimeBaseC.h to project. + * tao/TAO.dsp: + Added TimeBaseC.h to project. Thu Mar 2 21:03:09 2000 Jeff Parsons <parsons@cs.wustl.edu> - * tao/CONV_FRAMEC.h: - * tao/CONV_FRAMEC.cpp: - * tao/CurrentC.h: - * tao/CurrentC.cpp: - * tao/DomainC.h: - * tao/DomainC.cpp: - * tao/GIOPC.h: - * tao/GIOPC.cpp: - * tao/IOPC.h: - * tao/IOPC.cpp: - * tao/IORC.h: - * tao/IORC.cpp: - * tao.ImplRepoC.h: - * tao.ImplRepoC.cpp: - * tao/InterceptorC.h: - * tao/InterceptorC.i: - * tao/InterceptorC.cpp: - * tao/InterfaceC.h: - * tao/InterfaceC.cpp: - * tao/PolicyC.h: - * tao/PolicyC.cpp: - * tao/PollableC.h: - * tao/Pollable.cpp: - * tao/TAOC.h: - * tao/TAOC.cpp: - * tao/TimeBaseC.h: - * tao/TimeBaseC.cpp: - Replaced the Any operators with new versions using - compiled marshaling, and added the new CORBA 2.3 - overload for the extraction operator having an rhs of - pointer to const. Also put back some CDR stream - operators into Interceptor needed by the new Any - operators. + * tao/CONV_FRAMEC.h: + * tao/CONV_FRAMEC.cpp: + * tao/CurrentC.h: + * tao/CurrentC.cpp: + * tao/DomainC.h: + * tao/DomainC.cpp: + * tao/GIOPC.h: + * tao/GIOPC.cpp: + * tao/IOPC.h: + * tao/IOPC.cpp: + * tao/IORC.h: + * tao/IORC.cpp: + * tao.ImplRepoC.h: + * tao.ImplRepoC.cpp: + * tao/InterceptorC.h: + * tao/InterceptorC.i: + * tao/InterceptorC.cpp: + * tao/InterfaceC.h: + * tao/InterfaceC.cpp: + * tao/PolicyC.h: + * tao/PolicyC.cpp: + * tao/PollableC.h: + * tao/Pollable.cpp: + * tao/TAOC.h: + * tao/TAOC.cpp: + * tao/TimeBaseC.h: + * tao/TimeBaseC.cpp: + Replaced the Any operators with new versions using + compiled marshaling, and added the new CORBA 2.3 + overload for the extraction operator having an rhs of + pointer to const. Also put back some CDR stream + operators into Interceptor needed by the new Any + operators. Thu Mar 2 11:58:56 2000 Jeff Parsons <parsons@cs.wustl.edu> - * TAO_IDL/be/be_visitor_interface/any_op_cs.cpp: - In the extraction operator, removed an extra - assignment of the rhs to 0. + * TAO_IDL/be/be_visitor_interface/any_op_cs.cpp: + In the extraction operator, removed an extra + assignment of the rhs to 0. Thu Mar 2 09:24:16 2000 Carlos O'Ryan <coryan@uci.edu> - * tao/Object.h: - * tao/Object.i: - Add a static _unchecked_narrow() method to CORBA::Object, it is - useful when writing generic templates. Thanks to Andreas - Geisler <andreas.geisler@erls.siemens.de> for pointing this out. + * tao/Object.h: + * tao/Object.i: + Add a static _unchecked_narrow() method to CORBA::Object, it is + useful when writing generic templates. Thanks to Andreas + Geisler <andreas.geisler@erls.siemens.de> for pointing this out. Thu Mar 2 09:09:58 2000 Carlos O'Ryan <coryan@uci.edu> - * tao/Exception.h: - * tao/Exception.cpp: - The CORBA::UserException is abstract, the _raise() method cannot - be defined for it. + * tao/Exception.h: + * tao/Exception.cpp: + The CORBA::UserException is abstract, the _raise() method cannot + be defined for it. - * tao/POAC.i: - The ForwardRequest exception is not present with minimum CORBA, - yet i did not protect the CDR insertion and extraction operators - for it with TAO_HAS_MINIMUM_CORBA == 0 + * tao/POAC.i: + The ForwardRequest exception is not present with minimum CORBA, + yet i did not protect the CDR insertion and extraction operators + for it with TAO_HAS_MINIMUM_CORBA == 0 - * TAO_IDL/be/be_visitor_exception/cdr_op_ci.cpp: - For exceptions without any fields the operator>> declared on the - header file and the one defined in the .i file were not - matching. + * TAO_IDL/be/be_visitor_exception/cdr_op_ci.cpp: + For exceptions without any fields the operator>> declared on the + header file and the one defined in the .i file were not + matching. Wed Mar 1 21:36:38 2000 Darrell Brunsch <brunsch@uci.edu> diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_ObserverStrategy.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_ObserverStrategy.cpp index 0b23e6bbb61..e9cba370823 100644 --- a/TAO/orbsvcs/orbsvcs/Event/EC_ObserverStrategy.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/EC_ObserverStrategy.cpp @@ -323,7 +323,7 @@ TAO_EC_Basic_ObserverStrategy::fill_qos ( dep.length (headers.current_size () + 1); dep[0].event.header.type = ACE_ES_DISJUNCTION_DESIGNATOR; - dep[0].event.header.source = 0; + dep[0].event.header.source = headers.current_size (); dep[0].event.header.creation_time = ORBSVCS_Time::zero (); dep[0].rt_info = 0; diff --git a/TAO/orbsvcs/tests/Event/Basic/Basic.dsw b/TAO/orbsvcs/tests/Event/Basic/Basic.dsw index d2b111d5334..05b11352237 100644 --- a/TAO/orbsvcs/tests/Event/Basic/Basic.dsw +++ b/TAO/orbsvcs/tests/Event/Basic/Basic.dsw @@ -51,6 +51,18 @@ Package=<4> ###############################################################################
+Project: "Gateway"=.\Gateway.dsp - Package Owner=<4>
+
+Package=<5>
+{{{
+}}}
+
+Package=<4>
+{{{
+}}}
+
+###############################################################################
+
Project: "Disconnect"=.\Disconnect.dsp - Package Owner=<4>
Package=<5>
diff --git a/TAO/orbsvcs/tests/Event/Basic/Gateway.cpp b/TAO/orbsvcs/tests/Event/Basic/Gateway.cpp new file mode 100644 index 00000000000..e62a1454e41 --- /dev/null +++ b/TAO/orbsvcs/tests/Event/Basic/Gateway.cpp @@ -0,0 +1,239 @@ +// $Id$ + +#include "Counting_Consumer.h" +#include "Counting_Supplier.h" +#include "orbsvcs/Time_Utilities.h" +#include "orbsvcs/Event_Utilities.h" +#include "orbsvcs/Event/EC_Event_Channel.h" +#include "orbsvcs/Event/EC_Default_Factory.h" +#include "orbsvcs/Event/EC_Gateway.h" + +ACE_RCSID(EC_Tests, Gateway, "$Id$") + +int +main (int argc, char* argv[]) +{ + TAO_EC_Default_Factory::init_svcs (); + + ACE_DECLARE_NEW_CORBA_ENV; + ACE_TRY + { + // ORB initialization boiler plate... + CORBA::ORB_var orb = + CORBA::ORB_init (argc, argv, "", ACE_TRY_ENV); + ACE_TRY_CHECK; + + CORBA::Object_var object = + orb->resolve_initial_references ("RootPOA", ACE_TRY_ENV); + ACE_TRY_CHECK; + PortableServer::POA_var poa = + PortableServer::POA::_narrow (object.in (), ACE_TRY_ENV); + ACE_TRY_CHECK; + PortableServer::POAManager_var poa_manager = + poa->the_POAManager (ACE_TRY_ENV); + ACE_TRY_CHECK; + poa_manager->activate (ACE_TRY_ENV); + ACE_TRY_CHECK; + + // **************************************************************** + + TAO_EC_Event_Channel_Attributes attributes (poa.in (), + poa.in ()); + attributes.consumer_reconnect = 1; + attributes.supplier_reconnect = 1; + + TAO_EC_Event_Channel ec_impl_1 (attributes); + ec_impl_1.activate (ACE_TRY_ENV); + ACE_TRY_CHECK; + + RtecEventChannelAdmin::EventChannel_var event_channel_1 = + ec_impl_1._this (ACE_TRY_ENV); + ACE_TRY_CHECK; + + // **************************************************************** + + TAO_EC_Event_Channel ec_impl_2 (attributes); + ec_impl_2.activate (ACE_TRY_ENV); + ACE_TRY_CHECK; + + RtecEventChannelAdmin::EventChannel_var event_channel_2 = + ec_impl_2._this (ACE_TRY_ENV); + ACE_TRY_CHECK; + + // **************************************************************** + + // Obtain the consumer admin.. + RtecEventChannelAdmin::ConsumerAdmin_var consumer_admin_1 = + event_channel_1->for_consumers (ACE_TRY_ENV); + ACE_TRY_CHECK; + + // Obtain the supplier admin.. + RtecEventChannelAdmin::SupplierAdmin_var supplier_admin_1 = + event_channel_1->for_suppliers (ACE_TRY_ENV); + ACE_TRY_CHECK; + + // **************************************************************** + + // Obtain the consumer admin.. + RtecEventChannelAdmin::ConsumerAdmin_var consumer_admin_2 = + event_channel_2->for_consumers (ACE_TRY_ENV); + ACE_TRY_CHECK; + + // Obtain the supplier admin.. + RtecEventChannelAdmin::SupplierAdmin_var supplier_admin_2 = + event_channel_2->for_suppliers (ACE_TRY_ENV); + ACE_TRY_CHECK; + + // **************************************************************** + + TAO_EC_Gateway_IIOP gateway; + gateway.init (event_channel_1.in (), + event_channel_2.in (), + RtecScheduler::Scheduler::_nil (), + RtecScheduler::Scheduler::_nil (), + 0, 0, + ACE_TRY_ENV); + + RtecEventChannelAdmin::Observer_var obs = + gateway._this (ACE_TRY_ENV); + ACE_CHECK; + + RtecEventChannelAdmin::Observer_Handle h = + event_channel_2->append_observer (obs.in (), ACE_TRY_ENV); + ACE_CHECK; + + gateway.observer_handle (h); + + // **************************************************************** + + const int event_type = 20; + const int event_source = 10; + const int milliseconds = 50; + + EC_Counting_Supplier supplier_00; + + supplier_00.activate (consumer_admin_1.in (), + milliseconds, + ACE_TRY_ENV); + ACE_TRY_CHECK; + supplier_00.connect (supplier_admin_1.in (), + event_source, + event_type, + event_source, + event_type, + ACE_TRY_ENV); + ACE_TRY_CHECK; + + EC_Counting_Supplier supplier_01; + + supplier_01.activate (consumer_admin_1.in (), + milliseconds, + ACE_TRY_ENV); + ACE_TRY_CHECK; + supplier_01.connect (supplier_admin_1.in (), + event_source, + event_type + 1, + event_source, + event_type + 1, + ACE_TRY_ENV); + ACE_TRY_CHECK; + + // **************************************************************** + + EC_Counting_Consumer consumer_00 ("Consumer/00"); + // Create a consumer, intialize its RT_Info structures, and + // connnect to the event channel.... + + + { + ACE_ConsumerQOS_Factory consumer_qos; + consumer_qos.start_disjunction_group (1); + consumer_qos.insert_type (event_type, 0); + + consumer_00.connect (consumer_admin_2.in (), + consumer_qos.get_ConsumerQOS (), + ACE_TRY_ENV); + ACE_TRY_CHECK; + } + + // **************************************************************** + + ACE_Time_Value tv (5, 0); + // Wait for events, using work_pending()/perform_work() may help + // or using another thread, this example is too simple for that. + orb->run (tv); + + // **************************************************************** + + CORBA::ULong expected = + supplier_00.event_count; + CORBA::ULong discarded = + supplier_01.event_count; + consumer_00.dump_results (expected, 5); + + // **************************************************************** + + { + ACE_ConsumerQOS_Factory consumer_qos; + consumer_qos.start_disjunction_group (2); + consumer_qos.insert_type (event_type, 0); + consumer_qos.insert_type (event_type + 1, 0); + + consumer_00.connect (consumer_admin_2.in (), + consumer_qos.get_ConsumerQOS (), + ACE_TRY_ENV); + ACE_TRY_CHECK; + } + + // **************************************************************** + + tv = ACE_Time_Value (5, 0); + orb->run (tv); + + // **************************************************************** + + consumer_00.disconnect (ACE_TRY_ENV); + ACE_TRY_CHECK; + + supplier_01.deactivate (ACE_TRY_ENV); + ACE_TRY_CHECK; + supplier_00.deactivate (ACE_TRY_ENV); + ACE_TRY_CHECK; + + supplier_01.disconnect (ACE_TRY_ENV); + ACE_TRY_CHECK; + supplier_00.disconnect (ACE_TRY_ENV); + ACE_TRY_CHECK; + + gateway.shutdown (ACE_TRY_ENV); + ACE_CHECK; + + // **************************************************************** + + event_channel_1->destroy (ACE_TRY_ENV); + ACE_TRY_CHECK; + + event_channel_2->destroy (ACE_TRY_ENV); + ACE_TRY_CHECK; + + // **************************************************************** + + poa->destroy (1, 1, ACE_TRY_ENV); + ACE_TRY_CHECK; + + orb->destroy (ACE_TRY_ENV); + ACE_TRY_CHECK; + + expected = + supplier_00.event_count + + supplier_01.event_count - discarded; + consumer_00.dump_results (expected, 5); + } + ACE_CATCHANY + { + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Service"); + return 1; + } + ACE_ENDTRY; + return 0; +} diff --git a/TAO/orbsvcs/tests/Event/Basic/Gateway.dsp b/TAO/orbsvcs/tests/Event/Basic/Gateway.dsp new file mode 100644 index 00000000000..c6bf0fe295e --- /dev/null +++ b/TAO/orbsvcs/tests/Event/Basic/Gateway.dsp @@ -0,0 +1,99 @@ +# Microsoft Developer Studio Project File - Name="Gateway" - Package Owner=<4>
+# Microsoft Developer Studio Generated Build File, Format Version 6.00
+# ** DO NOT EDIT **
+
+# TARGTYPE "Win32 (x86) Console Application" 0x0103
+
+CFG=Gateway - Win32 Debug
+!MESSAGE This is not a valid makefile. To build this project using NMAKE,
+!MESSAGE use the Export Makefile command and run
+!MESSAGE
+!MESSAGE NMAKE /f "Gateway.mak".
+!MESSAGE
+!MESSAGE You can specify a configuration when running NMAKE
+!MESSAGE by defining the macro CFG on the command line. For example:
+!MESSAGE
+!MESSAGE NMAKE /f "Gateway.mak" CFG="Gateway - Win32 Debug"
+!MESSAGE
+!MESSAGE Possible choices for configuration are:
+!MESSAGE
+!MESSAGE "Gateway - Win32 Release" (based on\
+ "Win32 (x86) Console Application")
+!MESSAGE "Gateway - Win32 Debug" (based on\
+ "Win32 (x86) Console Application")
+!MESSAGE
+
+# Begin Project
+# PROP Scc_ProjName ""
+# PROP Scc_LocalPath ""
+CPP=cl.exe
+RSC=rc.exe
+
+!IF "$(CFG)" == "Gateway - Win32 Release"
+
+# PROP BASE Use_MFC 0
+# PROP BASE Use_Debug_Libraries 0
+# PROP BASE Output_Dir "Release"
+# PROP BASE Intermediate_Dir "Release"
+# PROP BASE Target_Dir ""
+# PROP Use_MFC 0
+# PROP Use_Debug_Libraries 0
+# PROP Output_Dir "Release"
+# PROP Intermediate_Dir "Release"
+# PROP Ignore_Export_Lib 0
+# PROP Target_Dir ""
+# ADD BASE CPP /nologo /W3 /GX /O2 /D "WIN32" /D "NDEBUG" /D "_CONSOLE" /D "_MBCS" /YX /FD /c
+# ADD CPP /nologo /MD /W3 /GX /O2 /I "..\lib" /I "..\..\.." /I "..\..\..\.." /I "..\..\..\..\.." /D "WIN32" /D "NDEBUG" /D "_CONSOLE" /D "_MBCS" /YX /FD /c
+# ADD BASE RSC /l 0x409 /d "NDEBUG"
+# ADD RSC /l 0x409 /d "NDEBUG"
+BSC32=bscmake.exe
+# ADD BASE BSC32 /nologo
+# ADD BSC32 /nologo
+LINK32=link.exe
+# ADD BASE LINK32 kernel32.lib user32.lib gdi32.lib winspool.lib comdlg32.lib advapi32.lib shell32.lib ole32.lib oleaut32.lib uuid.lib odbc32.lib odbccp32.lib /nologo /subsystem:console /machine:I386
+# ADD LINK32 ECTest.lib orbsvcs.lib TAO.lib ace.lib /nologo /subsystem:console /machine:I386 /libpath:"..\lib" /libpath:"..\..\..\orbsvcs" /libpath:"..\..\..\..\tao" /libpath:"..\..\..\..\..\ace"
+
+!ELSEIF "$(CFG)" == "Gateway - Win32 Debug"
+
+# PROP BASE Use_MFC 0
+# PROP BASE Use_Debug_Libraries 1
+# PROP BASE Output_Dir "Debug"
+# PROP BASE Intermediate_Dir "Debug"
+# PROP BASE Target_Dir ""
+# PROP Use_MFC 0
+# PROP Use_Debug_Libraries 1
+# PROP Output_Dir ""
+# PROP Intermediate_Dir "Debug"
+# PROP Ignore_Export_Lib 0
+# PROP Target_Dir ""
+# ADD BASE CPP /nologo /W3 /Gm /GX /Zi /Od /D "WIN32" /D "_DEBUG" /D "_CONSOLE" /D "_MBCS" /YX /FD /c
+# ADD CPP /nologo /MDd /W3 /Gm /GX /Zi /Od /I "..\lib" /I "..\..\.." /I "..\..\..\.." /I "..\..\..\..\.." /D "WIN32" /D "_DEBUG" /D "_CONSOLE" /D "_MBCS" /YX /FD /c
+# ADD BASE RSC /l 0x409 /d "_DEBUG"
+# ADD RSC /l 0x409 /d "_DEBUG"
+BSC32=bscmake.exe
+# ADD BASE BSC32 /nologo
+# ADD BSC32 /nologo
+LINK32=link.exe
+# ADD BASE LINK32 kernel32.lib user32.lib gdi32.lib winspool.lib comdlg32.lib advapi32.lib shell32.lib ole32.lib oleaut32.lib uuid.lib odbc32.lib odbccp32.lib /nologo /subsystem:console /debug /machine:I386 /pdbtype:sept
+# ADD LINK32 ECTestd.lib orbsvcsd.lib TAOd.lib aced.lib /nologo /subsystem:console /debug /machine:I386 /pdbtype:sept /libpath:"..\lib" /libpath:"..\..\..\orbsvcs" /libpath:"..\..\..\..\tao" /libpath:"..\..\..\..\..\ace"
+
+!ENDIF
+
+# Begin Target
+
+# Name "Gateway - Win32 Release"
+# Name "Gateway - Win32 Debug"
+# Begin Group "Header Files"
+
+# PROP Default_Filter ".h"
+# End Group
+# Begin Group "Source Files"
+
+# PROP Default_Filter ".cpp"
+# Begin Source File
+
+SOURCE=.\Gateway.cpp
+# End Source File
+# End Group
+# End Target
+# End Project
diff --git a/TAO/orbsvcs/tests/Event/Basic/Makefile b/TAO/orbsvcs/tests/Event/Basic/Makefile index 3a57523e012..efd204c65fa 100644 --- a/TAO/orbsvcs/tests/Event/Basic/Makefile +++ b/TAO/orbsvcs/tests/Event/Basic/Makefile @@ -24,7 +24,8 @@ BIN2 = Reconnect \ MT_Disconnect \ Atomic_Reconnect \ Bitmask \ - Complex + Complex \ + Gateway #### If the orbsvcs library wasn't built with all components, don't #### try to build certain tests. @@ -97,8 +98,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -113,6 +117,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -238,14 +251,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -434,8 +439,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -450,6 +458,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -575,14 +592,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -762,8 +771,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -778,6 +790,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -903,14 +924,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -1114,8 +1127,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -1130,6 +1146,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -1255,14 +1280,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -1456,8 +1473,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -1472,6 +1492,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -1597,14 +1626,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -1816,8 +1837,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -1832,6 +1856,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -1957,14 +1990,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -2158,8 +2183,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -2174,6 +2202,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -2299,14 +2336,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -2500,8 +2529,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -2516,6 +2548,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -2641,14 +2682,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -2844,8 +2877,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -2860,6 +2896,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -2985,14 +3030,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -3199,6 +3236,18 @@ endif $(ACE_ROOT)/ace/Containers_T.i \ $(ACE_ROOT)/ace/Containers_T.cpp \ $(ACE_ROOT)/ace/Malloc.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ $(ACE_ROOT)/ace/Malloc.i \ $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ @@ -3212,14 +3261,6 @@ endif $(ACE_ROOT)/ace/Mem_Map.h \ $(ACE_ROOT)/ace/Mem_Map.i \ $(ACE_ROOT)/ace/Memory_Pool.i \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(ACE_ROOT)/ace/Thread_Manager.i \ $(ACE_ROOT)/ace/Task.i \ $(ACE_ROOT)/ace/Task_T.h \ @@ -3526,8 +3567,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -3542,6 +3586,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -3667,14 +3720,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -3868,8 +3913,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -3884,6 +3932,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -4009,14 +4066,6 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ - $(ACE_ROOT)/ace/Singleton.h \ - $(ACE_ROOT)/ace/Singleton.i \ - $(ACE_ROOT)/ace/Singleton.cpp \ - $(ACE_ROOT)/ace/Object_Manager.h \ - $(ACE_ROOT)/ace/Object_Manager.i \ - $(ACE_ROOT)/ace/Managed_Object.h \ - $(ACE_ROOT)/ace/Managed_Object.i \ - $(ACE_ROOT)/ace/Managed_Object.cpp \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -4210,8 +4259,11 @@ endif $(ACE_ROOT)/ace/ACE.i \ $(ACE_ROOT)/ace/Malloc.h \ $(ACE_ROOT)/ace/Malloc_Base.h \ - $(ACE_ROOT)/ace/Malloc.i \ - $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ + $(ACE_ROOT)/ace/Singleton.h \ $(ACE_ROOT)/ace/Synch.h \ $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ @@ -4226,6 +4278,15 @@ endif $(ACE_ROOT)/ace/Thread.i \ $(ACE_ROOT)/ace/Atomic_Op.i \ $(ACE_ROOT)/ace/Synch_T.cpp \ + $(ACE_ROOT)/ace/Singleton.i \ + $(ACE_ROOT)/ace/Singleton.cpp \ + $(ACE_ROOT)/ace/Object_Manager.h \ + $(ACE_ROOT)/ace/Object_Manager.i \ + $(ACE_ROOT)/ace/Managed_Object.h \ + $(ACE_ROOT)/ace/Managed_Object.i \ + $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ $(ACE_ROOT)/ace/Free_List.h \ $(ACE_ROOT)/ace/Free_List.i \ $(ACE_ROOT)/ace/Free_List.cpp \ @@ -4351,7 +4412,218 @@ endif $(TAO_ROOT)/tao/Marshal.h \ $(TAO_ROOT)/tao/Marshal.i \ $(TAO_ROOT)/tao/singletons.h \ + $(TAO_ROOT)/tao/POA.h \ + $(TAO_ROOT)/tao/Object_Adapter.h \ + $(TAO_ROOT)/tao/Key_Adapters.h \ + $(ACE_ROOT)/ace/Map.h \ + $(ACE_ROOT)/ace/Map.i \ + $(ACE_ROOT)/ace/Map_T.h \ + $(ACE_ROOT)/ace/Pair.h \ + $(ACE_ROOT)/ace/Pair.i \ + $(ACE_ROOT)/ace/Pair_T.h \ + $(ACE_ROOT)/ace/Pair_T.i \ + $(ACE_ROOT)/ace/Pair_T.cpp \ + $(ACE_ROOT)/ace/Map_Manager.h \ + $(ACE_ROOT)/ace/Map_Manager.i \ + $(ACE_ROOT)/ace/Map_Manager.cpp \ + $(ACE_ROOT)/ace/Active_Map_Manager.h \ + $(ACE_ROOT)/ace/Active_Map_Manager.i \ + $(ACE_ROOT)/ace/Active_Map_Manager_T.h \ + $(ACE_ROOT)/ace/Active_Map_Manager_T.i \ + $(ACE_ROOT)/ace/Active_Map_Manager_T.cpp \ + $(ACE_ROOT)/ace/Map_T.i \ + $(ACE_ROOT)/ace/Map_T.cpp \ + $(TAO_ROOT)/tao/Key_Adapters.i \ + $(TAO_ROOT)/tao/Server_Strategy_Factory.h \ + $(TAO_ROOT)/tao/poa_macros.h \ + $(TAO_ROOT)/tao/POAS.h \ + $(TAO_ROOT)/tao/POA_CORBA.h \ + $(TAO_ROOT)/tao/DynAnyC.h \ + $(TAO_ROOT)/tao/DynAnyC.i \ + $(TAO_ROOT)/tao/DomainC.h \ + $(TAO_ROOT)/tao/DomainC.i \ + $(TAO_ROOT)/tao/POAS.i \ + $(TAO_ROOT)/tao/Active_Object_Map.h \ + $(TAO_ROOT)/tao/Active_Object_Map.i \ + $(TAO_ROOT)/tao/Object_Adapter.i \ + $(TAO_ROOT)/tao/POAManager.h \ + $(TAO_ROOT)/tao/POAManager.i \ + $(TAO_ROOT)/tao/ImplRepoC.h \ + $(TAO_ROOT)/tao/Operation_Table.h \ + $(TAO_ROOT)/tao/Stub.h \ + $(TAO_ROOT)/tao/Pluggable.h \ + $(ACE_ROOT)/ace/Message_Queue.h \ + $(ACE_ROOT)/ace/IO_Cntl_Msg.h \ + $(ACE_ROOT)/ace/Message_Queue_T.h \ + $(ACE_ROOT)/ace/Message_Queue_T.i \ + $(ACE_ROOT)/ace/Message_Queue_T.cpp \ + $(ACE_ROOT)/ace/Strategies.h \ + $(ACE_ROOT)/ace/Strategies_T.h \ + $(ACE_ROOT)/ace/Synch_Options.h \ + $(ACE_ROOT)/ace/Synch_Options.i \ + $(ACE_ROOT)/ace/Thread_Manager.h \ + $(ACE_ROOT)/ace/Thread_Manager.i \ + $(ACE_ROOT)/ace/Strategies_T.i \ + $(ACE_ROOT)/ace/Strategies_T.cpp \ + $(ACE_ROOT)/ace/Service_Repository.h \ + $(ACE_ROOT)/ace/Service_Types.h \ + $(ACE_ROOT)/ace/Service_Types.i \ + $(ACE_ROOT)/ace/Service_Repository.i \ + $(ACE_ROOT)/ace/WFMO_Reactor.h \ + $(ACE_ROOT)/ace/WFMO_Reactor.i \ + $(ACE_ROOT)/ace/Strategies.i \ + $(ACE_ROOT)/ace/Message_Queue.i \ + $(TAO_ROOT)/tao/Pluggable.i \ + $(TAO_ROOT)/tao/MProfile.h \ + $(TAO_ROOT)/tao/Profile.h \ + $(TAO_ROOT)/tao/Tagged_Components.h \ + $(TAO_ROOT)/tao/CONV_FRAMEC.h \ + $(TAO_ROOT)/tao/CONV_FRAMEC.i \ + $(TAO_ROOT)/tao/Tagged_Components.i \ + $(TAO_ROOT)/tao/Profile.i \ + $(TAO_ROOT)/tao/MProfile.i \ + $(TAO_ROOT)/tao/Stub.i \ + $(TAO_ROOT)/tao/ORB_Core.h \ + $(TAO_ROOT)/tao/Policy_Manager.h \ + $(TAO_ROOT)/tao/Policy_Manager.i \ + $(TAO_ROOT)/tao/Resource_Factory.h \ + $(TAO_ROOT)/tao/Protocol_Factory.h \ + $(TAO_ROOT)/tao/params.h \ + $(TAO_ROOT)/tao/params.i \ + $(TAO_ROOT)/tao/ORB_Core.i \ + $(ACE_ROOT)/ace/Dynamic_Service.h \ + $(ACE_ROOT)/ace/Dynamic_Service.cpp \ + $(TAO_ROOT)/tao/Invocation.h \ + $(TAO_ROOT)/tao/Reply_Dispatcher.h \ + $(TAO_ROOT)/tao/Reply_Dispatcher.i \ + $(TAO_ROOT)/tao/TAOC.h \ + $(TAO_ROOT)/tao/TAOC.i \ + $(TAO_ROOT)/tao/Invocation.i \ + $(TAO_ROOT)/tao/ImplRepoC.i \ + $(TAO_ROOT)/tao/POA.i \ + $(TAO_ROOT)/tao/debug.h \ + $(TAO_ROOT)/tao/Client_Strategy_Factory.h \ + $(TAO_ROOT)/tao/InconsistentTypeCodeC.h \ + $(TAO_ROOT)/tao/DynAny_i.h \ + $(TAO_ROOT)/tao/Union.h \ + $(TAO_ROOT)/tao/ValueBase.h \ + $(TAO_ROOT)/tao/ValueBase.i \ + $(TAO_ROOT)/tao/ValueFactory.h \ + $(TAO_ROOT)/tao/ValueFactory.i \ + $(TAO_ROOT)/tao/ObjectIDList.h \ + $(TAO_ROOT)/tao/ObjectIDList.i \ + $(TAO_ROOT)/tao/WrongTransactionC.h \ + $(TAO_ROOT)/tao/InterfaceC.h \ + $(TAO_ROOT)/tao/BoundsC.h \ + $(TAO_ROOT)/tao/BoundsC.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseC.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS_T.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS_T.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS_T.cpp \ + $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecDefaultEventDataS.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecDefaultEventDataC.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecDefaultEventDataC.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecDefaultEventDataS_T.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecDefaultEventDataS_T.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecDefaultEventDataS_T.cpp \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecDefaultEventDataS.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventCommC.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventCommC.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventCommS_T.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventCommS_T.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventCommS_T.cpp \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventCommS.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventChannelAdminC.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecSchedulerC.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecSchedulerC.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventChannelAdminC.i \ + ../lib/Counting_Supplier.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Channel_Clients.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Channel_Clients_T.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Channel_Clients_T.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Channel_Clients_T.cpp \ + $(ACE_ROOT)/ace/Task.h \ + $(ACE_ROOT)/ace/Task.i \ + $(ACE_ROOT)/ace/Task_T.h \ + $(ACE_ROOT)/ace/Task_T.i \ + $(ACE_ROOT)/ace/Task_T.cpp \ + $(ACE_ROOT)/ace/Module.h \ + $(ACE_ROOT)/ace/Module.i \ + $(ACE_ROOT)/ace/Module.cpp \ + $(ACE_ROOT)/ace/Stream_Modules.h \ + $(ACE_ROOT)/ace/Stream_Modules.i \ + $(ACE_ROOT)/ace/Stream_Modules.cpp \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Time_Utilities.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Time_Utilities.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event_Utilities.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event_Service_Constants.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event_Utilities.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Event_Channel.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Factory.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Factory.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Defaults.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventChannelAdminS.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecSchedulerS.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecSchedulerS_T.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecSchedulerS_T.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecSchedulerS_T.cpp \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecSchedulerS.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventChannelAdminS_T.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventChannelAdminS_T.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventChannelAdminS_T.cpp \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventChannelAdminS.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Event_Channel.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Default_Factory.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Default_Factory.i + +.obj/Gateway.o .obj/Gateway.so .shobj/Gateway.o .shobj/Gateway.so: Gateway.cpp ../lib/Counting_Consumer.h \ + ../lib/ectest_export.h \ + $(ACE_ROOT)/ace/OS.h \ + $(ACE_ROOT)/ace/inc_user_config.h \ + $(ACE_ROOT)/ace/Min_Max.h \ + $(ACE_ROOT)/ace/streams.h \ + $(ACE_ROOT)/ace/Basic_Types.h \ + $(ACE_ROOT)/ace/Basic_Types.i \ + $(ACE_ROOT)/ace/Trace.h \ + $(ACE_ROOT)/ace/OS.i \ + $(ACE_ROOT)/ace/Log_Msg.h \ + $(ACE_ROOT)/ace/Log_Record.h \ + $(ACE_ROOT)/ace/Log_Priority.h \ + $(ACE_ROOT)/ace/Log_Record.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventCommS.h \ + $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseS.h \ + $(TAO_ROOT)/tao/TimeBaseS.h \ + $(TAO_ROOT)/tao/TimeBaseC.h \ + $(TAO_ROOT)/tao/Any.h \ + $(TAO_ROOT)/tao/CDR.h \ + $(TAO_ROOT)/tao/corbafwd.h \ + $(ACE_ROOT)/ace/CDR_Stream.h \ + $(ACE_ROOT)/ace/Message_Block.h \ + $(ACE_ROOT)/ace/ACE.h \ + $(ACE_ROOT)/ace/ACE.i \ + $(ACE_ROOT)/ace/Malloc.h \ + $(ACE_ROOT)/ace/Malloc_Base.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.h \ + $(ACE_ROOT)/ace/Based_Pointer_T.i \ + $(ACE_ROOT)/ace/Based_Pointer_T.cpp \ + $(ACE_ROOT)/ace/Based_Pointer_Repository.h \ $(ACE_ROOT)/ace/Singleton.h \ + $(ACE_ROOT)/ace/Synch.h \ + $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \ + $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \ + $(ACE_ROOT)/ace/SV_Semaphore_Simple.i \ + $(ACE_ROOT)/ace/SV_Semaphore_Complex.i \ + $(ACE_ROOT)/ace/Synch.i \ + $(ACE_ROOT)/ace/Synch_T.h \ + $(ACE_ROOT)/ace/Event_Handler.h \ + $(ACE_ROOT)/ace/Event_Handler.i \ + $(ACE_ROOT)/ace/Synch_T.i \ + $(ACE_ROOT)/ace/Thread.h \ + $(ACE_ROOT)/ace/Thread.i \ + $(ACE_ROOT)/ace/Atomic_Op.i \ + $(ACE_ROOT)/ace/Synch_T.cpp \ $(ACE_ROOT)/ace/Singleton.i \ $(ACE_ROOT)/ace/Singleton.cpp \ $(ACE_ROOT)/ace/Object_Manager.h \ @@ -4359,6 +4631,133 @@ endif $(ACE_ROOT)/ace/Managed_Object.h \ $(ACE_ROOT)/ace/Managed_Object.i \ $(ACE_ROOT)/ace/Managed_Object.cpp \ + $(ACE_ROOT)/ace/Malloc.i \ + $(ACE_ROOT)/ace/Malloc_T.h \ + $(ACE_ROOT)/ace/Free_List.h \ + $(ACE_ROOT)/ace/Free_List.i \ + $(ACE_ROOT)/ace/Free_List.cpp \ + $(ACE_ROOT)/ace/Malloc_T.i \ + $(ACE_ROOT)/ace/Malloc_T.cpp \ + $(ACE_ROOT)/ace/Memory_Pool.h \ + $(ACE_ROOT)/ace/Signal.h \ + $(ACE_ROOT)/ace/Containers.h \ + $(ACE_ROOT)/ace/Containers.i \ + $(ACE_ROOT)/ace/Containers_T.h \ + $(ACE_ROOT)/ace/Containers_T.i \ + $(ACE_ROOT)/ace/Containers_T.cpp \ + $(ACE_ROOT)/ace/Signal.i \ + $(ACE_ROOT)/ace/Mem_Map.h \ + $(ACE_ROOT)/ace/Mem_Map.i \ + $(ACE_ROOT)/ace/Memory_Pool.i \ + $(ACE_ROOT)/ace/Message_Block.i \ + $(ACE_ROOT)/ace/Message_Block_T.h \ + $(ACE_ROOT)/ace/Message_Block_T.i \ + $(ACE_ROOT)/ace/Message_Block_T.cpp \ + $(ACE_ROOT)/ace/SString.h \ + $(ACE_ROOT)/ace/SString.i \ + $(ACE_ROOT)/ace/CDR_Stream.i \ + $(TAO_ROOT)/tao/try_macros.h \ + $(TAO_ROOT)/tao/orbconf.h \ + $(ACE_ROOT)/ace/CORBA_macros.h \ + $(TAO_ROOT)/tao/corbafwd.i \ + $(TAO_ROOT)/tao/Typecode.h \ + $(TAO_ROOT)/tao/Exception.h \ + $(TAO_ROOT)/tao/Exception.i \ + $(TAO_ROOT)/tao/Typecode.i \ + $(TAO_ROOT)/tao/CDR.i \ + $(TAO_ROOT)/tao/Environment.h \ + $(TAO_ROOT)/tao/Environment.i \ + $(TAO_ROOT)/tao/Object.h \ + $(TAO_ROOT)/tao/Object.i \ + $(TAO_ROOT)/tao/Any.i \ + $(TAO_ROOT)/tao/TimeBaseC.i \ + $(TAO_ROOT)/tao/TimeBaseS_T.h \ + $(TAO_ROOT)/tao/TimeBaseS_T.i \ + $(TAO_ROOT)/tao/TimeBaseS_T.cpp \ + $(TAO_ROOT)/tao/TimeBaseS.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/TimeBaseC.h \ + $(TAO_ROOT)/tao/corba.h \ + $(TAO_ROOT)/tao/ORB.h \ + $(TAO_ROOT)/tao/IOR_LookupTable.h \ + $(ACE_ROOT)/ace/Hash_Map_Manager.h \ + $(ACE_ROOT)/ace/Functor.h \ + $(ACE_ROOT)/ace/Functor.i \ + $(ACE_ROOT)/ace/Functor_T.h \ + $(ACE_ROOT)/ace/Functor_T.i \ + $(ACE_ROOT)/ace/Functor_T.cpp \ + $(ACE_ROOT)/ace/Hash_Map_Manager.i \ + $(ACE_ROOT)/ace/Hash_Map_Manager_T.h \ + $(ACE_ROOT)/ace/Hash_Map_Manager_T.i \ + $(ACE_ROOT)/ace/Hash_Map_Manager_T.cpp \ + $(ACE_ROOT)/ace/Service_Config.h \ + $(ACE_ROOT)/ace/Service_Object.h \ + $(ACE_ROOT)/ace/Shared_Object.h \ + $(ACE_ROOT)/ace/Shared_Object.i \ + $(ACE_ROOT)/ace/Service_Object.i \ + $(ACE_ROOT)/ace/Service_Config.i \ + $(ACE_ROOT)/ace/Reactor.h \ + $(ACE_ROOT)/ace/Handle_Set.h \ + $(ACE_ROOT)/ace/Handle_Set.i \ + $(ACE_ROOT)/ace/Timer_Queue.h \ + $(ACE_ROOT)/ace/Timer_Queue_T.h \ + $(ACE_ROOT)/ace/Timer_Queue_T.i \ + $(ACE_ROOT)/ace/Timer_Queue_T.cpp \ + $(ACE_ROOT)/ace/Reactor.i \ + $(ACE_ROOT)/ace/Reactor_Impl.h \ + $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \ + $(TAO_ROOT)/tao/Services.h \ + $(TAO_ROOT)/tao/Sequence.h \ + $(TAO_ROOT)/tao/Managed_Types.h \ + $(TAO_ROOT)/tao/Managed_Types.i \ + $(TAO_ROOT)/tao/Sequence.i \ + $(TAO_ROOT)/tao/Sequence_T.h \ + $(TAO_ROOT)/tao/Sequence_T.i \ + $(TAO_ROOT)/tao/Sequence_T.cpp \ + $(TAO_ROOT)/tao/varout.h \ + $(TAO_ROOT)/tao/varout.i \ + $(TAO_ROOT)/tao/varout.cpp \ + $(TAO_ROOT)/tao/Services.i \ + $(TAO_ROOT)/tao/IORManipulation.h \ + $(TAO_ROOT)/tao/IORS.h \ + $(TAO_ROOT)/tao/IORC.h \ + $(TAO_ROOT)/tao/IORC.i \ + $(TAO_ROOT)/tao/Servant_Base.h \ + $(TAO_ROOT)/tao/POAC.h \ + $(TAO_ROOT)/tao/PolicyC.h \ + $(TAO_ROOT)/tao/CurrentC.h \ + $(TAO_ROOT)/tao/CurrentC.i \ + $(TAO_ROOT)/tao/PolicyC.i \ + $(TAO_ROOT)/tao/POAC.i \ + $(TAO_ROOT)/tao/Servant_Base.i \ + $(TAO_ROOT)/tao/IORS.i \ + $(TAO_ROOT)/tao/Interceptor.h \ + $(TAO_ROOT)/tao/InterceptorS.h \ + $(TAO_ROOT)/tao/InterceptorC.h \ + $(TAO_ROOT)/tao/IOPC.h \ + $(TAO_ROOT)/tao/IOPC.i \ + $(TAO_ROOT)/tao/InterceptorC.i \ + $(TAO_ROOT)/tao/Interceptor.i \ + $(TAO_ROOT)/tao/ORB.i \ + $(TAO_ROOT)/tao/NVList.h \ + $(TAO_ROOT)/tao/NVList.i \ + $(TAO_ROOT)/tao/Principal.h \ + $(TAO_ROOT)/tao/Principal.i \ + $(TAO_ROOT)/tao/Request.h \ + $(TAO_ROOT)/tao/Context.h \ + $(TAO_ROOT)/tao/Context.i \ + $(TAO_ROOT)/tao/MessagingC.h \ + $(TAO_ROOT)/tao/PollableC.h \ + $(TAO_ROOT)/tao/MessagingC.i \ + $(TAO_ROOT)/tao/Request.i \ + $(TAO_ROOT)/tao/Server_Request.h \ + $(TAO_ROOT)/tao/Object_KeyC.h \ + $(TAO_ROOT)/tao/Object_KeyC.i \ + $(TAO_ROOT)/tao/GIOP.h \ + $(TAO_ROOT)/tao/GIOP.i \ + $(TAO_ROOT)/tao/Server_Request.i \ + $(TAO_ROOT)/tao/Marshal.h \ + $(TAO_ROOT)/tao/Marshal.i \ + $(TAO_ROOT)/tao/singletons.h \ $(TAO_ROOT)/tao/POA.h \ $(TAO_ROOT)/tao/Object_Adapter.h \ $(TAO_ROOT)/tao/Key_Adapters.h \ @@ -4523,6 +4922,7 @@ endif $(TAO_ROOT)/orbsvcs/orbsvcs/RtecEventChannelAdminS.i \ $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Event_Channel.i \ $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Default_Factory.h \ - $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Default_Factory.i + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Default_Factory.i \ + $(TAO_ROOT)/orbsvcs/orbsvcs/Event/EC_Gateway.h # IF YOU PUT ANYTHING HERE IT WILL GO AWAY diff --git a/TAO/orbsvcs/tests/Event/Basic/run_test.pl b/TAO/orbsvcs/tests/Event/Basic/run_test.pl index 7641fb9eb14..7bdd8ab0513 100755 --- a/TAO/orbsvcs/tests/Event/Basic/run_test.pl +++ b/TAO/orbsvcs/tests/Event/Basic/run_test.pl @@ -44,6 +44,14 @@ if ($T->TimedWait (60) == -1) { $T->Kill (); $T->TimedWait (1); } +print STDERR "\n\nGateway test\n"; +$T = Process::Create ($prefix . "Gateway".$EXE_EXT, + " -ORBsvcconf observer.conf"); +if ($T->TimedWait (60) == -1) { + print STDERR "ERROR: Test timedout\n"; + $status = 1; + $T->Kill (); $T->TimedWait (1); +} print STDERR "\n\nComplex event channel test,", "multiple ECs connected through gateways\n"; |