aboutsummaryrefslogtreecommitdiff
path: root/src/shared/DelayExecutor.h
diff options
context:
space:
mode:
authorXTZGZoReX <none@none>2010-04-05 13:08:47 +0200
committerXTZGZoReX <none@none>2010-04-05 13:08:47 +0200
commit7c277c87d8dffe89deee84592e337974fe0ef96e (patch)
tree4a7f53267c567f4f6377305d31b8b76d0f940fd6 /src/shared/DelayExecutor.h
parenta795a1110c6b62df841b8a48d8e634ede255c486 (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.h12
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