diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/mpeg/source/server/augmented_server.h')
| -rw-r--r-- | TAO/orbsvcs/tests/AVStreams/mpeg/source/server/augmented_server.h | 65 |
1 files changed, 35 insertions, 30 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/augmented_server.h b/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/augmented_server.h index c7823f966ed..7083b7cdedd 100644 --- a/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/augmented_server.h +++ b/TAO/orbsvcs/tests/AVStreams/mpeg/source/server/augmented_server.h @@ -5,7 +5,7 @@ // // = LIBRARY // server -// +// // = FILENAME // server.h // @@ -15,13 +15,18 @@ // = AUTHORS // Sumedh Mungee (sumedh@cs.wustl.edu) // Nagarajan Surendran (naga@cs.wustl.edu) -// +// // ============================================================================ -#if !defined (TAO_AV_SERVER_H) +#ifndef TAO_AV_SERVER_H #define TAO_AV_SERVER_H #include "ace/Get_Opt.h" + +#if !defined (ACE_LACKS_PRAGMA_ONCE) +# pragma once +#endif /* ACE_LACKS_PRAGMA_ONCE */ + #include "ace/Acceptor.h" #include "ace/Svc_Handler.h" #include "ace/SOCK_Acceptor.h" @@ -29,11 +34,11 @@ #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 "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" @@ -53,25 +58,25 @@ class AV_Audio_MMDevice : public TAO_MMDevice, - public TAO_Exportable + public TAO_Exportable { public: static const char* NUMBER_OF_CONNECTIONS; static const char* MAX_CONNECTIONS; static const char* SERVER_NAME; - + AV_Audio_MMDevice (TAO_AV_Endpoint_Process_Strategy *endpoint_strategy); // Default constructor virtual AVStreams::StreamEndPoint_B_ptr - create_B (AVStreams::StreamCtrl_ptr the_requester, - AVStreams::VDev_out the_vdev, - AVStreams::streamQoS &the_qos, - CORBA::Boolean_out met_qos, - char *&named_vdev, - const AVStreams::flowSpec &the_spec, - CORBA::Environment &env); + create_B (AVStreams::StreamCtrl_ptr the_requester, + AVStreams::VDev_out the_vdev, + AVStreams::streamQoS &the_qos, + CORBA::Boolean_out met_qos, + char *&named_vdev, + const AVStreams::flowSpec &the_spec, + CORBA::Environment &env); // Called by StreamCtrl to create a "B" type streamandpoint and vdev CORBA::ULong connections (void) const; @@ -84,7 +89,7 @@ public: CORBA::ULong offset = 0) const; private: - + CORBA::ULong connections_; // Number of active connections @@ -93,7 +98,7 @@ private: class AV_Server; -class AV_Server_Sig_Handler +class AV_Server_Sig_Handler : public virtual ACE_Event_Handler { public: @@ -105,7 +110,7 @@ public: // this will register this sig_handler // with the reactor for SIGCHLD,SIGTERM,SIGINT - virtual int shutdown (ACE_HANDLE, + virtual int shutdown (ACE_HANDLE, ACE_Reactor_Mask); virtual int handle_input (ACE_HANDLE); @@ -131,7 +136,7 @@ public: private: const AV_Server& av_server_; - + ACE_HANDLE handle_; // dummy handle for the sig handler. ACE_Sig_Set sig_set; @@ -140,7 +145,7 @@ private: class AV_Server { // = TITLE - // Defines a class that abstracts the functionality of a + // Defines a class that abstracts the functionality of a // video and audio server. // // = DESCRIPTION @@ -149,7 +154,7 @@ class AV_Server public: static const char* SERVICE_TYPE; - + AV_Server (void); // constructor @@ -162,10 +167,10 @@ public: // Run the AV_Server void shutdown (void) const; - + static void on_exit_routine (void); - // Routine called when this process exits. - + // Routine called when this process exits. + static pid_t current_pid_; // %% the pid the server is currently waiting on @@ -183,7 +188,7 @@ private: void export_properties (CORBA::Environment& _env); int resolve_trader (CORBA::Environment& _env); - + TAO_ORB_Manager orb_manager_; // the TAO ORB manager. @@ -193,16 +198,16 @@ private: TAO_Video_Repository video_rep_; // Dynamic property that assesses the contents of the sever's video // repository. - + CosTrading::Lookup_var trader_; // Reference to the Lookup interface of the trading service. - + CosTrading::OfferId_var offer_id_; // Server offer id. CosTradingRepos::ServiceTypeRepository::PropStructSeq prop_seq_; // Service type definition. - + CosNaming::NamingContext_var naming_context_; // The root naming context of the naming service |