rhmessaging commits: r4453 - store/trunk/cpp/lib/jrnl2.
by rhmessaging-commits＠lists.jboss.org
Author: kpvdr
Date: 2011-04-28 09:20:17 -0400 (Thu, 28 Apr 2011)
New Revision: 4453
Modified:
store/trunk/cpp/lib/jrnl2/JournalErrors.hpp
store/trunk/cpp/lib/jrnl2/RecordHeader.hpp
store/trunk/cpp/lib/jrnl2/ScopedLock.hpp
Log:
Whitespace/format changes in jrnl2 dir
Modified: store/trunk/cpp/lib/jrnl2/JournalErrors.hpp
===================================================================
--- store/trunk/cpp/lib/jrnl2/JournalErrors.hpp 2011-04-25 12:48:04 UTC (rev 4452)
+++ store/trunk/cpp/lib/jrnl2/JournalErrors.hpp 2011-04-28 13:20:17 UTC (rev 4453)
@@ -42,7 +42,7 @@
class JournalErrors
{
- static std::map<uint32_t, const char*> _s_errorMap; ///< Map of error messages
+ static std::map<uint32_t, const char*> _s_errorMap; ///< Map of error messages
static std::map<uint32_t, const char*>::iterator _s_errorMapIterator; ///< Iterator
static bool _s_initializedFlag; ///< Dummy flag, used to initialize map.
static bool _s_initialize(); ///< Static fn for initializing static data
Modified: store/trunk/cpp/lib/jrnl2/RecordHeader.hpp
===================================================================
--- store/trunk/cpp/lib/jrnl2/RecordHeader.hpp 2011-04-25 12:48:04 UTC (rev 4452)
+++ store/trunk/cpp/lib/jrnl2/RecordHeader.hpp 2011-04-28 13:20:17 UTC (rev 4453)
@@ -156,14 +156,12 @@
/**
* \brief Destructor.
*/
- virtual inline ~RecordHeader()
- {}
+ virtual inline ~RecordHeader() {}
/**
* \brief Convenience copy method.
*/
- virtual inline void copy(const RecordHeader& rh)
- {
+ virtual inline void copy(const RecordHeader& rh) {
_magic = rh._magic;
_version = rh._version;
_bigEndianFlag = rh._bigEndianFlag;
@@ -174,8 +172,7 @@
/**
* \brief Resets all fields to default values (mostly 0).
*/
- virtual inline void reset()
- {
+ virtual inline void reset() {
_magic = 0;
_version = 0;
_bigEndianFlag = 0;
@@ -188,9 +185,7 @@
*
* \return true if the Overwrite Indicator flag is set, false otherwise.
*/
- inline bool getOverwriteIndicator() const {
- return _flags & HDR_OVERWRITE_INDICATOR_MASK;
- }
+ inline bool getOverwriteIndicator() const { return _flags & HDR_OVERWRITE_INDICATOR_MASK; }
/**
* \brief Set the value of the Overwrite Indicator for this record
@@ -207,9 +202,7 @@
*
* \return Size of record header in bytes.
*/
- static inline std::size_t getHeaderSize() {
- return sizeof(RecordHeader);
- }
+ static inline std::size_t getHeaderSize() { return sizeof(RecordHeader); }
/**
* \brief Return the body (data) size of this record in bytes. Must be implemented
@@ -337,8 +330,7 @@
/**
* \brief Destructor.
*/
- virtual inline ~RecordTail()
- {}
+ virtual inline ~RecordTail() {}
/**
* \brief Convenience copy method.
@@ -363,9 +355,7 @@
/**
* \brief Returns the size of the header in bytes.
*/
- inline static std::size_t getSize() {
- return sizeof(RecordTail);
- }
+ inline static std::size_t getSize() { return sizeof(RecordTail); }
}; // struct RecordTail
@@ -529,8 +519,7 @@
/**
* \brief Destructor.
*/
- virtual ~FileHeader()
- {}
+ virtual ~FileHeader() {}
/**
* \brief Convenience copy method.
@@ -573,36 +562,28 @@
*
* \return Size of record header in bytes.
*/
- static inline std::size_t getHeaderSize() {
- return sizeof(FileHeader);
- }
+ static inline std::size_t getHeaderSize() { return sizeof(FileHeader); }
/**
* \brief Return the body (data) size of this record in bytes.
*
* \return Size of record body in bytes. By definition, a FileHeader has no body.
*/
- inline std::size_t getBodySize() const {
- return 0;
- }
+ inline std::size_t getBodySize() const { return 0; }
/**
* \brief Return total size of this record in bytes, being in the case of the
* FileHeader the size of the header itself only.
*/
- inline std::size_t getRecordSize() const {
- return getHeaderSize();
- }
+ inline std::size_t getRecordSize() const { return getHeaderSize(); }
/**
* \brief Gets the current time from the system clock and sets the timestamp in the struct.
*/
- inline void setTimestamp()
- {
+ inline void setTimestamp() {
// TODO: Standardize on method for getting time that does not require a context switch.
timespec ts;
- if (::clock_gettime(CLOCK_REALTIME, &ts))
- {
+ if (::clock_gettime(CLOCK_REALTIME, &ts)) {
std::ostringstream oss;
oss << FORMAT_SYSERR(errno);
throw JournalException(JournalErrors::JERR_RTCLOCK, oss.str(), "FileHeader", "setTimestamp");
@@ -615,8 +596,7 @@
*
* \param ts Timestamp from which the file header time stamp is to be copied
*/
- inline void setTimestamp(const timespec& ts)
- {
+ inline void setTimestamp(const timespec& ts) {
_timestampSeconds = ts.tv_sec;
_timestampNanoSeconds = ts.tv_nsec;
}
@@ -795,18 +775,14 @@
*
* \return Size of record header in bytes.
*/
- static inline std::size_t getHeaderSize() {
- return sizeof(EventHeader);
- }
+ static inline std::size_t getHeaderSize() { return sizeof(EventHeader); }
/**
* \brief Return the body (data) size of this record in bytes.
*
* \return Size of record body in bytes.
*/
- virtual inline std::size_t getBodySize() const {
- return _xidSize + _dataSize;
- }
+ virtual inline std::size_t getBodySize() const { return _xidSize + _dataSize; }
/**
* \brief Return total size of this record in bytes, being in the case of the
@@ -917,9 +893,7 @@
*
* \return true if the Transient flag for this record is set, false otherwise.
*/
- inline bool getTransientFlag() const {
- return _flags & ENQ_HDR_TRANSIENT_MASK;
- }
+ inline bool getTransientFlag() const { return _flags & ENQ_HDR_TRANSIENT_MASK; }
/**
* \brief Set the value of the Transient flag for this record.
@@ -938,9 +912,7 @@
*
* \return true if the Transient flag for this record is set, false otherwise.
*/
- inline bool getExternalFlag() const {
- return _flags & ENQ_HDR_EXTERNAL_MASK;
- }
+ inline bool getExternalFlag() const { return _flags & ENQ_HDR_EXTERNAL_MASK; }
/**
* \brief Set the value of the External flag for this record.
@@ -958,9 +930,7 @@
*
* \return Size of record header in bytes.
*/
- static inline std::size_t getHeaderSize() {
- return sizeof(EnqueueHeader);
- }
+ static inline std::size_t getHeaderSize() { return sizeof(EnqueueHeader); }
}; // struct EnqueueHeader
@@ -1120,9 +1090,7 @@
* \return true if the tplCommitOnTxnComplFlag flag for this record is set, false
* otherwise.
*/
- inline bool getTplCommitOnTxnComplFlag() const {
- return _flags & DEQ_HDR_TPL_COMMIT_ON_TXN_COMPL_MASK;
- }
+ inline bool getTplCommitOnTxnComplFlag() const { return _flags & DEQ_HDR_TPL_COMMIT_ON_TXN_COMPL_MASK; }
/**
* \brief Set the value of the tplCommitOnTxnComplFlag for this record. This is
@@ -1142,18 +1110,14 @@
*
* \return Size of record header in bytes.
*/
- static std::size_t getHeaderSize() {
- return sizeof(DequeueHeader);
- }
+ static std::size_t getHeaderSize() { return sizeof(DequeueHeader); }
/**
* \brief Return the body (xid and data) size of this record in bytes.
*
* \return Size of record body in bytes.
*/
- std::size_t getBodySize() const {
- return _xidSize;
- }
+ std::size_t getBodySize() const { return _xidSize; }
/**
* \brief Return total size of this record in bytes, being in the case of the
@@ -1274,8 +1238,7 @@
/**
* \brief Destructor.
*/
- virtual ~TransactionHeader()
- {}
+ virtual ~TransactionHeader() {}
/**
* \brief Convenience copy method.
Modified: store/trunk/cpp/lib/jrnl2/ScopedLock.hpp
===================================================================
--- store/trunk/cpp/lib/jrnl2/ScopedLock.hpp 2011-04-25 12:48:04 UTC (rev 4452)
+++ store/trunk/cpp/lib/jrnl2/ScopedLock.hpp 2011-04-28 13:20:17 UTC (rev 4453)
@@ -7,7 +7,7 @@
*
* \author Kim van der Riet
*
- * Copyright (c) 2010 Red Hat, Inc.
+ * Copyright (c) 2010, 2011 Red Hat, Inc.
*
* This file is part of the Qpid async store library msgstore.so.
*
@@ -46,7 +46,7 @@
class ScopedMutex
{
protected:
- mutable pthread_mutex_t _m;
+ mutable ::pthread_mutex_t _m;
public:
inline ScopedMutex() {
PTHREAD_CHK(::pthread_mutex_init(&_m, 0), "::pthread_mutex_init", "ScopedMutex", "ScopedMutex");
@@ -54,7 +54,7 @@
inline ~ScopedMutex() {
PTHREAD_CHK(::pthread_mutex_destroy(&_m), "::pthread_mutex_destroy", "ScopedMutex", "~ScopedMutex");
}
- inline pthread_mutex_t* get() const { return &_m; }
+ inline ::pthread_mutex_t* get() const { return &_m; }
};
// Scoped-mutex (sm) container, superclass for scoped lock classes
@@ -65,7 +65,7 @@
public:
ScopedMutexContainer(const ScopedMutex& sm) : _sm(sm) {}
virtual ~ScopedMutexContainer() {}
- inline pthread_mutex_t* get() const { return _sm.get(); }
+ inline ::pthread_mutex_t* get() const { return _sm.get(); }
};
// Ultra-simple scoped lock class, auto-releases mutex when it goes out-of-scope
@@ -89,11 +89,13 @@
inline ScopedTryLock(const ScopedMutex& sm) : ScopedMutexContainer(sm), _lockedFlag(false) {
int ret = ::pthread_mutex_trylock(_sm.get());
_lockedFlag = (ret == 0); // check if lock obtained
- if (!_lockedFlag && ret != EBUSY) PTHREAD_CHK(ret, "::pthread_mutex_trylock", "ScopedTryLock", "ScopedTryLock");
+ if (!_lockedFlag && ret != EBUSY)
+ PTHREAD_CHK(ret, "::pthread_mutex_trylock", "ScopedTryLock", "ScopedTryLock");
}
virtual inline ~ScopedTryLock() {
if (_lockedFlag)
- PTHREAD_CHK(::pthread_mutex_unlock(_sm.get()), "::pthread_mutex_unlock", "ScopedTryLock", "~ScopedTryLock");
+ PTHREAD_CHK(::pthread_mutex_unlock(_sm.get()), "::pthread_mutex_unlock", "ScopedTryLock",
+ "~ScopedTryLock");
}
inline bool isLocked() const { return _lockedFlag; }
};
@@ -102,13 +104,15 @@
class ScopedConditionVariable
{
protected:
- mutable pthread_cond_t _cv;
+ mutable ::pthread_cond_t _cv;
public:
inline ScopedConditionVariable() {
- PTHREAD_CHK(::pthread_cond_init(&_cv, 0), "pthread_cond_init", "ScopedConditionVariable", "ScopedConditionVariable");
+ PTHREAD_CHK(::pthread_cond_init(&_cv, 0), "pthread_cond_init", "ScopedConditionVariable",
+ "ScopedConditionVariable");
}
inline ~ScopedConditionVariable() {
- PTHREAD_CHK(::pthread_cond_destroy(&_cv), "pthread_cond_destroy", "ScopedConditionVariable", "~ScopedConditionVariable");
+ PTHREAD_CHK(::pthread_cond_destroy(&_cv), "pthread_cond_destroy", "ScopedConditionVariable",
+ "~ScopedConditionVariable");
}
inline void wait(ScopedLock& sl) {
PTHREAD_CHK(::pthread_cond_wait(&_cv, sl.get()), "pthread_cond_wait", "ScopedConditionVariable", "wait");
@@ -117,7 +121,8 @@
PTHREAD_CHK(::pthread_cond_signal(&_cv), "pthread_cond_signal", "ScopedConditionVariable", "notify_one");
}
inline void notify_all() {
- PTHREAD_CHK(::pthread_cond_broadcast(&_cv), "pthread_cond_broadcast", "ScopedConditionVariable", "notify_all");
+ PTHREAD_CHK(::pthread_cond_broadcast(&_cv), "pthread_cond_broadcast", "ScopedConditionVariable",
+ "notify_all");
}
};
13 years, 8 months
Newsletter Mon, 25 Apr 2011 12:56:36 -0300
by rhmessaging-commits＠lists.jboss.org
Hello!
Do you want a pleasant future, increase in money, and the admiration of all?
Today only:
We can assist with Diplomas from prestigious universities based on your present knowledge and work experience.
Get a Degree in 4 weeks with our program!
~Our program will let EVERYONE with professional experience
gain a 100% verified Degree:
~Doctorate
~Bachelors
~Masters
- Just think about it...
- Follow YOUR Dreams!
- Live a much better life by earning or upgrading your degree.
This is a best chance to make a right move and receive your due
benefits... if you are qualified but are lacking that piece of paper. Get one from us in a fraction of the time.
Contact us 24 hours to start improving your life!
~CALL~
1-310-205-2502
You must leave us a message with your phone number with country code if outside USA and name and we will contact you asap.
It is your move...
Make the right move.
Best regards.
Do Not Reply to this Email.
We do not reply to text inquiries, and our server will reject all response traffic.
We apologize for any inconvenience this may have caused you.
13 years, 8 months
rhmessaging commits: r4452 - store/trunk/cpp/lib/jrnl2.
by rhmessaging-commits＠lists.jboss.org
Author: kpvdr
Date: 2011-04-25 08:48:04 -0400 (Mon, 25 Apr 2011)
New Revision: 4452
Modified:
store/trunk/cpp/lib/jrnl2/ScopedLock.hpp
Log:
Additions to jrnl2 simple locks collection
Modified: store/trunk/cpp/lib/jrnl2/ScopedLock.hpp
===================================================================
--- store/trunk/cpp/lib/jrnl2/ScopedLock.hpp 2011-04-12 14:55:07 UTC (rev 4451)
+++ store/trunk/cpp/lib/jrnl2/ScopedLock.hpp 2011-04-25 12:48:04 UTC (rev 4452)
@@ -48,13 +48,11 @@
protected:
mutable pthread_mutex_t _m;
public:
- inline ScopedMutex()
- {
- PTHREAD_CHK(::pthread_mutex_init(&_m, 0), "::pthread_mutex_init", "smutex", "smutex");
+ inline ScopedMutex() {
+ PTHREAD_CHK(::pthread_mutex_init(&_m, 0), "::pthread_mutex_init", "ScopedMutex", "ScopedMutex");
}
- inline ~ScopedMutex()
- {
- PTHREAD_CHK(::pthread_mutex_destroy(&_m), "::pthread_mutex_destroy", "smutex", "~smutex");
+ inline ~ScopedMutex() {
+ PTHREAD_CHK(::pthread_mutex_destroy(&_m), "::pthread_mutex_destroy", "ScopedMutex", "~ScopedMutex");
}
inline pthread_mutex_t* get() const { return &_m; }
};
@@ -67,20 +65,18 @@
public:
ScopedMutexContainer(const ScopedMutex& sm) : _sm(sm) {}
virtual ~ScopedMutexContainer() {}
- inline const ScopedMutex& get() const { return _sm; }
+ inline pthread_mutex_t* get() const { return _sm.get(); }
};
// Ultra-simple scoped lock class, auto-releases mutex when it goes out-of-scope
class ScopedLock : public ScopedMutexContainer
{
public:
- inline ScopedLock(const ScopedMutex& sm) : ScopedMutexContainer(sm)
- {
- PTHREAD_CHK(::pthread_mutex_lock(_sm.get()), "::pthread_mutex_lock", "slock", "slock");
+ inline ScopedLock(const ScopedMutex& sm) : ScopedMutexContainer(sm) {
+ PTHREAD_CHK(::pthread_mutex_lock(_sm.get()), "::pthread_mutex_lock", "ScopedLock", "ScopedLock");
}
- virtual inline ~ScopedLock()
- {
- PTHREAD_CHK(::pthread_mutex_unlock(_sm.get()), "::pthread_mutex_unlock", "slock", "~slock");
+ virtual inline ~ScopedLock() {
+ PTHREAD_CHK(::pthread_mutex_unlock(_sm.get()), "::pthread_mutex_unlock", "ScopedLock", "~ScopedLock");
}
};
@@ -90,20 +86,42 @@
protected:
bool _lockedFlag;
public:
- inline ScopedTryLock(const ScopedMutex& sm) : ScopedMutexContainer(sm), _lockedFlag(false)
- {
+ inline ScopedTryLock(const ScopedMutex& sm) : ScopedMutexContainer(sm), _lockedFlag(false) {
int ret = ::pthread_mutex_trylock(_sm.get());
_lockedFlag = (ret == 0); // check if lock obtained
- if (!_lockedFlag && ret != EBUSY) PTHREAD_CHK(ret, "::pthread_mutex_trylock", "stlock", "stlock");
+ if (!_lockedFlag && ret != EBUSY) PTHREAD_CHK(ret, "::pthread_mutex_trylock", "ScopedTryLock", "ScopedTryLock");
}
- virtual inline ~ScopedTryLock()
- {
+ virtual inline ~ScopedTryLock() {
if (_lockedFlag)
- PTHREAD_CHK(::pthread_mutex_unlock(_sm.get()), "::pthread_mutex_unlock", "stlock", "~stlock");
+ PTHREAD_CHK(::pthread_mutex_unlock(_sm.get()), "::pthread_mutex_unlock", "ScopedTryLock", "~ScopedTryLock");
}
inline bool isLocked() const { return _lockedFlag; }
};
+ // Ultra-simple scoped condition variable class
+ class ScopedConditionVariable
+ {
+ protected:
+ mutable pthread_cond_t _cv;
+ public:
+ inline ScopedConditionVariable() {
+ PTHREAD_CHK(::pthread_cond_init(&_cv, 0), "pthread_cond_init", "ScopedConditionVariable", "ScopedConditionVariable");
+ }
+ inline ~ScopedConditionVariable() {
+ PTHREAD_CHK(::pthread_cond_destroy(&_cv), "pthread_cond_destroy", "ScopedConditionVariable", "~ScopedConditionVariable");
+ }
+ inline void wait(ScopedLock& sl) {
+ PTHREAD_CHK(::pthread_cond_wait(&_cv, sl.get()), "pthread_cond_wait", "ScopedConditionVariable", "wait");
+ }
+ inline void notify_one() {
+ PTHREAD_CHK(::pthread_cond_signal(&_cv), "pthread_cond_signal", "ScopedConditionVariable", "notify_one");
+ }
+ inline void notify_all() {
+ PTHREAD_CHK(::pthread_cond_broadcast(&_cv), "pthread_cond_broadcast", "ScopedConditionVariable", "notify_all");
+ }
+ };
+
+
} // namespace journal2
} // namespace mrg
13 years, 8 months
rhmessaging commits: r4451 - store/trunk/cpp/tools.
by rhmessaging-commits＠lists.jboss.org
Author: kpvdr
Date: 2011-04-12 10:55:07 -0400 (Tue, 12 Apr 2011)
New Revision: 4451
Modified:
store/trunk/cpp/tools/janal.py
Log:
Fixed tools janal.py lib where the format of journal file names for empty files was incorrect (not hex).
Modified: store/trunk/cpp/tools/janal.py
===================================================================
--- store/trunk/cpp/tools/janal.py 2011-04-12 14:46:51 UTC (rev 4450)
+++ store/trunk/cpp/tools/janal.py 2011-04-12 14:55:07 UTC (rev 4451)
@@ -270,7 +270,7 @@
ostr += " %s %s: owi=%-5s rid=0x%x, fro=0x%x ts=%s\n" % (tmp, os.path.basename(tup[1]), tup[2],
tup[3], tup[4], tup[5])
for i in range(self.__flist[-1][0] + 1, self.__jinf.get_num_jrnl_files()):
- ostr += " %s.%04d.jdat: <empty>\n" % (self.__jinf.get_jrnl_base_name(), i)
+ ostr += " %s.%04x.jdat: <empty>\n" % (self.__jinf.get_jrnl_base_name(), i)
return ostr
# Analysis
13 years, 8 months
rhmessaging commits: r4450 - in store/trunk/cpp: lib and 1 other directory.
by rhmessaging-commits＠lists.jboss.org
Author: kpvdr
Date: 2011-04-12 10:46:51 -0400 (Tue, 12 Apr 2011)
New Revision: 4450
Modified:
store/trunk/cpp/configure.ac
store/trunk/cpp/lib/MessageStoreImpl.cpp
Log:
Updated store help to include the store file size and number limits. Fixed error text for when qpid lib headers are not found.
Modified: store/trunk/cpp/configure.ac
===================================================================
--- store/trunk/cpp/configure.ac 2011-03-30 16:03:06 UTC (rev 4449)
+++ store/trunk/cpp/configure.ac 2011-04-12 14:46:51 UTC (rev 4450)
@@ -117,7 +117,7 @@
fail=1
# Give any/all diagnostics before failing.
test $fail = 1 &&
- AC_MSG_ERROR([Missing required qpid libraries/headers. Install package qpidd-devel or use --with-qpid-checkout])
+ AC_MSG_ERROR([Missing required qpid libraries/headers. Install source rpms or use one of --with-qpid-checkout or --with-qpid-prefix])
QPID_CXXFLAGS="-I$QPID_INCLUDE"
QPID_LIBS="-L$QPID_LIB -lqpidbroker -lqpidcommon"
fi
Modified: store/trunk/cpp/lib/MessageStoreImpl.cpp
===================================================================
--- store/trunk/cpp/lib/MessageStoreImpl.cpp 2011-03-30 16:03:06 UTC (rev 4449)
+++ store/trunk/cpp/lib/MessageStoreImpl.cpp 2011-04-12 14:46:51 UTC (rev 4450)
@@ -1684,20 +1684,30 @@
tplJrnlFsizePgs(defTplJrnlFileSizePgs),
tplWCachePageSizeKib(defTplWCachePageSize)
{
+ std::ostringstream oss1;
+ oss1 << "Default number of files for each journal instance (queue). [Allowable values: " <<
+ JRNL_MIN_NUM_FILES << " - " << JRNL_MAX_NUM_FILES << "]";
+ std::ostringstream oss2;
+ oss2 << "Default size for each journal file in multiples of read pages (1 read page = 64kiB). [Allowable values: " <<
+ JRNL_MIN_FILE_SIZE / JRNL_RMGR_PAGE_SIZE << " - " << JRNL_MAX_FILE_SIZE / JRNL_RMGR_PAGE_SIZE << "]";
+ std::ostringstream oss3;
+ oss3 << "Number of files for transaction prepared list journal instance. [Allowable values: " <<
+ JRNL_MIN_NUM_FILES << " - " << JRNL_MAX_NUM_FILES << "]";
+ std::ostringstream oss4;
+ oss4 << "Size of each transaction prepared list journal file in multiples of read pages (1 read page = 64kiB) [Allowable values: " <<
+ JRNL_MIN_FILE_SIZE / JRNL_RMGR_PAGE_SIZE << " - " << JRNL_MAX_FILE_SIZE / JRNL_RMGR_PAGE_SIZE << "]";
addOptions()
("store-dir", qpid::optValue(storeDir, "DIR"),
"Store directory location for persistence (instead of using --data-dir value). "
"Required if --no-data-dir is also used.")
- ("num-jfiles", qpid::optValue(numJrnlFiles, "N"),
- "Default number of files for each journal instance (queue).")
+ ("num-jfiles", qpid::optValue(numJrnlFiles, "N"), oss1.str().c_str())
+ ("jfile-size-pgs", qpid::optValue(jrnlFsizePgs, "N"), oss2.str().c_str())
// TODO: Uncomment these lines when auto-expand is enabled.
// ("auto-expand", qpid::optValue(autoJrnlExpand, "yes|no"),
// "If yes|true|1, allows journal to auto-expand by adding additional journal files as needed. "
// "If no|false|0, the number of journal files will remain fixed (num-jfiles).")
// ("max-auto-expand-jfiles", qpid::optValue(autoJrnlExpandMaxFiles, "N"),
// "Maximum number of journal files allowed from auto-expanding; must be greater than --num-jfiles parameter.")
- ("jfile-size-pgs", qpid::optValue(jrnlFsizePgs, "N"),
- "Default size for each journal file in multiples of read pages (1 read page = 64kiB)")
("truncate", qpid::optValue(truncateFlag, "yes|no"),
"If yes|true|1, will truncate the store (discard any existing records). If no|false|0, will preserve "
"the existing store files for recovery.")
@@ -1705,10 +1715,8 @@
"Size of the pages in the write page cache in KiB. "
"Allowable values - powers of 2: 1, 2, 4, ... , 128. "
"Lower values decrease latency at the expense of throughput.")
- ("tpl-num-jfiles", qpid::optValue(tplNumJrnlFiles, "N"),
- "Number of files for transaction prepared list journal instance")
- ("tpl-jfile-size-pgs", qpid::optValue(tplJrnlFsizePgs, "N"),
- "Size of each transaction prepared list journal file in multiples of read pages (1 read page = 64kiB)")
+ ("tpl-num-jfiles", qpid::optValue(tplNumJrnlFiles, "N"), oss3.str().c_str())
+ ("tpl-jfile-size-pgs", qpid::optValue(tplJrnlFsizePgs, "N"), oss4.str().c_str())
("tpl-wcache-page-size", qpid::optValue(tplWCachePageSizeKib, "N"),
"Size of the pages in the transaction prepared list write page cache in KiB. "
"Allowable values - powers of 2: 1, 2, 4, ... , 128. "
13 years, 8 months
Newsletter Tue, 12 Apr 2011 11:12:28 -0300
by rhmessaging-commits＠lists.jboss.org
Hi there!
Do you want an extraordinary future, double in money earning, and the admiration of all?
Today only:
We can assist with Diplomas from prestigious universities based on your present knowledge and work experience.
Get a Degree in 6 weeks with our program!
~Our program will let EVERYONE with professional experience
gain a 100% verified Degree:
~Doctorate
~Bachelors
~Masters
- Just think about it...
- You can realize YOUR Dreams!
- Live a wonderful life by earning or upgrading your degree.
This is a nice way to make a right move and receive your due
benefits... if you are qualified but are lacking that piece of paper. Get one from us in a fraction of the time.
Call Today to start improving your life!
~CALL US~
1-310-205-2502
Please leave us a message with your phone number with country code if outside USA and name and we'll contact you asap.
It is your way...
Make the right decision.
Sincerely.
Do Not Reply to this Email.
We do not reply to text inquiries, and our server will reject all response traffic.
We apologize for any inconvenience this may have caused you.
13 years, 8 months