|
version 1.1, 2005/02/21 17:54:30
|
version 1.2, 2005/03/10 00:38:20
|
|
|
|
| //thread pool settings | //thread pool settings |
| static struct timeval create_time = {0, 1}; | static struct timeval create_time = {0, 1}; |
| static struct timeval destroy_time = {15, 0}; | static struct timeval destroy_time = {15, 0}; |
| static struct timeval deadlock_time = {0, 0}; |
|
| | |
| //retry settings | //retry settings |
| //ATTN: Do we want to make these configurable? If so, is a global setting for all the consumers ok? | //ATTN: Do we want to make these configurable? If so, is a global setting for all the consumers ok? |
|
|
|
| _optionMgr.registerOptions(optionsTable, NUM_OPTIONS); | _optionMgr.registerOptions(optionsTable, NUM_OPTIONS); |
| | |
| _thread_pool = new ThreadPool(0, "ConsumerManager", 0, 0, | _thread_pool = new ThreadPool(0, "ConsumerManager", 0, 0, |
| create_time, destroy_time, deadlock_time); |
create_time, destroy_time); |
| | |
| _init(); | _init(); |
| | |
Return to
ConsumerManager.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / DynListener