TAO/orbsvcs/tests/AVStreams/Pluggable_Flow_Protocol/receiver.h

   1 /* -*- C++ -*- */
   2
   3 //=============================================================================
   4 /**
   5  *  @file    receiver.h
   6  *
   7  *  This application receives data from a AV sender and writes it to
   8  *  a file.
   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/Policy.h"
  19
  20 /**
  21  * @class Receiver_Callback
  22  *
  23  * @brief Application defined callback object.
  24  *
  25  * AVStreams calls this class when data shows up from a sender.
  26  */
  27 class Receiver_Callback : public TAO_AV_Callback
  28 {
  29 public:
  30   /// Constructor.
  31   Receiver_Callback ();
  32
  33   // Method that is called when there is data to be received from a
  34   // sender.
  35   int receive_frame (ACE_Message_Block *frame,
  36                      TAO_AV_frame_info *frame_info,
  37                      const ACE_Addr &peer_address);
  38
  39   // Called when the sender is done sending data and wants to close
  40   // down the connection.
  41   int handle_destroy ();
  42
  43 private:
  44   /// Keeping a count of the incoming frames.
  45   int frame_count_;
  46 };
  47
  48 /**
  49  * @class Receiver_StreamEndPoint
  50  *
  51  * @brief Application defined stream endpoint object.
  52  *
  53  * AVStreams calls this class during connection setup.
  54  */
  55 class Receiver_StreamEndPoint : public TAO_Server_StreamEndPoint
  56 {
  57 public:
  58   // Create a receiver application callback.
  59   int get_callback (const char *flowname,
  60                     TAO_AV_Callback *&callback);
  61
  62 private:
  63   /// Receiver application callback.
  64   Receiver_Callback callback_;
  65 };
  66
  67 /**
  68  * @class Receiver
  69  *
  70  * @brief Receiver application class.
  71  *
  72  * This class receives data from a AV sender and writes it to
  73  * a file.
  74  */
  75 class Receiver
  76 {
  77 public:
  78   /// Constructor
  79   Receiver ();
  80
  81   /// Destructor.
  82   ~Receiver ();
  83
  84   /// Initialize data components.
  85   int init (int argc,
  86             ACE_TCHAR *argv[]);
  87
  88 protected:
  89   /// The Naming Service Client.
  90   TAO_Naming_Client naming_client_;
  91
  92   /// The endpoint reactive strategy.
  93   TAO_AV_Endpoint_Reactive_Strategy_B
  94   <Receiver_StreamEndPoint,TAO_VDev,AV_Null_MediaCtrl> reactive_strategy_;
  95
  96   /// Receiver MMDevice.
  97   TAO_MMDevice *mmdevice_;
  98 };