|
version 1.13, 2002/03/29 17:36:41
|
version 1.14, 2002/04/01 10:49:22
|
|
|
|
| #include <Pegasus/Common/Cimom.h> | #include <Pegasus/Common/Cimom.h> |
| #include <Pegasus/Common/CimomMessage.h> | #include <Pegasus/Common/CimomMessage.h> |
| #include <Pegasus/Common/MessageQueueService.h> | #include <Pegasus/Common/MessageQueueService.h> |
| |
#include <Pegasus/Common/peg_authorization.h> |
| | |
| #include <bitset> |
|
| | |
| PEGASUS_NAMESPACE_BEGIN | PEGASUS_NAMESPACE_BEGIN |
| | |
|
|
|
| public: | public: |
| typedef MessageQueueService Base; | typedef MessageQueueService Base; |
| | |
| enum |
static const Uint32 GET_CLIENT_HANDLE; |
| { |
static const Uint32 REGISTER_MODULE; |
| GET_CLIENT_HANDLE, |
static const Uint32 DEREGISTER_MODULE; |
| REGISTER_MODULE, |
static const Uint32 FIND_SERVICE; |
| DEREGISTER_MODULE, |
static const Uint32 FIND_MODULE_IN_SERVICE; |
| FIND_SERVICE, |
static const Uint32 GET_MODULE_REFERENCE; |
| FIND_MODULE_IN_SERVICE, |
static const Uint32 MODULE_SEND_WAIT; |
| GET_MODULE_REFERENCE, |
static const Uint32 MODULE_SEND_WAIT_MODULE; |
| MODULE_SEND_WAIT, |
static const Uint32 MODULE_SEND_ASYNC; |
| MODULE_SEND_WAIT_MODULE, |
static const Uint32 MODULE_SEND_ASYNC_MODULE; |
| MODULE_SEND_ASYNC, |
static const Uint32 BLOCKING_THREAD_EXEC; |
| MODULE_SEND_ASYNC_MODULE, |
static const Uint32 ASYNC_THREAD_EXEC; |
| BLOCKING_THREAD_EXEC, |
static const Uint32 CLIENT_SEND_WAIT; |
| ASYNC_THREAD_EXEC, |
static const Uint32 CLIENT_SEND_WAIT_MODULE; |
| NUMBER_OPERATIONS |
static const Uint32 CLIENT_SEND_ASYNC; |
| } ; |
static const Uint32 CLIENT_SEND_ASYNC_MODULE; |
| |
|
| private: | private: |
| class PEGASUS_COMMON_LINKAGE client_handle |
class PEGASUS_COMMON_LINKAGE client_handle : pegasus_authorization_handle |
| { | { |
| public: | public: |
| client_handle(void) |
typedef pegasus_authorization_handle Base; |
| : _allowed_operations(0), |
|
| _allowed_destinations(0), |
client_handle(pegasus_base_identity & id) |
| _allowed_sources(0), |
:Base(id) |
| _identity(NULL) |
|
| { | { |
| } | } |
| |
|
| ~client_handle(void); | ~client_handle(void); |
| |
virtual Boolean authorized(Uint32 operation); |
| |
virtual Boolean authorized(void); |
| | |
| private: | private: |
| friend class ModuleController; |
bitset<32> allowed_operations; |
| client_handle(Uint32 operations, |
|
| Uint32 destinations, |
|
| Uint32 sources, |
|
| void *identity) |
|
| : _allowed_operations(operations), |
|
| _allowed_destinations(destinations), |
|
| _allowed_sources(sources), |
|
| _identity(identity) |
|
| { |
|
| } |
|
| |
|
| bitset<NUMBER_OPERATIONS> _allowed_operations; |
|
| bitset<128> _allowed_destinations; |
|
| bitset<128> _allowed_sources; |
|
| void *_identity; |
|
| |
|
| Boolean allowed(Uint32 operation, |
|
| Uint32 destination, |
|
| Uint32 source, |
|
| void *identity) |
|
| { |
|
| return true; |
|
| } |
|
| }; | }; |
| | |
| public: | public: |
|
|
|
| void async_thread_exec(pegasus_module & handle, | void async_thread_exec(pegasus_module & handle, |
| PEGASUS_THREAD_RETURN (PEGASUS_THREAD_CDECL *thread_func)(void *), | PEGASUS_THREAD_RETURN (PEGASUS_THREAD_CDECL *thread_func)(void *), |
| void *parm) throw(Permission, Deadlock, IPCException); | void *parm) throw(Permission, Deadlock, IPCException); |
| |
|
| Boolean verify_handle(pegasus_module *); | Boolean verify_handle(pegasus_module *); |
| protected: | protected: |
| // ATTN-RK-P2-20010322: These methods are pure virtual in superclass | // ATTN-RK-P2-20010322: These methods are pure virtual in superclass |
Return to
ModuleController.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common