1 files changed, 100 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/tests/AVStreams/Pluggable_Flow_Protocol/receiver.h b/trunk/TAO/orbsvcs/tests/AVStreams/Pluggable_Flow_Protocol/receiver.h
new file mode 100644
index 00000000000..39c4ac3b39e
--- /dev/null
+++ b/trunk/TAO/orbsvcs/tests/AVStreams/Pluggable_Flow_Protocol/receiver.h
@@ -0,0 +1,100 @@
+/* -*- C++ -*- */
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    TAO/orbsvcs/tests/AVStreams/Simple
+//
+// = FILENAME
+//    receiver.h
+//
+// = DESCRIPTION
+//    This application receives data from a AV sender and writes it to
+//    a file.
+//
+// = AUTHOR
+//    Yamuna Krishnamurthy <yamuna@cs.wustl.edu>
+//
+// ============================================================================
+
+#include "orbsvcs/Naming/Naming_Client.h"
+#include "orbsvcs/AV/AVStreams_i.h"
+#include "orbsvcs/AV/Endpoint_Strategy.h"
+#include "orbsvcs/AV/Policy.h"
+
+class Receiver_Callback : public TAO_AV_Callback
+{
+  // = TITLE
+  //    Application defined callback object.
+  //
+  // = DESCRIPTION
+  //    AVStreams calls this class when data shows up from a sender.
+public:
+
+  Receiver_Callback (void);
+  // Constructor.
+
+  // Method that is called when there is data to be received from a
+  // sender.
+  int receive_frame (ACE_Message_Block *frame,
+                     TAO_AV_frame_info *frame_info,
+                     const ACE_Addr &peer_address);
+
+  // Called when the sender is done sending data and wants to close
+  // down the connection.
+  int handle_destroy (void);
+
+private:
+  int frame_count_;
+  // Keeping a count of the incoming frames.
+};
+
+class Receiver_StreamEndPoint : public TAO_Server_StreamEndPoint
+{
+  // = TITLE
+  //    Application defined stream endpoint object.
+  //
+  // = DESCRIPTION
+  //    AVStreams calls this class during connection setup.
+public:
+  // Create a receiver application callback.
+  int get_callback (const char *flowname,
+                    TAO_AV_Callback *&callback);
+
+private:
+  Receiver_Callback callback_;
+  // Receiver application callback.
+};
+
+class Receiver
+{
+  // = TITLE
+  //    Receiver application class.
+  //
+  // = DESCRIPTION
+  //    This class receives data from a AV sender and writes it to
+  //    a file.
+public:
+  Receiver (void);
+  // Constructor
+
+  ~Receiver (void);
+  // Destructor.
+
+  int init (int argc,
+            char **argv
+            ACE_ENV_ARG_DECL);
+  // Initialize data components.
+
+protected:
+  TAO_Naming_Client naming_client_;
+  // The Naming Service Client.
+
+  TAO_AV_Endpoint_Reactive_Strategy_B
+  <Receiver_StreamEndPoint,TAO_VDev,AV_Null_MediaCtrl> reactive_strategy_;
+  // The endpoint reactive strategy.
+
+  TAO_MMDevice *mmdevice_;
+  // Receiver MMDevice.
+};