diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/mpeg/source/server/vs.h')
-rw-r--r-- | TAO/orbsvcs/tests/AVStreams/mpeg/source/server/vs.h | 212 |
1 files changed, 0 insertions, 212 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/vs.h b/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/vs.h deleted file mode 100644 index a25d479af65..00000000000 --- a/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/vs.h +++ /dev/null @@ -1,212 +0,0 @@ -/* -*- c++ -*- */ -/* $Id$ */ - -// ============================================================================ -// -// = LIBRARY -// server -// -// = FILENAME -// vs.h -// -// = DESCRIPTION -// @@ Please add a synopsis of this file. -// -// = AUTHORS -// Sumedh Mungee (sumedh@cs.wustl.edu) -// Nagarajan Surendran (naga@cs.wustl.edu) -// -// ============================================================================ - -#if !defined (TAO_AV_VS_H) -#define TAO_AV_VS_H - -#include "ace/Get_Opt.h" -#include "ace/Acceptor.h" -#include "ace/Svc_Handler.h" -#include "ace/SOCK_Acceptor.h" -#include "ace/INET_Addr.h" -#include "ace/SOCK_CODgram.h" -#include "ace/Select_Reactor.h" - -#include "include/common.h" -#include "mpeg_server/server_proto.h" -#include "mpeg_shared/fileio.h" -#include "mpeg_shared/routine.h" -#include "mpeg_shared/com.h" -#include "mpeg_server/Video_Control_i.h" -#include "orbsvcs/orbsvcs/Naming/Naming_Utils.h" - -#if defined (NATIVE_ATM) -#include "atmcom.h" -#endif /* NATIVE_ATM */ - -#include "mpeg_server/Video_Server.h" - -// Forward declaration. -class AV_Svc_Handler; - -// @@ We should probably try to replace the ACE_Acceptor with the -// ACE_Strategy_Acceptor using the ACE_Process_Strategy... -class AV_Acceptor - : public virtual ACE_Acceptor <AV_Svc_Handler, ACE_SOCK_ACCEPTOR> -{ - // = TITLE - // This defines a AV_Acceptor which is an Acceptor and - // overrides the make_svc_handler method of the Acceptor. - // - // = DESCRIPTION - // This class overrides the Acceptor's make_svc_handler so that a - // AV_Svc_Handler can be created with a non-default constructor. -public: - virtual int make_svc_handler (AV_Svc_Handler *&sh); - // Create a new <AV_Svc_Handler> passing 'this' to the service - // handler. -}; - -class AV_Svc_Handler - : public virtual ACE_Svc_Handler <ACE_SOCK_STREAM, ACE_NULL_SYNCH> -{ - // = TITLE - // This class defines the service handler for a new connection to - // the AV_Server. - // - // = DESCRIPTION - // This calls the handle_connection method for a new connection - // which demuxes the connection to a video or audio server - // depending on the connection request. -public: - // = Initialization method. - AV_Svc_Handler (ACE_Reactor * = 0, - AV_Acceptor * = 0); - - virtual int open (void *); - // Perform the work of the SVC_HANDLER. Called by the acceptor - // when a new connection shows up - - virtual int handle_connection (ACE_HANDLE = ACE_INVALID_HANDLE); - // Handle one client connection. - - virtual int svc (void); - // Thread method - - virtual int close (u_long); - // Called if ACE_Svc_Handler is closed down unexpectedly. - - int handle_timeout (const ACE_Time_Value &, - const void *arg); - // handle the timeout - -private: - - ACE_SOCK_CODgram dgram_; - // the UDP data socket - - ACE_INET_Addr server_data_addr_; - // Data (UDP) Address of this server. - - ACE_INET_Addr client_data_addr_; - // Data (UDP) Address of the client. - - AV_Acceptor *acceptor_; - // Pointer to the Acceptor that created us so that we can remove it - // from the <ACE_Reactor> when we <fork>. - - // @@ need a similar component for audio! - Video_Server *vs_; -}; - -class AV_Server_Sig_Handler - : public virtual ACE_Event_Handler -{ -public: - AV_Server_Sig_Handler (void); - - virtual ACE_HANDLE get_handle (void) const; - - int register_handler (void); - // this will register this sig_handler - // with the reactor for SIGCHLD,SIGTERM,SIGINT - - virtual int shutdown (ACE_HANDLE, - ACE_Reactor_Mask); - - virtual int handle_input (ACE_HANDLE); - // handle input on the dummy handle. - - virtual int handle_signal (ACE_HANDLE signum, - siginfo_t * = 0, - ucontext_t* = 0); - // handles the SIGCHLD,SIGTERM,SIGINT for the parent process i.e - // the main thread.. - - void int_handler (int sig); - // Signal handler function for SIGTERM,SIGBUS,SIGINT - - void clear_child (int sig); - // Signal handler function for SIGCHLD - - ~AV_Server_Sig_Handler (void); - // Destructor - -private: - ACE_HANDLE handle_; - // dummy handle for the sig handler. - ACE_Sig_Set sig_set; -}; - -class AV_Server -{ - // = TITLE - // Defines a class that abstracts the functionality of a - // video and audio server. - // - // = DESCRIPTION - // Using the class is as simple as calling init () first and then - // run. It uses an acceptor with the default ACE_Reactor::instance (). -public: - AV_Server (void); - // constructor - - int init (int argc, - char **argv, - CORBA::Environment& env); - // Initialize the AV_Server - - int run (CORBA::Environment& env); - // Run the AV_Server - - static void on_exit_routine (void); - // Routine called when this process exits. - - ~AV_Server (void); - // Destructor -private: - - // @@ Why are some of these data members pointers and others - // objects? Shouldn't we be consistent here? - - TAO_Naming_Server naming_server_; - // the TAO naming server - - TAO_ORB_Manager orb_manager_; - // the TAO ORB manager. - - Video_Control_i video_control_; - // The Video_Control implementation object. - - AV_Acceptor acceptor_; - // the acceptor - - AV_Server_Sig_Handler signal_handler_; - // Signal handler for SIGCHLD,SIGINT,SIGTERM,SIGBUS - - ACE_INET_Addr server_control_addr_; - // Control (TCP) Address of this server. - - int parse_args (int argcs, - char **argv); - // Parse the arguments. -}; - -#endif /* TAO_AV_VS_H */ |