summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h')
-rw-r--r--TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h125
1 files changed, 0 insertions, 125 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h b/TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h
deleted file mode 100644
index 1d0a3b48aa8..00000000000
--- a/TAO/orbsvcs/tests/AVStreams/Multicast/ftp.h
+++ /dev/null
@@ -1,125 +0,0 @@
-/* -*- 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 (void);
- // FTP_Client_Callback (FTP_Client_Flow_Handler *handler);
-// virtual int handle_start (void);
-// virtual int handle_stop (void);
- virtual int handle_end_stream (void);
- void set_protocol_object (TAO_AV_Protocol_Object *protocol_object) {this->protocol_object_ = protocol_object;}
- virtual int handle_timeout (void *arg);
- virtual void get_timeout (ACE_Time_Value *&tv,
- void *&arg);
-
-protected:
- int count_;
- // FTP_Client_Flow_Handler *handler_;
- TAO_AV_Protocol_Object *protocol_object_;
-};
-
-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 */