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);