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
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Sender_QoS_Event_Handler.cpp
*
* $Id: Sender_QoS_Event_Handler.cpp 93639 2011-03-24 13:32:13Z johnnyw $
*
* @author Vishal Kachroo <vishal@cs.wustl.edu>
*/
//=============================================================================
#include "Sender_QoS_Event_Handler.h"
#include "ace/Log_Msg.h"
#include "Fill_ACE_QoS.h"
// Constructor.
Sender_QoS_Event_Handler::Sender_QoS_Event_Handler (void)
{
}
// Constructor.
Sender_QoS_Event_Handler::Sender_QoS_Event_Handler (const ACE_SOCK_Dgram_Mcast_QoS
&dgram_mcast_qos,
ACE_QoS_Session *qos_session)
: dgram_mcast_qos_ (dgram_mcast_qos),
qos_session_ (qos_session)
{
}
// Destructor.
Sender_QoS_Event_Handler::~Sender_QoS_Event_Handler (void)
{
}
// Return the handle of the Dgram_Mcast. This method is called
// internally by the reactor.
ACE_HANDLE
Sender_QoS_Event_Handler::get_handle (void) const
{
return this->dgram_mcast_qos_.get_handle ();
}
// Handle the QoS Event. In this case send data to the receiver
// using WSASendTo() that uses overlapped I/O.
int
Sender_QoS_Event_Handler::handle_qos (ACE_HANDLE)
{
ACE_DEBUG ((LM_DEBUG,
"\nReceived a QOS event. Inside handle_qos ()\n"));
// We have received an RSVP event. The following update_qos () call
// calls rapi_dispatch () in case of RAPI and WSAIoctl (GET_QOS) in
// case of W2K. It then does the QoS parameter translation and updates
// the QoS session object with the latest QoS. This call replaces the
// direct call that was being made to WSAIoctl (GET_QOS) here for the
// Win2K example.
if (this->qos_session_->update_qos () == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"Error in updating QoS\n"),
-1);
else
ACE_DEBUG ((LM_DEBUG,
" Updating QOS succeeds.\n"));
// Now proactively query the QoS object for QoS.
ACE_QoS ace_get_qos = this->qos_session_->qos ();
ACE_DEBUG ((LM_DEBUG,
"\nReceiving Flowspec :\t\t\tSending Flowspec :\n\n"
"\tToken Rate = %d\t\t\tToken Rate = %d\n"
"\tToken Bucket Size = %d\t\t\tToken Bucket Size = %d\n"
"\tPeak Bandwidth = %d\t\t\tPeak Bandwidth = %d\n"
"\tLatency = %d\t\t\t\tLatency = %d\n"
"\tDelay Variation = %d\t\t\tDelay Variation = %d\n"
"\tService Type = %d\t\t\tService Type = %d\n"
"\tMax SDU Size = %d\t\t\tMax SDU Size = %d\n"
"\tMinimum Policed Size = %d\t\tMinimum Policed Size = %d\n\n",
ace_get_qos.receiving_flowspec ()->token_rate (),
ace_get_qos.sending_flowspec ()->token_rate (),
ace_get_qos.receiving_flowspec ()->token_bucket_size (),
ace_get_qos.sending_flowspec ()->token_bucket_size (),
ace_get_qos.receiving_flowspec ()->peak_bandwidth (),
ace_get_qos.sending_flowspec ()->peak_bandwidth (),
ace_get_qos.receiving_flowspec ()->latency (),
ace_get_qos.sending_flowspec ()->latency (),
ace_get_qos.receiving_flowspec ()->delay_variation (),
ace_get_qos.sending_flowspec ()->delay_variation (),
ace_get_qos.receiving_flowspec ()->service_type (),
ace_get_qos.sending_flowspec ()->service_type (),
ace_get_qos.receiving_flowspec ()->max_sdu_size (),
ace_get_qos.sending_flowspec ()->max_sdu_size (),
ace_get_qos.receiving_flowspec ()->minimum_policed_size (),
ace_get_qos.sending_flowspec ()->minimum_policed_size ()));
// This is SPECIFIC TO WIN2K and should be done in the qos_update function.
// ACE_QoS ace_get_qos;
// u_long dwBytes;
// if (ACE_OS::ioctl (this->dgram_mcast_qos_.get_handle (),
// ACE_SIO_GET_QOS,
// ace_get_qos,
// &dwBytes) == -1)
// ACE_ERROR ((LM_ERROR,
// "Error in Qos get ACE_OS::ioctl ()\n"
// "Bytes Returned = %d\n",
// dwBytes));
// else
// ACE_DEBUG ((LM_DEBUG,
// "Getting QOS using ACE_OS::ioctl () succeeds.\n"));
const char* msg = "Hello sent on a QoS enabled session !!\n";
iovec iov[1];
iov[0].iov_base = const_cast<char *>(msg);
iov[0].iov_len = ACE_OS::strlen(msg);
size_t bytes_sent = 0;
// Send "Hello" to the QoS session address to which the receiver has
// subscribed.
if (this->dgram_mcast_qos_.send (iov,
1,
bytes_sent,
0,
this->qos_session_->dest_addr (),
0,
0) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"Error in dgram_mcast.send ()\n"),
-1);
else
ACE_DEBUG ((LM_DEBUG,
"Using ACE_OS::sendto () : Bytes sent : %d",
bytes_sent));
//
// create a dynamic flow spec on each callback to test QoS retransmits
//
ACE_CString flow_id ("flow_id");
Fill_ACE_QoS flow_spec_list;
ACE_DEBUG ((LM_DEBUG,
"\nA new flow spec! in QoS handler."));
static int token_rate = 9400;
++token_rate;
static int peak_bw = 18500;
++peak_bw;
switch (flow_spec_list.map ().bind (flow_id,
new ACE_Flow_Spec (token_rate,
708,
peak_bw,
0,
0,
ACE_SERVICETYPE_CONTROLLEDLOAD,
368,
368,
25,
1)))
{
case 1 :
ACE_ERROR_RETURN ((LM_ERROR,
"Unable to bind the new flow spec\n"
"The Flow Spec name already exists\n"),
-1);
break;
case -1 :
ACE_ERROR_RETURN ((LM_ERROR,
"Unable to bind the new flow spec\n"),
-1);
break;
}
//
// set up the new qos
//
ACE_QoS another_qos_sender;
if (flow_spec_list.fill_simplex_sender_qos (another_qos_sender,
flow_id) !=0)
ACE_ERROR_RETURN ((LM_ERROR,
"Unable to fill handler-simplex sender qos\n"),
-1);
else
ACE_DEBUG ((LM_DEBUG,
"Successfully built a new flowspec in handle_qos!\n"));
//
// change the qos for the current session
//
ACE_QoS_Manager qos_manager = this->dgram_mcast_qos_.qos_manager ();
ACE_DEBUG ((LM_DEBUG,
"QoS Manager was built in handle_qos!\n"));
// Set the QoS for the session. Replaces the ioctl () call that
// was being made previously.
if (this->qos_session_->qos (&this->dgram_mcast_qos_,
&qos_manager,
another_qos_sender) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"Unable to set QoS\n"),
-1);
else
ACE_DEBUG ((LM_DEBUG,
"Setting QOS succeeds.\n"));
// ACE_SOCK_Dgram_Mcast_QoS dgram_mcast_qos_;
// ACE_QoS_Session *qos_session_;
return 0;
}
|
