summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/AdminProperties.h
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:11 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:11 +0000
commit6b846cf03c0bcbd8c276cb0af61a181e5f98eaae (patch)
treeda50d054f9c761c3f6a5923f6979e93306c56d68 /TAO/orbsvcs/orbsvcs/Notify/AdminProperties.h
parent0e555b9150d38e3b3473ba325b56db2642e6352b (diff)
downloadATCD-6b846cf03c0bcbd8c276cb0af61a181e5f98eaae.tar.gz
Repo restructuring
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/AdminProperties.h')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/AdminProperties.h133
1 files changed, 0 insertions, 133 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/AdminProperties.h b/TAO/orbsvcs/orbsvcs/Notify/AdminProperties.h
deleted file mode 100644
index 163e22dc13c..00000000000
--- a/TAO/orbsvcs/orbsvcs/Notify/AdminProperties.h
+++ /dev/null
@@ -1,133 +0,0 @@
-/* -*- C++ -*- */
-/**
- * @file AdminProperties.h
- *
- * $Id$
- *
- * @author Pradeep Gore <pradeep@oomworks.com>
- *
- *
- */
-
-#ifndef TAO_Notify_ADMINPROPERTIES_H
-#define TAO_Notify_ADMINPROPERTIES_H
-
-#include /**/ "ace/pre.h"
-
-#include "orbsvcs/Notify/notify_serv_export.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "orbsvcs/Notify/PropertySeq.h"
-#include "orbsvcs/Notify/Property_T.h"
-#include "orbsvcs/Notify/Property.h"
-#include "orbsvcs/Notify/Property_Boolean.h"
-
-#include "tao/orbconf.h"
-
-#include "ace/Atomic_Op.h"
-#include "ace/Bound_Ptr.h"
-#include "ace/Condition_Thread_Mutex.h"
-
-TAO_BEGIN_VERSIONED_NAMESPACE_DECL
-
-/**
- * @class TAO_Notify_AdminProperties
- *
- * @brief The AdminProperties per EventChannel.
- *
- */
-class TAO_Notify_Serv_Export TAO_Notify_AdminProperties
- : public TAO_Notify_PropertySeq
-{
-public:
- typedef ACE_Strong_Bound_Ptr<TAO_Notify_AdminProperties, TAO_SYNCH_MUTEX> Ptr;
- /// Constuctor
- TAO_Notify_AdminProperties (void);
-
- /// Destructor
- virtual ~TAO_Notify_AdminProperties ();
-
- // Init
- int init (const CosNotification::PropertySeq& prop_seq);
-
- // finish initialization after values are set by topology load
- void init ();
-
- // = Const Accessors
- const TAO_Notify_Property_Long& max_global_queue_length (void) const;
- const TAO_Notify_Property_Long& max_consumers (void) const;
- const TAO_Notify_Property_Long& max_suppliers (void) const;
- const TAO_Notify_Property_Boolean& reject_new_events (void) const;
-
- // = Non-const accessors
- TAO_Notify_Property_Long & max_global_queue_length (void);
- TAO_Notify_Property_Long & max_consumers (void);
- TAO_Notify_Property_Long & max_suppliers (void);
- TAO_Notify_Property_Boolean & reject_new_events (void);
-
- CORBA::Long& global_queue_length (void);
- TAO_SYNCH_MUTEX& global_queue_lock (void);
- TAO_SYNCH_CONDITION& global_queue_not_full (void);
-
- TAO_Notify_Atomic_Property_Long& consumers (void);
- TAO_Notify_Atomic_Property_Long& suppliers (void);
-
- // = Helper method
- /// Returns true if Queue is full
- CORBA::Boolean queue_full (void);
-
-protected:
- // @@ Pradeep can you explain why there is any maximum for these
- // values? Should they be configurable by the user so the resource
- // requirements can be bounded?
-
- // = Admin. properties
- // for all these properties the default O implies no limit
- /**
- * The maximum number of events that will be queued by the channel before
- * the channel begins discarding events or rejecting new events upon
- * receipt of each new event.
- */
- TAO_Notify_Property_Long max_global_queue_length_;
-
- /// The maximum number of consumers that can be connected to the channel at
- /// any given time.
- TAO_Notify_Property_Long max_consumers_;
-
- /// The maximum number of suppliers that can be connected to the channel at
- /// any given time.
- TAO_Notify_Property_Long max_suppliers_;
-
- /// Reject any new event.
- TAO_Notify_Property_Boolean reject_new_events_;
-
- //= Variables
- /// This is used to count the queue length across all buffers in the Notify Service
- /// to enforce the "MaxQueueLength" property.
- CORBA::Long global_queue_length_;
-
- /// Global queue lock used to serialize access to all queues.
- TAO_SYNCH_MUTEX global_queue_lock_;
-
- /// The condition that the queue_length_ is not at max.
- TAO_SYNCH_CONDITION global_queue_not_full_;
-
- /// These are used to count the number of consumers and suppliers connected to
- /// the system.
- TAO_Notify_Atomic_Property_Long consumers_;
- TAO_Notify_Atomic_Property_Long suppliers_;
-};
-
-
-TAO_END_VERSIONED_NAMESPACE_DECL
-
-#if defined (__ACE_INLINE__)
-#include "orbsvcs/Notify/AdminProperties.inl"
-#endif /* __ACE_INLINE__ */
-
-
-#include /**/ "ace/post.h"
-#endif /* TAO_Notify_ADMINPROPERTIES_H */