version 1.48, 2006/07/25 19:11:15
|
version 1.48.2.2, 2006/07/28 23:52:11
|
|
|
#include <Pegasus/Common/Constants.h> | #include <Pegasus/Common/Constants.h> |
#include <Pegasus/Common/Message.h> | #include <Pegasus/Common/Message.h> |
#include <Pegasus/Common/InternalException.h> | #include <Pegasus/Common/InternalException.h> |
#include <Pegasus/Common/IPC.h> |
|
#include <Pegasus/Common/Thread.h> | #include <Pegasus/Common/Thread.h> |
#include <Pegasus/Common/AsyncOpNode.h> | #include <Pegasus/Common/AsyncOpNode.h> |
#include <Pegasus/Common/Cimom.h> | #include <Pegasus/Common/Cimom.h> |
|
|
| |
void lock() | void lock() |
{ | { |
_thread_safety.lock(pegasus_thread_self()); |
_thread_safety.lock(); |
} | } |
| |
void unlock() | void unlock() |
|
|
/* Sint16 min_threads, */ | /* Sint16 min_threads, */ |
/* Sint16 max_threads, */ | /* Sint16 max_threads, */ |
/* struct timeval & create_thread, */ | /* struct timeval & create_thread, */ |
/* struct timeval & destroy_thread); */ |
/* struct timeval & Threads::cancel); */ |
| |
~ModuleController(); | ~ModuleController(); |
| |
|
|
class _module_lock | class _module_lock |
{ | { |
public: | public: |
_module_lock(List<pegasus_module, RecursiveMutex> * list) |
_module_lock(List<pegasus_module, Mutex> * list) |
:_list(list) | :_list(list) |
{ | { |
_list->lock(); | _list->lock(); |
|
|
| |
private: | private: |
_module_lock(); | _module_lock(); |
List<pegasus_module, RecursiveMutex> * _list; |
List<pegasus_module, Mutex> * _list; |
}; | }; |
| |
| |
| |
static void _async_handleEnqueue(AsyncOpNode *h, MessageQueue *q, void *parm); | static void _async_handleEnqueue(AsyncOpNode *h, MessageQueue *q, void *parm); |
List<pegasus_module, RecursiveMutex> _modules; |
List<pegasus_module, Mutex> _modules; |
AsyncReply *_send_wait(Uint32, AsyncRequest *); | AsyncReply *_send_wait(Uint32, AsyncRequest *); |
AsyncReply *_send_wait(Uint32, const String &, AsyncRequest *); | AsyncReply *_send_wait(Uint32, const String &, AsyncRequest *); |
| |