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
|
/* -*- 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/OS_NS_string.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 ()));
return 0;
}
|
