[rhmessaging-commits] rhmessaging commits: r3903 - store/trunk/cpp/lib/gen/qmf/com/redhat/rhm/store.
rhmessaging-commits at lists.jboss.org
rhmessaging-commits at lists.jboss.org
Fri Apr 9 13:20:28 EDT 2010
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;
More information about the rhmessaging-commits
mailing list