diff options
| author | Alan Conway <aconway@apache.org> | 2012-10-15 21:35:38 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2012-10-15 21:35:38 +0000 |
| commit | 0d533491f135278fda9fa8c10d45e11da0c04d03 (patch) | |
| tree | c097eec9b651dcf12e84fad3eca1b8d433c9ad14 /qpid/cpp/include | |
| parent | 38f2ef8faa174042d11eae77c50a606d0063ed8c (diff) | |
| download | qpid-python-0d533491f135278fda9fa8c10d45e11da0c04d03.tar.gz | |
MQPID-4286: QMF queries for HA replication take too long to process (Jason Dillaman)
Rework ManagementAgent locks, get rid of shared buffers that were points of contention.
Minor log message improvements in ha code.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1398530 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/include')
| -rw-r--r-- | qpid/cpp/include/qpid/management/Manageable.h | 2 | ||||
| -rw-r--r-- | qpid/cpp/include/qpid/management/ManagementObject.h | 8 |
2 files changed, 6 insertions, 4 deletions
diff --git a/qpid/cpp/include/qpid/management/Manageable.h b/qpid/cpp/include/qpid/management/Manageable.h index 1e5cd8bc42..fd1e604f58 100644 --- a/qpid/cpp/include/qpid/management/Manageable.h +++ b/qpid/cpp/include/qpid/management/Manageable.h @@ -55,7 +55,7 @@ class QPID_COMMON_EXTERN Manageable // // This accessor function returns a pointer to the management object. // - virtual ManagementObject* GetManagementObject(void) const = 0; + virtual ManagementObject::shared_ptr GetManagementObject(void) const = 0; // Every "Manageable" object must implement ManagementMethod. This // function is called when a remote management client invokes a method diff --git a/qpid/cpp/include/qpid/management/ManagementObject.h b/qpid/cpp/include/qpid/management/ManagementObject.h index 16bf21038c..2aca6fb1c5 100644 --- a/qpid/cpp/include/qpid/management/ManagementObject.h +++ b/qpid/cpp/include/qpid/management/ManagementObject.h @@ -25,7 +25,7 @@ #include "qpid/management/Mutex.h" #include "qpid/types/Variant.h" - +#include <boost/shared_ptr.hpp> #include <map> #include <vector> @@ -155,6 +155,8 @@ protected: QPID_COMMON_EXTERN uint32_t writeTimestampsSize() const; public: + typedef boost::shared_ptr<ManagementObject> shared_ptr; + QPID_COMMON_EXTERN static const uint8_t MD5_LEN = 16; QPID_COMMON_EXTERN static int maxThreads; //typedef void (*writeSchemaCall_t) (qpid::framing::Buffer&); @@ -227,8 +229,8 @@ protected: //QPID_COMMON_EXTERN void mapDecode(const types::Variant::Map& map); }; -typedef std::map<ObjectId, ManagementObject*> ManagementObjectMap; -typedef std::vector<ManagementObject*> ManagementObjectVector; +typedef std::map<ObjectId, ManagementObject::shared_ptr> ManagementObjectMap; +typedef std::vector<ManagementObject::shared_ptr> ManagementObjectVector; }} |