1 files changed, 116 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h b/TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h
new file mode 100644
index 00000000000..0b36782eb5a
--- /dev/null
+++ b/TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h
@@ -0,0 +1,116 @@
+/* -*- C++ -*- */
+// $Id$
+
+#ifndef TAO_AV_FTP_H
+#define TAO_AV_FTP_H
+
+#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/Transport.h"
+#include "orbsvcs/AV/sfp.h"
+#include "orbsvcs/AV/MCast.h"
+
+class FTP_Client_Flow_Handler
+  :public virtual ACE_Event_Handler
+{
+public:
+  FTP_Client_Flow_Handler (TAO_ORB_Manager *orb_manager,
+                           ACE_Time_Value &timeout);
+  virtual int handle_timeout (const ACE_Time_Value &tv,
+                              const void *arg = 0);
+  virtual int start (void);
+  virtual int stop (void);
+  virtual int set_protocol_object (TAO_AV_Protocol_Object *object);
+protected:
+  TAO_ORB_Manager *orb_manager_;
+  long timer_id_;
+  int count_;
+  TAO_AV_Protocol_Object *protocol_object_;
+  ACE_Time_Value timeout_;
+};
+
+class FTP_Client_Callback
+  :public TAO_AV_Callback
+{
+public:
+  FTP_Client_Callback (FTP_Client_Flow_Handler *handler);
+  virtual int handle_start (void);
+  virtual int handle_stop (void);
+protected:
+  FTP_Client_Flow_Handler *handler_;
+};
+
+class FTP_Client_StreamEndPoint
+  :public TAO_Client_StreamEndPoint
+{
+public:
+  FTP_Client_StreamEndPoint (TAO_ORB_Manager *orb_manager = 0);
+
+  virtual int get_callback (const char *flowname,
+                            TAO_AV_Callback *&callback);
+
+  virtual int set_protocol_object (const char *flowname,
+                                   TAO_AV_Protocol_Object *object);
+protected:
+  TAO_ORB_Manager *orb_manager_;
+  FTP_Client_Flow_Handler *handler_;
+  FTP_Client_Callback *callback_;
+};
+
+typedef TAO_AV_Endpoint_Reactive_Strategy_A<FTP_Client_StreamEndPoint,TAO_VDev,AV_Null_MediaCtrl> ENDPOINT_STRATEGY;
+
+class Client;
+class Endpoint_Reactive_Strategy
+  : public ENDPOINT_STRATEGY
+{
+public:
+  Endpoint_Reactive_Strategy (TAO_ORB_Manager *orb_manager,
+                              Client *client_ptr);
+  // constructor . The orb manager is needed for the TAO_AV_Endpoint_Reactive_Strategy_A.
+
+  virtual int make_stream_endpoint (FTP_Client_StreamEndPoint *& endpoint);
+  // hook to make our streamendpoint taking a Client pointer
+private:
+  Client *client_;
+  // pointer to command handler object
+  TAO_ORB_Manager *orb_manager_;
+};
+
+
+class Client
+{
+public:
+  Client (void);
+  int init (int argc, char **argv);
+  int run (void);
+  FILE *file (void);
+  char *flowname (void);
+  TAO_StreamCtrl* streamctrl (void);
+private:
+  int parse_args (int argc, char **argv);
+  int bind_to_server (const char *name);
+  TAO_ORB_Manager *orb_manager_;
+  Endpoint_Reactive_Strategy endpoint_strategy_;
+  AVStreams::MMDevice_var server_mmdevice_;
+  TAO_MMDevice client_mmdevice_;
+  TAO_StreamCtrl streamctrl_;
+  // Video stream controller
+
+  int argc_;
+  char **argv_;
+  const char *filename_;
+  const char *address_;
+
+  TAO_Naming_Client my_naming_client_;
+  FILE *fp_;
+  char *protocol_;
+  char *flowname_;
+  int use_sfp_;
+};
+
+typedef ACE_Singleton<Client,ACE_Null_Mutex> CLIENT;
+
+#endif /* TAO_AV_FTP_H */