blob: 1b4a7ef940a1474b9d31faff3b26e114c540f375 (
plain)
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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO/orbsvcs/tests/AVStreams/Simple_Three_Stage
//
// = FILENAME
// sender.h
//
// = DESCRIPTION
// Sender that reads data from a file and sends it
// at a requested data rate.
//
// = AUTHOR
// Yamuna Krishnamurthy <yamuna@cs.wustl.edu>
//
// ============================================================================
#ifndef TAO_AV_SENDER_H
#define TAO_AV_SENDER_H
#include "ace/Get_Opt.h"
#include "orbsvcs/Naming/Naming_Utils.h"
#include "orbsvcs/AV/AVStreams_i.h"
#include "orbsvcs/AV/Endpoint_Strategy.h"
#include "orbsvcs/AV/Policy.h"
#include "orbsvcs/AV/Protocol_Factory.h"
class Sender_Callback : public TAO_AV_Callback
{
// = TITLE
// Defines a class for the sender application callback.
//
// = DESCRIPTION
// This class overides the methods of the TAO_AV_Callback so the
// AVStreams can make upcalls to the application.
public:
int handle_start (void);
// Method called when the device is ready to start sending data
};
class Sender_StreamEndPoint : public TAO_Server_StreamEndPoint
{
// = TITLE
// Defines the sender stream endpoint.
//
// = DESCRIPTION
// This class overrides the methods of TAO_ClientStreamendpoint
// so the application can perform its processing during post and pre
// connection set up.
public:
Sender_StreamEndPoint (void);
//Contructor
virtual int get_callback (const char *flowname,
TAO_AV_Callback *&callback);
// Create the application client callback and return its handle to the
// AVStreams for further application callbacks
virtual int set_protocol_object (const char *flowname,
TAO_AV_Protocol_Object *object);
// Set protocol object corresponding to the transport protocol chosen.
protected:
Sender_Callback callback_;
// Reference to the client application callback.
};
typedef TAO_AV_Endpoint_Reactive_Strategy_B <Sender_StreamEndPoint,TAO_VDev,AV_Null_MediaCtrl> ENDPOINT_STRATEGY;
class Sender
{
// = TITLE
// Defines the Client Application
//
// = DESCRIPTION
// The actual client program that streams data
// to the distributers that are waiting for data.
public:
Sender (void);
// Constructor
int init (int argc,
char **argv,
CORBA::Environment&);
// Method to initialize the various data components.
void set_protocol_object (TAO_AV_Protocol_Object *protocol_object);
// Set the protocol object corresponding to the transport protocol chosen.
void set_endpoint (Sender_StreamEndPoint* endpoint);
Sender_StreamEndPoint* get_endpoint (void);
// Accessor methods for setting/getting the sender stream endpoint
int pace_data (CORBA::Environment&);
// Method to pace and send data from a file.
FILE *file (void);
// File handle from which data is read to be sent.
TAO_StreamCtrl* streamctrl (void);
// The stream control interface that manages the stream set up
int frame_rate (void);
// The requested frame rate for sending each frame of data read from the file.
private:
int parse_args (int argc, char **argv);
// Method to parse the command line arguments.
int register_sender (CORBA::Environment& ACE_TRY_ENV);
// Method that binds the client to the Naming Service
ENDPOINT_STRATEGY endpoint_strategy_;
// The reactive strategy of the client.
AVStreams::MMDevice_var receiver_mmdevice_;
// The receiver MMDevice that the sender connects to
TAO_MMDevice* sender_mmdevice_;
// The sender MMDevice.
Sender_StreamEndPoint* endpoint_;
// Reference to the sender streamendpoint
int count_;
// Number of frames sent.
int argc_;
char **argv_;
ACE_CString filename_;
// File from which data is read.
TAO_Naming_Client my_naming_client_;
// The Naming Service client.
FILE *fp_;
// File handle of the file read from.
int frame_rate_;
// The sepcified data frame rate
ACE_Message_Block mb;
// Message block into which data is read from a file and then sent.
TAO_AV_Protocol_Object* protocol_object_;
// Protocol object corresponding to the transport protocol selected.
};
typedef ACE_Singleton<Sender,ACE_Null_Mutex> SENDER;
// Create a singleton instance of the Sender.
#endif /* TAO_AV_FTP_H */
|
