blob: 81cb9178934b636359ea11bc778c1010d880ed29 (
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
|
// -*- C++ -*-
// $Id$
/**
* @file C++ Implementation: Monitor_Thread
*
* @brief Defines implementation of Monitor_Thread.
*
*/
#include "Monitor_Thread.h"
#include "ace/TP_Reactor.h"
#include "tao/Exception.h"
Monitor_Thread::Monitor_Thread (void)
: reactor_ (new ACE_TP_Reactor())
{
}
int
Monitor_Thread::svc (void)
{
try
{
if (reactor_.run_reactor_event_loop() == -1)
{
ACE_ERROR_RETURN ((LM_ERROR,
"Monitor_Thread: "
"run_reactor_event_loop failed\n"),
-1);
}
}
catch (CORBA::Exception & ex)
{
ACE_DEBUG ((LM_ERROR,
"Monitor_Thread::svc - caught %s",
ex._info ().c_str ()));
return -1;
}
return 0;
}
/*
int Monitor_Thread::register_handler (ACE_Event_Handler *event_handler, ACE_Reactor_Mask mask)
{
return reactor_.register_handler (event_handler, mask);
}
*/
ACE_Reactor * Monitor_Thread::get_reactor (void)
{
return &reactor_;
}
|
