blob: 55af2c1d478ba2b810cfe34c47fa626c6a22c8c7 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
#include "Deployment_Scheduler.h"
#include "dance/Logger/Log_Macros.h"
#if !defined (__ACE_INLINE__)
#include "dance/LocalityManager/Scheduler/Deployment_Scheduler.inl"
#endif
namespace DAnCE
{
Deployment_Scheduler::Deployment_Scheduler (void)
: multithread_ (false)
{
}
Deployment_Scheduler::~Deployment_Scheduler (void)
{
}
int
Deployment_Scheduler::schedule_event (Deployment_Event *event)
{
int const retval = this->event_queue_.enqueue (event);
if (retval == -1)
{
DANCE_ERROR (DANCE_LOG_ERROR,
(LM_ERROR, DLINFO
ACE_TEXT ("Deployment_Scheduler::schedule_event - ")
ACE_TEXT ("Error: Unable to schedule event for execution\n")));
}
return retval;
}
void
Deployment_Scheduler::terminate_scheduler (void)
{
this->event_queue_.queue ()->close ();
}
int
Deployment_Scheduler::svc (void)
{
for ( ; ; )
{
auto_ptr < ACE_Method_Request > de (this->event_queue_.dequeue ());
if (de.get ())
{
DANCE_DEBUG (DANCE_LOG_DETAILED_TRACE,
(LM_TRACE, DLINFO
ACE_TEXT ("Deployment_Scheduler::svc - ")
ACE_TEXT ("Invoking a deployment event\n")));
de->call ();
}
else
{
break;
}
}
return 0;
}
void Deployment_Scheduler::perform_work (void)
{
auto_ptr < ACE_Method_Request > de (this->event_queue_.dequeue ());
if (de.get ())
{
DANCE_DEBUG (DANCE_LOG_DETAILED_TRACE,
(LM_TRACE, DLINFO
ACE_TEXT ("Deployment_Scheduler::perform_work - ")
ACE_TEXT ("Invoking a deployment event\n")));
de->call ();
}
}
}
|