[rhmessaging-commits] rhmessaging commits: r3902 - store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store.
rhmessaging-commits at lists.jboss.org
rhmessaging-commits at lists.jboss.org
Thu Apr 8 23:54:13 EDT 2010
Author: tedross
Date: 2010-04-08 23:54:13 -0400 (Thu, 08 Apr 2010)
New Revision: 3902
Modified:
store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/ArgsJournalExpand.h
store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.cpp
store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.cpp
store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.cpp
store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.cpp
store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp
store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp
Log:
Updated generated files with the latest generator.
Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/ArgsJournalExpand.h
===================================================================
--- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/ArgsJournalExpand.h 2010-04-08 16:38:12 UTC (rev 3901)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/ArgsJournalExpand.h 2010-04-09 03:54:13 UTC (rev 3902)
@@ -25,8 +25,6 @@
// Please do not edit.
#include "qpid/management/Args.h"
-//#include "qpid/framing/FieldTable.h"
-//#include "qpid/framing/Uuid.h"
#include <string>
namespace qmf {
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 2010-04-08 16:38:12 UTC (rev 3901)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.cpp 2010-04-09 03:54:13 UTC (rev 3902)
@@ -23,8 +23,9 @@
#include "qpid/log/Statement.h"
#include "qpid/management/Manageable.h"
-#include "qpid/framing/FieldTable.h"
-#include "qpid/framing/Buffer.h"
+#include "qpid/management/Buffer.h"
+#include "qpid/types/Variant.h"
+#include "qpid/amqp_0_10/Codecs.h"
#include "qpid/management/ManagementAgent.h"
#include "EventCreated.h"
@@ -65,8 +66,8 @@
{
const int _bufSize = 65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
- ::qpid::framing::FieldTable ft;
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
+ ::qpid::types::Variant::Map ft;
// Schema class header:
buf.putOctet (CLASS_KIND_EVENT);
@@ -77,22 +78,22 @@
// Arguments
ft.clear();
- ft.setString (NAME, "jrnlId");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setString (DESC, "Journal Id");
- buf.put (ft);
+ ft[NAME] = "jrnlId";
+ ft[TYPE] = TYPE_SSTR;
+ ft[DESC] = "Journal Id";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "fileSize");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (DESC, "Journal file size in bytes");
- buf.put (ft);
+ ft[NAME] = "fileSize";
+ ft[TYPE] = TYPE_U32;
+ ft[DESC] = "Journal file size in bytes";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "numFiles");
- ft.setInt (TYPE, TYPE_U16);
- ft.setString (DESC, "Number of journal files");
- buf.put (ft);
+ ft[NAME] = "numFiles";
+ ft[TYPE] = TYPE_U16;
+ ft[DESC] = "Number of journal files";
+ buf.putMap(ft);
{
@@ -106,7 +107,7 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
buf.putShortString(jrnlId);
buf.putLong(fileSize);
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 2010-04-08 16:38:12 UTC (rev 3901)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.cpp 2010-04-09 03:54:13 UTC (rev 3902)
@@ -23,8 +23,9 @@
#include "qpid/log/Statement.h"
#include "qpid/management/Manageable.h"
-#include "qpid/framing/FieldTable.h"
-#include "qpid/framing/Buffer.h"
+#include "qpid/management/Buffer.h"
+#include "qpid/types/Variant.h"
+#include "qpid/amqp_0_10/Codecs.h"
#include "qpid/management/ManagementAgent.h"
#include "EventEnqThresholdExceeded.h"
@@ -63,8 +64,8 @@
{
const int _bufSize = 65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
- ::qpid::framing::FieldTable ft;
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
+ ::qpid::types::Variant::Map ft;
// Schema class header:
buf.putOctet (CLASS_KIND_EVENT);
@@ -75,16 +76,16 @@
// Arguments
ft.clear();
- ft.setString (NAME, "jrnlId");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setString (DESC, "Journal Id");
- buf.put (ft);
+ ft[NAME] = "jrnlId";
+ ft[TYPE] = TYPE_SSTR;
+ ft[DESC] = "Journal Id";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "what");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setString (DESC, "Description of event");
- buf.put (ft);
+ ft[NAME] = "what";
+ ft[TYPE] = TYPE_SSTR;
+ ft[DESC] = "Description of event";
+ buf.putMap(ft);
{
@@ -98,7 +99,7 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
buf.putShortString(jrnlId);
buf.putShortString(what);
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 2010-04-08 16:38:12 UTC (rev 3901)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.cpp 2010-04-09 03:54:13 UTC (rev 3902)
@@ -23,8 +23,9 @@
#include "qpid/log/Statement.h"
#include "qpid/management/Manageable.h"
-#include "qpid/framing/FieldTable.h"
-#include "qpid/framing/Buffer.h"
+#include "qpid/management/Buffer.h"
+#include "qpid/types/Variant.h"
+#include "qpid/amqp_0_10/Codecs.h"
#include "qpid/management/ManagementAgent.h"
#include "EventFull.h"
@@ -63,8 +64,8 @@
{
const int _bufSize = 65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
- ::qpid::framing::FieldTable ft;
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
+ ::qpid::types::Variant::Map ft;
// Schema class header:
buf.putOctet (CLASS_KIND_EVENT);
@@ -75,16 +76,16 @@
// Arguments
ft.clear();
- ft.setString (NAME, "jrnlId");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setString (DESC, "Journal Id");
- buf.put (ft);
+ ft[NAME] = "jrnlId";
+ ft[TYPE] = TYPE_SSTR;
+ ft[DESC] = "Journal Id";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "what");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setString (DESC, "Description of event");
- buf.put (ft);
+ ft[NAME] = "what";
+ ft[TYPE] = TYPE_SSTR;
+ ft[DESC] = "Description of event";
+ buf.putMap(ft);
{
@@ -98,7 +99,7 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
buf.putShortString(jrnlId);
buf.putShortString(what);
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 2010-04-08 16:38:12 UTC (rev 3901)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.cpp 2010-04-09 03:54:13 UTC (rev 3902)
@@ -23,8 +23,9 @@
#include "qpid/log/Statement.h"
#include "qpid/management/Manageable.h"
-#include "qpid/framing/FieldTable.h"
-#include "qpid/framing/Buffer.h"
+#include "qpid/management/Buffer.h"
+#include "qpid/types/Variant.h"
+#include "qpid/amqp_0_10/Codecs.h"
#include "qpid/management/ManagementAgent.h"
#include "EventRecovered.h"
@@ -73,8 +74,8 @@
{
const int _bufSize = 65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
- ::qpid::framing::FieldTable ft;
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
+ ::qpid::types::Variant::Map ft;
// Schema class header:
buf.putOctet (CLASS_KIND_EVENT);
@@ -85,46 +86,46 @@
// Arguments
ft.clear();
- ft.setString (NAME, "jrnlId");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setString (DESC, "Journal Id");
- buf.put (ft);
+ ft[NAME] = "jrnlId";
+ ft[TYPE] = TYPE_SSTR;
+ ft[DESC] = "Journal Id";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "fileSize");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (DESC, "Journal file size in bytes");
- buf.put (ft);
+ ft[NAME] = "fileSize";
+ ft[TYPE] = TYPE_U32;
+ ft[DESC] = "Journal file size in bytes";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "numFiles");
- ft.setInt (TYPE, TYPE_U16);
- ft.setString (DESC, "Number of journal files");
- buf.put (ft);
+ ft[NAME] = "numFiles";
+ ft[TYPE] = TYPE_U16;
+ ft[DESC] = "Number of journal files";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "numEnq");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (DESC, "Number of recovered enqueues");
- buf.put (ft);
+ ft[NAME] = "numEnq";
+ ft[TYPE] = TYPE_U32;
+ ft[DESC] = "Number of recovered enqueues";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "numTxn");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (DESC, "Number of recovered transactions");
- buf.put (ft);
+ ft[NAME] = "numTxn";
+ ft[TYPE] = TYPE_U32;
+ ft[DESC] = "Number of recovered transactions";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "numTxnEnq");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (DESC, "Number of recovered transactional enqueues");
- buf.put (ft);
+ ft[NAME] = "numTxnEnq";
+ ft[TYPE] = TYPE_U32;
+ ft[DESC] = "Number of recovered transactional enqueues";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "numTxnDeq");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (DESC, "Number of recovered transactional dequeues");
- buf.put (ft);
+ ft[NAME] = "numTxnDeq";
+ ft[TYPE] = TYPE_U32;
+ ft[DESC] = "Number of recovered transactional dequeues";
+ buf.putMap(ft);
{
@@ -138,7 +139,7 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
buf.putShortString(jrnlId);
buf.putLong(fileSize);
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-04-08 16:38:12 UTC (rev 3901)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp 2010-04-09 03:54:13 UTC (rev 3902)
@@ -23,8 +23,9 @@
#include "qpid/log/Statement.h"
#include "qpid/management/Manageable.h"
-#include "qpid/framing/FieldTable.h"
-#include "qpid/framing/Buffer.h"
+#include "qpid/management/Buffer.h"
+#include "qpid/types/Variant.h"
+#include "qpid/amqp_0_10/Codecs.h"
#include "qpid/management/ManagementAgent.h"
#include "Journal.h"
#include "ArgsJournalExpand.h"
@@ -123,8 +124,8 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
- ::qpid::framing::FieldTable ft;
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
+ ::qpid::types::Variant::Map ft;
// Schema class header:
buf.putOctet (CLASS_KIND_TABLE);
@@ -137,347 +138,347 @@
// Properties
ft.clear();
- ft.setString (NAME, "queueRef");
- ft.setInt (TYPE, TYPE_REF);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- buf.put (ft);
+ ft[NAME] = "queueRef";
+ ft[TYPE] = TYPE_REF;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "name");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 1);
- ft.setInt (IS_OPTIONAL, 0);
- buf.put (ft);
+ ft[NAME] = "name";
+ ft[TYPE] = TYPE_SSTR;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 1;
+ ft[IS_OPTIONAL] = 0;
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "directory");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (DESC, "Directory containing journal files");
- buf.put (ft);
+ ft[NAME] = "directory";
+ ft[TYPE] = TYPE_SSTR;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[DESC] = "Directory containing journal files";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "baseFileName");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (DESC, "Base filename prefix for journal");
- buf.put (ft);
+ ft[NAME] = "baseFileName";
+ ft[TYPE] = TYPE_SSTR;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[DESC] = "Base filename prefix for journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "writePageSize");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "byte");
- ft.setString (DESC, "Page size in write-page-cache");
- buf.put (ft);
+ ft[NAME] = "writePageSize";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "byte";
+ ft[DESC] = "Page size in write-page-cache";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "writePages");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "wpage");
- ft.setString (DESC, "Number of pages in write-page-cache");
- buf.put (ft);
+ ft[NAME] = "writePages";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "wpage";
+ ft[DESC] = "Number of pages in write-page-cache";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "readPageSize");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "byte");
- ft.setString (DESC, "Page size in read-page-cache");
- buf.put (ft);
+ ft[NAME] = "readPageSize";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "byte";
+ ft[DESC] = "Page size in read-page-cache";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "readPages");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "rpage");
- ft.setString (DESC, "Number of pages in read-page-cache");
- buf.put (ft);
+ ft[NAME] = "readPages";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "rpage";
+ ft[DESC] = "Number of pages in read-page-cache";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "initialFileCount");
- ft.setInt (TYPE, TYPE_U16);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files initially allocated to this journal");
- buf.put (ft);
+ ft[NAME] = "initialFileCount";
+ ft[TYPE] = TYPE_U16;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files initially allocated to this journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "autoExpand");
- ft.setInt (TYPE, TYPE_BOOL);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (DESC, "Auto-expand enabled");
- buf.put (ft);
+ ft[NAME] = "autoExpand";
+ ft[TYPE] = TYPE_BOOL;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[DESC] = "Auto-expand enabled";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "currentFileCount");
- ft.setInt (TYPE, TYPE_U16);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files currently allocated to this journal");
- buf.put (ft);
+ ft[NAME] = "currentFileCount";
+ ft[TYPE] = TYPE_U16;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files currently allocated to this journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "maxFileCount");
- ft.setInt (TYPE, TYPE_U16);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Max number of files allowed for this journal");
- buf.put (ft);
+ ft[NAME] = "maxFileCount";
+ ft[TYPE] = TYPE_U16;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "file";
+ ft[DESC] = "Max number of files allowed for this journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "dataFileSize");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "byte");
- ft.setString (DESC, "Size of each journal data file");
- buf.put (ft);
+ ft[NAME] = "dataFileSize";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "byte";
+ ft[DESC] = "Size of each journal data file";
+ buf.putMap(ft);
// Statistics
ft.clear();
- ft.setString (NAME, "recordDepth");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Number of currently enqueued records (durable messages)");
- buf.put (ft);
+ ft[NAME] = "recordDepth";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "record";
+ ft[DESC] = "Number of currently enqueued records (durable messages)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "recordDepthHigh");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Number of currently enqueued records (durable messages) (High)");
- buf.put (ft);
+ ft[NAME] = "recordDepthHigh";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "record";
+ ft[DESC] = "Number of currently enqueued records (durable messages) (High)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "recordDepthLow");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Number of currently enqueued records (durable messages) (Low)");
- buf.put (ft);
+ ft[NAME] = "recordDepthLow";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "record";
+ ft[DESC] = "Number of currently enqueued records (durable messages) (Low)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "enqueues");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total enqueued records on journal");
- buf.put (ft);
+ ft[NAME] = "enqueues";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total enqueued records on journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "dequeues");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total dequeued records on journal");
- buf.put (ft);
+ ft[NAME] = "dequeues";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total dequeued records on journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "txn");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total open transactions (xids) on journal");
- buf.put (ft);
+ ft[NAME] = "txn";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total open transactions (xids) on journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "txnEnqueues");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total transactional enqueued records on journal");
- buf.put (ft);
+ ft[NAME] = "txnEnqueues";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total transactional enqueued records on journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "txnDequeues");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total transactional dequeued records on journal");
- buf.put (ft);
+ ft[NAME] = "txnDequeues";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total transactional dequeued records on journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "txnCommits");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total transactional commit records on journal");
- buf.put (ft);
+ ft[NAME] = "txnCommits";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total transactional commit records on journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "txnAborts");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total transactional abort records on journal");
- buf.put (ft);
+ ft[NAME] = "txnAborts";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total transactional abort records on journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "outstandingAIOs");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "aio_op");
- ft.setString (DESC, "Number of currently outstanding AIO requests in Async IO system");
- buf.put (ft);
+ ft[NAME] = "outstandingAIOs";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "aio_op";
+ ft[DESC] = "Number of currently outstanding AIO requests in Async IO system";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "outstandingAIOsHigh");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "aio_op");
- ft.setString (DESC, "Number of currently outstanding AIO requests in Async IO system (High)");
- buf.put (ft);
+ ft[NAME] = "outstandingAIOsHigh";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "aio_op";
+ ft[DESC] = "Number of currently outstanding AIO requests in Async IO system (High)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "outstandingAIOsLow");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "aio_op");
- ft.setString (DESC, "Number of currently outstanding AIO requests in Async IO system (Low)");
- buf.put (ft);
+ ft[NAME] = "outstandingAIOsLow";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "aio_op";
+ ft[DESC] = "Number of currently outstanding AIO requests in Async IO system (Low)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "freeFileCount");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files free on this journal. Includes free files trapped in holes.");
- buf.put (ft);
+ ft[NAME] = "freeFileCount";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files free on this journal. Includes free files trapped in holes.";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "freeFileCountHigh");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files free on this journal. Includes free files trapped in holes. (High)");
- buf.put (ft);
+ ft[NAME] = "freeFileCountHigh";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files free on this journal. Includes free files trapped in holes. (High)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "freeFileCountLow");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files free on this journal. Includes free files trapped in holes. (Low)");
- buf.put (ft);
+ ft[NAME] = "freeFileCountLow";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files free on this journal. Includes free files trapped in holes. (Low)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "availableFileCount");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files available to be written. Excluding holes");
- buf.put (ft);
+ ft[NAME] = "availableFileCount";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files available to be written. Excluding holes";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "availableFileCountHigh");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files available to be written. Excluding holes (High)");
- buf.put (ft);
+ ft[NAME] = "availableFileCountHigh";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files available to be written. Excluding holes (High)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "availableFileCountLow");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files available to be written. Excluding holes (Low)");
- buf.put (ft);
+ ft[NAME] = "availableFileCountLow";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files available to be written. Excluding holes (Low)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "writeWaitFailures");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "AIO Wait failures on write");
- buf.put (ft);
+ ft[NAME] = "writeWaitFailures";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "AIO Wait failures on write";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "writeBusyFailures");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "AIO Busy failures on write");
- buf.put (ft);
+ ft[NAME] = "writeBusyFailures";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "AIO Busy failures on write";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "readRecordCount");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Records read from the journal");
- buf.put (ft);
+ ft[NAME] = "readRecordCount";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Records read from the journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "readBusyFailures");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "AIO Busy failures on read");
- buf.put (ft);
+ ft[NAME] = "readBusyFailures";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "AIO Busy failures on read";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "writePageCacheDepth");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "wpage");
- ft.setString (DESC, "Current depth of write-page-cache");
- buf.put (ft);
+ ft[NAME] = "writePageCacheDepth";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "wpage";
+ ft[DESC] = "Current depth of write-page-cache";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "writePageCacheDepthHigh");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "wpage");
- ft.setString (DESC, "Current depth of write-page-cache (High)");
- buf.put (ft);
+ ft[NAME] = "writePageCacheDepthHigh";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "wpage";
+ ft[DESC] = "Current depth of write-page-cache (High)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "writePageCacheDepthLow");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "wpage");
- ft.setString (DESC, "Current depth of write-page-cache (Low)");
- buf.put (ft);
+ ft[NAME] = "writePageCacheDepthLow";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "wpage";
+ ft[DESC] = "Current depth of write-page-cache (Low)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "readPageCacheDepth");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "rpage");
- ft.setString (DESC, "Current depth of read-page-cache");
- buf.put (ft);
+ ft[NAME] = "readPageCacheDepth";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "rpage";
+ ft[DESC] = "Current depth of read-page-cache";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "readPageCacheDepthHigh");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "rpage");
- ft.setString (DESC, "Current depth of read-page-cache (High)");
- buf.put (ft);
+ ft[NAME] = "readPageCacheDepthHigh";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "rpage";
+ ft[DESC] = "Current depth of read-page-cache (High)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "readPageCacheDepthLow");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "rpage");
- ft.setString (DESC, "Current depth of read-page-cache (Low)");
- buf.put (ft);
+ ft[NAME] = "readPageCacheDepthLow";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "rpage";
+ ft[DESC] = "Current depth of read-page-cache (Low)";
+ buf.putMap(ft);
// Methods
ft.clear();
- ft.setString (NAME, "expand");
- ft.setInt (ARGCOUNT, 1);
- ft.setString (DESC, "Increase number of files allocated for this journal");
- buf.put (ft);
+ ft[NAME] = "expand";
+ ft[ARGCOUNT] = 1;
+ ft[DESC] = "Increase number of files allocated for this journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "by");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (DIR, "I");
- ft.setString (DESC, "Number of files to increase journal size by");
- buf.put (ft);
+ ft[NAME] = "by";
+ ft[TYPE] = TYPE_U32;
+ ft[DIR] = "I";
+ ft[DESC] = "Number of files to increase journal size by";
+ buf.putMap(ft);
{
@@ -548,7 +549,7 @@
{
char *_tmpBuf = new char[_sBuf.length()];
memcpy(_tmpBuf, _sBuf.data(), _sBuf.length());
- ::qpid::framing::Buffer buf(_tmpBuf, _sBuf.length());
+ ::qpid::management::Buffer buf(_tmpBuf, _sBuf.length());
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
{
@@ -580,7 +581,7 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
configChanged = false;
@@ -618,7 +619,7 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
instChanged = false;
@@ -696,12 +697,12 @@
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer outBuf(_msgChars, _bufSize);
+ ::qpid::management::Buffer outBuf(_msgChars, _bufSize);
char *_tmpBuf = new char[inStr.length()];
memcpy(_tmpBuf, inStr.data(), inStr.length());
- ::qpid::framing::Buffer inBuf(_tmpBuf, inStr.length());
+ ::qpid::management::Buffer inBuf(_tmpBuf, inStr.length());
if (methodName == "expand") {
_matched = true;
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-04-08 16:38:12 UTC (rev 3901)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp 2010-04-09 03:54:13 UTC (rev 3902)
@@ -23,8 +23,9 @@
#include "qpid/log/Statement.h"
#include "qpid/management/Manageable.h"
-#include "qpid/framing/FieldTable.h"
-#include "qpid/framing/Buffer.h"
+#include "qpid/management/Buffer.h"
+#include "qpid/types/Variant.h"
+#include "qpid/amqp_0_10/Codecs.h"
#include "qpid/management/ManagementAgent.h"
#include "Store.h"
@@ -107,8 +108,8 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
- ::qpid::framing::FieldTable ft;
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
+ ::qpid::types::Variant::Map ft;
// Schema class header:
buf.putOctet (CLASS_KIND_TABLE);
@@ -121,174 +122,174 @@
// Properties
ft.clear();
- ft.setString (NAME, "brokerRef");
- ft.setInt (TYPE, TYPE_REF);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 1);
- ft.setInt (IS_OPTIONAL, 0);
- buf.put (ft);
+ ft[NAME] = "brokerRef";
+ ft[TYPE] = TYPE_REF;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 1;
+ ft[IS_OPTIONAL] = 0;
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "location");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (DESC, "Logical directory on disk");
- buf.put (ft);
+ ft[NAME] = "location";
+ ft[TYPE] = TYPE_SSTR;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[DESC] = "Logical directory on disk";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "defaultInitialFileCount");
- ft.setInt (TYPE, TYPE_U16);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Default number of files initially allocated to each journal");
- buf.put (ft);
+ ft[NAME] = "defaultInitialFileCount";
+ ft[TYPE] = TYPE_U16;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "file";
+ ft[DESC] = "Default number of files initially allocated to each journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "defaultDataFileSize");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "RdPg");
- ft.setString (DESC, "Default size of each journal data file");
- buf.put (ft);
+ ft[NAME] = "defaultDataFileSize";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "RdPg";
+ ft[DESC] = "Default size of each journal data file";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplIsInitialized");
- ft.setInt (TYPE, TYPE_BOOL);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (DESC, "Transaction prepared list has been initialized by a transactional prepare");
- buf.put (ft);
+ ft[NAME] = "tplIsInitialized";
+ ft[TYPE] = TYPE_BOOL;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[DESC] = "Transaction prepared list has been initialized by a transactional prepare";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplDirectory");
- ft.setInt (TYPE, TYPE_SSTR);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (DESC, "Transaction prepared list directory");
- buf.put (ft);
+ ft[NAME] = "tplDirectory";
+ ft[TYPE] = TYPE_SSTR;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[DESC] = "Transaction prepared list directory";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplWritePageSize");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "byte");
- ft.setString (DESC, "Page size in transaction prepared list write-page-cache");
- buf.put (ft);
+ ft[NAME] = "tplWritePageSize";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "byte";
+ ft[DESC] = "Page size in transaction prepared list write-page-cache";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplWritePages");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "wpage");
- ft.setString (DESC, "Number of pages in transaction prepared list write-page-cache");
- buf.put (ft);
+ ft[NAME] = "tplWritePages";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "wpage";
+ ft[DESC] = "Number of pages in transaction prepared list write-page-cache";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplInitialFileCount");
- ft.setInt (TYPE, TYPE_U16);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files initially allocated to transaction prepared list journal");
- buf.put (ft);
+ ft[NAME] = "tplInitialFileCount";
+ ft[TYPE] = TYPE_U16;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files initially allocated to transaction prepared list journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplDataFileSize");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "byte");
- ft.setString (DESC, "Size of each journal data file in transaction prepared list journal");
- buf.put (ft);
+ ft[NAME] = "tplDataFileSize";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "byte";
+ ft[DESC] = "Size of each journal data file in transaction prepared list journal";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplCurrentFileCount");
- ft.setInt (TYPE, TYPE_U32);
- ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (IS_INDEX, 0);
- ft.setInt (IS_OPTIONAL, 0);
- ft.setString (UNIT, "file");
- ft.setString (DESC, "Number of files currently allocated to transaction prepared list journal");
- buf.put (ft);
+ ft[NAME] = "tplCurrentFileCount";
+ ft[TYPE] = TYPE_U32;
+ ft[ACCESS] = ACCESS_RO;
+ ft[IS_INDEX] = 0;
+ ft[IS_OPTIONAL] = 0;
+ ft[UNIT] = "file";
+ ft[DESC] = "Number of files currently allocated to transaction prepared list journal";
+ buf.putMap(ft);
// Statistics
ft.clear();
- ft.setString (NAME, "tplTransactionDepth");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "txn");
- ft.setString (DESC, "Number of currently enqueued prepared transactions");
- buf.put (ft);
+ ft[NAME] = "tplTransactionDepth";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "txn";
+ ft[DESC] = "Number of currently enqueued prepared transactions";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplTransactionDepthHigh");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "txn");
- ft.setString (DESC, "Number of currently enqueued prepared transactions (High)");
- buf.put (ft);
+ ft[NAME] = "tplTransactionDepthHigh";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "txn";
+ ft[DESC] = "Number of currently enqueued prepared transactions (High)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplTransactionDepthLow");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "txn");
- ft.setString (DESC, "Number of currently enqueued prepared transactions (Low)");
- buf.put (ft);
+ ft[NAME] = "tplTransactionDepthLow";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "txn";
+ ft[DESC] = "Number of currently enqueued prepared transactions (Low)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplTxnPrepares");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total transaction prepares on transaction prepared list");
- buf.put (ft);
+ ft[NAME] = "tplTxnPrepares";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total transaction prepares on transaction prepared list";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplTxnCommits");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total transaction commits on transaction prepared list");
- buf.put (ft);
+ ft[NAME] = "tplTxnCommits";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total transaction commits on transaction prepared list";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplTxnAborts");
- ft.setInt (TYPE, TYPE_U64);
- ft.setString (UNIT, "record");
- ft.setString (DESC, "Total transaction aborts on transaction prepared list");
- buf.put (ft);
+ ft[NAME] = "tplTxnAborts";
+ ft[TYPE] = TYPE_U64;
+ ft[UNIT] = "record";
+ ft[DESC] = "Total transaction aborts on transaction prepared list";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplOutstandingAIOs");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "aio_op");
- ft.setString (DESC, "Number of currently outstanding AIO requests in Async IO system");
- buf.put (ft);
+ ft[NAME] = "tplOutstandingAIOs";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "aio_op";
+ ft[DESC] = "Number of currently outstanding AIO requests in Async IO system";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplOutstandingAIOsHigh");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "aio_op");
- ft.setString (DESC, "Number of currently outstanding AIO requests in Async IO system (High)");
- buf.put (ft);
+ ft[NAME] = "tplOutstandingAIOsHigh";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "aio_op";
+ ft[DESC] = "Number of currently outstanding AIO requests in Async IO system (High)";
+ buf.putMap(ft);
ft.clear();
- ft.setString (NAME, "tplOutstandingAIOsLow");
- ft.setInt (TYPE, TYPE_U32);
- ft.setString (UNIT, "aio_op");
- ft.setString (DESC, "Number of currently outstanding AIO requests in Async IO system (Low)");
- buf.put (ft);
+ ft[NAME] = "tplOutstandingAIOsLow";
+ ft[TYPE] = TYPE_U32;
+ ft[UNIT] = "aio_op";
+ ft[DESC] = "Number of currently outstanding AIO requests in Async IO system (Low)";
+ buf.putMap(ft);
// Methods
@@ -343,7 +344,7 @@
{
char *_tmpBuf = new char[_sBuf.length()];
memcpy(_tmpBuf, _sBuf.data(), _sBuf.length());
- ::qpid::framing::Buffer buf(_tmpBuf, _sBuf.length());
+ ::qpid::management::Buffer buf(_tmpBuf, _sBuf.length());
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
{
@@ -373,7 +374,7 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
configChanged = false;
@@ -409,7 +410,7 @@
{
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer buf(_msgChars, _bufSize);
+ ::qpid::management::Buffer buf(_msgChars, _bufSize);
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
instChanged = false;
@@ -459,7 +460,7 @@
const int _bufSize=65536;
char _msgChars[_bufSize];
- ::qpid::framing::Buffer outBuf(_msgChars, _bufSize);
+ ::qpid::management::Buffer outBuf(_msgChars, _bufSize);
More information about the rhmessaging-commits
mailing list