diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h')
-rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h | 166 |
1 files changed, 0 insertions, 166 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h b/TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h deleted file mode 100644 index 6b5e8ef9e76..00000000000 --- a/TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h +++ /dev/null @@ -1,166 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// TAO/orbsvcs/tests/AVStreams/Component_Switching -// -// = FILENAME -// sender.h -// -// = DESCRIPTION -// This application reads data from a file and sends it to s -// receiver. -// -// = AUTHOR -// Yamuna Krishnamurthy <yamuna@cs.wustl.edu> -// -// ============================================================================ - -#include "Connection_Manager.h" -#include "orbsvcs/AV/AVStreams_i.h" -#include "orbsvcs/AV/Endpoint_Strategy.h" -#include "orbsvcs/AV/Protocol_Factory.h" - -class Signal_Handler : public ACE_Event_Handler -{ - // TITLE - // This class Handles the SIGINT signal through the Reactor. - // Useful to gracefully release the process - -public: - - Signal_Handler (void); - - int handle_signal(int signum, siginfo_t*,ucontext_t*); - // Override this method to implement graceful shutdown. - -}; - - -class Sender_Callback : public TAO_AV_Callback -{ - // = TITLE - // Defines a class for the sender application callback. - // - // = DESCRIPTION - // This class overides the methods of the TAO_AV_Callback so the - // AVStreams can make upcalls to the application. - -public: - - int handle_destroy (void); - /// Called when the sender has finished reading the file and wants - /// to close down the connection. Also called when the distributer - /// tears down the connection when it switches to a new sender. - - ACE_CString &flowname (void); - void flowname (const ACE_CString &flowname); - /// Accessor methods for the flowname of the callback - -private: - ACE_CString flowname_; - /// Flowname of the callback. -}; - -class Sender_StreamEndPoint : public TAO_Client_StreamEndPoint -{ - // = TITLE - // Defines a sender stream endpoint. -public: - int get_callback (const char *flowname, - TAO_AV_Callback *&callback); - /// Create the application callback and return its handle to - /// AVStreams for further application callbacks. - - int set_protocol_object (const char *flowname, - TAO_AV_Protocol_Object *object); - /// Set protocol object corresponding to the transport protocol - /// chosen. - - CORBA::Boolean handle_preconnect (AVStreams::flowSpec &flowspec); - /// Perform application specific actions before accepting new - /// connections. - -protected: - Sender_Callback callback_; - /// Application callback. -}; - -typedef TAO_AV_Endpoint_Reactive_Strategy_A - <Sender_StreamEndPoint, - TAO_VDev, - AV_Null_MediaCtrl> - SENDER_ENDPOINT_STRATEGY; - -class Sender -{ - /// = TITLE - // Sender Application. - // - // = DESCRIPTION - // Class is responsible for streaming (and pacing) data to a - // receiver. -public: - Sender (void); - /// Constructor - - ~Sender (void); - /// Destructor - - void shut_down (ACE_ENV_SINGLE_ARG_DECL_NOT_USED); - - int init (int argc, - char **argv - ACE_ENV_ARG_DECL_NOT_USED); - /// Method to initialize the various data components. - - int pace_data (ACE_ENV_SINGLE_ARG_DECL_NOT_USED); - /// Method to pace and send data from a file. - - Connection_Manager &connection_manager (void); - /// Accessor to the connection manager. - -private: - int parse_args (int argc, char **argv); - /// Method to parse the command line arguments. - - SENDER_ENDPOINT_STRATEGY endpoint_strategy_; - /// The endpoint strategy used by the sender. - - TAO_MMDevice *sender_mmdevice_; - /// The sender MMDevice. - - int frame_count_; - /// Number of frames sent. - - ACE_CString filename_; - /// File from which data is read. - - FILE *input_file_; - /// File handle of the file read from. - - double frame_rate_; - /// Rate at which the data will be sent. - - ACE_Message_Block mb_; - /// Message block into which data is read from a file and then sent. - - ACE_CString sender_name_; - /// Name of this sender. - - Connection_Manager connection_manager_; - /// Connection manager. - - // int stream_count_; - /// Teh count of the number of streams that are active - - Signal_Handler signal_handler_; - /// Reference to the signal handler. -}; - - - - - |