version 1.81, 2003/10/17 18:08:01
|
version 1.82.6.1, 2003/10/29 22:09:18
|
|
|
//%////-*-c++-*-//////////////////////////////////////////////////////////////// |
//%2003//////////////////////////////////////////////////////////////////////// |
// | // |
// Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM, |
// Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Development |
// The Open Group, Tivoli Systems |
// Company, L. P., IBM Corp., The Open Group, Tivoli Systems. |
|
// Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.; |
|
// IBM Corp.; EMC Corporation, The Open Group. |
// | // |
// Permission is hereby granted, free of charge, to any person obtaining a copy | // Permission is hereby granted, free of charge, to any person obtaining a copy |
// of this software and associated documentation files (the "Software"), to | // of this software and associated documentation files (the "Software"), to |
|
|
MessageQueueService::MessageQueueService(const char *name, | MessageQueueService::MessageQueueService(const char *name, |
Uint32 queueID, | Uint32 queueID, |
Uint32 capabilities, | Uint32 capabilities, |
Uint32 mask) |
Uint32 mask, |
|
int threads) |
: Base(name, true, queueID), | : Base(name, true, queueID), |
| |
_mask(mask), | _mask(mask), |
|
|
_meta_dispatcher_mutex.unlock(); | _meta_dispatcher_mutex.unlock(); |
throw NullPointer(); | throw NullPointer(); |
} | } |
_thread_pool = new ThreadPool(0, "MessageQueueService", 0, 0, |
_thread_pool = new ThreadPool(0, "MessageQueueService", 0, threads, |
create_time, destroy_time, deadlock_time); | create_time, destroy_time, deadlock_time); |
| |
_polling_thread = new Thread(polling_routine, | _polling_thread = new Thread(polling_routine, |