diff options
author | XTZGZoReX <none@none> | 2010-04-05 13:08:47 +0200 |
---|---|---|
committer | XTZGZoReX <none@none> | 2010-04-05 13:08:47 +0200 |
commit | 7c277c87d8dffe89deee84592e337974fe0ef96e (patch) | |
tree | 4a7f53267c567f4f6377305d31b8b76d0f940fd6 /src/shared/DelayExecutor.h | |
parent | a795a1110c6b62df841b8a48d8e634ede255c486 (diff) |
* Only call Database::ThreadStart()/ThreadEnd() once per thread.
* Some cleanups in MapUpdater/DelayExecutor.
--HG--
branch : trunk
Diffstat (limited to 'src/shared/DelayExecutor.h')
-rw-r--r-- | src/shared/DelayExecutor.h | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/shared/DelayExecutor.h b/src/shared/DelayExecutor.h index 7a160d5ec92..664d8ca78a2 100644 --- a/src/shared/DelayExecutor.h +++ b/src/shared/DelayExecutor.h @@ -1,5 +1,5 @@ #ifndef _M_DELAY_EXECUTOR_H -#define _M_DELAY_EXECUTOR_H +#define _M_DELAY_EXECUTOR_H #include <ace/Task.h> #include <ace/Activation_Queue.h> @@ -8,6 +8,7 @@ class DelayExecutor : protected ACE_Task_Base { public: + DelayExecutor(); virtual ~DelayExecutor(); @@ -15,19 +16,22 @@ class DelayExecutor : protected ACE_Task_Base int execute(ACE_Method_Request* new_req); - int activate(int num_threads = 1, ACE_Method_Request* pre_svc_hook = 0, ACE_Method_Request* post_svc_hook = 0); + int activate(int num_threads = 1, ACE_Method_Request* pre_svc_hook = NULL, ACE_Method_Request* post_svc_hook = NULL); int deactivate(); bool activated(); - virtual int svc(void); + virtual int svc(); + private: + ACE_Activation_Queue queue_; ACE_Method_Request* pre_svc_hook_; ACE_Method_Request* post_svc_hook_; + bool activated_; void activated(bool s); - bool activated_; }; + #endif // _M_DELAY_EXECUTOR_H |