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
151
152
153
154
155
156
157
158
159
160
161
162
163
|
#ifndef _qpid_agent_ManagementAgent_
#define _qpid_agent_ManagementAgent_
//
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership. The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License. You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
//
#include "qpid/agent/QmfAgentImportExport.h"
#include "qpid/management/ManagementObject.h"
#include "qpid/management/ManagementEvent.h"
#include "qpid/management/Manageable.h"
#include "qpid/sys/Mutex.h"
#include "qpid/client/ConnectionSettings.h"
namespace qpid {
namespace management {
class ManagementAgent
{
public:
class Singleton {
public:
QMF_AGENT_EXTERN Singleton(bool disableManagement = false);
QMF_AGENT_EXTERN ~Singleton();
QMF_AGENT_EXTERN static ManagementAgent* getInstance();
private:
static sys::Mutex lock;
static bool disabled;
static int refCount;
static ManagementAgent* agent;
};
typedef enum {
SEV_EMERG = 0,
SEV_ALERT = 1,
SEV_CRIT = 2,
SEV_ERROR = 3,
SEV_WARN = 4,
SEV_NOTE = 5,
SEV_INFO = 6,
SEV_DEBUG = 7,
SEV_DEFAULT = 8
} severity_t;
ManagementAgent() {}
virtual ~ManagementAgent() {}
virtual int getMaxThreads() = 0;
// Connect to a management broker
//
// brokerHost - Hostname or IP address (dotted-quad) of broker.
//
// brokerPort - TCP port of broker.
//
// intervalSeconds - The interval (in seconds) that this agent shall use
// between broadcast updates to the broker.
//
// useExternalThread - If true, the thread of control used for callbacks
// must be supplied by the user of the object (via the
// pollCallbacks method).
//
// If false, callbacks shall be invoked on the management
// agent's thread. In this case, the callback implementations
// MUST be thread safe.
//
// storeFile - File where this process has read and write access. This
// file shall be used to store persistent state.
//
virtual void init(const std::string& brokerHost = "localhost",
uint16_t brokerPort = 5672,
uint16_t intervalSeconds = 10,
bool useExternalThread = false,
const std::string& storeFile = "",
const std::string& uid = "guest",
const std::string& pwd = "guest",
const std::string& mech = "PLAIN",
const std::string& proto = "tcp") = 0;
virtual void init(const client::ConnectionSettings& settings,
uint16_t intervalSeconds = 10,
bool useExternalThread = false,
const std::string& storeFile = "") = 0;
// Register a schema with the management agent. This is normally called by the
// package initializer generated by the management code generator.
//
virtual void
registerClass(const std::string& packageName,
const std::string& className,
uint8_t* md5Sum,
management::ManagementObject::writeSchemaCall_t schemaCall) = 0;
virtual void
registerEvent(const std::string& packageName,
const std::string& eventName,
uint8_t* md5Sum,
management::ManagementEvent::writeSchemaCall_t schemaCall) = 0;
// Add a management object to the agent. Once added, this object shall be visible
// in the greater management context.
//
// Please note that ManagementObject instances are not explicitly deleted from
// the management agent. When the core object represented by a management object
// is deleted, the "resourceDestroy" method on the management object must be called.
// It will then be reclaimed in due course by the management agent.
//
// Once a ManagementObject instance is added to the agent, the agent then owns the
// instance. The caller MUST NOT free the resources of the instance at any time.
// When it is no longer needed, invoke its "resourceDestroy" method and discard the
// pointer. This allows the management agent to report the deletion of the object
// in an orderly way.
//
virtual ObjectId addObject(ManagementObject* objectPtr, uint64_t persistId = 0) = 0;
//
//
virtual void raiseEvent(const ManagementEvent& event,
severity_t severity = SEV_DEFAULT) = 0;
// If "useExternalThread" was set to true in init, this method must
// be called to provide a thread for any pending method calls that have arrived.
// The method calls for ManagementObject instances shall be invoked synchronously
// during the execution of this method.
//
// callLimit may optionally be used to limit the number of callbacks invoked.
// if 0, no limit is imposed.
//
// The return value is the number of callbacks that remain queued after this
// call is complete. It can be used to determine whether or not further calls
// to pollCallbacks are necessary to clear the backlog. If callLimit is zero,
// the return value will also be zero.
//
virtual uint32_t pollCallbacks(uint32_t callLimit = 0) = 0;
// If "useExternalThread" was set to true in the constructor, this method provides
// a standard file descriptor that can be used in a select statement to signal that
// there are method callbacks ready (i.e. that "pollCallbacks" will result in at
// least one method call). When this fd is ready-for-read, pollCallbacks may be
// invoked. Calling pollCallbacks shall reset the ready-to-read state of the fd.
//
virtual int getSignalFd() = 0;
};
}}
#endif /*!_qpid_agent_ManagementAgent_*/
|
