Author: tedross Date: 2012-10-30 13:46:55 -0400 (Tue, 30 Oct 2012) New Revision: 4518 Modified: store/trunk/cpp/lib/JournalImpl.cpp store/trunk/cpp/lib/JournalImpl.h store/trunk/cpp/lib/MessageStoreImpl.cpp store/trunk/cpp/lib/MessageStoreImpl.h store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.cpp store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.h store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.cpp store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.h store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.cpp store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.h store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.cpp store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.h store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Package.h store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h Log: Regenerated the qmf files. Updated the usage of the management interface to match changes in the qpid code. Modified: store/trunk/cpp/lib/JournalImpl.cpp =================================================================== --- store/trunk/cpp/lib/JournalImpl.cpp 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/JournalImpl.cpp 2012-10-30 17:46:55 UTC (rev 4518) @@ -70,7 +70,6 @@ _dlen(0), _dtok(), _external(false), - _mgmtObject(0), deleteCallback(onDelete) { getEventsFireEventsPtr = new GetEventsFireEvent(this, getEventsTimeout); @@ -99,9 +98,9 @@ inactivityFireEventPtr->cancel(); free_read_buffers(); - if (_mgmtObject != 0) { + if (_mgmtObject.get() != 0) { _mgmtObject->resourceDestroy(); - _mgmtObject = 0; + _mgmtObject.reset(); } log(LOG_NOTICE, "Destroyed"); @@ -113,8 +112,7 @@ _agent = a; if (_agent != 0) { - _mgmtObject = new _qmf::Journal - (_agent, (qpid::management::Manageable*) this); + _mgmtObject = _qmf::Journal::shared_ptr(new _qmf::Journal(_agent, (qpid::management::Manageable*) this)); _mgmtObject->set_name(_jid); _mgmtObject->set_directory(_jdir.dirname()); @@ -375,11 +373,11 @@ JournalImpl::enqueue_txn_data_record(const void* const data_buff, const size_t tot_data_len, const size_t this_data_len, data_tok* dtokp, const std::string& xid, const bool transient) { - bool txn_incr = _mgmtObject != 0 ? _tmap.in_map(xid) : false; + bool txn_incr = _mgmtObject.get() != 0 ? _tmap.in_map(xid) : false; handleIoResult(jcntl::enqueue_txn_data_record(data_buff, tot_data_len, this_data_len, dtokp, xid, transient)); - if (_mgmtObject != 0) + if (_mgmtObject.get() != 0) { if (!txn_incr) // If this xid was not in _tmap, it will be now... _mgmtObject->inc_txn(); @@ -393,11 +391,11 @@ JournalImpl::enqueue_extern_txn_data_record(const size_t tot_data_len, data_tok* dtokp, const std::string& xid, const bool transient) { - bool txn_incr = _mgmtObject != 0 ? _tmap.in_map(xid) : false; + bool txn_incr = _mgmtObject.get() != 0 ? _tmap.in_map(xid) : false; handleIoResult(jcntl::enqueue_extern_txn_data_record(tot_data_len, dtokp, xid, transient)); - if (_mgmtObject != 0) + if (_mgmtObject.get() != 0) { if (!txn_incr) // If this xid was not in _tmap, it will be now... _mgmtObject->inc_txn(); @@ -412,7 +410,7 @@ { handleIoResult(jcntl::dequeue_data_record(dtokp, txn_coml_commit)); - if (_mgmtObject != 0) + if (_mgmtObject.get() != 0) { _mgmtObject->inc_dequeues(); _mgmtObject->inc_txnDequeues(); @@ -423,11 +421,11 @@ void JournalImpl::dequeue_txn_data_record(data_tok* const dtokp, const std::string& xid, const bool txn_coml_commit) { - bool txn_incr = _mgmtObject != 0 ? _tmap.in_map(xid) : false; + bool txn_incr = _mgmtObject.get() != 0 ? _tmap.in_map(xid) : false; handleIoResult(jcntl::dequeue_txn_data_record(dtokp, xid, txn_coml_commit)); - if (_mgmtObject != 0) + if (_mgmtObject.get() != 0) { if (!txn_incr) // If this xid was not in _tmap, it will be now... _mgmtObject->inc_txn(); @@ -442,7 +440,7 @@ { handleIoResult(jcntl::txn_abort(dtokp, xid)); - if (_mgmtObject != 0) + if (_mgmtObject.get() != 0) { _mgmtObject->dec_txn(); _mgmtObject->inc_txnAborts(); @@ -454,7 +452,7 @@ { handleIoResult(jcntl::txn_commit(dtokp, xid)); - if (_mgmtObject != 0) + if (_mgmtObject.get() != 0) { _mgmtObject->dec_txn(); _mgmtObject->inc_txnCommits(); @@ -469,9 +467,9 @@ ifep->cancel(); jcntl::stop(block_till_aio_cmpl); - if (_mgmtObject != 0) { + if (_mgmtObject.get() != 0) { _mgmtObject->resourceDestroy(); - _mgmtObject = 0; + _mgmtObject.reset(); } } Modified: store/trunk/cpp/lib/JournalImpl.h =================================================================== --- store/trunk/cpp/lib/JournalImpl.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/JournalImpl.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -100,7 +100,7 @@ bool _external; qpid::management::ManagementAgent* _agent; - qmf::com::redhat::rhm::store::Journal* _mgmtObject; + qmf::com::redhat::rhm::store::Journal::shared_ptr _mgmtObject; DeleteCallback deleteCallback; public: @@ -207,7 +207,7 @@ virtual void wr_aio_cb(std::vector<mrg::journal::data_tok*>& dtokl); virtual void rd_aio_cb(std::vector<u_int16_t>& pil); - qpid::management::ManagementObject* GetManagementObject (void) const + qpid::management::ManagementObject::shared_ptr GetManagementObject (void) const { return _mgmtObject; } qpid::management::Manageable::status_t ManagementMethod (uint32_t, Modified: store/trunk/cpp/lib/MessageStoreImpl.cpp =================================================================== --- store/trunk/cpp/lib/MessageStoreImpl.cpp 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/MessageStoreImpl.cpp 2012-10-30 17:46:55 UTC (rev 4518) @@ -75,7 +75,6 @@ isInit(false), envPath(envpath), timer(timer_), - mgmtObject(0), agent(0) {} @@ -226,7 +225,7 @@ agent = broker->getManagementAgent(); if (agent != 0) { _qmf::Package packageInitializer(agent); - mgmtObject = new _qmf::Store(agent, this, broker); + mgmtObject = _qmf::Store::shared_ptr(new _qmf::Store(agent, this, broker)); mgmtObject->set_location(storeDir); mgmtObject->set_defaultInitialFileCount(numJrnlFiles); @@ -403,9 +402,9 @@ } } - if (mgmtObject != 0) { + if (mgmtObject.get() != 0) { mgmtObject->resourceDestroy(); - mgmtObject = 0; + mgmtObject.reset(); } } @@ -445,7 +444,7 @@ if (!tplStorePtr->is_ready()) { journal::jdir::create_dir(getTplBaseDir()); tplStorePtr->initialize(tplNumJrnlFiles, false, 0, tplJrnlFsizeSblks, tplWCacheNumPages, tplWCachePgSizeSblks); - if (mgmtObject != 0) mgmtObject->set_tplIsInitialized(true); + if (mgmtObject.get() != 0) mgmtObject->set_tplIsInitialized(true); } } @@ -481,9 +480,9 @@ QPID_LOG(error, "Unknown error in MessageStoreImpl::~MessageStoreImpl()"); } - if (mgmtObject != 0) { + if (mgmtObject.get() != 0) { mgmtObject->resourceDestroy(); - mgmtObject = 0; + mgmtObject.reset(); } } @@ -708,7 +707,7 @@ //recover transactions: for (txn_list::iterator i = prepared.begin(); i != prepared.end(); i++) { const PreparedTransaction pt = *i; - if (mgmtObject != 0) { + if (mgmtObject.get() != 0) { mgmtObject->inc_tplTransactionDepth(); mgmtObject->inc_tplTxnPrepares(); } @@ -1439,7 +1438,7 @@ tplStorePtr->dequeue_txn_data_record(txn.getDtok(), txn.getXid(), commit); } txn.complete(commit); - if (mgmtObject != 0) { + if (mgmtObject.get() != 0) { mgmtObject->dec_tplTransactionDepth(); if (commit) mgmtObject->inc_tplTxnCommits(); @@ -1493,7 +1492,7 @@ ctxt->prepare(tplStorePtr.get()); // make sure all the data is written to disk before returning ctxt->sync(); - if (mgmtObject != 0) { + if (mgmtObject.get() != 0) { mgmtObject->inc_tplTransactionDepth(); mgmtObject->inc_tplTxnPrepares(); } Modified: store/trunk/cpp/lib/MessageStoreImpl.h =================================================================== --- store/trunk/cpp/lib/MessageStoreImpl.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/MessageStoreImpl.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -154,7 +154,7 @@ const char* envPath; qpid::sys::Timer& timer; - qmf::com::redhat::rhm::store::Store* mgmtObject; + qmf::com::redhat::rhm::store::Store::shared_ptr mgmtObject; qpid::management::ManagementAgent* agent; @@ -363,7 +363,7 @@ void abort(qpid::broker::TransactionContext& ctxt); - qpid::management::ManagementObject* GetManagementObject (void) const + qpid::management::ManagementObject::shared_ptr GetManagementObject (void) const { return mgmtObject; } inline qpid::management::Manageable::status_t ManagementMethod (u_int32_t, qpid::management::Args&) Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.cpp =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.cpp 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.cpp 2012-10-30 17:46:55 UTC (rev 4518) @@ -36,8 +36,8 @@ using qpid::management::Mutex; using std::string; -string EventCreated::packageName = string ("com.redhat.rhm.store"); -string EventCreated::eventName = string ("created"); +string EventCreated::PACKAGE_NAME = string ("com.redhat.rhm.store"); +string EventCreated::EVENT_NAME = string ("created"); uint8_t EventCreated::md5Sum[16] = {0x6f,0x7,0x35,0xf6,0xdc,0xa3,0x18,0x29,0x23,0xf0,0x19,0x61,0xcc,0xe7,0x1c,0x5b}; @@ -59,7 +59,7 @@ void EventCreated::registerSelf(ManagementAgent* agent) { - agent->registerEvent(packageName, eventName, md5Sum, writeSchema); + agent->registerEvent(PACKAGE_NAME, EVENT_NAME, md5Sum, writeSchema); } void EventCreated::writeSchema (std::string& schema) @@ -71,8 +71,8 @@ // Schema class header: buf.putOctet (CLASS_KIND_EVENT); - buf.putShortString (packageName); // Package Name - buf.putShortString (eventName); // Event Name + buf.putShortString (PACKAGE_NAME); // Package Name + buf.putShortString (EVENT_NAME); // Event Name buf.putBin128 (md5Sum); // Schema Hash buf.putShort (3); // Argument Count @@ -128,3 +128,8 @@ map["numFiles"] = ::qpid::types::Variant(numFiles); } + +bool EventCreated::match(const std::string& evt, const std::string& pkg) +{ + return EVENT_NAME == evt && PACKAGE_NAME == pkg; +} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -25,6 +25,7 @@ // Please do not edit. #include "qpid/management/ManagementEvent.h" +#include "qmf/BrokerImportExport.h" namespace qmf { namespace com { @@ -33,12 +34,10 @@ namespace store { -class EventCreated : public ::qpid::management::ManagementEvent +QPID_BROKER_CLASS_EXTERN class EventCreated : public ::qpid::management::ManagementEvent { private: static void writeSchema (std::string& schema); - static std::string packageName; - static std::string eventName; static uint8_t md5Sum[MD5_LEN]; const std::string& jrnlId; @@ -47,20 +46,25 @@ public: + QPID_BROKER_EXTERN static std::string PACKAGE_NAME; + QPID_BROKER_EXTERN static std::string EVENT_NAME; + writeSchemaCall_t getWriteSchemaCall(void) { return writeSchema; } - EventCreated(const std::string& _jrnlId, + QPID_BROKER_EXTERN EventCreated(const std::string& _jrnlId, const uint32_t _fileSize, const uint16_t _numFiles); - ~EventCreated() {}; + QPID_BROKER_EXTERN ~EventCreated() {}; static void registerSelf(::qpid::management::ManagementAgent* agent); - std::string& getPackageName() const { return packageName; } - std::string& getEventName() const { return eventName; } + std::string& getPackageName() const { return PACKAGE_NAME; } + std::string& getEventName() const { return EVENT_NAME; } uint8_t* getMd5Sum() const { return md5Sum; } uint8_t getSeverity() const { return 5; } - void encode(std::string& buffer) const; - void mapEncode(::qpid::types::Variant::Map& map) const; + QPID_BROKER_EXTERN void encode(std::string& buffer) const; + QPID_BROKER_EXTERN void mapEncode(::qpid::types::Variant::Map& map) const; + + QPID_BROKER_EXTERN static bool match(const std::string& evt, const std::string& pkg); }; }}}}} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.cpp =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.cpp 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.cpp 2012-10-30 17:46:55 UTC (rev 4518) @@ -36,8 +36,8 @@ using qpid::management::Mutex; using std::string; -string EventEnqThresholdExceeded::packageName = string ("com.redhat.rhm.store"); -string EventEnqThresholdExceeded::eventName = string ("enqThresholdExceeded"); +string EventEnqThresholdExceeded::PACKAGE_NAME = string ("com.redhat.rhm.store"); +string EventEnqThresholdExceeded::EVENT_NAME = string ("enqThresholdExceeded"); uint8_t EventEnqThresholdExceeded::md5Sum[16] = {0x5b,0x1f,0xd4,0x87,0x9c,0xf6,0x1e,0xc3,0xdc,0x3e,0xc4,0x4,0x49,0xf3,0xa8,0xf3}; @@ -57,7 +57,7 @@ void EventEnqThresholdExceeded::registerSelf(ManagementAgent* agent) { - agent->registerEvent(packageName, eventName, md5Sum, writeSchema); + agent->registerEvent(PACKAGE_NAME, EVENT_NAME, md5Sum, writeSchema); } void EventEnqThresholdExceeded::writeSchema (std::string& schema) @@ -69,8 +69,8 @@ // Schema class header: buf.putOctet (CLASS_KIND_EVENT); - buf.putShortString (packageName); // Package Name - buf.putShortString (eventName); // Event Name + buf.putShortString (PACKAGE_NAME); // Package Name + buf.putShortString (EVENT_NAME); // Event Name buf.putBin128 (md5Sum); // Schema Hash buf.putShort (2); // Argument Count @@ -118,3 +118,8 @@ map["what"] = ::qpid::types::Variant(what); } + +bool EventEnqThresholdExceeded::match(const std::string& evt, const std::string& pkg) +{ + return EVENT_NAME == evt && PACKAGE_NAME == pkg; +} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -25,6 +25,7 @@ // Please do not edit. #include "qpid/management/ManagementEvent.h" +#include "qmf/BrokerImportExport.h" namespace qmf { namespace com { @@ -33,12 +34,10 @@ namespace store { -class EventEnqThresholdExceeded : public ::qpid::management::ManagementEvent +QPID_BROKER_CLASS_EXTERN class EventEnqThresholdExceeded : public ::qpid::management::ManagementEvent { private: static void writeSchema (std::string& schema); - static std::string packageName; - static std::string eventName; static uint8_t md5Sum[MD5_LEN]; const std::string& jrnlId; @@ -46,19 +45,24 @@ public: + QPID_BROKER_EXTERN static std::string PACKAGE_NAME; + QPID_BROKER_EXTERN static std::string EVENT_NAME; + writeSchemaCall_t getWriteSchemaCall(void) { return writeSchema; } - EventEnqThresholdExceeded(const std::string& _jrnlId, + QPID_BROKER_EXTERN EventEnqThresholdExceeded(const std::string& _jrnlId, const std::string& _what); - ~EventEnqThresholdExceeded() {}; + QPID_BROKER_EXTERN ~EventEnqThresholdExceeded() {}; static void registerSelf(::qpid::management::ManagementAgent* agent); - std::string& getPackageName() const { return packageName; } - std::string& getEventName() const { return eventName; } + std::string& getPackageName() const { return PACKAGE_NAME; } + std::string& getEventName() const { return EVENT_NAME; } uint8_t* getMd5Sum() const { return md5Sum; } uint8_t getSeverity() const { return 4; } - void encode(std::string& buffer) const; - void mapEncode(::qpid::types::Variant::Map& map) const; + QPID_BROKER_EXTERN void encode(std::string& buffer) const; + QPID_BROKER_EXTERN void mapEncode(::qpid::types::Variant::Map& map) const; + + QPID_BROKER_EXTERN static bool match(const std::string& evt, const std::string& pkg); }; }}}}} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.cpp =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.cpp 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.cpp 2012-10-30 17:46:55 UTC (rev 4518) @@ -36,8 +36,8 @@ using qpid::management::Mutex; using std::string; -string EventFull::packageName = string ("com.redhat.rhm.store"); -string EventFull::eventName = string ("full"); +string EventFull::PACKAGE_NAME = string ("com.redhat.rhm.store"); +string EventFull::EVENT_NAME = string ("full"); uint8_t EventFull::md5Sum[16] = {0x23,0x4c,0x70,0xc1,0xb0,0xeb,0x4e,0x5d,0x72,0x37,0x56,0x60,0xc3,0x10,0x78,0x68}; @@ -57,7 +57,7 @@ void EventFull::registerSelf(ManagementAgent* agent) { - agent->registerEvent(packageName, eventName, md5Sum, writeSchema); + agent->registerEvent(PACKAGE_NAME, EVENT_NAME, md5Sum, writeSchema); } void EventFull::writeSchema (std::string& schema) @@ -69,8 +69,8 @@ // Schema class header: buf.putOctet (CLASS_KIND_EVENT); - buf.putShortString (packageName); // Package Name - buf.putShortString (eventName); // Event Name + buf.putShortString (PACKAGE_NAME); // Package Name + buf.putShortString (EVENT_NAME); // Event Name buf.putBin128 (md5Sum); // Schema Hash buf.putShort (2); // Argument Count @@ -118,3 +118,8 @@ map["what"] = ::qpid::types::Variant(what); } + +bool EventFull::match(const std::string& evt, const std::string& pkg) +{ + return EVENT_NAME == evt && PACKAGE_NAME == pkg; +} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -25,6 +25,7 @@ // Please do not edit. #include "qpid/management/ManagementEvent.h" +#include "qmf/BrokerImportExport.h" namespace qmf { namespace com { @@ -33,12 +34,10 @@ namespace store { -class EventFull : public ::qpid::management::ManagementEvent +QPID_BROKER_CLASS_EXTERN class EventFull : public ::qpid::management::ManagementEvent { private: static void writeSchema (std::string& schema); - static std::string packageName; - static std::string eventName; static uint8_t md5Sum[MD5_LEN]; const std::string& jrnlId; @@ -46,19 +45,24 @@ public: + QPID_BROKER_EXTERN static std::string PACKAGE_NAME; + QPID_BROKER_EXTERN static std::string EVENT_NAME; + writeSchemaCall_t getWriteSchemaCall(void) { return writeSchema; } - EventFull(const std::string& _jrnlId, + QPID_BROKER_EXTERN EventFull(const std::string& _jrnlId, const std::string& _what); - ~EventFull() {}; + QPID_BROKER_EXTERN ~EventFull() {}; static void registerSelf(::qpid::management::ManagementAgent* agent); - std::string& getPackageName() const { return packageName; } - std::string& getEventName() const { return eventName; } + std::string& getPackageName() const { return PACKAGE_NAME; } + std::string& getEventName() const { return EVENT_NAME; } uint8_t* getMd5Sum() const { return md5Sum; } uint8_t getSeverity() const { return 3; } - void encode(std::string& buffer) const; - void mapEncode(::qpid::types::Variant::Map& map) const; + QPID_BROKER_EXTERN void encode(std::string& buffer) const; + QPID_BROKER_EXTERN void mapEncode(::qpid::types::Variant::Map& map) const; + + QPID_BROKER_EXTERN static bool match(const std::string& evt, const std::string& pkg); }; }}}}} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.cpp =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.cpp 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.cpp 2012-10-30 17:46:55 UTC (rev 4518) @@ -36,8 +36,8 @@ using qpid::management::Mutex; using std::string; -string EventRecovered::packageName = string ("com.redhat.rhm.store"); -string EventRecovered::eventName = string ("recovered"); +string EventRecovered::PACKAGE_NAME = string ("com.redhat.rhm.store"); +string EventRecovered::EVENT_NAME = string ("recovered"); uint8_t EventRecovered::md5Sum[16] = {0x23,0x28,0x44,0x5a,0x72,0xb0,0x1e,0xda,0x7d,0xff,0x0,0x9,0x1,0x6d,0xa8,0xd4}; @@ -67,7 +67,7 @@ void EventRecovered::registerSelf(ManagementAgent* agent) { - agent->registerEvent(packageName, eventName, md5Sum, writeSchema); + agent->registerEvent(PACKAGE_NAME, EVENT_NAME, md5Sum, writeSchema); } void EventRecovered::writeSchema (std::string& schema) @@ -79,8 +79,8 @@ // Schema class header: buf.putOctet (CLASS_KIND_EVENT); - buf.putShortString (packageName); // Package Name - buf.putShortString (eventName); // Event Name + buf.putShortString (PACKAGE_NAME); // Package Name + buf.putShortString (EVENT_NAME); // Event Name buf.putBin128 (md5Sum); // Schema Hash buf.putShort (7); // Argument Count @@ -168,3 +168,8 @@ map["numTxnDeq"] = ::qpid::types::Variant(numTxnDeq); } + +bool EventRecovered::match(const std::string& evt, const std::string& pkg) +{ + return EVENT_NAME == evt && PACKAGE_NAME == pkg; +} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -25,6 +25,7 @@ // Please do not edit. #include "qpid/management/ManagementEvent.h" +#include "qmf/BrokerImportExport.h" namespace qmf { namespace com { @@ -33,12 +34,10 @@ namespace store { -class EventRecovered : public ::qpid::management::ManagementEvent +QPID_BROKER_CLASS_EXTERN class EventRecovered : public ::qpid::management::ManagementEvent { private: static void writeSchema (std::string& schema); - static std::string packageName; - static std::string eventName; static uint8_t md5Sum[MD5_LEN]; const std::string& jrnlId; @@ -51,24 +50,29 @@ public: + QPID_BROKER_EXTERN static std::string PACKAGE_NAME; + QPID_BROKER_EXTERN static std::string EVENT_NAME; + writeSchemaCall_t getWriteSchemaCall(void) { return writeSchema; } - EventRecovered(const std::string& _jrnlId, + QPID_BROKER_EXTERN EventRecovered(const std::string& _jrnlId, const uint32_t _fileSize, const uint16_t _numFiles, const uint32_t _numEnq, const uint32_t _numTxn, const uint32_t _numTxnEnq, const uint32_t _numTxnDeq); - ~EventRecovered() {}; + QPID_BROKER_EXTERN ~EventRecovered() {}; static void registerSelf(::qpid::management::ManagementAgent* agent); - std::string& getPackageName() const { return packageName; } - std::string& getEventName() const { return eventName; } + std::string& getPackageName() const { return PACKAGE_NAME; } + std::string& getEventName() const { return EVENT_NAME; } uint8_t* getMd5Sum() const { return md5Sum; } uint8_t getSeverity() const { return 5; } - void encode(std::string& buffer) const; - void mapEncode(::qpid::types::Variant::Map& map) const; + QPID_BROKER_EXTERN void encode(std::string& buffer) const; + QPID_BROKER_EXTERN void mapEncode(::qpid::types::Variant::Map& map) const; + + QPID_BROKER_EXTERN static bool match(const std::string& evt, const std::string& pkg); }; }}}}} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp 2012-10-30 17:46:55 UTC (rev 4518) @@ -7,9 +7,9 @@ // 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 @@ -29,8 +29,10 @@ #include "Journal.h" #include "ArgsJournalExpand.h" + #include <iostream> #include <sstream> +#include <string.h> using namespace qmf::com::redhat::rhm::store; using qpid::management::ManagementAgent; @@ -58,7 +60,7 @@ readPageSize = 0; readPages = 0; initialFileCount = 0; - autoExpand = 0; + autoExpand = false; currentFileCount = 0; maxFileCount = 0; dataFileSize = 0; @@ -87,11 +89,13 @@ for (int idx = 0; idx < maxThreads; idx++) perThreadStatsArray[idx] = 0; + } Journal::~Journal () { + for (int idx = 0; idx < maxThreads; idx++) if (perThreadStatsArray[idx] != 0) delete perThreadStatsArray[idx]; @@ -741,7 +745,6 @@ } - void Journal::mapEncodeValues (::qpid::types::Variant::Map& _map, bool includeProperties, bool includeStatistics) @@ -832,42 +835,68 @@ if ((_i = _map.find("queueRef")) != _map.end()) { queueRef = _i->second; + } else { + queueRef = ::qpid::management::ObjectId(); } if ((_i = _map.find("name")) != _map.end()) { name = (_i->second).getString(); + } else { + name = ""; } if ((_i = _map.find("directory")) != _map.end()) { directory = (_i->second).getString(); + } else { + directory = ""; } if ((_i = _map.find("baseFileName")) != _map.end()) { baseFileName = (_i->second).getString(); + } else { + baseFileName = ""; } if ((_i = _map.find("writePageSize")) != _map.end()) { writePageSize = _i->second; + } else { + writePageSize = 0; } if ((_i = _map.find("writePages")) != _map.end()) { writePages = _i->second; + } else { + writePages = 0; } if ((_i = _map.find("readPageSize")) != _map.end()) { readPageSize = _i->second; + } else { + readPageSize = 0; } if ((_i = _map.find("readPages")) != _map.end()) { readPages = _i->second; + } else { + readPages = 0; } if ((_i = _map.find("initialFileCount")) != _map.end()) { initialFileCount = _i->second; + } else { + initialFileCount = 0; } if ((_i = _map.find("autoExpand")) != _map.end()) { autoExpand = _i->second; + } else { + autoExpand = false; } if ((_i = _map.find("currentFileCount")) != _map.end()) { currentFileCount = _i->second; + } else { + currentFileCount = 0; } if ((_i = _map.find("maxFileCount")) != _map.end()) { maxFileCount = _i->second; + } else { + maxFileCount = 0; } if ((_i = _map.find("dataFileSize")) != _map.end()) { dataFileSize = _i->second; + } else { + dataFileSize = 0; } } @@ -883,6 +912,8 @@ ::qpid::types::Variant::Map::const_iterator _i; if ((_i = inMap.find("by")) != inMap.end()) { ioArgs.i_by = _i->second; + } else { + ioArgs.i_by = 0; } bool allow = coreObject->AuthorizeMethod(METHOD_EXPAND, ioArgs, userId); if (allow) Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -1,6 +1,6 @@ -#ifndef _MANAGEMENT_JOURNAL_ -#define _MANAGEMENT_JOURNAL_ +#ifndef _MANAGEMENT_COM_REDHAT_RHM_STORE_JOURNAL_ +#define _MANAGEMENT_COM_REDHAT_RHM_STORE_JOURNAL_ // // Licensed to the Apache Software Foundation (ASF) under one @@ -25,6 +25,8 @@ // Please do not edit. #include "qpid/management/ManagementObject.h" +#include "qmf/BrokerImportExport.h" +#include <limits> namespace qpid { namespace management { @@ -39,7 +41,7 @@ namespace store { -class Journal : public ::qpid::management::ManagementObject +QPID_BROKER_CLASS_EXTERN class Journal : public ::qpid::management::ManagementObject { private: @@ -85,6 +87,8 @@ // Per-Thread Statistics + + public: struct PerThreadStats { uint64_t enqueues; uint64_t dequeues; @@ -99,6 +103,7 @@ uint64_t readBusyFailures; }; + private: struct PerThreadStats** perThreadStatsArray; @@ -127,44 +132,50 @@ void aggregatePerThreadStats(struct PerThreadStats*) const; public: - static void writeSchema(std::string& schema); - void mapEncodeValues(::qpid::types::Variant::Map& map, - bool includeProperties=true, - bool includeStatistics=true); - void mapDecodeValues(const ::qpid::types::Variant::Map& map); - void doMethod(std::string& methodName, - const ::qpid::types::Variant::Map& inMap, - ::qpid::types::Variant::Map& outMap, - const std::string& userId); - std::string getKey() const; + typedef boost::shared_ptr<Journal> shared_ptr; - uint32_t writePropertiesSize() const; - void readProperties(const std::string& buf); - void writeProperties(std::string& buf) const; - void writeStatistics(std::string& buf, bool skipHeaders = false); - void doMethod(std::string& methodName, - const std::string& inBuf, - std::string& outBuf, - const std::string& userId); + QPID_BROKER_EXTERN static void writeSchema(std::string& schema); + QPID_BROKER_EXTERN void mapEncodeValues(::qpid::types::Variant::Map& map, + bool includeProperties=true, + bool includeStatistics=true); + QPID_BROKER_EXTERN void mapDecodeValues(const ::qpid::types::Variant::Map& map); + QPID_BROKER_EXTERN void doMethod(std::string& methodName, + const ::qpid::types::Variant::Map& inMap, + ::qpid::types::Variant::Map& outMap, + const std::string& userId); + QPID_BROKER_EXTERN std::string getKey() const; + QPID_BROKER_EXTERN uint32_t writePropertiesSize() const; + QPID_BROKER_EXTERN void readProperties(const std::string& buf); + QPID_BROKER_EXTERN void writeProperties(std::string& buf) const; + QPID_BROKER_EXTERN void writeStatistics(std::string& buf, bool skipHeaders = false); + QPID_BROKER_EXTERN void doMethod(std::string& methodName, + const std::string& inBuf, + std::string& outBuf, + const std::string& userId); + writeSchemaCall_t getWriteSchemaCall() { return writeSchema; } - Journal(::qpid::management::ManagementAgent* agent, - ::qpid::management::Manageable* coreObject); - ~Journal(); + QPID_BROKER_EXTERN Journal( + ::qpid::management::ManagementAgent* agent, + ::qpid::management::Manageable* coreObject); + QPID_BROKER_EXTERN ~Journal(); + void setReference(::qpid::management::ObjectId objectId) { queueRef = objectId; } - static void registerSelf(::qpid::management::ManagementAgent* agent); + QPID_BROKER_EXTERN static void registerSelf( + ::qpid::management::ManagementAgent* agent); + std::string& getPackageName() const { return packageName; } std::string& getClassName() const { return className; } uint8_t* getMd5Sum() const { return md5Sum; } // Method IDs - static const uint32_t METHOD_EXPAND = 1; + QPID_BROKER_EXTERN static const uint32_t METHOD_EXPAND = 1; // Accessor Methods inline void set_queueRef (const ::qpid::management::ObjectId& val) { @@ -457,6 +468,11 @@ instChanged = true; } + + + struct PerThreadStats* getStatistics() { return getThreadStats(); } + void statisticsUpdated() { instChanged = true; } + }; }}}}} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Package.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Package.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Package.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -25,6 +25,7 @@ // Please do not edit. #include "qpid/management/ManagementAgent.h" +#include "qmf/BrokerImportExport.h" namespace qmf { namespace com { @@ -36,8 +37,8 @@ class Package { public: - Package (::qpid::management::ManagementAgent* agent); - ~Package () {} + QPID_BROKER_EXTERN Package (::qpid::management::ManagementAgent* agent); + QPID_BROKER_EXTERN ~Package () {} }; }}}}} Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp 2012-10-30 17:46:55 UTC (rev 4518) @@ -7,9 +7,9 @@ // 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 @@ -28,8 +28,10 @@ #include "qpid/management/ManagementAgent.h" #include "Store.h" + #include <iostream> #include <sstream> +#include <string.h> using namespace qmf::com::redhat::rhm::store; using qpid::management::ManagementAgent; @@ -51,7 +53,7 @@ location = ""; defaultInitialFileCount = 0; defaultDataFileSize = 0; - tplIsInitialized = 0; + tplIsInitialized = false; tplDirectory = ""; tplWritePageSize = 0; tplWritePages = 0; @@ -71,11 +73,13 @@ for (int idx = 0; idx < maxThreads; idx++) perThreadStatsArray[idx] = 0; + } Store::~Store () { + for (int idx = 0; idx < maxThreads; idx++) if (perThreadStatsArray[idx] != 0) delete perThreadStatsArray[idx]; @@ -485,7 +489,6 @@ } - void Store::mapEncodeValues (::qpid::types::Variant::Map& _map, bool includeProperties, bool includeStatistics) @@ -546,36 +549,58 @@ if ((_i = _map.find("brokerRef")) != _map.end()) { brokerRef = _i->second; + } else { + brokerRef = ::qpid::management::ObjectId(); } if ((_i = _map.find("location")) != _map.end()) { location = (_i->second).getString(); + } else { + location = ""; } if ((_i = _map.find("defaultInitialFileCount")) != _map.end()) { defaultInitialFileCount = _i->second; + } else { + defaultInitialFileCount = 0; } if ((_i = _map.find("defaultDataFileSize")) != _map.end()) { defaultDataFileSize = _i->second; + } else { + defaultDataFileSize = 0; } if ((_i = _map.find("tplIsInitialized")) != _map.end()) { tplIsInitialized = _i->second; + } else { + tplIsInitialized = false; } if ((_i = _map.find("tplDirectory")) != _map.end()) { tplDirectory = (_i->second).getString(); + } else { + tplDirectory = ""; } if ((_i = _map.find("tplWritePageSize")) != _map.end()) { tplWritePageSize = _i->second; + } else { + tplWritePageSize = 0; } if ((_i = _map.find("tplWritePages")) != _map.end()) { tplWritePages = _i->second; + } else { + tplWritePages = 0; } if ((_i = _map.find("tplInitialFileCount")) != _map.end()) { tplInitialFileCount = _i->second; + } else { + tplInitialFileCount = 0; } if ((_i = _map.find("tplDataFileSize")) != _map.end()) { tplDataFileSize = _i->second; + } else { + tplDataFileSize = 0; } if ((_i = _map.find("tplCurrentFileCount")) != _map.end()) { tplCurrentFileCount = _i->second; + } else { + tplCurrentFileCount = 0; } } Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h 2012-10-30 17:45:52 UTC (rev 4517) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h 2012-10-30 17:46:55 UTC (rev 4518) @@ -1,6 +1,6 @@ -#ifndef _MANAGEMENT_STORE_ -#define _MANAGEMENT_STORE_ +#ifndef _MANAGEMENT_COM_REDHAT_RHM_STORE_STORE_ +#define _MANAGEMENT_COM_REDHAT_RHM_STORE_STORE_ // // Licensed to the Apache Software Foundation (ASF) under one @@ -25,6 +25,8 @@ // Please do not edit. #include "qpid/management/ManagementObject.h" +#include "qmf/BrokerImportExport.h" +#include <limits> namespace qpid { namespace management { @@ -39,7 +41,7 @@ namespace store { -class Store : public ::qpid::management::ManagementObject +QPID_BROKER_CLASS_EXTERN class Store : public ::qpid::management::ManagementObject { private: @@ -71,12 +73,15 @@ // Per-Thread Statistics + + public: struct PerThreadStats { uint64_t tplTxnPrepares; uint64_t tplTxnCommits; uint64_t tplTxnAborts; }; + private: struct PerThreadStats** perThreadStatsArray; @@ -97,37 +102,43 @@ void aggregatePerThreadStats(struct PerThreadStats*) const; public: - static void writeSchema(std::string& schema); - void mapEncodeValues(::qpid::types::Variant::Map& map, - bool includeProperties=true, - bool includeStatistics=true); - void mapDecodeValues(const ::qpid::types::Variant::Map& map); - void doMethod(std::string& methodName, - const ::qpid::types::Variant::Map& inMap, - ::qpid::types::Variant::Map& outMap, - const std::string& userId); - std::string getKey() const; + typedef boost::shared_ptr<Store> shared_ptr; - uint32_t writePropertiesSize() const; - void readProperties(const std::string& buf); - void writeProperties(std::string& buf) const; - void writeStatistics(std::string& buf, bool skipHeaders = false); - void doMethod(std::string& methodName, - const std::string& inBuf, - std::string& outBuf, - const std::string& userId); + QPID_BROKER_EXTERN static void writeSchema(std::string& schema); + QPID_BROKER_EXTERN void mapEncodeValues(::qpid::types::Variant::Map& map, + bool includeProperties=true, + bool includeStatistics=true); + QPID_BROKER_EXTERN void mapDecodeValues(const ::qpid::types::Variant::Map& map); + QPID_BROKER_EXTERN void doMethod(std::string& methodName, + const ::qpid::types::Variant::Map& inMap, + ::qpid::types::Variant::Map& outMap, + const std::string& userId); + QPID_BROKER_EXTERN std::string getKey() const; + QPID_BROKER_EXTERN uint32_t writePropertiesSize() const; + QPID_BROKER_EXTERN void readProperties(const std::string& buf); + QPID_BROKER_EXTERN void writeProperties(std::string& buf) const; + QPID_BROKER_EXTERN void writeStatistics(std::string& buf, bool skipHeaders = false); + QPID_BROKER_EXTERN void doMethod(std::string& methodName, + const std::string& inBuf, + std::string& outBuf, + const std::string& userId); + writeSchemaCall_t getWriteSchemaCall() { return writeSchema; } - Store(::qpid::management::ManagementAgent* agent, - ::qpid::management::Manageable* coreObject, ::qpid::management::Manageable* _parent); - ~Store(); + QPID_BROKER_EXTERN Store( + ::qpid::management::ManagementAgent* agent, + ::qpid::management::Manageable* coreObject, ::qpid::management::Manageable* _parent); + QPID_BROKER_EXTERN ~Store(); + - static void registerSelf(::qpid::management::ManagementAgent* agent); + QPID_BROKER_EXTERN static void registerSelf( + ::qpid::management::ManagementAgent* agent); + std::string& getPackageName() const { return packageName; } std::string& getClassName() const { return className; } uint8_t* getMd5Sum() const { return md5Sum; } @@ -287,6 +298,11 @@ instChanged = true; } + + + struct PerThreadStats* getStatistics() { return getThreadStats(); } + void statisticsUpdated() { instChanged = true; } + }; }}}}}