summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.cpp80
1 files changed, 5 insertions, 75 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.cpp b/TAO/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.cpp
index 01d329da0ba..a9cdb9c8233 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.cpp
+++ b/TAO/orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.cpp
@@ -1,22 +1,11 @@
/* -*- C++ -*- $Id$ */
-#include "Notify_QoSAdmin_i.h"
+#include "orbsvcs/orbsvcs/Notify/Notify_QoSAdmin_i.h"
ACE_RCSID(Notify, Notify_QoSAdmin_i, "$Id$")
// Implementation skeleton constructor
TAO_Notify_QoSAdmin_i::TAO_Notify_QoSAdmin_i (void)
- :event_reliability_ (CosNotification::BestEffort),
- connection_reliability_ (CosNotification::BestEffort),
- priority_ (CosNotification::DefaultPriority),
- timeout_ (0),
- start_time_supported_ (0),
- stop_time_supported_ (0),
- max_events_per_consumer_ (0),
- order_policy_ (CosNotification::AnyOrder),
- discard_policy_ (CosNotification::AnyOrder),
- maximum_batch_size_ (1),
- pacing_interval_ (0)
{
}
@@ -37,75 +26,16 @@ CosNotification::QoSProperties * TAO_Notify_QoSAdmin_i::get_qos (
}
void
-TAO_Notify_QoSAdmin_i::set_qos (const CosNotification::QoSProperties & qos,
- CORBA::Environment & ACE_TRY_ENV
+TAO_Notify_QoSAdmin_i::set_qos (
+ const CosNotification::QoSProperties & /*qos*/,
+ CORBA::Environment & //ACE_TRY_ENV
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotification::UnsupportedQoS
))
{
- for (CORBA::ULong index = 0; index < qos.length (); ++index)
- {
- ACE_CString property_name(qos[index].name);
-
- if (property_name.compare (CosNotification::EventReliability) == 0)
- {
- CosNotification::PropertyErrorSeq err_seq(1);
- err_seq.length (1);
-
- err_seq[0].code = CosNotification::UNSUPPORTED_PROPERTY;
- err_seq[0].name = CORBA::string_dup (CosNotification::EventReliability);
-
- ACE_THROW (CosNotification::UnsupportedQoS (err_seq));
- }
- else if (property_name.compare (CosNotification::ConnectionReliability) == 0)
- {
- CosNotification::PropertyErrorSeq err_seq(1);
- err_seq.length (1);
-
- err_seq[0].code = CosNotification::UNSUPPORTED_PROPERTY;
- err_seq[0].name = CORBA::string_dup (CosNotification::ConnectionReliability);
-
- ACE_THROW (CosNotification::UnsupportedQoS (err_seq));
- }
- else if (property_name.compare (CosNotification::Priority) == 0)
- {
- qos[index].value >>= this->priority_;
- }
- else if (property_name.compare (CosNotification::Timeout))
- {
- qos[index].value >>= this->timeout_;
- }
- else if (property_name.compare (CosNotification::StartTimeSupported))
- {
- qos[index].value >>= CORBA::Any::to_boolean (this->start_time_supported_);
- }
- else if (property_name.compare (CosNotification::StopTimeSupported))
- {
- qos[index].value >>= CORBA::Any::to_boolean (this->stop_time_supported_);
- }
- else if (property_name.compare (CosNotification::MaxEventsPerConsumer))
- {
- qos[index].value >>= this->max_events_per_consumer_;
- }
- else if (property_name.compare (CosNotification::OrderPolicy))
- {
- qos[index].value >>= this->order_policy_;
- }
- else if (property_name.compare (CosNotification::DiscardPolicy))
- {
- qos[index].value >>= this->discard_policy_;
- }
- else if (property_name.compare (CosNotification::MaximumBatchSize))
- {
- qos[index].value >>= this->maximum_batch_size_;
- }
- else if (property_name.compare (CosNotification::DiscardPolicy))
- {
- qos[index].value >>= this->pacing_interval_;
- }
- }
+ //Add your implementation here
return;
}