diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h | 49 |
1 files changed, 49 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h b/TAO/orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h new file mode 100644 index 00000000000..f18ae892b2d --- /dev/null +++ b/TAO/orbsvcs/orbsvcs/LWFT/AppSideMonitor_Thread.h @@ -0,0 +1,49 @@ +// -*- C++ -*- +// $Id$ + +/** + * @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); + + AppSideMonitor_Thread (ACE_Barrier &thread_barrier, + u_short port); + + void stop (void); + 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_ |