diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2019-04-17 16:04:18 +0200 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2019-04-17 16:04:18 +0200 |
commit | 05f90a87cdb1cb354ffd8608ed4b01a9b7bbc70e (patch) | |
tree | 9eb6c7d826e821769d16e7a2e1671c6991ef00aa /TAO/orbsvcs/tests/Notify/Reconnecting | |
parent | afed34cf77bd8d2e2acbeb5991be019aade1c777 (diff) | |
download | ATCD-05f90a87cdb1cb354ffd8608ed4b01a9b7bbc70e.tar.gz |
Layout changes
* TAO/orbsvcs/DevGuideExamples/NotifyService/Filtering/StructuredEventConsumer_i.h:
* TAO/orbsvcs/DevGuideExamples/NotifyService/OfferSubscriptions/StructuredEventConsumer_i.h:
* TAO/orbsvcs/DevGuideExamples/NotifyService/QoSProperties/StructuredEventConsumer_i.h:
* TAO/orbsvcs/DevGuideExamples/NotifyService/RTNotify/StructuredEventConsumer_i.h:
* TAO/orbsvcs/FT_ReplicationManager/FT_FaultConsumer.h:
* TAO/orbsvcs/FT_ReplicationManager/FT_ReplicationManager.h:
* TAO/orbsvcs/Fault_Detector/FT_FaultDetectorFactory_i.h:
* TAO/orbsvcs/Fault_Detector/Fault_Detector_i.h:
* TAO/orbsvcs/Fault_Notifier/FT_Notifier_i.h:
* TAO/orbsvcs/examples/Log/Notify/Notify_Consumer.h:
* TAO/orbsvcs/examples/Log/Notify/Notify_Supplier.h:
* TAO/orbsvcs/examples/Notify/Filter/Filter.h:
* TAO/orbsvcs/examples/Notify/Lanes/Supplier.h:
* TAO/orbsvcs/examples/Notify/Subscribe/Subscribe.h:
* TAO/orbsvcs/examples/Notify/ThreadPool/Consumer.h:
* TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/UpdateableHandler.h:
* TAO/orbsvcs/orbsvcs/IFRService/ComponentRepository_i.cpp:
* TAO/orbsvcs/orbsvcs/Notify/Standard_Event_Persistence.cpp:
* TAO/orbsvcs/orbsvcs/PortableGroup/PG_FactoryRegistry.h:
* TAO/orbsvcs/tests/Notify/Persistent_Filter/Filter.h:
* TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp:
* TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.h:
* TAO/orbsvcs/tests/Notify/Reconnecting/Supplier.cpp:
* TAO/orbsvcs/tests/Notify/lib/Consumer_T.cpp:
* TAO/orbsvcs/tests/Notify/lib/Consumer_T.h:
* TAO/orbsvcs/tests/Notify/lib/PushConsumer.h:
* TAO/orbsvcs/tests/Notify/lib/SequencePushConsumer.h:
* TAO/orbsvcs/tests/Notify/lib/StructuredPushConsumer.h:
* TAO/orbsvcs/tests/Notify/lib/Supplier_T.cpp:
* TAO/orbsvcs/tests/Notify/lib/Supplier_T.h:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/Reconnecting')
-rw-r--r-- | TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp | 8 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.h | 10 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/Notify/Reconnecting/Supplier.cpp | 4 |
3 files changed, 6 insertions, 16 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp b/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp index 7bc87083d6d..4b43325d224 100644 --- a/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp +++ b/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp @@ -1138,9 +1138,7 @@ Consumer_Main::find_notify_factory (void) this->naming_context_->resolve (name); this->ecf_ = - CosNotifyChannelAdmin::EventChannelFactory::_narrow ( - obj.in () - ); + CosNotifyChannelAdmin::EventChannelFactory::_narrow (obj.in ()); } return ! CORBA::is_nil (this->ecf_.in ()); } @@ -1399,9 +1397,7 @@ Consumer_Main::init_structured_proxy_supplier (void) { try { - proxy = this->sa_->get_proxy_supplier ( - this->structured_proxy_id_ - ); + proxy = this->sa_->get_proxy_supplier (this->structured_proxy_id_); ok = ! CORBA::is_nil (proxy.in ()); if (this->verbose_) { diff --git a/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.h b/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.h index f1980469a0b..26f4b891391 100644 --- a/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.h +++ b/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.h @@ -101,15 +101,11 @@ public: virtual void offer_change ( const CosNotification::EventTypeSeq & added, - const CosNotification::EventTypeSeq & removed - ); + const CosNotification::EventTypeSeq & removed); - virtual void push ( - const CORBA::Any & data - ); + virtual void push (const CORBA::Any & data); - virtual void disconnect_push_consumer ( - ); + virtual void disconnect_push_consumer (); size_t received () const; void set_expectations (size_t expecte, size_t fail, size_t serial_number, bool verbose); diff --git a/TAO/orbsvcs/tests/Notify/Reconnecting/Supplier.cpp b/TAO/orbsvcs/tests/Notify/Reconnecting/Supplier.cpp index 7af8337bd6c..c550f4178fe 100644 --- a/TAO/orbsvcs/tests/Notify/Reconnecting/Supplier.cpp +++ b/TAO/orbsvcs/tests/Notify/Reconnecting/Supplier.cpp @@ -534,9 +534,7 @@ Supplier_Main::find_notify_factory (void) this->naming_context_->resolve (name); this->ecf_ = - CosNotifyChannelAdmin::EventChannelFactory::_narrow ( - obj.in () - ); + CosNotifyChannelAdmin::EventChannelFactory::_narrow (obj.in ()); } return ! CORBA::is_nil (this->ecf_.in ()); } |