13 #include <sys/types.h>
14 #ifdef HAVE_SYS_SOCKET_H
15 # include <sys/socket.h>
16 # define OPTVAL_T(t) (t)
17 # define OPTVAL_GT(t) (t)
19 #ifdef HAVE_SYS_IOCTL_H
20 #include <sys/ioctl.h>
22 #ifdef HAVE_WS2TCPIP_H
24 # define OPTVAL_T(t) (const char*)(t)
25 # define OPTVAL_GT(t) (char*)(t)
27 # define CMSG_DATA WSA_CMSG_DATA
32 return !COAP_DISABLE_TCP;
54 sock->
fd = socket(server->
addr.
sa.sa_family, SOCK_STREAM, 0);
58 "coap_socket_connect_tcp1: socket: %s\n",
70 "coap_socket_connect_tcp1: ioctl FIONBIO: %s\n",
75 switch (server->
addr.
sa.sa_family) {
77 if (connect_addr.
addr.
sin.sin_port == 0)
78 connect_addr.
addr.
sin.sin_port = htons(default_port);
81 if (connect_addr.
addr.
sin6.sin6_port == 0)
82 connect_addr.
addr.
sin6.sin6_port = htons(default_port);
85 if (setsockopt(sock->
fd, IPPROTO_IPV6, IPV6_V6ONLY, OPTVAL_T(&off),
sizeof(off)) ==
COAP_SOCKET_ERROR)
87 "coap_socket_connect_tcp1: setsockopt IPV6_V6ONLY: %s\n",
96 if (local_if && local_if->
addr.
sa.sa_family) {
98 if (setsockopt(sock->
fd, SOL_SOCKET, SO_REUSEADDR, OPTVAL_T(&on),
sizeof(on)) ==
COAP_SOCKET_ERROR)
100 "coap_socket_connect_tcp1: setsockopt SO_REUSEADDR: %s\n",
102 if (bind(sock->
fd, &local_if->
addr.
sa,
103 local_if->
addr.
sa.sa_family == AF_INET ?
104 (socklen_t)
sizeof(
struct sockaddr_in) :
111 local_addr->
addr.
sa.sa_family = server->
addr.
sa.sa_family;
116 if (WSAGetLastError() == WSAEWOULDBLOCK) {
118 if (errno == EINPROGRESS) {
157 int optlen = (int)
sizeof( error );
159 socklen_t optlen = (socklen_t)
sizeof( error );
164 if (getsockopt(sock->
fd, SOL_SOCKET, SO_ERROR, OPTVAL_GT(&error),
172 "coap_socket_finish_connect_tcp: connect failed: %s\n",
203 sock->
fd = socket(listen_addr->
addr.
sa.sa_family, SOCK_STREAM, 0);
221 if (setsockopt (sock->
fd, SOL_SOCKET, SO_KEEPALIVE, OPTVAL_T(&on),
224 "coap_socket_bind_tcp: setsockopt SO_KEEPALIVE: %s\n",
227 if (setsockopt(sock->
fd, SOL_SOCKET, SO_REUSEADDR, OPTVAL_T(&on),
230 "coap_socket_bind_tcp: setsockopt SO_REUSEADDR: %s\n",
233 switch (listen_addr->
addr.
sa.sa_family) {
239 if (setsockopt(sock->
fd, IPPROTO_IPV6, IPV6_V6ONLY, OPTVAL_T(&off),
sizeof(off)) ==
COAP_SOCKET_ERROR)
241 "coap_socket_bind_tcp: setsockopt IPV6_V6ONLY: %s\n",
249 if (bind(sock->
fd, &listen_addr->
addr.
sa,
250 listen_addr->
addr.
sa.sa_family == AF_INET ?
251 (socklen_t)
sizeof(
struct sockaddr_in) :
258 bound_addr->
size = (socklen_t)
sizeof(*bound_addr);
259 if (getsockname(sock->
fd, &bound_addr->
addr.
sa, &bound_addr->
size) < 0) {
293 new_client->
fd = accept(server->
fd, &remote_addr->
addr.
sa,
301 if (getsockname( new_client->
fd, &local_addr->
addr.
sa, &local_addr->
size) < 0)
COAP_STATIC_INLINE void coap_address_copy(coap_address_t *dst, const coap_address_t *src)
Pulls together all the internal only header files.
void coap_socket_close(coap_socket_t *sock)
const char * coap_socket_strerror(void)
const char * coap_socket_format_errno(int error)
#define COAP_SOCKET_ERROR
#define COAP_SOCKET_CAN_ACCEPT
non blocking server socket can now accept without blocking
#define COAP_SOCKET_CAN_CONNECT
non blocking client socket can now connect without blocking
#define COAP_SOCKET_WANT_CONNECT
non blocking client socket is waiting for connect
#define COAP_SOCKET_CONNECTED
the socket is connected
#define COAP_INVALID_SOCKET
int coap_tcp_is_supported(void)
Check whether TCP is available.
#define coap_log(level,...)
Logging function.
int coap_socket_bind_tcp(coap_socket_t *sock, const coap_address_t *listen_addr, coap_address_t *bound_addr)
Create a new TCP socket and then listen for new incoming TCP sessions.
int coap_socket_connect_tcp1(coap_socket_t *sock, const coap_address_t *local_if, const coap_address_t *server, int default_port, coap_address_t *local_addr, coap_address_t *remote_addr)
Create a new TCP socket and initiate the connection.
int coap_socket_accept_tcp(coap_socket_t *server, coap_socket_t *new_client, coap_address_t *local_addr, coap_address_t *remote_addr)
Accept a new incoming TCP session.
int coap_socket_connect_tcp2(coap_socket_t *sock, coap_address_t *local_addr, coap_address_t *remote_addr)
Complete the TCP Connection.
multi-purpose address abstraction
socklen_t size
size of addr
union coap_address_t::@0 addr
coap_socket_flags_t flags