|
version 1.29, 2002/06/04 21:34:15
|
version 1.30, 2002/06/07 00:03:34
|
|
|
|
| //%///////////////////////////////////////////////////////////////////////////// |
//%///////////-*-c++-*-///////////////////////////////////////////////////////// |
| // | // |
| // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM, | // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM, |
| // The Open Group, Tivoli Systems | // The Open Group, Tivoli Systems |
|
|
|
| | |
| | |
| ModuleController(const char *name); | ModuleController(const char *name); |
| ModuleController(const char *name, |
/* ModuleController(const char *name, */ |
| 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 & destroy_thread, */ |
| struct timeval & deadlock); |
/* struct timeval & deadlock); */ |
| | |
| | |
| ~ModuleController(void); | ~ModuleController(void); |
|
|
|
| virtual void _handle_async_request(AsyncRequest *rq); | virtual void _handle_async_request(AsyncRequest *rq); |
| virtual void _handle_async_callback(AsyncOpNode *op); | virtual void _handle_async_callback(AsyncOpNode *op); |
| | |
| |
|
| |
|
| |
|
| private: | private: |
| static void _async_handleEnqueue(AsyncOpNode *h, MessageQueue *q, void *parm); | static void _async_handleEnqueue(AsyncOpNode *h, MessageQueue *q, void *parm); |
| DQueue<pegasus_module> _modules; | DQueue<pegasus_module> _modules; |
| ThreadPool _thread_pool; |
|
| pegasus_module _internal_module; | pegasus_module _internal_module; |
| AsyncReply *_send_wait(Uint32, AsyncRequest *); | AsyncReply *_send_wait(Uint32, AsyncRequest *); |
| AsyncReply *_send_wait(Uint32, const String &, AsyncRequest *); | AsyncReply *_send_wait(Uint32, const String &, AsyncRequest *); |
Return to
ModuleController.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common