Author: tedross Date: 2010-02-03 09:30:51 -0500 (Wed, 03 Feb 2010) New Revision: 3837 Modified: 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/Store.cpp store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h Log: Regenerated management components. 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 2010-02-02 21:43:22 UTC (rev 3836) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp 2010-02-03 14:30:51 UTC (rev 3837) @@ -28,6 +28,7 @@ #include "Journal.h" #include "ArgsJournalExpand.h" +#include <iostream> using namespace qmf::com::redhat::rhm::store; using namespace qpid::framing; @@ -513,6 +514,27 @@ } +void Journal::readProperties (Buffer& buf) +{ + ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + readTimestamps(buf); + + queueRef.decode(buf); + buf.getShortString(name); + buf.getShortString(directory); + buf.getShortString(baseFileName); + writePageSize = buf.getLong(); + writePages = buf.getLong(); + readPageSize = buf.getLong(); + readPages = buf.getLong(); + initialFileCount = buf.getShort(); + autoExpand = buf.getOctet()==1; + currentFileCount = buf.getShort(); + maxFileCount = buf.getShort(); + dataFileSize = buf.getLong(); + +} + void Journal::writeProperties (Buffer& buf) { ::qpid::sys::Mutex::ScopedLock mutex(accessLock); @@ -614,3 +636,12 @@ outBuf.putLong(status); outBuf.putShortString(Manageable::StatusText(status, text)); } + +std::string Journal::getKey() const +{ + std::stringstream key; + + key << name; + return key.str(); +} + 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 2010-02-02 21:43:22 UTC (rev 3836) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h 2010-02-03 14:30:51 UTC (rev 3837) @@ -130,12 +130,14 @@ // Private Methods static void writeSchema(::qpid::framing::Buffer& buf); + void readProperties(::qpid::framing::Buffer& buf); void writeProperties(::qpid::framing::Buffer& buf); void writeStatistics(::qpid::framing::Buffer& buf, bool skipHeaders = false); void doMethod(std::string& methodName, ::qpid::framing::Buffer& inBuf, ::qpid::framing::Buffer& outBuf); + std::string getKey() const; writeSchemaCall_t getWriteSchemaCall() { return writeSchema; } public: 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 2010-02-02 21:43:22 UTC (rev 3836) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp 2010-02-03 14:30:51 UTC (rev 3837) @@ -27,6 +27,7 @@ #include "qpid/management/ManagementAgent.h" #include "Store.h" +#include <iostream> using namespace qmf::com::redhat::rhm::store; using namespace qpid::framing; @@ -310,6 +311,25 @@ } +void Store::readProperties (Buffer& buf) +{ + ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + readTimestamps(buf); + + brokerRef.decode(buf); + buf.getShortString(location); + defaultInitialFileCount = buf.getShort(); + defaultDataFileSize = buf.getLong(); + tplIsInitialized = buf.getOctet()==1; + buf.getShortString(tplDirectory); + tplWritePageSize = buf.getLong(); + tplWritePages = buf.getLong(); + tplInitialFileCount = buf.getShort(); + tplDataFileSize = buf.getLong(); + tplCurrentFileCount = buf.getLong(); + +} + void Store::writeProperties (Buffer& buf) { ::qpid::sys::Mutex::ScopedLock mutex(accessLock); @@ -372,3 +392,12 @@ outBuf.putLong(status); outBuf.putShortString(Manageable::StatusText(status, text)); } + +std::string Store::getKey() const +{ + std::stringstream key; + + key << brokerRef.getV2Key(); + return key.str(); +} + 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 2010-02-02 21:43:22 UTC (rev 3836) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h 2010-02-03 14:30:51 UTC (rev 3837) @@ -100,12 +100,14 @@ // Private Methods static void writeSchema(::qpid::framing::Buffer& buf); + void readProperties(::qpid::framing::Buffer& buf); void writeProperties(::qpid::framing::Buffer& buf); void writeStatistics(::qpid::framing::Buffer& buf, bool skipHeaders = false); void doMethod(std::string& methodName, ::qpid::framing::Buffer& inBuf, ::qpid::framing::Buffer& outBuf); + std::string getKey() const; writeSchemaCall_t getWriteSchemaCall() { return writeSchema; } public: