Tue Aug 31 18:07:35 1999 Nagarajan Surendran <naga@cs.wustl.edu>

1 files changed, 72 insertions, 0 deletions

diff --git a/TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.h b/TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.h
new file mode 100644
index 00000000000..c62d88142ab
--- /dev/null
+++ b/TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.h
@@ -0,0 +1,72 @@
+/* -*- C++ -*- */
+// $Id$
+
+#include "ace/Get_Opt.h"
+#include "tao/TAO.h"
+#include "orbsvcs/Naming/Naming_Utils.h"
+#include "orbsvcs/AV/AVStreams_i.h"
+#include "orbsvcs/AV/Endpoint_Strategy.h"
+#include "orbsvcs/AV/Flows_T.h"
+#include "orbsvcs/AV/sfp.h"
+#include "orbsvcs/AV/MCast.h"
+#include "orbsvcs/AV/Policy.h"
+
+class FTP_Server_Callback
+  :public TAO_AV_Callback
+{
+public:
+  virtual int handle_stop (void);
+  virtual int receive_frame (ACE_Message_Block *frame,
+                             TAO_AV_frame_info *frame_info,
+                             const ACE_Addr &);
+  virtual int handle_end_stream (void);
+};
+
+class FTP_Server_FlowEndPoint
+  :public TAO_FlowConsumer
+{
+public:
+  FTP_Server_FlowEndPoint (void);
+  int get_callback (const char *flowname,
+                    TAO_AV_Callback *&callback);
+};
+
+// class FTP_Server_FDev
+//   :public TAO_FDev
+// {
+// public:
+//   FTP_Server_FDev (void);
+//   virtual AVStreams::FlowConsumer_ptr make_consumer (AVStreams::FlowConnection_ptr the_requester,
+//                                                        AVStreams::QoS & the_qos,
+//                                                        CORBA::Boolean_out met_qos,
+//                                                        char *& named_fdev,
+//                                                        CORBA::Environment &env = CORBA::Environment::default_environment ());
+//   // bridge method for the application to override the consumer object
+//   // creation. Default implementation creates a TAO_FlowConsumer.
+
+// };
+
+typedef TAO_FDev <TAO_FlowProducer, FTP_Server_FlowEndPoint> FTP_Server_FDev;
+
+class Server
+{
+public:
+  Server (void);
+  int init (int argc,
+            char **argv);
+  int run (void);
+  FILE *file (void);
+  AVStreams::protocolSpec protocols (void);
+  const char *format (void);
+protected:
+  int parse_args (int argc,char **argv);
+  TAO_ORB_Manager *orb_manager_;
+  TAO_Naming_Client my_naming_client_;
+  TAO_AV_Endpoint_Reactive_Strategy_B <TAO_StreamEndPoint_B,TAO_VDev,AV_Null_MediaCtrl> reactive_strategy_;
+  TAO_MMDevice *mmdevice_;
+  FTP_Server_FDev *fdev_;
+  FILE *fp_;
+  char *protocol_;
+};
+
+typedef ACE_Singleton<Server,ACE_Null_Mutex> SERVER;