diff options
Diffstat (limited to 'CIAO/ciao/FTComponentServer/AppMonitor/AppSideMonitor_Thread.h')
-rw-r--r-- | CIAO/ciao/FTComponentServer/AppMonitor/AppSideMonitor_Thread.h | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/CIAO/ciao/FTComponentServer/AppMonitor/AppSideMonitor_Thread.h b/CIAO/ciao/FTComponentServer/AppMonitor/AppSideMonitor_Thread.h new file mode 100644 index 00000000000..8b03230e61f --- /dev/null +++ b/CIAO/ciao/FTComponentServer/AppMonitor/AppSideMonitor_Thread.h @@ -0,0 +1,45 @@ +/** + * @file C++ Interface: AppSideMonitor_Thread + * + * @brief Declares interface for AppSideMonitor_Thread. + * + */ + +#ifndef __APPSIDEMONITOR_THREAD_H_ +#define __APPSIDEMONITOR_THREAD_H_ + +#include "ace/Task.h" +#include "ace/SOCK_Acceptor.h" +#include "ace/Reactor.h" +#include "ace/Barrier.h" +#include "ace/Acceptor.h" + +#include "AppSideMonitor_Handler.h" + +/** + * @class AppSideMonitor_Thread + * + * @brief Encapsulates AppSideMonitor_Thread + */ + +class AppSideMonitor_Thread : public ACE_Task_Base +{ +public: + + AppSideMonitor_Thread (ACE_Barrier *thread_barrier, + u_short port); + + void stop (); + virtual int svc (void); + +private: + u_short port_; + ACE_SOCK_Acceptor::PEER_ADDR serv_addr_; + ACE_Reactor reactor_; + ACE_Acceptor <AppSideMonitor_Handler, ACE_SOCK_Acceptor> acceptor_; + ACE_Barrier *synchronizer_; +}; + + + +#endif /// __APPSIDEMONITOR_THREAD_H_ |