[rhmessaging-commits] rhmessaging commits: r3837 - store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store.

[rhmessaging-commits at lists.jboss.org]

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: