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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ACE_wrappers/examples/QOS
//
// = FILENAME
// Receiver_QoS_Event_Handler.cpp
//
// = AUTHOR
// Vishal Kachroo <vishal@cs.wustl.edu>
//
// ============================================================================
#include "Receiver_QoS_Event_Handler.h"
#include "ace/Log_Msg.h"
#include "ace/SString.h"
#include "Fill_ACE_QoS.h"
// Constructor.
Receiver_QoS_Event_Handler::Receiver_QoS_Event_Handler (void)
{
}
Receiver_QoS_Event_Handler::Receiver_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.
Receiver_QoS_Event_Handler::~Receiver_QoS_Event_Handler (void)
{
}
// Return the handle of the Dgram_Mcast. This method is called
// internally by the reactor.
ACE_HANDLE
Receiver_QoS_Event_Handler::get_handle (void) const
{
return this->dgram_mcast_qos_.get_handle ();
}
// Called when there is a READ activity on the dgram_mcast_qos handle.
int
Receiver_QoS_Event_Handler::handle_input (ACE_HANDLE)
{
char buf[BUFSIZ];
iovec iov;
iov.iov_base = buf;
iov.iov_len = BUFSIZ;
ACE_OS::memset (iov.iov_base,
0,
BUFSIZ);
ACE_DEBUG ((LM_DEBUG,
"Inside handle_input () of Receiver_QoS_Event_Handler ()\n"));
// Receive message from multicast group.
ssize_t result =
this->dgram_mcast_qos_.recv (&iov,
1,
this->remote_addr_);
if (result != -1)
{
ACE_DEBUG ((LM_DEBUG,
"Message Received : %s",
iov.iov_base));
return 0;
}
else
return -1;
}
// Called when there is a QoS Event.
int
Receiver_QoS_Event_Handler::handle_qos (ACE_HANDLE fd)
{
ACE_UNUSED_ARG (fd);
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 ()));
//
// 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_receiver;
if (flow_spec_list.fill_simplex_receiver_qos (another_qos_receiver,
flow_id) !=0)
ACE_ERROR_RETURN ((LM_ERROR,
"Unable to fill handler-simplex receiver 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_receiver) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
"Unable to set QoS\n"),
-1);
else
ACE_DEBUG ((LM_DEBUG,
"Setting QOS succeeds.\n"));
return 0;
}
|
