summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h')
-rw-r--r--TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h166
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.
-};
-
-
-
-
-