blob: c179a105c2b392831b244bef6d549d84c9ee14e9 (
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++ -*- */
//=============================================================================
/**
* @file sender.h
*
* This application reads data from a file and sends it to s
* receiver.
*
* @author Yamuna Krishnamurthy <yamuna@cs.wustl.edu>
*/
//=============================================================================
#include "Connection_Manager.h"
#include "orbsvcs/AV/AVStreams_i.h"
#include "orbsvcs/AV/Endpoint_Strategy.h"
#include "orbsvcs/AV/Protocol_Factory.h"
/**
* @class Signal_Handler
*
* This class Handles the SIGINT signal through the Reactor.
* Useful to gracefully release the process
*/
class Signal_Handler : public ACE_Event_Handler
{
public:
Signal_Handler (void);
/// Override this method to implement graceful shutdown.
int handle_signal(int signum, siginfo_t*,ucontext_t*);
};
/**
* @class Sender_Callback
*
* @brief Defines a class for the sender application callback.
*
* This class overrides the methods of the TAO_AV_Callback so the
* AVStreams can make upcalls to the application.
*/
class Sender_Callback : public TAO_AV_Callback
{
public:
/**
* Called when the sender has finished reading the file and wants
* to close down the connection. Also called when the distributer
* tears down the connection when it switches to a new sender.
*/
int handle_destroy (void);
/// Accessor methods for the flowname of the callback
ACE_CString &flowname (void);
void flowname (const ACE_CString &flowname);
private:
//// Flowname of the callback.
ACE_CString flowname_;
};
/**
* @class Sender_StreamEndPoint
*
* @brief Defines a sender stream endpoint.
*/
class Sender_StreamEndPoint : public TAO_Client_StreamEndPoint
{
public:
//// Create the application callback and return its handle to
//// AVStreams for further application callbacks.
int get_callback (const char *flowname,
TAO_AV_Callback *&callback);
//// Set protocol object corresponding to the transport protocol
//// chosen.
int set_protocol_object (const char *flowname,
TAO_AV_Protocol_Object *object);
//// Perform application specific actions before accepting new
//// connections.
CORBA::Boolean handle_preconnect (AVStreams::flowSpec &flowspec);
protected:
//// Application callback.
Sender_Callback callback_;
};
typedef TAO_AV_Endpoint_Reactive_Strategy_A
<Sender_StreamEndPoint,
TAO_VDev,
AV_Null_MediaCtrl>
SENDER_ENDPOINT_STRATEGY;
/**
* @class Sender
*
* @brief Sender Application.
*
* Class is responsible for streaming (and pacing) data to a
* receiver.
*/
class Sender
{
public:
//// Constructor
Sender (void);
//// Destructor
~Sender (void);
void shut_down (void);
//// Method to initialize the various data components.
int init (int argc,
ACE_TCHAR *argv[]);
//// Method to pace and send data from a file.
int pace_data (void);
//// Accessor to the connection manager.
Connection_Manager &connection_manager (void);
private:
//// Method to parse the command line arguments.
int parse_args (int argc, ACE_TCHAR *argv[]);
//// The endpoint strategy used by the sender.
SENDER_ENDPOINT_STRATEGY endpoint_strategy_;
//// The sender MMDevice.
TAO_MMDevice *sender_mmdevice_;
//// Number of frames sent.
int frame_count_;
//// File from which data is read.
ACE_CString filename_;
//// File handle of the file read from.
FILE *input_file_;
//// Rate at which the data will be sent.
double frame_rate_;
//// Message block into which data is read from a file and then sent.
ACE_Message_Block mb_;
//// Name of this sender.
ACE_CString sender_name_;
//// Connection manager.
Connection_Manager connection_manager_;
//// Reference to the signal handler.
Signal_Handler signal_handler_;
};
|
