summaryrefslogtreecommitdiff
path: root/ace
diff options
context:
space:
mode:
authorvishal <vishal@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1999-09-27 22:07:48 +0000
committervishal <vishal@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1999-09-27 22:07:48 +0000
commit1c603aadcc6912f1fe2c34538313aa44763b5d04 (patch)
treece9dd85e45f4a8c2a53264efa199f979a806ab2c /ace
parent8eb2fc06a6701754d88be18bf9502ecc45bee87e (diff)
downloadATCD-1c603aadcc6912f1fe2c34538313aa44763b5d04.tar.gz
*** empty log message ***
Diffstat (limited to 'ace')
-rw-r--r--ace/OS.h4
-rw-r--r--ace/OS.i130
2 files changed, 67 insertions, 67 deletions
diff --git a/ace/OS.h b/ace/OS.h
index 9a7ead2a7fa..615d87b9753 100644
--- a/ace/OS.h
+++ b/ace/OS.h
@@ -5843,9 +5843,9 @@ public:
ACE_OVERLAPPED_COMPLETION_FUNC func);
// QoS-enabled <ioctl>.
static int ioctl (ACE_HANDLE socket,
- u_long io_control_code,
+ u_long io_control_code,
ACE_QoS &ace_qos,
- u_long *bytes_returned,
+ u_long *bytes_returned,
void *buffer_p = 0,
u_long buffer = 0,
ACE_OVERLAPPED *overlapped = 0,
diff --git a/ace/OS.i b/ace/OS.i
index a23d15e3ec1..9251deac5fe 100644
--- a/ace/OS.i
+++ b/ace/OS.i
@@ -5196,81 +5196,81 @@ ACE_OS::ioctl (ACE_HANDLE socket,
ACE_INLINE int
ACE_OS::ioctl (ACE_HANDLE socket,
- u_long io_control_code,
+ u_long io_control_code,
ACE_QoS &ace_qos,
- u_long *bytes_returned,
+ u_long *bytes_returned,
void *buffer_p,
u_long buffer,
ACE_OVERLAPPED *overlapped,
ACE_OVERLAPPED_COMPLETION_FUNC func)
{
#if defined (ACE_HAS_WINSOCK2) && (ACE_HAS_WINSOCK2 != 0)
-
+
QOS qos;
DWORD qos_len = 0;
-
+
if (io_control_code == SIO_SET_QOS)
- {
- qos.SendingFlowspec = ace_qos.sending_flowspec ();
- qos.ReceivingFlowspec = ace_qos.receiving_flowspec ();
- qos.ProviderSpecific = (WSABUF) ace_qos.provider_specific ();
-
- qos_len = sizeof (QOS) + ace_qos.provider_specific ().iov_len;
-
- ACE_SOCKCALL_RETURN (::WSAIoctl ((ACE_SOCKET) socket,
- io_control_code,
- &qos,
- qos_len,
- buffer_p,
- buffer,
- bytes_returned,
- (WSAOVERLAPPED *) overlapped,
- func),
- int,
- SOCKET_ERROR);
- }
- else
- {
-
- ACE_SOCKCALL_RETURN (::WSAIoctl ((ACE_SOCKET) socket,
- io_control_code,
- buffer_p,
- buffer,
- &qos,
- qos_len,
- bytes_returned,
- (WSAOVERLAPPED *) overlapped,
- func),
- int,
- SOCKET_ERROR);
-
- ACE_Flow_Spec sending_flowspec (qos.SendingFlowspec.TokenRate,
- qos.SendingFlowspec.TokenBucketSize,
- qos.SendingFlowspec.PeakBandwidth,
- qos.SendingFlowspec.Latency,
- qos.SendingFlowspec.DelayVariation,
- qos.SendingFlowspec.ServiceType,
- qos.SendingFlowspec.MaxSduSize,
- qos.SendingFlowspec.MinimumPolicedSize,
- 0,
- 0);
-
- ACE_Flow_Spec receiving_flowspec (qos.ReceivingFlowspec.TokenRate,
- qos.ReceivingFlowspec.TokenBucketSize,
- qos.ReceivingFlowspec.PeakBandwidth,
- qos.ReceivingFlowspec.Latency,
- qos.ReceivingFlowspec.DelayVariation,
- qos.ReceivingFlowspec.ServiceType,
- qos.ReceivingFlowspec.MaxSduSize,
- qos.ReceivingFlowspec.MinimumPolicedSize,
- 0,
- 0);
-
- ace_qos.sending_flowspec (sending_flowspec);
- ace_qos.receiving_flowspec (receiving_flowspec);
- ace_qos.provider_specific (*((struct iovec *) (&qos.ProviderSpecific)));
- }
-
+ {
+ qos.SendingFlowspec = ace_qos.sending_flowspec ();
+ qos.ReceivingFlowspec = ace_qos.receiving_flowspec ();
+ qos.ProviderSpecific = (WSABUF) ace_qos.provider_specific ();
+
+ qos_len = sizeof (QOS) + ace_qos.provider_specific ().iov_len;
+
+ ACE_SOCKCALL_RETURN (::WSAIoctl ((ACE_SOCKET) socket,
+ io_control_code,
+ &qos,
+ qos_len,
+ buffer_p,
+ buffer,
+ bytes_returned,
+ (WSAOVERLAPPED *) overlapped,
+ func),
+ int,
+ SOCKET_ERROR);
+ }
+ else
+ {
+
+ ACE_SOCKCALL_RETURN (::WSAIoctl ((ACE_SOCKET) socket,
+ io_control_code,
+ buffer_p,
+ buffer,
+ &qos,
+ qos_len,
+ bytes_returned,
+ (WSAOVERLAPPED *) overlapped,
+ func),
+ int,
+ SOCKET_ERROR);
+
+ ACE_Flow_Spec sending_flowspec (qos.SendingFlowspec.TokenRate,
+ qos.SendingFlowspec.TokenBucketSize,
+ qos.SendingFlowspec.PeakBandwidth,
+ qos.SendingFlowspec.Latency,
+ qos.SendingFlowspec.DelayVariation,
+ qos.SendingFlowspec.ServiceType,
+ qos.SendingFlowspec.MaxSduSize,
+ qos.SendingFlowspec.MinimumPolicedSize,
+ 0,
+ 0);
+
+ ACE_Flow_Spec receiving_flowspec (qos.ReceivingFlowspec.TokenRate,
+ qos.ReceivingFlowspec.TokenBucketSize,
+ qos.ReceivingFlowspec.PeakBandwidth,
+ qos.ReceivingFlowspec.Latency,
+ qos.ReceivingFlowspec.DelayVariation,
+ qos.ReceivingFlowspec.ServiceType,
+ qos.ReceivingFlowspec.MaxSduSize,
+ qos.ReceivingFlowspec.MinimumPolicedSize,
+ 0,
+ 0);
+
+ ace_qos.sending_flowspec (sending_flowspec);
+ ace_qos.receiving_flowspec (receiving_flowspec);
+ ace_qos.provider_specific (*((struct iovec *) (&qos.ProviderSpecific)));
+ }
+
#else
ACE_UNUSED_ARG (socket);
ACE_UNUSED_ARG (io_control_code);