summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/Reconnecting
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2019-04-17 16:04:18 +0200
committerJohnny Willemsen <jwillemsen@remedy.nl>2019-04-17 16:04:18 +0200
commit05f90a87cdb1cb354ffd8608ed4b01a9b7bbc70e (patch)
tree9eb6c7d826e821769d16e7a2e1671c6991ef00aa /TAO/orbsvcs/tests/Notify/Reconnecting
parentafed34cf77bd8d2e2acbeb5991be019aade1c777 (diff)
downloadATCD-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.cpp8
-rw-r--r--TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.h10
-rw-r--r--TAO/orbsvcs/tests/Notify/Reconnecting/Supplier.cpp4
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 ());
}