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
219
220
221
222
|
// -*- C++ -*-
//=============================================================================
/**
* @file OS_NS_sys_socket.h
*
* $Id$
*
* @author Douglas C. Schmidt <schmidt@cs.wustl.edu>
* @author Jesper S. M|ller<stophph@diku.dk>
* @author and a cast of thousands...
*
* Originally in OS.h.
*/
//=============================================================================
#ifndef ACE_OS_NS_SYS_SOCKET_H
# define ACE_OS_NS_SYS_SOCKET_H
# include /**/ "ace/pre.h"
# include "ace/config-all.h"
# if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
# endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/os_include/sys/os_socket.h"
#include "ace/OS_NS_stropts.h"
class ACE_Accept_QoS_Params;
class ACE_QoS_Params;
namespace ACE_OS {
# if defined (ACE_WIN32)
/// Keeps track of whether we've already initialized WinSock...
extern int socket_initialized_;
# endif /* ACE_WIN32 */
//@{ @name A set of wrappers for sockets.
/// BSD-style <accept> (no QoS).
ACE_HANDLE accept (ACE_HANDLE handle,
struct sockaddr *addr,
int *addrlen);
#if !defined (ACE_HAS_WINCE)
/**
* QoS-enabled <accept>, which passes <qos_params> to <accept>. If
* the OS platform doesn't support QoS-enabled <accept> then the
* <qos_params> are ignored and the BSD-style <accept> is called.
*/
ACE_HANDLE accept (ACE_HANDLE handle,
struct sockaddr *addr,
int *addrlen,
const ACE_Accept_QoS_Params &qos_params);
#endif // ACE_HAS_WINCE
int bind (ACE_HANDLE s,
struct sockaddr *name,
int namelen);
// takes care of windows specific requirement to call closesocket
int closesocket (ACE_HANDLE s);
/// BSD-style <connect> (no QoS).
int connect (ACE_HANDLE handle,
struct sockaddr *addr,
int addrlen);
#if !defined (ACE_HAS_WINCE)
/**
* QoS-enabled <connect>, which passes <qos_params> to <connect>.
* If the OS platform doesn't support QoS-enabled <connect> then the
* <qos_params> are ignored and the BSD-style <connect> is called.
*/
int connect (ACE_HANDLE handle,
const sockaddr *addr,
int addrlen,
const ACE_QoS_Params &qos_params);
#endif // ACE_HAS_WINCE
/// Retrieve information about available transport protocols
/// installed on the local machine. Windows specific...
int enum_protocols (int *protocols,
ACE_Protocol_Info *protocol_buffer,
u_long *buffer_length);
int getpeername (ACE_HANDLE handle,
struct sockaddr *addr,
int *addrlen);
int getsockname (ACE_HANDLE handle,
struct sockaddr *addr,
int *addrlen);
int getsockopt (ACE_HANDLE handle,
int level,
int optname,
char *optval,
int *optlen);
#if !defined (ACE_HAS_WINCE)
/// Joins a leaf node into a QoS-enabled multi-point session.
ACE_HANDLE join_leaf (ACE_HANDLE socket,
const sockaddr *name,
int namelen,
const ACE_QoS_Params &qos_params);
#endif // ACE_HAS_WINCE
int listen (ACE_HANDLE handle,
int backlog);
int recv (ACE_HANDLE handle,
char *buf,
size_t len,
int flags = 0);
int recvfrom (ACE_HANDLE handle,
char *buf,
size_t len,
int flags,
struct sockaddr *addr,
int *addrlen);
int recvfrom (ACE_HANDLE handle,
iovec *buffers,
int buffer_count,
size_t &number_of_bytes_recvd,
int &flags,
struct sockaddr *addr,
int *addrlen,
ACE_OVERLAPPED *overlapped,
ACE_OVERLAPPED_COMPLETION_FUNC func);
int recvmsg (ACE_HANDLE handle,
struct msghdr *msg,
int flags);
ssize_t recvv (ACE_HANDLE handle,
iovec *iov,
int iovlen);
int send (ACE_HANDLE handle,
const char *buf,
size_t len,
int flags = 0);
int sendmsg (ACE_HANDLE handle,
const struct msghdr *msg,
int flags);
int sendto (ACE_HANDLE handle,
const char *buf,
size_t len,
int flags,
const struct sockaddr *addr,
int addrlen);
int sendto (ACE_HANDLE handle,
const iovec *buffers,
int buffer_count,
size_t &number_of_bytes_sent,
int flags,
const struct sockaddr *addr,
int addrlen,
ACE_OVERLAPPED *overlapped,
ACE_OVERLAPPED_COMPLETION_FUNC func);
ssize_t sendv (ACE_HANDLE handle,
const iovec *iov,
int iovcnt);
/// Manipulate the options associated with a socket.
int setsockopt (ACE_HANDLE handle,
int level,
int optname,
const char *optval,
int optlen);
int shutdown (ACE_HANDLE handle,
int how);
/// Initialize WinSock before first use (e.g., when a DLL is first
/// loaded or the first use of a socket() call.
int socket_init (int version_high = 1,
int version_low = 1);
/// Finalize WinSock after last use (e.g., when a DLL is unloaded).
int socket_fini (void);
/// Create a BSD-style socket (no QoS).
ACE_HANDLE socket (int protocol_family,
int type,
int proto);
/// Create a QoS-enabled socket. If the OS platform doesn't support
/// QoS-enabled <socket> then the BSD-style <socket> is called.
ACE_HANDLE socket (int protocol_family,
int type,
int proto,
ACE_Protocol_Info *protocolinfo,
ACE_SOCK_GROUP g,
u_long flags);
int socketpair (int domain,
int type,
int protocol,
ACE_HANDLE sv[2]);
} /* namespace ACE_OS */
# if defined (ACE_HAS_INLINED_OSCALLS)
# if defined (ACE_INLINE)
# undef ACE_INLINE
# endif /* ACE_INLINE */
# define ACE_INLINE inline
# include "ace/OS_NS_sys_socket.inl"
# endif /* ACE_HAS_INLINED_OSCALLS */
# include /**/ "ace/post.h"
#endif /* ACE_OS_NS_SYS_SOCKET_H */
|
