[rhmessaging-commits] rhmessaging commits: r2866 - store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store.
rhmessaging-commits at lists.jboss.org
rhmessaging-commits at lists.jboss.org
Fri Nov 21 15:47:58 EST 2008
Author: tedross
Date: 2008-11-21 15:47:57 -0500 (Fri, 21 Nov 2008)
New Revision: 2866
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 QMF files
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 2008-11-21 17:20:38 UTC (rev 2865)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp 2008-11-21 20:47:57 UTC (rev 2866)
@@ -99,8 +99,8 @@
const string NAME("name");
const string TYPE("type");
const string ACCESS("access");
- const string INDEX("index");
- const string OPTIONAL("optional");
+ const string IS_INDEX("index");
+ const string IS_OPTIONAL("optional");
const string UNIT("unit");
const string MIN("min");
const string MAX("max");
@@ -135,24 +135,24 @@
ft.setString (NAME, "queueRef");
ft.setInt (TYPE, TYPE_REF);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ ft.setInt (IS_INDEX, 0);
+ ft.setInt (IS_OPTIONAL, 0);
buf.put (ft);
ft = FieldTable ();
ft.setString (NAME, "name");
ft.setInt (TYPE, TYPE_SSTR);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 1);
- ft.setInt (OPTIONAL, 0);
+ ft.setInt (IS_INDEX, 1);
+ ft.setInt (IS_OPTIONAL, 0);
buf.put (ft);
ft = FieldTable ();
ft.setString (NAME, "directory");
ft.setInt (TYPE, TYPE_SSTR);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ ft.setInt (IS_INDEX, 0);
+ ft.setInt (IS_OPTIONAL, 0);
ft.setString (DESC, "Directory containing journal files");
buf.put (ft);
@@ -160,8 +160,8 @@
ft.setString (NAME, "baseFileName");
ft.setInt (TYPE, TYPE_SSTR);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ ft.setInt (IS_INDEX, 0);
+ ft.setInt (IS_OPTIONAL, 0);
ft.setString (DESC, "Base filename prefix for journal");
buf.put (ft);
@@ -169,8 +169,8 @@
ft.setString (NAME, "writePageSize");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -179,8 +179,8 @@
ft.setString (NAME, "writePages");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -189,8 +189,8 @@
ft.setString (NAME, "readPageSize");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -199,8 +199,8 @@
ft.setString (NAME, "readPages");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -209,8 +209,8 @@
ft.setString (NAME, "initialFileCount");
ft.setInt (TYPE, TYPE_U16);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -219,8 +219,8 @@
ft.setString (NAME, "dataFileSize");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -229,8 +229,8 @@
ft.setString (NAME, "currentFileCount");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
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 2008-11-21 17:20:38 UTC (rev 2865)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h 2008-11-21 20:47:57 UTC (rev 2866)
@@ -150,6 +150,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
queueRef = val;
configChanged = true;
+ setUpdateTime();
}
inline const ::qpid::management::ObjectId& get_queueRef() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -159,6 +160,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
name = val;
configChanged = true;
+ setUpdateTime();
}
inline const std::string& get_name() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -168,6 +170,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
directory = val;
configChanged = true;
+ setUpdateTime();
}
inline const std::string& get_directory() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -177,6 +180,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
baseFileName = val;
configChanged = true;
+ setUpdateTime();
}
inline const std::string& get_baseFileName() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -186,6 +190,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
writePageSize = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_writePageSize() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -195,6 +200,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
writePages = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_writePages() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -204,6 +210,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
readPageSize = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_readPageSize() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -213,6 +220,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
readPages = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_readPages() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -222,6 +230,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
initialFileCount = val;
configChanged = true;
+ setUpdateTime();
}
inline uint16_t get_initialFileCount() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -231,6 +240,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
dataFileSize = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_dataFileSize() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -240,6 +250,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
currentFileCount = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_currentFileCount() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -251,6 +262,7 @@
if (recordDepthHigh < recordDepth)
recordDepthHigh = recordDepth;
instChanged = true;
+ setUpdateTime();
}
inline void dec_recordDepth (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -258,54 +270,67 @@
if (recordDepthLow > recordDepth)
recordDepthLow = recordDepth;
instChanged = true;
+ setUpdateTime();
}
inline void inc_enqueues (uint64_t by = 1) {
getThreadStats()->enqueues += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_enqueues (uint64_t by = 1) {
getThreadStats()->enqueues -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_dequeues (uint64_t by = 1) {
getThreadStats()->dequeues += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_dequeues (uint64_t by = 1) {
getThreadStats()->dequeues -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_txnEnqueues (uint64_t by = 1) {
getThreadStats()->txnEnqueues += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_txnEnqueues (uint64_t by = 1) {
getThreadStats()->txnEnqueues -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_txnDequeues (uint64_t by = 1) {
getThreadStats()->txnDequeues += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_txnDequeues (uint64_t by = 1) {
getThreadStats()->txnDequeues -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_txnCommits (uint64_t by = 1) {
getThreadStats()->txnCommits += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_txnCommits (uint64_t by = 1) {
getThreadStats()->txnCommits -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_txnAborts (uint64_t by = 1) {
getThreadStats()->txnAborts += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_txnAborts (uint64_t by = 1) {
getThreadStats()->txnAborts -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_outstandingAIOs (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -313,6 +338,7 @@
if (outstandingAIOsHigh < outstandingAIOs)
outstandingAIOsHigh = outstandingAIOs;
instChanged = true;
+ setUpdateTime();
}
inline void dec_outstandingAIOs (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -320,6 +346,7 @@
if (outstandingAIOsLow > outstandingAIOs)
outstandingAIOsLow = outstandingAIOs;
instChanged = true;
+ setUpdateTime();
}
inline void inc_freeFileCount (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -327,6 +354,7 @@
if (freeFileCountHigh < freeFileCount)
freeFileCountHigh = freeFileCount;
instChanged = true;
+ setUpdateTime();
}
inline void dec_freeFileCount (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -334,6 +362,7 @@
if (freeFileCountLow > freeFileCount)
freeFileCountLow = freeFileCount;
instChanged = true;
+ setUpdateTime();
}
inline void inc_availableFileCount (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -341,6 +370,7 @@
if (availableFileCountHigh < availableFileCount)
availableFileCountHigh = availableFileCount;
instChanged = true;
+ setUpdateTime();
}
inline void dec_availableFileCount (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -348,38 +378,47 @@
if (availableFileCountLow > availableFileCount)
availableFileCountLow = availableFileCount;
instChanged = true;
+ setUpdateTime();
}
inline void inc_writeWaitFailures (uint64_t by = 1) {
getThreadStats()->writeWaitFailures += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_writeWaitFailures (uint64_t by = 1) {
getThreadStats()->writeWaitFailures -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_writeBusyFailures (uint64_t by = 1) {
getThreadStats()->writeBusyFailures += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_writeBusyFailures (uint64_t by = 1) {
getThreadStats()->writeBusyFailures -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_readRecordCount (uint64_t by = 1) {
getThreadStats()->readRecordCount += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_readRecordCount (uint64_t by = 1) {
getThreadStats()->readRecordCount -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_readBusyFailures (uint64_t by = 1) {
getThreadStats()->readBusyFailures += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_readBusyFailures (uint64_t by = 1) {
getThreadStats()->readBusyFailures -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_writePageCacheDepth (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -387,6 +426,7 @@
if (writePageCacheDepthHigh < writePageCacheDepth)
writePageCacheDepthHigh = writePageCacheDepth;
instChanged = true;
+ setUpdateTime();
}
inline void dec_writePageCacheDepth (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -394,6 +434,7 @@
if (writePageCacheDepthLow > writePageCacheDepth)
writePageCacheDepthLow = writePageCacheDepth;
instChanged = true;
+ setUpdateTime();
}
inline void inc_readPageCacheDepth (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -401,6 +442,7 @@
if (readPageCacheDepthHigh < readPageCacheDepth)
readPageCacheDepthHigh = readPageCacheDepth;
instChanged = true;
+ setUpdateTime();
}
inline void dec_readPageCacheDepth (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -408,6 +450,7 @@
if (readPageCacheDepthLow > readPageCacheDepth)
readPageCacheDepthLow = readPageCacheDepth;
instChanged = true;
+ setUpdateTime();
}
};
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 2008-11-21 17:20:38 UTC (rev 2865)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp 2008-11-21 20:47:57 UTC (rev 2866)
@@ -85,8 +85,8 @@
const string NAME("name");
const string TYPE("type");
const string ACCESS("access");
- const string INDEX("index");
- const string OPTIONAL("optional");
+ const string IS_INDEX("index");
+ const string IS_OPTIONAL("optional");
const string UNIT("unit");
const string MIN("min");
const string MAX("max");
@@ -121,16 +121,16 @@
ft.setString (NAME, "brokerRef");
ft.setInt (TYPE, TYPE_REF);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 1);
- ft.setInt (OPTIONAL, 0);
+ ft.setInt (IS_INDEX, 1);
+ ft.setInt (IS_OPTIONAL, 0);
buf.put (ft);
ft = FieldTable ();
ft.setString (NAME, "location");
ft.setInt (TYPE, TYPE_SSTR);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ ft.setInt (IS_INDEX, 0);
+ ft.setInt (IS_OPTIONAL, 0);
ft.setString (DESC, "Logical directory on disk");
buf.put (ft);
@@ -138,8 +138,8 @@
ft.setString (NAME, "defaultInitialFileCount");
ft.setInt (TYPE, TYPE_U16);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -148,8 +148,8 @@
ft.setString (NAME, "defaultDataFileSize");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -158,8 +158,8 @@
ft.setString (NAME, "tplIsInitialized");
ft.setInt (TYPE, TYPE_BOOL);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -167,8 +167,8 @@
ft.setString (NAME, "tplDirectory");
ft.setInt (TYPE, TYPE_SSTR);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ ft.setInt (IS_INDEX, 0);
+ ft.setInt (IS_OPTIONAL, 0);
ft.setString (DESC, "Transaction prepared list directory");
buf.put (ft);
@@ -176,8 +176,8 @@
ft.setString (NAME, "tplWritePageSize");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -186,8 +186,8 @@
ft.setString (NAME, "tplWritePages");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -196,8 +196,8 @@
ft.setString (NAME, "tplInitialFileCount");
ft.setInt (TYPE, TYPE_U16);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -206,8 +206,8 @@
ft.setString (NAME, "tplDataFileSize");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
@@ -216,8 +216,8 @@
ft.setString (NAME, "tplCurrentFileCount");
ft.setInt (TYPE, TYPE_U32);
ft.setInt (ACCESS, ACCESS_RO);
- ft.setInt (INDEX, 0);
- ft.setInt (OPTIONAL, 0);
+ 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);
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 2008-11-21 17:20:38 UTC (rev 2865)
+++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h 2008-11-21 20:47:57 UTC (rev 2866)
@@ -122,6 +122,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
brokerRef = val;
configChanged = true;
+ setUpdateTime();
}
inline const ::qpid::management::ObjectId& get_brokerRef() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -131,6 +132,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
location = val;
configChanged = true;
+ setUpdateTime();
}
inline const std::string& get_location() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -140,6 +142,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
defaultInitialFileCount = val;
configChanged = true;
+ setUpdateTime();
}
inline uint16_t get_defaultInitialFileCount() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -149,6 +152,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
defaultDataFileSize = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_defaultDataFileSize() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -158,6 +162,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
tplIsInitialized = val;
configChanged = true;
+ setUpdateTime();
}
inline uint8_t get_tplIsInitialized() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -167,6 +172,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
tplDirectory = val;
configChanged = true;
+ setUpdateTime();
}
inline const std::string& get_tplDirectory() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -176,6 +182,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
tplWritePageSize = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_tplWritePageSize() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -185,6 +192,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
tplWritePages = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_tplWritePages() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -194,6 +202,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
tplInitialFileCount = val;
configChanged = true;
+ setUpdateTime();
}
inline uint16_t get_tplInitialFileCount() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -203,6 +212,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
tplDataFileSize = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_tplDataFileSize() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -212,6 +222,7 @@
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
tplCurrentFileCount = val;
configChanged = true;
+ setUpdateTime();
}
inline uint32_t get_tplCurrentFileCount() {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -223,6 +234,7 @@
if (tplTransactionDepthHigh < tplTransactionDepth)
tplTransactionDepthHigh = tplTransactionDepth;
instChanged = true;
+ setUpdateTime();
}
inline void dec_tplTransactionDepth (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -230,30 +242,37 @@
if (tplTransactionDepthLow > tplTransactionDepth)
tplTransactionDepthLow = tplTransactionDepth;
instChanged = true;
+ setUpdateTime();
}
inline void inc_tplTxnPrepares (uint64_t by = 1) {
getThreadStats()->tplTxnPrepares += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_tplTxnPrepares (uint64_t by = 1) {
getThreadStats()->tplTxnPrepares -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_tplTxnCommits (uint64_t by = 1) {
getThreadStats()->tplTxnCommits += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_tplTxnCommits (uint64_t by = 1) {
getThreadStats()->tplTxnCommits -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_tplTxnAborts (uint64_t by = 1) {
getThreadStats()->tplTxnAborts += by;
instChanged = true;
+ setUpdateTime();
}
inline void dec_tplTxnAborts (uint64_t by = 1) {
getThreadStats()->tplTxnAborts -= by;
instChanged = true;
+ setUpdateTime();
}
inline void inc_tplOutstandingAIOs (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -261,6 +280,7 @@
if (tplOutstandingAIOsHigh < tplOutstandingAIOs)
tplOutstandingAIOsHigh = tplOutstandingAIOs;
instChanged = true;
+ setUpdateTime();
}
inline void dec_tplOutstandingAIOs (uint32_t by = 1) {
::qpid::sys::Mutex::ScopedLock mutex(accessLock);
@@ -268,6 +288,7 @@
if (tplOutstandingAIOsLow > tplOutstandingAIOs)
tplOutstandingAIOsLow = tplOutstandingAIOs;
instChanged = true;
+ setUpdateTime();
}
};
More information about the rhmessaging-commits
mailing list