1 files changed, 89 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/tests/AVStreams/Full_Profile/ftp.h b/trunk/TAO/orbsvcs/tests/AVStreams/Full_Profile/ftp.h
new file mode 100644
index 00000000000..bb0cfdd19c0
--- /dev/null
+++ b/trunk/TAO/orbsvcs/tests/AVStreams/Full_Profile/ftp.h
@@ -0,0 +1,89 @@
+/* -*- C++ -*- */
+// $Id$
+
+#ifndef TAO_AV_FTP_H
+#define TAO_AV_FTP_H
+
+#include "ace/Get_Opt.h"
+#include "ace/High_Res_Timer.h"
+#include "orbsvcs/AV/AVStreams_i.h"
+#include "orbsvcs/AV/Flows_T.h"
+#include "orbsvcs/AV/Endpoint_Strategy.h"
+#include "orbsvcs/AV/Transport.h"
+#include "orbsvcs/AV/sfp.h"
+#include "orbsvcs/AV/MCast.h"
+
+class Client;
+
+class FTP_Client_Callback;
+
+class FTP_Client_Producer
+  :public virtual TAO_FlowProducer
+{
+public:
+  FTP_Client_Producer (void);
+  virtual int get_callback (const char *flowname,
+                            TAO_AV_Callback *&callback);
+  int set_protocol_object (const char *flowname,
+                           TAO_AV_Protocol_Object *object);
+protected:
+  FTP_Client_Callback *callback_;
+};
+
+class FTP_Client_Callback
+  :public TAO_AV_Callback
+{
+public:
+  FTP_Client_Callback (void);
+  virtual int handle_timeout (void *arg);
+  virtual int handle_end_stream (void);
+  virtual void get_timeout (ACE_Time_Value *&tv,
+                            void *&arg);
+  void set_protocol_object (TAO_AV_Protocol_Object *protocol_object) {this->protocol_object_ = protocol_object;}
+
+protected:
+  int count_;
+  TAO_AV_Protocol_Object *protocol_object_;
+};
+
+typedef TAO_AV_Endpoint_Reactive_Strategy_A<TAO_StreamEndPoint_A,TAO_VDev,AV_Null_MediaCtrl> ENDPOINT_STRATEGY;
+
+class Client
+{
+public:
+  Client (void);
+  int init (int argc, char **argv);
+  int run (void);
+  FILE *file (void);
+  const char *flowname (void);
+  TAO_StreamCtrl* streamctrl (void);
+  AVStreams::protocolSpec protocols (void);
+  const char *format (void);
+  const char *address (void);
+private:
+  int parse_args (int argc, char **argv);
+  ENDPOINT_STRATEGY endpoint_strategy_;
+  TAO_StreamCtrl streamctrl_;
+  // Video stream controller
+
+  int argc_;
+  char **argv_;
+  const char *filename_;
+  ACE_CString address_;
+  ACE_CString peer_addr_;
+
+  FILE *fp_;
+  char *protocol_;
+  ACE_CString flowname_;
+  int use_sfp_;
+  CORBA::ORB_var orb_;
+  PortableServer::POA_ptr poa_;
+  TAO_StreamEndPoint_A *streamendpoint_a_;
+  AVStreams::StreamEndPoint_A_var sep_a_;
+  FTP_Client_Producer *fep_a_;
+  AVStreams::FlowProducer_var fep_a_obj_;
+};
+
+typedef ACE_Unmanaged_Singleton<Client,ACE_Null_Mutex> CLIENT;
+
+#endif /* TAO_AV_FTP_H */