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

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