TAO/orbsvcs/tests/AVStreams/Multiple_Flows/sender.h

   1 /* -*- C++ -*- */
   2
   3 //=============================================================================
   4 /**
   5  *  @file    sender.h
   6  *
   7  *  This application reads data from a file and sends it to s
   8  *  receiver.
   9  *
  10  *  @author Yamuna Krishnamurthy <yamuna@cs.wustl.edu>
  11  */
  12 //=============================================================================
  13
  14
  15 #include "orbsvcs/Naming/Naming_Client.h"
  16 #include "orbsvcs/AV/AVStreams_i.h"
  17 #include "orbsvcs/AV/Endpoint_Strategy.h"
  18 #include "orbsvcs/AV/Protocol_Factory.h"
  19
  20 typedef ACE_Unbounded_Set<TAO_AV_Protocol_Object*> ProtocolObject_Set;
  21 typedef ACE_Unbounded_Set_Iterator<TAO_AV_Protocol_Object*> ProtocolObject_SetItor;
  22
  23 /**
  24  * @class Sender_StreamEndPoint
  25  *
  26  * @brief Defines a sender stream endpoint.
  27  */
  28 class Sender_StreamEndPoint : public TAO_Client_StreamEndPoint
  29 {
  30 public:
  31   /// Create the application callback and return its handle to
  32   /// AVStreams for further application callbacks.
  33   int get_callback (const char *flowname,
  34                     TAO_AV_Callback *&callback);
  35
  36   /// Set protocol object corresponding to the transport protocol
  37   /// chosen.
  38   int set_protocol_object (const char *flowname,
  39                            TAO_AV_Protocol_Object *object);
  40
  41 protected:
  42   /// Application callback.
  43   TAO_AV_Callback callback_;
  44 };
  45
  46 typedef TAO_AV_Endpoint_Reactive_Strategy_A
  47           <Sender_StreamEndPoint,
  48            TAO_VDev,
  49            AV_Null_MediaCtrl>
  50         SENDER_ENDPOINT_STRATEGY;
  51
  52 /**
  53  * @class Sender
  54  *
  55  * @brief Sender Application.
  56  *
  57  * Class is responsible for streaming (and pacing) data to a
  58  * receiver.
  59  */
  60 class Sender
  61 {
  62 public:
  63   /// Constructor
  64   Sender ();
  65
  66   /// Method to initialize the various data components.
  67   int init (int argc,
  68             ACE_TCHAR *argv[]);
  69
  70   /// Method to pace and send data from a file.
  71   int pace_data ();
  72
  73   /// Set the protocol object corresponding to the transport protocol chosen.
  74   void protocol_object (TAO_AV_Protocol_Object *protocol_object);
  75
  76   void shutdown ();
  77
  78 private:
  79   /// Method to parse the command line arguments.
  80   int parse_args (int argc, ACE_TCHAR *argv[]);
  81
  82   /// Method that binds the sender to the receiver.
  83   int bind_to_receiver ();
  84
  85   /// The endpoint strategy used by the sender.
  86   SENDER_ENDPOINT_STRATEGY endpoint_strategy_;
  87
  88   /// The receiver MMDevice that the sender connects to.
  89   AVStreams::MMDevice_var receiver_mmdevice_;
  90
  91   /// The sender MMDevice.
  92   TAO_MMDevice *sender_mmdevice_;
  93
  94   /// Stream controller
  95   TAO_StreamCtrl *streamctrl_;
  96
  97   /// Number of frames sent.
  98   int frame_count_;
  99
 100   /// File from which data is read.
 101   ACE_CString filename_;
 102
 103   /// The Naming Service client.
 104   TAO_Naming_Client naming_client_;
 105
 106   /// File handle of the file read from.
 107   FILE *input_file_;
 108
 109   /// Selected protocol - default is UDP
 110   ACE_CString protocol_;
 111
 112   /// Rate at which the data will be sent.
 113   int frame_rate_;
 114
 115   /// Message block into which data is read from a file and then sent.
 116   ACE_Message_Block mb_;
 117
 118   /// Protocol object corresponding to the transport protocol selected.
 119   ProtocolObject_Set protocol_object_;
 120 };