blob: 163e22dc13c384f372419b5d5a3c93f560cdc170 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
/* -*- 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 */
|
