summaryrefslogtreecommitdiff
path: root/cpp/src
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2010-02-03 13:35:58 +0000
committerTed Ross <tross@apache.org>2010-02-03 13:35:58 +0000
commitcdd5f08c0889b3d857ca5d80d71b424dad46664e (patch)
treef8bdf8bb71db05306272e0df5da38014d3a273cc /cpp/src
parent74b516ec03a03c6a2385802d70101a9940c60a14 (diff)
downloadqpid-python-cdd5f08c0889b3d857ca5d80d71b424dad46664e.tar.gz
Changes to management code generation:
1) Added readProperties(Buffer) method to ManagementObject to help in the serialization and unserialization of data for cluster replication. 2) Added hooks to ManagementObject and ObjectId to prepare for QMFv2 object naming. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@906038 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
-rw-r--r--cpp/src/qpid/management/ManagementAgent.cpp1
-rw-r--r--cpp/src/qpid/management/ManagementObject.cpp15
2 files changed, 16 insertions, 0 deletions
diff --git a/cpp/src/qpid/management/ManagementAgent.cpp b/cpp/src/qpid/management/ManagementAgent.cpp
index e00f394a01..460a11d0f0 100644
--- a/cpp/src/qpid/management/ManagementAgent.cpp
+++ b/cpp/src/qpid/management/ManagementAgent.cpp
@@ -194,6 +194,7 @@ ObjectId ManagementAgent::addObject(ManagementObject* object,
}
ObjectId objId(0 /*flags*/ , sequence, brokerBank, 0, objectNum);
+ objId.setV2Key(object->getKey());
object->setObjectId(objId);
newManagementObjects[objId] = object;
diff --git a/cpp/src/qpid/management/ManagementObject.cpp b/cpp/src/qpid/management/ManagementObject.cpp
index bcb6159663..6cbe386517 100644
--- a/cpp/src/qpid/management/ManagementObject.cpp
+++ b/cpp/src/qpid/management/ManagementObject.cpp
@@ -169,6 +169,21 @@ void ManagementObject::writeTimestamps (framing::Buffer& buf)
objectId.encode(buf);
}
+void ManagementObject::readTimestamps (framing::Buffer& buf)
+{
+ std::string unused;
+ uint8_t unusedUuid[16];
+ ObjectId unusedObjectId;
+
+ buf.getShortString(unused);
+ buf.getShortString(unused);
+ buf.getBin128(unusedUuid);
+ updateTime = buf.getLongLong();
+ createTime = buf.getLongLong();
+ destroyTime = buf.getLongLong();
+ unusedObjectId.decode(buf);
+}
+
void ManagementObject::setReference(ObjectId) {}
int ManagementObject::getThreadIndex() {