1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
/* -*- 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/Flows_T.h"
#include "orbsvcs/AV/Endpoint_Strategy.h"
#include "orbsvcs/AV/sfp.h"
#include "orbsvcs/AV/MCast.h"
// class FTP_Client_Flow_Handler
// // :public virtual ACE_Event_Handler,
// public virtual TAO_FlowProducer
// {
// 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 get_callback (const char *flowname,
// TAO_AV_Callback *&callback);
// protected:
// TAO_ORB_Manager *orb_manager_;
// long timer_id_;
// int count_;
// 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_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);
// virtual int get_frame (ACE_Message_Block *&block,TAO_AV_frame_info *&frame_info);
void set_protocol_object (TAO_AV_Protocol_Object *protocol_object) {this->protocol_object_ = protocol_object;}
protected:
// FTP_Client_Flow_Handler *handler_;
int count_;
TAO_AV_Protocol_Object *protocol_object_;
};
// class FTP_Client_FDev
// :public TAO_FDev
// {
// public:
// FTP_Client_FDev (TAO_ORB_Manager *orb_manger);
// virtual AVStreams::FlowProducer_ptr make_producer (AVStreams::FlowConnection_ptr the_requester,
// AVStreams::QoS & the_qos,
// CORBA::Boolean_out met_qos,
// char *& named_fdev,
// CORBA::Environment &env = CORBA::Environment::default_environment ());
// protected:
// TAO_ORB_Manager *orb_manager_;
// };
typedef TAO_AV_Endpoint_Reactive_Strategy_A<TAO_StreamEndPoint_A,TAO_VDev,AV_Null_MediaCtrl> ENDPOINT_STRATEGY;
typedef TAO_FDev <FTP_Client_Producer,TAO_FlowConsumer> FTP_Client_FDev;
class Client
{
public:
Client (void);
int init (int argc, char **argv);
int run (void);
FILE *file (void);
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);
int bind_to_server (const char *name);
TAO_ORB_Manager *orb_manager_;
ENDPOINT_STRATEGY endpoint_strategy_;
AVStreams::MMDevice_var server_mmdevice_;
TAO_MMDevice client_mmdevice_;
FTP_Client_FDev *fdev_;
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 */
|
