summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormday <mday>2003-10-29 22:09:18 +0000
committermday <mday>2003-10-29 22:09:18 +0000
commitada9df3f831c1d98935bfd2466bba7c8faa72d5d (patch)
tree10fde5fec8076912ff91557dbd279bc56f45b0f5
parent3e67ef1809f73447838493e038fbd9984f7fab37 (diff)
downloadtog-pegasus-tuning.zip
tog-pegasus-tuning.tar.gz
tog-pegasus-tuning.tar.xz
tuning branchtuning
-rw-r--r--src/Pegasus/Common/MessageQueueService.cpp5
-rw-r--r--src/Pegasus/Common/MessageQueueService.h3
2 files changed, 5 insertions, 3 deletions
diff --git a/src/Pegasus/Common/MessageQueueService.cpp b/src/Pegasus/Common/MessageQueueService.cpp
index 40e0b82..806a8ba 100644
--- a/src/Pegasus/Common/MessageQueueService.cpp
+++ b/src/Pegasus/Common/MessageQueueService.cpp
@@ -178,7 +178,8 @@ AtomicInt MessageQueueService::_check_idle_flag(0);
MessageQueueService::MessageQueueService(const char *name,
Uint32 queueID,
Uint32 capabilities,
- Uint32 mask)
+ Uint32 mask,
+ int threads)
: Base(name, true, queueID),
_mask(mask),
@@ -208,7 +209,7 @@ MessageQueueService::MessageQueueService(const char *name,
_meta_dispatcher_mutex.unlock();
throw NullPointer();
}
- _thread_pool = new ThreadPool(0, "MessageQueueService", 0, 0,
+ _thread_pool = new ThreadPool(0, "MessageQueueService", 0, threads,
create_time, destroy_time, deadlock_time);
_polling_thread = new Thread(polling_routine,
diff --git a/src/Pegasus/Common/MessageQueueService.h b/src/Pegasus/Common/MessageQueueService.h
index 973c830..23d913c 100644
--- a/src/Pegasus/Common/MessageQueueService.h
+++ b/src/Pegasus/Common/MessageQueueService.h
@@ -61,7 +61,8 @@ class PEGASUS_COMMON_LINKAGE MessageQueueService : public MessageQueue
message_mask::type_service |
message_mask::ha_request |
message_mask::ha_reply |
- message_mask::ha_async ) ;
+ message_mask::ha_async,
+ int threads=0) ;
virtual ~MessageQueueService(void);