blob: 4fdf3f1d7debd2c24f6bbc5b622a8ab65c0c8b0b (
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
164
165
166
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO/orbsvcs/tests/AVStreams/Component_Switching
//
// = FILENAME
// sender.h
//
// = DESCRIPTION
// 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 : public ACE_Event_Handler
{
// TITLE
// This class Handles the SIGINT signal through the Reactor.
// Useful to gracefully release the process
public:
Signal_Handler (void);
int handle_signal(int signum, siginfo_t*,ucontext_t*);
// Override this method to implement graceful shutdown.
};
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_destroy (void);
/// 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.
ACE_CString &flowname (void);
void flowname (const ACE_CString &flowname);
/// Accessor methods for the flowname of the callback
private:
ACE_CString flowname_;
/// Flowname of the callback.
};
class Sender_StreamEndPoint : public TAO_Client_StreamEndPoint
{
// = TITLE
// Defines a sender stream endpoint.
public:
int get_callback (const char *flowname,
TAO_AV_Callback *&callback);
/// Create the application callback and return its handle to
/// AVStreams for further application callbacks.
int set_protocol_object (const char *flowname,
TAO_AV_Protocol_Object *object);
/// Set protocol object corresponding to the transport protocol
/// chosen.
CORBA::Boolean handle_preconnect (AVStreams::flowSpec &flowspec);
/// Perform application specific actions before accepting new
/// connections.
protected:
Sender_Callback callback_;
/// Application callback.
};
typedef TAO_AV_Endpoint_Reactive_Strategy_A
<Sender_StreamEndPoint,
TAO_VDev,
AV_Null_MediaCtrl>
SENDER_ENDPOINT_STRATEGY;
class Sender
{
/// = TITLE
// Sender Application.
//
// = DESCRIPTION
// Class is responsible for streaming (and pacing) data to a
// receiver.
public:
Sender (void);
/// Constructor
~Sender (void);
/// Destructor
void shut_down (void);
int init (int argc,
char **argv
ACE_ENV_ARG_DECL_NOT_USED);
/// Method to initialize the various data components.
int pace_data (void);
/// Method to pace and send data from a file.
Connection_Manager &connection_manager (void);
/// Accessor to the connection manager.
private:
int parse_args (int argc, char **argv);
/// Method to parse the command line arguments.
SENDER_ENDPOINT_STRATEGY endpoint_strategy_;
/// The endpoint strategy used by the sender.
TAO_MMDevice *sender_mmdevice_;
/// The sender MMDevice.
int frame_count_;
/// Number of frames sent.
ACE_CString filename_;
/// File from which data is read.
FILE *input_file_;
/// File handle of the file read from.
double frame_rate_;
/// Rate at which the data will be sent.
ACE_Message_Block mb_;
/// Message block into which data is read from a file and then sent.
ACE_CString sender_name_;
/// Name of this sender.
Connection_Manager connection_manager_;
/// Connection manager.
// int stream_count_;
/// Teh count of the number of streams that are active
Signal_Handler signal_handler_;
/// Reference to the signal handler.
};
|
