[rhmessaging-commits] rhmessaging commits: r2077 - store/trunk/cpp/lib/gen/qpid/management.

Author: tedross Date: 2008-05-22 11:53:50 -0400 (Thu, 22 May 2008) New Revision: 2077 Modified: store/trunk/cpp/lib/gen/qpid/management/Journal.cpp store/trunk/cpp/lib/gen/qpid/management/Journal.h store/trunk/cpp/lib/gen/qpid/management/Store.cpp store/trunk/cpp/lib/gen/qpid/management/Store.h Log: Regenerated management files Modified: store/trunk/cpp/lib/gen/qpid/management/Journal.cpp =================================================================== --- store/trunk/cpp/lib/gen/qpid/management/Journal.cpp 2008-05-21 15:55:53 UTC (rev 2076) +++ store/trunk/cpp/lib/gen/qpid/management/Journal.cpp 2008-05-22 15:53:50 UTC (rev 2077) @@ -377,7 +377,7 @@ void Journal::writeConfig (Buffer& buf) { - sys::RWlock::ScopedRlock readLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); configChanged = false; writeTimestamps (buf); @@ -393,7 +393,7 @@ void Journal::writeInstrumentation (Buffer& buf, bool skipHeaders) { - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); instChanged = false; if (!skipHeaders) Modified: store/trunk/cpp/lib/gen/qpid/management/Journal.h =================================================================== --- store/trunk/cpp/lib/gen/qpid/management/Journal.h 2008-05-21 15:55:53 UTC (rev 2076) +++ store/trunk/cpp/lib/gen/qpid/management/Journal.h 2008-05-22 15:53:50 UTC (rev 2077) @@ -105,71 +105,69 @@ // Accessor Methods inline void set_name (std::string val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); name = val; configChanged = true; } inline void set_journalDirectory (std::string val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalDirectory = val; configChanged = true; } inline void set_journalBaseFileName (std::string val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalBaseFileName = val; configChanged = true; } inline void set_journalWritePageSize (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalWritePageSize = val; configChanged = true; } inline void set_journalWritePages (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalWritePages = val; configChanged = true; } inline void set_journalReadPageSize (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalReadPageSize = val; configChanged = true; } inline void set_journalReadPages (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalReadPages = val; configChanged = true; } inline void set_initialFileCount (uint16_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); initialFileCount = val; instChanged = true; } inline void set_dataFileSize (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); dataFileSize = val; instChanged = true; } inline void set_journalCurrentFileCount (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalCurrentFileCount = val; instChanged = true; } inline void inc_journalRecordDepth (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalRecordDepth += by; if (journalRecordDepthHigh < journalRecordDepth) journalRecordDepthHigh = journalRecordDepth; instChanged = true; } inline void dec_journalRecordDepth (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalRecordDepth -= by; if (journalRecordDepthLow > journalRecordDepth) journalRecordDepthLow = journalRecordDepth; instChanged = true; } inline void set_journalRecordDepth (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalRecordDepth = val; if (journalRecordDepthLow > val) journalRecordDepthLow = val; @@ -178,51 +176,45 @@ instChanged = true; } inline void inc_journalRecordEnqueues (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalRecordEnqueues += by; instChanged = true; } inline void dec_journalRecordEnqueues (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalRecordEnqueues -= by; instChanged = true; } inline void set_journalRecordEnqueues (uint64_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalRecordEnqueues = val; instChanged = true; } inline void inc_journalRecordDequeues (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalRecordDequeues += by; instChanged = true; } inline void dec_journalRecordDequeues (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalRecordDequeues -= by; instChanged = true; } inline void set_journalRecordDequeues (uint64_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalRecordDequeues = val; instChanged = true; } inline void inc_journalOutstandingAIOs (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalOutstandingAIOs += by; if (journalOutstandingAIOsHigh < journalOutstandingAIOs) journalOutstandingAIOsHigh = journalOutstandingAIOs; instChanged = true; } inline void dec_journalOutstandingAIOs (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalOutstandingAIOs -= by; if (journalOutstandingAIOsLow > journalOutstandingAIOs) journalOutstandingAIOsLow = journalOutstandingAIOs; instChanged = true; } inline void set_journalOutstandingAIOs (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalOutstandingAIOs = val; if (journalOutstandingAIOsLow > val) journalOutstandingAIOsLow = val; @@ -231,21 +223,19 @@ instChanged = true; } inline void inc_journalFreeFileCount (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalFreeFileCount += by; if (journalFreeFileCountHigh < journalFreeFileCount) journalFreeFileCountHigh = journalFreeFileCount; instChanged = true; } inline void dec_journalFreeFileCount (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalFreeFileCount -= by; if (journalFreeFileCountLow > journalFreeFileCount) journalFreeFileCountLow = journalFreeFileCount; instChanged = true; } inline void set_journalFreeFileCount (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalFreeFileCount = val; if (journalFreeFileCountLow > val) journalFreeFileCountLow = val; @@ -254,21 +244,19 @@ instChanged = true; } inline void inc_journalAvailableFileCount (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalAvailableFileCount += by; if (journalAvailableFileCountHigh < journalAvailableFileCount) journalAvailableFileCountHigh = journalAvailableFileCount; instChanged = true; } inline void dec_journalAvailableFileCount (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalAvailableFileCount -= by; if (journalAvailableFileCountLow > journalAvailableFileCount) journalAvailableFileCountLow = journalAvailableFileCount; instChanged = true; } inline void set_journalAvailableFileCount (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalAvailableFileCount = val; if (journalAvailableFileCountLow > val) journalAvailableFileCountLow = val; @@ -277,81 +265,71 @@ instChanged = true; } inline void inc_journalWriteWaitFailures (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalWriteWaitFailures += by; instChanged = true; } inline void dec_journalWriteWaitFailures (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalWriteWaitFailures -= by; instChanged = true; } inline void set_journalWriteWaitFailures (uint64_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalWriteWaitFailures = val; instChanged = true; } inline void inc_journalWriteBusyFailures (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalWriteBusyFailures += by; instChanged = true; } inline void dec_journalWriteBusyFailures (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalWriteBusyFailures -= by; instChanged = true; } inline void set_journalWriteBusyFailures (uint64_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalWriteBusyFailures = val; instChanged = true; } inline void inc_journalReadRecordCount (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalReadRecordCount += by; instChanged = true; } inline void dec_journalReadRecordCount (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalReadRecordCount -= by; instChanged = true; } inline void set_journalReadRecordCount (uint64_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalReadRecordCount = val; instChanged = true; } inline void inc_journalReadBusyFailures (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalReadBusyFailures += by; instChanged = true; } inline void dec_journalReadBusyFailures (uint64_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalReadBusyFailures -= by; instChanged = true; } inline void set_journalReadBusyFailures (uint64_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalReadBusyFailures = val; instChanged = true; } inline void inc_journalWritePageCacheDepth (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalWritePageCacheDepth += by; if (journalWritePageCacheDepthHigh < journalWritePageCacheDepth) journalWritePageCacheDepthHigh = journalWritePageCacheDepth; instChanged = true; } inline void dec_journalWritePageCacheDepth (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalWritePageCacheDepth -= by; if (journalWritePageCacheDepthLow > journalWritePageCacheDepth) journalWritePageCacheDepthLow = journalWritePageCacheDepth; instChanged = true; } inline void set_journalWritePageCacheDepth (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalWritePageCacheDepth = val; if (journalWritePageCacheDepthLow > val) journalWritePageCacheDepthLow = val; @@ -360,21 +338,19 @@ instChanged = true; } inline void inc_journalReadPageCacheDepth (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalReadPageCacheDepth += by; if (journalReadPageCacheDepthHigh < journalReadPageCacheDepth) journalReadPageCacheDepthHigh = journalReadPageCacheDepth; instChanged = true; } inline void dec_journalReadPageCacheDepth (uint32_t by = 1){ - sys::RWlock::ScopedWlock writeLock (accessLock); journalReadPageCacheDepth -= by; if (journalReadPageCacheDepthLow > journalReadPageCacheDepth) journalReadPageCacheDepthLow = journalReadPageCacheDepth; instChanged = true; } inline void set_journalReadPageCacheDepth (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); journalReadPageCacheDepth = val; if (journalReadPageCacheDepthLow > val) journalReadPageCacheDepthLow = val; Modified: store/trunk/cpp/lib/gen/qpid/management/Store.cpp =================================================================== --- store/trunk/cpp/lib/gen/qpid/management/Store.cpp 2008-05-21 15:55:53 UTC (rev 2076) +++ store/trunk/cpp/lib/gen/qpid/management/Store.cpp 2008-05-22 15:53:50 UTC (rev 2077) @@ -129,7 +129,7 @@ void Store::writeConfig (Buffer& buf) { - sys::RWlock::ScopedRlock readLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); configChanged = false; writeTimestamps (buf); @@ -143,7 +143,7 @@ void Store::writeInstrumentation (Buffer& buf, bool skipHeaders) { - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); instChanged = false; if (!skipHeaders) Modified: store/trunk/cpp/lib/gen/qpid/management/Store.h =================================================================== --- store/trunk/cpp/lib/gen/qpid/management/Store.h 2008-05-21 15:55:53 UTC (rev 2076) +++ store/trunk/cpp/lib/gen/qpid/management/Store.h 2008-05-22 15:53:50 UTC (rev 2077) @@ -77,27 +77,27 @@ // Accessor Methods inline void set_brokerRef (uint64_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); brokerRef = val; configChanged = true; } inline void set_location (std::string val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); location = val; configChanged = true; } inline void set_async (uint8_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); async = val; configChanged = true; } inline void set_defaultInitialFileCount (uint16_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); defaultInitialFileCount = val; configChanged = true; } inline void set_defaultDataFileSize (uint32_t val){ - sys::RWlock::ScopedWlock writeLock (accessLock); + sys::Mutex::ScopedLock mutex(accessLock); defaultDataFileSize = val; configChanged = true; }