blob: c327755e9566416df012d2c954486d99f0ea18b3 (
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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
// -*- C++ -*-
//=============================================================================
/**
* @file Monitor_Base.h
*
* @author Jeff Parsons <j.parsons@vanderbilt.edu>
*/
//=============================================================================
#ifndef MONITOR_BASE_H
#define MONITOR_BASE_H
#include /**/ "ace/pre.h"
#include "ace/Monitor_Control_Types.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if defined (ACE_HAS_MONITOR_FRAMEWORK) && (ACE_HAS_MONITOR_FRAMEWORK == 1)
#include "ace/Refcountable_T.h"
#include "ace/Thread_Mutex.h"
#include "ace/Synch_Traits.h"
#include "ace/CDR_Base.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
class ETCL_Constraint;
namespace ACE
{
namespace Monitor_Control
{
class Control_Action;
/**
* @class Monitor_Base
*
* @brief Base class from which the template monitor point class is
* derived.
*/
class ACE_Export Monitor_Base
: private ACE_Refcountable_T<ACE_SYNCH_MUTEX>
{
public:
typedef Monitor_Control_Types::ConstraintList CONSTRAINTS;
typedef CONSTRAINTS::const_iterator CONSTRAINT_ITERATOR;
Monitor_Base (const char* name,
Monitor_Control_Types::Information_Type type);
virtual ~Monitor_Base ();
/// Implemented by the most-derived class. Does the actual
/// work of fetching the monitored value.
virtual void update ();
/// Updates the monitor's data if it is a numeric floating point.
virtual void receive (double data);
/// Updates the monitor's data if it is an integer size.
virtual void receive (size_t data);
/// Updates the monitor's data if it is a string type.
virtual void receive (const Monitor_Control_Types::NameList& data);
/// Add a constraint, returns a unique constraint id.
long add_constraint (const char* expression,
Control_Action* action = 0);
/// Remove a constraint and return the associated control action,
/// which may be shared, for deletion or further use.
Control_Action* remove_constraint (const long constraint_id);
/// Get all constraints
CONSTRAINTS& constraints ();
/// Reset function.
virtual void clear ();
/// Data accessors.
void retrieve (Monitor_Control_Types::Data& data) const;
void retrieve_and_clear (Monitor_Control_Types::Data& data);
/// Common to all monitors.
void add_to_registry (
const ACE_Time_Value& time = ACE_Time_Value::zero);
void remove_from_registry ();
const char* name () const;
void name (const char* new_name);
void add_ref ();
void remove_ref ();
/// Calculate the average of the accumulated samples.
double average () const;
/// Calculate the sum of the squares of the samples.
double sum_of_squares () const;
/// Returns the number of samples
size_t count () const;
/// Returns the minimum sample value
double minimum_sample () const;
/// Returns the maximum sample value
double maximum_sample () const;
/// Returns the most recent sample value
double last_sample () const;
/// Return the type of this statistic
Monitor_Control_Types::Information_Type type () const;
/// Return the list or error msg if wrong type.
Monitor_Control_Types::NameList get_list () const;
protected:
/// Overridden in some monitors (for example the OS monitors) where
/// clearing requires monitor-specific actions.
virtual void clear_i ();
protected:
Monitor_Control_Types::Data data_;
mutable ACE_SYNCH_MUTEX mutex_;
CONSTRAINTS constraints_;
private:
ACE_CString name_;
};
}
}
ACE_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "ace/Monitor_Base.inl"
#endif /* __ACE_INLINE__ */
#endif /* ACE_HAS_MONITOR_FRAMEWORK==1 */
#include /**/ "ace/post.h"
#endif // MONITOR_BASE_H
|
