1 files changed, 165 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h b/TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h
new file mode 100644
index 00000000000..ed66e878f34
--- /dev/null
+++ b/TAO/orbsvcs/tests/AVStreams/Component_Switching/sender.h
@@ -0,0 +1,165 @@
+/* -*- 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 (void);
+
+  int init (int argc,
+            char **argv);
+  /// Method to initialize the various data components.
+
+  int pace_data (void);
+  /// 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.
+};
+
+
+
+
+