diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.h')
-rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.h | 70 |
1 files changed, 70 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..bdd2957c2ec --- /dev/null +++ b/TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.h @@ -0,0 +1,70 @@ +/* -*- C++ -*- */ +// $Id$ + +#include "ace/Get_Opt.h" +#include "orbsvcs/Naming/Naming_Client.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, +// ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS); +// // 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_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_Unmanaged_Singleton<Server,ACE_Null_Mutex> FTP_SERVER; |