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

Author: tedross Date: 2010-04-09 13:20:27 -0400 (Fri, 09 Apr 2010) New Revision: 3903 Modified: 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/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: Re-generated QMF files to use new isolated Mutex feature. 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-09 03:54:13 UTC (rev 3902) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventCreated.cpp 2010-04-09 17:20:27 UTC (rev 3903) @@ -21,7 +21,6 @@ // This source file was created by a code generator. // Please do not edit. -#include "qpid/log/Statement.h" #include "qpid/management/Manageable.h" #include "qpid/management/Buffer.h" #include "qpid/types/Variant.h" @@ -34,6 +33,7 @@ using qpid::management::Manageable; using qpid::management::ManagementObject; using qpid::management::Args; +using qpid::management::Mutex; using std::string; string EventCreated::packageName = string ("com.redhat.rhm.store"); 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-09 03:54:13 UTC (rev 3902) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventEnqThresholdExceeded.cpp 2010-04-09 17:20:27 UTC (rev 3903) @@ -21,7 +21,6 @@ // This source file was created by a code generator. // Please do not edit. -#include "qpid/log/Statement.h" #include "qpid/management/Manageable.h" #include "qpid/management/Buffer.h" #include "qpid/types/Variant.h" @@ -34,6 +33,7 @@ using qpid::management::Manageable; using qpid::management::ManagementObject; using qpid::management::Args; +using qpid::management::Mutex; using std::string; string EventEnqThresholdExceeded::packageName = string ("com.redhat.rhm.store"); 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-09 03:54:13 UTC (rev 3902) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventFull.cpp 2010-04-09 17:20:27 UTC (rev 3903) @@ -21,7 +21,6 @@ // This source file was created by a code generator. // Please do not edit. -#include "qpid/log/Statement.h" #include "qpid/management/Manageable.h" #include "qpid/management/Buffer.h" #include "qpid/types/Variant.h" @@ -34,6 +33,7 @@ using qpid::management::Manageable; using qpid::management::ManagementObject; using qpid::management::Args; +using qpid::management::Mutex; using std::string; string EventFull::packageName = string ("com.redhat.rhm.store"); 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-09 03:54:13 UTC (rev 3902) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/EventRecovered.cpp 2010-04-09 17:20:27 UTC (rev 3903) @@ -21,7 +21,6 @@ // This source file was created by a code generator. // Please do not edit. -#include "qpid/log/Statement.h" #include "qpid/management/Manageable.h" #include "qpid/management/Buffer.h" #include "qpid/types/Variant.h" @@ -34,6 +33,7 @@ using qpid::management::Manageable; using qpid::management::ManagementObject; using qpid::management::Args; +using qpid::management::Mutex; using std::string; string EventRecovered::packageName = string ("com.redhat.rhm.store"); 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-09 03:54:13 UTC (rev 3902) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.cpp 2010-04-09 17:20:27 UTC (rev 3903) @@ -21,7 +21,6 @@ // This source file was created by a code generator. // Please do not edit. -#include "qpid/log/Statement.h" #include "qpid/management/Manageable.h" #include "qpid/management/Buffer.h" #include "qpid/types/Variant.h" @@ -37,6 +36,7 @@ using qpid::management::Manageable; using qpid::management::ManagementObject; using qpid::management::Args; +using qpid::management::Mutex; using std::string; string Journal::packageName = string ("com.redhat.rhm.store"); @@ -550,7 +550,7 @@ char *_tmpBuf = new char[_sBuf.length()]; memcpy(_tmpBuf, _sBuf.data(), _sBuf.length()); ::qpid::management::Buffer buf(_tmpBuf, _sBuf.length()); - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); { std::string _tbuf; @@ -583,7 +583,7 @@ char _msgChars[_bufSize]; ::qpid::management::Buffer buf(_msgChars, _bufSize); - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); configChanged = false; { @@ -621,7 +621,7 @@ char _msgChars[_bufSize]; ::qpid::management::Buffer buf(_msgChars, _bufSize); - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); instChanged = false; @@ -742,7 +742,7 @@ bool includeStatistics) { using namespace ::qpid::types; - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); if (includeProperties) { configChanged = false; @@ -823,7 +823,7 @@ void Journal::mapDecodeValues (const ::qpid::types::Variant::Map& _map) { ::qpid::types::Variant::Map::const_iterator _i; - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); if ((_i = _map.find("queueRef")) != _map.end()) { queueRef = _i->second; Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h 2010-04-09 03:54:13 UTC (rev 3902) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Journal.h 2010-04-09 17:20:27 UTC (rev 3903) @@ -166,131 +166,131 @@ // Accessor Methods inline void set_queueRef (const ::qpid::management::ObjectId& val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); queueRef = val; configChanged = true; } inline const ::qpid::management::ObjectId& get_queueRef() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return queueRef; } inline void set_name (const std::string& val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); name = val; configChanged = true; } inline const std::string& get_name() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return name; } inline void set_directory (const std::string& val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); directory = val; configChanged = true; } inline const std::string& get_directory() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return directory; } inline void set_baseFileName (const std::string& val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); baseFileName = val; configChanged = true; } inline const std::string& get_baseFileName() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return baseFileName; } inline void set_writePageSize (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); writePageSize = val; configChanged = true; } inline uint32_t get_writePageSize() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return writePageSize; } inline void set_writePages (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); writePages = val; configChanged = true; } inline uint32_t get_writePages() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return writePages; } inline void set_readPageSize (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); readPageSize = val; configChanged = true; } inline uint32_t get_readPageSize() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return readPageSize; } inline void set_readPages (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); readPages = val; configChanged = true; } inline uint32_t get_readPages() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return readPages; } inline void set_initialFileCount (uint16_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); initialFileCount = val; configChanged = true; } inline uint16_t get_initialFileCount() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return initialFileCount; } inline void set_autoExpand (uint8_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); autoExpand = val; configChanged = true; } inline uint8_t get_autoExpand() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return autoExpand; } inline void set_currentFileCount (uint16_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); currentFileCount = val; configChanged = true; } inline uint16_t get_currentFileCount() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return currentFileCount; } inline void set_maxFileCount (uint16_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); maxFileCount = val; configChanged = true; } inline uint16_t get_maxFileCount() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return maxFileCount; } inline void set_dataFileSize (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); dataFileSize = val; configChanged = true; } inline uint32_t get_dataFileSize() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return dataFileSize; } inline void inc_recordDepth (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); recordDepth += by; if (recordDepthHigh < recordDepth) recordDepthHigh = recordDepth; instChanged = true; } inline void dec_recordDepth (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); recordDepth -= by; if (recordDepthLow > recordDepth) recordDepthLow = recordDepth; @@ -353,42 +353,42 @@ instChanged = true; } inline void inc_outstandingAIOs (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); outstandingAIOs += by; if (outstandingAIOsHigh < outstandingAIOs) outstandingAIOsHigh = outstandingAIOs; instChanged = true; } inline void dec_outstandingAIOs (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); outstandingAIOs -= by; if (outstandingAIOsLow > outstandingAIOs) outstandingAIOsLow = outstandingAIOs; instChanged = true; } inline void inc_freeFileCount (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); freeFileCount += by; if (freeFileCountHigh < freeFileCount) freeFileCountHigh = freeFileCount; instChanged = true; } inline void dec_freeFileCount (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); freeFileCount -= by; if (freeFileCountLow > freeFileCount) freeFileCountLow = freeFileCount; instChanged = true; } inline void inc_availableFileCount (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); availableFileCount += by; if (availableFileCountHigh < availableFileCount) availableFileCountHigh = availableFileCount; instChanged = true; } inline void dec_availableFileCount (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); availableFileCount -= by; if (availableFileCountLow > availableFileCount) availableFileCountLow = availableFileCount; @@ -427,28 +427,28 @@ instChanged = true; } inline void inc_writePageCacheDepth (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); writePageCacheDepth += by; if (writePageCacheDepthHigh < writePageCacheDepth) writePageCacheDepthHigh = writePageCacheDepth; instChanged = true; } inline void dec_writePageCacheDepth (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); writePageCacheDepth -= by; if (writePageCacheDepthLow > writePageCacheDepth) writePageCacheDepthLow = writePageCacheDepth; instChanged = true; } inline void inc_readPageCacheDepth (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); readPageCacheDepth += by; if (readPageCacheDepthHigh < readPageCacheDepth) readPageCacheDepthHigh = readPageCacheDepth; instChanged = true; } inline void dec_readPageCacheDepth (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); readPageCacheDepth -= by; if (readPageCacheDepthLow > readPageCacheDepth) readPageCacheDepthLow = readPageCacheDepth; 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-09 03:54:13 UTC (rev 3902) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.cpp 2010-04-09 17:20:27 UTC (rev 3903) @@ -21,7 +21,6 @@ // This source file was created by a code generator. // Please do not edit. -#include "qpid/log/Statement.h" #include "qpid/management/Manageable.h" #include "qpid/management/Buffer.h" #include "qpid/types/Variant.h" @@ -36,6 +35,7 @@ using qpid::management::Manageable; using qpid::management::ManagementObject; using qpid::management::Args; +using qpid::management::Mutex; using std::string; string Store::packageName = string ("com.redhat.rhm.store"); @@ -345,7 +345,7 @@ char *_tmpBuf = new char[_sBuf.length()]; memcpy(_tmpBuf, _sBuf.data(), _sBuf.length()); ::qpid::management::Buffer buf(_tmpBuf, _sBuf.length()); - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); { std::string _tbuf; @@ -376,7 +376,7 @@ char _msgChars[_bufSize]; ::qpid::management::Buffer buf(_msgChars, _bufSize); - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); configChanged = false; { @@ -412,7 +412,7 @@ char _msgChars[_bufSize]; ::qpid::management::Buffer buf(_msgChars, _bufSize); - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); instChanged = false; @@ -490,7 +490,7 @@ bool includeStatistics) { using namespace ::qpid::types; - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); if (includeProperties) { configChanged = false; @@ -541,7 +541,7 @@ void Store::mapDecodeValues (const ::qpid::types::Variant::Map& _map) { ::qpid::types::Variant::Map::const_iterator _i; - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + Mutex::ScopedLock mutex(accessLock); if ((_i = _map.find("brokerRef")) != _map.end()) { brokerRef = _i->second; Modified: store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h =================================================================== --- store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h 2010-04-09 03:54:13 UTC (rev 3902) +++ store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store/Store.h 2010-04-09 17:20:27 UTC (rev 3903) @@ -134,113 +134,113 @@ // Accessor Methods inline void set_brokerRef (const ::qpid::management::ObjectId& val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); brokerRef = val; configChanged = true; } inline const ::qpid::management::ObjectId& get_brokerRef() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return brokerRef; } inline void set_location (const std::string& val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); location = val; configChanged = true; } inline const std::string& get_location() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return location; } inline void set_defaultInitialFileCount (uint16_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); defaultInitialFileCount = val; configChanged = true; } inline uint16_t get_defaultInitialFileCount() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return defaultInitialFileCount; } inline void set_defaultDataFileSize (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); defaultDataFileSize = val; configChanged = true; } inline uint32_t get_defaultDataFileSize() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return defaultDataFileSize; } inline void set_tplIsInitialized (uint8_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplIsInitialized = val; configChanged = true; } inline uint8_t get_tplIsInitialized() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return tplIsInitialized; } inline void set_tplDirectory (const std::string& val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplDirectory = val; configChanged = true; } inline const std::string& get_tplDirectory() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return tplDirectory; } inline void set_tplWritePageSize (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplWritePageSize = val; configChanged = true; } inline uint32_t get_tplWritePageSize() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return tplWritePageSize; } inline void set_tplWritePages (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplWritePages = val; configChanged = true; } inline uint32_t get_tplWritePages() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return tplWritePages; } inline void set_tplInitialFileCount (uint16_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplInitialFileCount = val; configChanged = true; } inline uint16_t get_tplInitialFileCount() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return tplInitialFileCount; } inline void set_tplDataFileSize (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplDataFileSize = val; configChanged = true; } inline uint32_t get_tplDataFileSize() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return tplDataFileSize; } inline void set_tplCurrentFileCount (uint32_t val) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplCurrentFileCount = val; configChanged = true; } inline uint32_t get_tplCurrentFileCount() { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); return tplCurrentFileCount; } inline void inc_tplTransactionDepth (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplTransactionDepth += by; if (tplTransactionDepthHigh < tplTransactionDepth) tplTransactionDepthHigh = tplTransactionDepth; instChanged = true; } inline void dec_tplTransactionDepth (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplTransactionDepth -= by; if (tplTransactionDepthLow > tplTransactionDepth) tplTransactionDepthLow = tplTransactionDepth; @@ -271,14 +271,14 @@ instChanged = true; } inline void inc_tplOutstandingAIOs (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplOutstandingAIOs += by; if (tplOutstandingAIOsHigh < tplOutstandingAIOs) tplOutstandingAIOsHigh = tplOutstandingAIOs; instChanged = true; } inline void dec_tplOutstandingAIOs (uint32_t by = 1) { - ::qpid::sys::Mutex::ScopedLock mutex(accessLock); + ::qpid::management::Mutex::ScopedLock mutex(accessLock); tplOutstandingAIOs -= by; if (tplOutstandingAIOsLow > tplOutstandingAIOs) tplOutstandingAIOsLow = tplOutstandingAIOs;