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
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
|
#ifndef _ManagementObject_
#define _ManagementObject_
/*
*
* 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/CommonImportExport.h"
#include "qpid/management/Mutex.h"
#include "qpid/types/Variant.h"
#include <map>
#include <vector>
#ifdef _IN_QPID_BROKER
#include <boost/shared_ptr.hpp>
#endif
namespace qpid {
namespace management {
class Manageable;
class ObjectId;
class ManagementObject;
class AgentAttachment {
friend class ObjectId;
private:
uint64_t first;
public:
AgentAttachment() : first(0) {}
QPID_COMMON_EXTERN void setBanks(uint32_t broker, uint32_t bank);
uint64_t getFirst() const { return first; }
};
class ObjectId {
protected:
const AgentAttachment* agent;
uint64_t first;
uint64_t second;
uint64_t agentEpoch;
std::string v2Key;
std::string agentName;
void fromString(const std::string&);
public:
QPID_COMMON_INLINE_EXTERN ObjectId() : agent(0), first(0), second(0), agentEpoch(0) {}
QPID_COMMON_INLINE_EXTERN ObjectId(const types::Variant& map) :
agent(0), first(0), second(0), agentEpoch(0) { mapDecode(map.asMap()); }
QPID_COMMON_EXTERN ObjectId(uint8_t flags, uint16_t seq, uint32_t broker);
QPID_COMMON_EXTERN ObjectId(AgentAttachment* _agent, uint8_t flags, uint16_t seq);
QPID_COMMON_EXTERN ObjectId(std::istream&);
QPID_COMMON_EXTERN ObjectId(const std::string&);
QPID_COMMON_INLINE_EXTERN ObjectId(const std::string& agentAddress, const std::string& key,
uint64_t epoch=0) : agent(0), first(0), second(0),
agentEpoch(epoch), v2Key(key), agentName(agentAddress) {}
// Deprecated:
QPID_COMMON_EXTERN ObjectId(uint8_t flags, uint16_t seq, uint32_t broker, uint64_t object);
QPID_COMMON_EXTERN bool operator==(const ObjectId &other) const;
QPID_COMMON_EXTERN bool operator<(const ObjectId &other) const;
QPID_COMMON_EXTERN void mapEncode(types::Variant::Map& map) const;
QPID_COMMON_EXTERN void mapDecode(const types::Variant::Map& map);
QPID_COMMON_EXTERN operator types::Variant::Map() const;
QPID_COMMON_INLINE_EXTERN uint32_t encodedSize() const { return 16; };
QPID_COMMON_EXTERN void encode(std::string& buffer) const;
QPID_COMMON_EXTERN void decode(const std::string& buffer);
QPID_COMMON_EXTERN bool equalV1(const ObjectId &other) const;
QPID_COMMON_INLINE_EXTERN void setV2Key(const std::string& _key) { v2Key = _key; }
QPID_COMMON_EXTERN void setV2Key(const ManagementObject& object);
QPID_COMMON_INLINE_EXTERN void setAgentName(const std::string& _name) { agentName = _name; }
QPID_COMMON_INLINE_EXTERN const std::string& getAgentName() const { return agentName; }
QPID_COMMON_INLINE_EXTERN const std::string& getV2Key() const { return v2Key; }
friend QPID_COMMON_EXTERN std::ostream& operator<<(std::ostream&, const ObjectId&);
};
class ManagementItem {
public:
static const uint8_t TYPE_U8 = 1;
static const uint8_t TYPE_U16 = 2;
static const uint8_t TYPE_U32 = 3;
static const uint8_t TYPE_U64 = 4;
static const uint8_t TYPE_SSTR = 6;
static const uint8_t TYPE_LSTR = 7;
static const uint8_t TYPE_ABSTIME = 8;
static const uint8_t TYPE_DELTATIME = 9;
static const uint8_t TYPE_REF = 10;
static const uint8_t TYPE_BOOL = 11;
static const uint8_t TYPE_FLOAT = 12;
static const uint8_t TYPE_DOUBLE = 13;
static const uint8_t TYPE_UUID = 14;
static const uint8_t TYPE_FTABLE = 15;
static const uint8_t TYPE_S8 = 16;
static const uint8_t TYPE_S16 = 17;
static const uint8_t TYPE_S32 = 18;
static const uint8_t TYPE_S64 = 19;
static const uint8_t TYPE_LIST = 21;
static const uint8_t ACCESS_RC = 1;
static const uint8_t ACCESS_RW = 2;
static const uint8_t ACCESS_RO = 3;
static const uint8_t DIR_I = 1;
static const uint8_t DIR_O = 2;
static const uint8_t DIR_IO = 3;
static const uint8_t FLAG_CONFIG = 0x01;
static const uint8_t FLAG_INDEX = 0x02;
static const uint8_t FLAG_END = 0x80;
const static uint8_t CLASS_KIND_TABLE = 1;
const static uint8_t CLASS_KIND_EVENT = 2;
public:
virtual ~ManagementItem() {}
};
class QPID_COMMON_CLASS_EXTERN ManagementObject : public ManagementItem
{
protected:
uint64_t createTime;
uint64_t destroyTime;
uint64_t updateTime;
ObjectId objectId;
mutable bool configChanged;
mutable bool instChanged;
bool deleted;
Manageable* coreObject;
mutable Mutex accessLock;
uint32_t flags;
static int nextThreadIndex;
bool forcePublish;
QPID_COMMON_EXTERN int getThreadIndex();
QPID_COMMON_EXTERN void writeTimestamps(std::string& buf) const;
QPID_COMMON_EXTERN void readTimestamps(const std::string& buf);
QPID_COMMON_EXTERN uint32_t writeTimestampsSize() const;
public:
#ifdef _IN_QPID_BROKER
typedef boost::shared_ptr<ManagementObject> shared_ptr;
#endif
QPID_COMMON_EXTERN static const uint8_t MD5_LEN = 16;
QPID_COMMON_EXTERN static int maxThreads;
//typedef void (*writeSchemaCall_t) (qpid::framing::Buffer&);
typedef void (*writeSchemaCall_t) (std::string&);
QPID_COMMON_EXTERN ManagementObject(Manageable* _core);
virtual ~ManagementObject() {}
virtual writeSchemaCall_t getWriteSchemaCall() = 0;
virtual std::string getKey() const = 0;
// Encode & Decode the property and statistics values
// for this object.
virtual void mapEncodeValues(types::Variant::Map& map,
bool includeProperties,
bool includeStatistics) = 0;
virtual void mapDecodeValues(const types::Variant::Map& map) = 0;
virtual void doMethod(std::string& methodName,
const types::Variant::Map& inMap,
types::Variant::Map& outMap,
const std::string& userId) = 0;
QPID_COMMON_EXTERN void writeTimestamps(types::Variant::Map& map) const;
QPID_COMMON_EXTERN void readTimestamps(const types::Variant::Map& buf);
/**
* The following five methods are not pure-virtual because they will only
* be overridden in cases where QMFv1 is to be supported.
*/
virtual uint32_t writePropertiesSize() const { return 0; }
virtual void readProperties(const std::string&) {}
virtual void writeProperties(std::string&) const {}
virtual void writeStatistics(std::string&, bool = false) {}
virtual void doMethod(std::string&, const std::string&, std::string&, const std::string&) {}
QPID_COMMON_EXTERN virtual void setReference(ObjectId objectId);
virtual std::string& getClassName() const = 0;
virtual std::string& getPackageName() const = 0;
virtual uint8_t* getMd5Sum() const = 0;
void setObjectId(ObjectId oid) { objectId = oid; }
ObjectId getObjectId() { return objectId; }
inline bool getConfigChanged() { return configChanged; }
virtual bool getInstChanged() { return instChanged; }
virtual bool hasInst() { return true; }
inline void setForcePublish(bool f) { forcePublish = f; }
inline bool getForcePublish() { return forcePublish; }
QPID_COMMON_EXTERN void setUpdateTime();
QPID_COMMON_EXTERN void resourceDestroy();
inline bool isDeleted() { return deleted; }
inline void setFlags(uint32_t f) { flags = f; }
inline uint32_t getFlags() { return flags; }
bool isSameClass(ManagementObject& other) {
for (int idx = 0; idx < MD5_LEN; idx++)
if (other.getMd5Sum()[idx] != getMd5Sum()[idx])
return false;
return other.getClassName() == getClassName() &&
other.getPackageName() == getPackageName();
}
// QPID_COMMON_EXTERN void encode(qpid::framing::Buffer& buf) const { writeProperties(buf); }
// QPID_COMMON_EXTERN void decode(qpid::framing::Buffer& buf) { readProperties(buf); }
//QPID_COMMON_EXTERN uint32_t encodedSize() const { return writePropertiesSize(); }
// Encode/Decode the entire object as a map
//QPID_COMMON_EXTERN void mapEncode(types::Variant::Map& map,
//bool includeProperties=true,
//bool includeStatistics=true);
//QPID_COMMON_EXTERN void mapDecode(const types::Variant::Map& map);
};
#ifdef _IN_QPID_BROKER
typedef std::map<ObjectId, ManagementObject::shared_ptr> ManagementObjectMap;
typedef std::vector<ManagementObject::shared_ptr> ManagementObjectVector;
#endif
}}
#endif /*!_ManagementObject_*/
|
