22#ifdef HAVE_SYS_SELECT_H
23# include <sys/select.h>
25#ifdef HAVE_SYS_SOCKET_H
26# include <sys/socket.h>
27# define OPTVAL_T(t) (t)
28# define OPTVAL_GT(t) (t)
30#ifdef HAVE_SYS_IOCTL_H
33#ifdef HAVE_NETINET_IN_H
34# include <netinet/in.h>
38# define OPTVAL_T(t) (const char*)(t)
39# define OPTVAL_GT(t) (char*)(t)
41# define CMSG_DATA WSA_CMSG_DATA
49#ifdef COAP_EPOLL_SUPPORT
51#include <sys/timerfd.h>
57#if !defined(WITH_CONTIKI) && !defined(RIOT_VERSION) && !(WITH_LWIP)
59#if defined(IP_PKTINFO)
60# define GEN_IP_PKTINFO IP_PKTINFO
61#elif defined(IP_RECVDSTADDR)
62# define GEN_IP_PKTINFO IP_RECVDSTADDR
64# error "Need IP_PKTINFO or IP_RECVDSTADDR to request ancillary data from OS."
68#ifdef IPV6_RECVPKTINFO
69# define GEN_IPV6_PKTINFO IPV6_RECVPKTINFO
70#elif defined(IPV6_PKTINFO)
71# define GEN_IPV6_PKTINFO IPV6_PKTINFO
73# error "Need IPV6_PKTINFO or IPV6_RECVPKTINFO to request ancillary data from OS."
77#if COAP_SERVER_SUPPORT
89#if !defined(WITH_CONTIKI) && !defined(WITH_LWIP)
98 struct timeval timeout = {0, 0};
104 sock->
fd = socket(listen_addr->
addr.
sa.sa_family, SOCK_DGRAM, 0);
119 if (setsockopt(sock->
fd, SOL_SOCKET, SO_REUSEADDR, OPTVAL_T(&on),
sizeof(on)) ==
COAP_SOCKET_ERROR)
120 coap_log_warn(
"coap_socket_bind_udp: setsockopt SO_REUSEADDR: %s\n",
123 switch (listen_addr->
addr.
sa.sa_family) {
126 if (setsockopt(sock->
fd, IPPROTO_IP, GEN_IP_PKTINFO, OPTVAL_T(&on),
128 coap_log_alert(
"coap_socket_bind_udp: setsockopt IP_PKTINFO: %s\n",
134 if (setsockopt(sock->
fd, IPPROTO_IPV6, IPV6_V6ONLY, OPTVAL_T(&off),
136 coap_log_alert(
"coap_socket_bind_udp: setsockopt IPV6_V6ONLY: %s\n",
138#if !defined(ESPIDF_VERSION)
139 if (setsockopt(sock->
fd, IPPROTO_IPV6, GEN_IPV6_PKTINFO, OPTVAL_T(&on),
141 coap_log_alert(
"coap_socket_bind_udp: setsockopt IPV6_PKTINFO: %s\n",
144 setsockopt(sock->
fd, IPPROTO_IP, GEN_IP_PKTINFO, OPTVAL_T(&on),
sizeof(on));
148#if COAP_AF_UNIX_SUPPORT
157 if (setsockopt(sock->
fd, SOL_SOCKET, SO_RCVTIMEO, OPTVAL_T(&timeout),
159 coap_log_alert(
"coap_socket_bind_udp: setsockopt SO_RCVTIMEO: %s\n",
163 if (bind(sock->
fd, &listen_addr->
addr.
sa,
165 listen_addr->
addr.
sa.sa_family == AF_INET ?
166 (socklen_t)
sizeof(
struct sockaddr_in) :
174 bound_addr->
size = (socklen_t)
sizeof(*bound_addr);
175 if (getsockname(sock->
fd, &bound_addr->
addr.
sa, &bound_addr->
size) < 0) {
180#if defined(RIOT_VERSION) && defined(COAP_SERVER_SUPPORT)
182 bound_addr->
addr.
sa.sa_family == AF_INET6) {
183 bound_addr->
addr.
sin6.sin6_scope_id =
184 listen_addr->
addr.
sin6.sin6_scope_id;
185 bound_addr->
addr.
sin6.sin6_flowinfo = 0;
196#if COAP_CLIENT_SUPPORT
210 struct timeval timeout = {0, 0};
216#if !defined(RIOT_VERSION)
222 sock->
fd = socket(connect_addr.
addr.
sa.sa_family, SOCK_DGRAM, 0);
237 coap_log_warn(
"coap_socket_connect_udp: ioctl FIONBIO: %s\n",
242 switch (connect_addr.
addr.
sa.sa_family) {
245 if (connect_addr.
addr.
sin.sin_port == 0)
246 connect_addr.
addr.
sin.sin_port = htons(default_port);
251 if (connect_addr.
addr.
sin6.sin6_port == 0)
252 connect_addr.
addr.
sin6.sin6_port = htons(default_port);
255 if (setsockopt(sock->
fd, IPPROTO_IPV6, IPV6_V6ONLY, OPTVAL_T(&off),
257 coap_log_warn(
"coap_socket_connect_udp: setsockopt IPV6_V6ONLY: %s\n",
262#if COAP_AF_UNIX_SUPPORT
267 coap_log_alert(
"coap_socket_connect_udp: unsupported sa_family %d\n",
268 connect_addr.
addr.
sa.sa_family);
272 if (local_if && local_if->
addr.
sa.sa_family) {
273 if (local_if->
addr.
sa.sa_family != connect_addr.
addr.
sa.sa_family) {
274 coap_log_warn(
"coap_socket_connect_udp: local address family != "
275 "remote address family\n");
279 if (setsockopt(sock->
fd, SOL_SOCKET, SO_REUSEADDR, OPTVAL_T(&on),
sizeof(on)) ==
COAP_SOCKET_ERROR)
280 coap_log_warn(
"coap_socket_connect_udp: setsockopt SO_REUSEADDR: %s\n",
283 if (bind(sock->
fd, &local_if->
addr.
sa,
285 local_if->
addr.
sa.sa_family == AF_INET ?
286 (socklen_t)
sizeof(
struct sockaddr_in) :
293#if COAP_AF_UNIX_SUPPORT
294 }
else if (connect_addr.
addr.
sa.sa_family == AF_UNIX) {
296 coap_log_warn(
"coap_socket_connect_udp: local address required\n");
302#if !defined(RIOT_VERSION)
304 if (!(local_if && local_if->
addr.
sa.sa_family)) {
309 bind_addr.
addr.
sa.sa_family = connect_addr.
addr.
sa.sa_family;
310 if (bind(sock->
fd, &bind_addr.
addr.
sa,
312 bind_addr.
addr.
sa.sa_family == AF_INET ?
313 (socklen_t)
sizeof(
struct sockaddr_in) :
322 coap_log_warn(
"coap_socket_connect_udp: getsockname for multicast socket: %s\n",
329 setsockopt(sock->
fd, SOL_SOCKET, SO_BROADCAST, OPTVAL_T(&on),
331 coap_log_warn(
"coap_socket_connect_udp: setsockopt SO_BROADCAST: %s\n",
336 if (!(local_if && local_if->
addr.
sa.sa_family)) {
341 bind_addr.
addr.
sa.sa_family = connect_addr.
addr.
sa.sa_family;
343 if (bind_addr.
addr.
sa.sa_family == AF_INET6)
346 if (bind(sock->
fd, &bind_addr.
addr.
sa,
347 bind_addr.
addr.
sa.sa_family == AF_INET ?
348 (socklen_t)
sizeof(
struct sockaddr_in) :
355 if (setsockopt(sock->
fd, SOL_SOCKET, SO_RCVTIMEO, OPTVAL_T(&timeout),
357 coap_log_alert(
"coap_socket_bind_udp: setsockopt SO_RCVTIMEO: %s\n",
362#if COAP_AF_UNIX_SUPPORT
363 if (connect_addr.
addr.
sa.sa_family == AF_UNIX) {
397#ifdef COAP_EPOLL_SUPPORT
398#if COAP_SERVER_SUPPORT
404 if (context != NULL) {
406 struct epoll_event event;
409 ret = epoll_ctl(context->epfd, EPOLL_CTL_DEL, sock->
fd, &event);
410 if (ret == -1 && errno != ENOENT) {
416#if COAP_SERVER_SUPPORT
417#if COAP_AF_UNIX_SUPPORT
426#if COAP_CLIENT_SUPPORT
427#if COAP_AF_UNIX_SUPPORT
443#ifdef COAP_EPOLL_SUPPORT
449 struct epoll_event event;
452#if COAP_MAX_LOGGING_LEVEL < _COAP_LOG_ERR
459#if COAP_SERVER_SUPPORT
469 memset(&event, 0,
sizeof(event));
470 event.events = events;
471 event.data.ptr = sock;
473 ret = epoll_ctl(context->epfd, EPOLL_CTL_ADD, sock->
fd, &event);
486 struct epoll_event event;
489#if COAP_MAX_LOGGING_LEVEL < _COAP_LOG_ERR
496#if COAP_SERVER_SUPPORT
505 event.events = events;
506 event.data.ptr = sock;
508 ret = epoll_ctl(context->epfd, EPOLL_CTL_MOD, sock->
fd, &event);
510#if (COAP_MAX_LOGGING_LEVEL < COAP_LOG_ERR)
521 if (context->eptimerfd != -1) {
525 if (context->next_timeout == 0 || context->next_timeout > now + delay) {
526 struct itimerspec new_value;
529 context->next_timeout = now + delay;
530 memset(&new_value, 0,
sizeof(new_value));
532 new_value.it_value.tv_nsec = 1;
538 ret = timerfd_settime(context->eptimerfd, 0, &new_value, NULL);
541 "coap_resource_notify_observers",
544#ifdef COAP_DEBUG_WAKEUP_TIMES
547 new_value.it_value.tv_sec, new_value.it_value.tv_nsec);
558coap_win_error_to_errno(
void) {
559 int w_error = WSAGetLastError();
561 case WSA_NOT_ENOUGH_MEMORY:
564 case WSA_INVALID_PARAMETER:
597 case WSAECONNABORTED:
598 errno = ECONNABORTED;
609 case WSAECONNREFUSED:
610 errno = ECONNREFUSED;
613 coap_log_err(
"WSAGetLastError: %d mapping to errno failed - please fix\n",
633 r = send(sock->
fd, (
const char *)data, (
int)data_len, 0);
636#define MSG_NOSIGNAL 0
642 coap_win_error_to_errno();
645#
if EAGAIN != EWOULDBLOCK
646 errno == EWOULDBLOCK ||
650#ifdef COAP_EPOLL_SUPPORT
659 if (errno == EPIPE || errno == ECONNRESET) {
668 if (r < (ssize_t)data_len) {
670#ifdef COAP_EPOLL_SUPPORT
691 r = recv(sock->
fd, (
char *)data, (
int)data_len, 0);
693 r = recv(sock->
fd, data, data_len, 0);
697 sock->
flags &= ~COAP_SOCKET_CAN_READ;
701 sock->
flags &= ~COAP_SOCKET_CAN_READ;
703 coap_win_error_to_errno();
706#
if EAGAIN != EWOULDBLOCK
707 errno == EWOULDBLOCK ||
712 if (errno != ECONNRESET) {
718 if (r < (ssize_t)data_len)
719 sock->
flags &= ~COAP_SOCKET_CAN_READ;
725#if !defined(WITH_LWIP)
726#if (!defined(WITH_CONTIKI)) != ( defined(HAVE_NETINET_IN_H) || defined(HAVE_WS2TCPIP_H) )
730#if !defined(__MINGW32__)
745#if !defined(WITH_CONTIKI) && !defined(SOL_IP)
747#define SOL_IP IPPROTO_IP
750#define COAP_SOL_IP IPPROTO_IP
752#define COAP_SOL_IP SOL_IP
757#if !defined(__MINGW32__)
758static __declspec(thread) LPFN_WSARECVMSG lpWSARecvMsg = NULL;
761#define msghdr _WSAMSG
763#define msg_namelen namelen
764#define msg_iov lpBuffers
765#define msg_iovlen dwBufferCount
766#define msg_control Control.buf
767#define msg_controllen Control.len
771#define iov_len_t u_long
773#define CMSG_DATA WSA_CMSG_DATA
774#define ipi_spec_dst ipi_addr
775#if !defined(__MINGW32__)
776#pragma warning( disable : 4116 )
779#define iov_len_t size_t
782#if defined(_CYGWIN_ENV)
783#define ipi_spec_dst ipi_addr
786#if !defined(RIOT_VERSION) && !defined(WITH_LWIP) && !defined(WITH_CONTIKI)
794 const uint8_t *data,
size_t datalen) {
795 ssize_t bytes_written = 0;
798 bytes_written = (ssize_t)datalen;
801 bytes_written = send(sock->
fd, (
const char *)data, (
int)datalen, 0);
803 bytes_written = send(sock->
fd, data, datalen, 0);
806#if defined(_WIN32) && !defined(__MINGW32__)
807 DWORD dwNumberOfBytesSent = 0;
810#ifdef HAVE_STRUCT_CMSGHDR
819 memcpy(&iov[0].iov_base, &data,
sizeof(iov[0].iov_base));
822 memset(buf, 0,
sizeof(buf));
824 memset(&mhdr, 0,
sizeof(
struct msghdr));
825 memcpy(&mhdr.msg_name, &addr,
sizeof(mhdr.msg_name));
827 (socklen_t)
sizeof(
struct sockaddr_in) :
838 struct cmsghdr *cmsg;
842#if defined(IP_PKTINFO)
844 mhdr.msg_control = buf;
845 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_pktinfo));
847 cmsg = CMSG_FIRSTHDR(&mhdr);
849 cmsg->cmsg_type = IP_PKTINFO;
850 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_pktinfo));
852 pktinfo = (
struct in_pktinfo *)CMSG_DATA(cmsg);
858#elif defined(IP_SENDSRCADDR)
859 mhdr.msg_control = buf;
860 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_addr));
862 cmsg = CMSG_FIRSTHDR(&mhdr);
863 cmsg->cmsg_level = IPPROTO_IP;
864 cmsg->cmsg_type = IP_SENDSRCADDR;
865 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_addr));
867 memcpy(CMSG_DATA(cmsg),
869 sizeof(
struct in_addr));
874 mhdr.msg_control = buf;
875 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in6_pktinfo));
877 cmsg = CMSG_FIRSTHDR(&mhdr);
878 cmsg->cmsg_level = IPPROTO_IPV6;
879 cmsg->cmsg_type = IPV6_PKTINFO;
880 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in6_pktinfo));
896#if defined(IP_PKTINFO)
897 struct cmsghdr *cmsg;
900 mhdr.msg_control = buf;
901 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_pktinfo));
903 cmsg = CMSG_FIRSTHDR(&mhdr);
905 cmsg->cmsg_type = IP_PKTINFO;
906 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_pktinfo));
908 pktinfo = (
struct in_pktinfo *)CMSG_DATA(cmsg);
914#elif defined(IP_SENDSRCADDR)
915 struct cmsghdr *cmsg;
916 mhdr.msg_control = buf;
917 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_addr));
919 cmsg = CMSG_FIRSTHDR(&mhdr);
920 cmsg->cmsg_level = IPPROTO_IP;
921 cmsg->cmsg_type = IP_SENDSRCADDR;
922 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_addr));
924 memcpy(CMSG_DATA(cmsg),
926 sizeof(
struct in_addr));
931#if COAP_AF_UNIX_SUPPORT
943#if defined(_WIN32) && !defined(__MINGW32__)
944 r = WSASendMsg(sock->
fd, &mhdr, 0 , &dwNumberOfBytesSent, NULL ,
947 bytes_written = (ssize_t)dwNumberOfBytesSent;
950 coap_win_error_to_errno();
953#ifdef HAVE_STRUCT_CMSGHDR
954 bytes_written = sendmsg(sock->
fd, &mhdr, 0);
956 bytes_written = sendto(sock->
fd, (
const void *)data, datalen, 0,
963 if (bytes_written < 0)
966 return bytes_written;
970#define SIN6(A) ((struct sockaddr_in6 *)(A))
978#if !defined(WITH_LWIP) && !defined(WITH_CONTIKI)
996 sock->
flags &= ~COAP_SOCKET_CAN_READ;
1007 coap_win_error_to_errno();
1009 if (errno == ECONNREFUSED || errno == EHOSTUNREACH || errno == ECONNRESET) {
1022 }
else if (len > 0) {
1023 packet->
length = (size_t)len;
1026#if defined(_WIN32) && !defined(__MINGW32__)
1027 DWORD dwNumberOfBytesRecvd = 0;
1030#ifdef HAVE_STRUCT_CMSGHDR
1033 struct cmsghdr *cmsg;
1035 struct iovec iov[1];
1037 iov[0].iov_base = packet->
payload;
1040 memset(&mhdr, 0,
sizeof(
struct msghdr));
1046 mhdr.msg_iovlen = 1;
1048 mhdr.msg_control = buf;
1049 mhdr.msg_controllen =
sizeof(buf);
1052 cmsg = (
struct cmsghdr *)buf;
1053 cmsg->cmsg_len = CMSG_LEN(
sizeof(buf));
1054 cmsg->cmsg_level = -1;
1055 cmsg->cmsg_type = -1;
1058 if (!lpWSARecvMsg) {
1059 GUID wsaid = WSAID_WSARECVMSG;
1060 DWORD cbBytesReturned = 0;
1061 if (WSAIoctl(sock->
fd, SIO_GET_EXTENSION_FUNCTION_POINTER, &wsaid,
sizeof(wsaid), &lpWSARecvMsg,
1062 sizeof(lpWSARecvMsg), &cbBytesReturned, NULL, NULL) != 0) {
1067 r = lpWSARecvMsg(sock->
fd, &mhdr, &dwNumberOfBytesRecvd, NULL ,
1070 len = (ssize_t)dwNumberOfBytesRecvd;
1072 coap_win_error_to_errno();
1074 len = recvmsg(sock->
fd, &mhdr, 0);
1081#if defined(RIOT_VERSION) && defined(COAP_SERVER_SUPPORT) && COAP_IPV6_SUPPORT
1093 coap_win_error_to_errno();
1095 if (errno == ECONNREFUSED || errno == EHOSTUNREACH || errno == ECONNRESET) {
1106#ifdef HAVE_STRUCT_CMSGHDR
1110 packet->
length = (size_t)len;
1114 for (cmsg = CMSG_FIRSTHDR(&mhdr); cmsg; cmsg = CMSG_NXTHDR(&mhdr, cmsg)) {
1116#if COAP_IPV6_SUPPORT
1118 if (cmsg->cmsg_level == IPPROTO_IPV6 && cmsg->cmsg_type == IPV6_PKTINFO) {
1123 u.c = CMSG_DATA(cmsg);
1124 packet->
ifindex = (int)(u.p->ipi6_ifindex);
1126 &u.p->ipi6_addr,
sizeof(
struct in6_addr));
1132#if COAP_IPV4_SUPPORT
1134#if defined(IP_PKTINFO)
1135 if (cmsg->cmsg_level ==
COAP_SOL_IP && cmsg->cmsg_type == IP_PKTINFO) {
1140 u.c = CMSG_DATA(cmsg);
1141 packet->
ifindex = u.p->ipi_ifindex;
1142#if COAP_IPV6_SUPPORT
1148 &u.p->ipi_addr,
sizeof(
struct in_addr));
1153 &u.p->ipi_addr,
sizeof(
struct in_addr));
1159#if defined(IP_RECVDSTADDR)
1160 if (cmsg->cmsg_level == IPPROTO_IP && cmsg->cmsg_type == IP_RECVDSTADDR) {
1163 CMSG_DATA(cmsg),
sizeof(
struct in_addr));
1172 if (cmsg->cmsg_level != -1 && cmsg->cmsg_type != -1) {
1173 coap_log_debug(
"cmsg_level = %d and cmsg_type = %d not supported - fix\n",
1174 cmsg->cmsg_level, cmsg->cmsg_type);
1188 packet->
length = (size_t)len;
1195#if defined(RIOT_VERSION) && defined(COAP_SERVER_SUPPORT) && COAP_IPV6_SUPPORT
1216#ifndef COAP_EPOLL_SUPPORT
1219 coap_log_emerg(
"coap_io_prepare_epoll() requires libcoap compiled for using epoll\n");
1223 unsigned int max_sockets =
sizeof(sockets)/
sizeof(sockets[0]);
1224 unsigned int num_sockets;
1225 unsigned int timeout;
1230 ctx->next_timeout = timeout ? now + timeout : 0;
1231 if (ctx->eptimerfd != -1) {
1232 struct itimerspec new_value;
1235 memset(&new_value, 0,
sizeof(new_value));
1237 if (ctx->next_timeout != 0 && ctx->next_timeout > now) {
1238 coap_tick_t rem_timeout = ctx->next_timeout - now;
1244#ifdef COAP_DEBUG_WAKEUP_TIMES
1246 new_value.it_value.tv_sec, new_value.it_value.tv_nsec);
1249 ret = timerfd_settime(ctx->eptimerfd, 0, &new_value, NULL);
1252 "coap_io_prepare_epoll",
1267 unsigned int max_sockets,
1268 unsigned int *num_sockets,
1274#if COAP_SERVER_SUPPORT
1275 int check_dtls_timeouts = 0;
1277#if defined(COAP_EPOLL_SUPPORT) || defined(WITH_LWIP)
1284#if COAP_SERVER_SUPPORT
1288#if COAP_ASYNC_SUPPORT
1290 timeout = coap_check_async(ctx, now);
1301 if (nextpdu && (timeout == 0 ||
1309 if (tls_timeout > 0) {
1314 if (timeout == 0 || tls_timeout - now < timeout)
1315 timeout = tls_timeout - now;
1317#if COAP_SERVER_SUPPORT
1319 check_dtls_timeouts = 1;
1323#if COAP_SERVER_SUPPORT
1333#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITH_LWIP)
1335 if (*num_sockets < max_sockets)
1336 sockets[(*num_sockets)++] = &ep->
sock;
1350 s_timeout = (s->
last_rx_tx + session_timeout) - now;
1351 if (timeout == 0 || s_timeout < timeout)
1352 timeout = s_timeout;
1360 while (tls_timeout > 0 && tls_timeout <= now) {
1373 if (tls_timeout > 0 && (timeout == 0 || tls_timeout - now < timeout))
1374 timeout = tls_timeout - now;
1379 if (timeout == 0 || s_timeout < timeout)
1380 timeout = s_timeout;
1386 if (timeout == 0 || s_timeout < timeout)
1387 timeout = s_timeout;
1390#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITH_LWIP)
1392 if (*num_sockets < max_sockets)
1393 sockets[(*num_sockets)++] = &s->
sock;
1396#if COAP_Q_BLOCK_SUPPORT
1402 s_timeout = coap_block_check_q_block2_xmit(s, now);
1403 if (timeout == 0 || s_timeout < timeout)
1404 timeout = s_timeout;
1413#if COAP_CLIENT_SUPPORT
1430 if (timeout == 0 || s_timeout < timeout)
1431 timeout = s_timeout;
1434#if !COAP_DISABLE_TCP
1447 if (timeout == 0 || s_timeout < timeout)
1448 timeout = s_timeout;
1458 while (tls_timeout > 0 && tls_timeout <= now) {
1470 if (tls_timeout > 0 && (timeout == 0 || tls_timeout - now < timeout))
1471 timeout = tls_timeout - now;
1477 if (timeout == 0 || s_timeout < timeout)
1478 timeout = s_timeout;
1484 if (timeout == 0 || s_timeout < timeout)
1485 timeout = s_timeout;
1488#if COAP_Q_BLOCK_SUPPORT
1494 s_timeout = coap_block_check_q_block1_xmit(s, now);
1495 if (timeout == 0 || s_timeout < timeout)
1496 timeout = s_timeout;
1500#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITHLWIP)
1505 if (*num_sockets < max_sockets)
1506 sockets[(*num_sockets)++] = &s->
sock;
1517#if !defined(WITH_LWIP) && !defined(CONTIKI)
1525 int enfds, fd_set *ereadfds, fd_set *ewritefds,
1526 fd_set *eexceptfds) {
1529 unsigned int timeout;
1530#ifndef COAP_EPOLL_SUPPORT
1538#ifndef COAP_EPOLL_SUPPORT
1543 if (timeout == 0 || timeout_ms < timeout)
1544 timeout = timeout_ms;
1571#if !COAP_DISABLE_TCP
1585 }
else if (timeout > 0) {
1586 tv.tv_usec = (timeout % 1000) * 1000;
1587 tv.tv_sec = (long)(timeout / 1000);
1591 timeout > 0 ? &tv : NULL);
1595 coap_win_error_to_errno();
1597 if (errno != EINTR) {
1617#if !COAP_DISABLE_TCP
1643 if (timeout == 0 || timeout_ms < timeout)
1644 timeout = timeout_ms;
1648 int etimeout = timeout;
1656 }
else if (etimeout < 0) {
1663 if (errno != EINTR) {
1664 coap_log_err(
"epoll_wait: unexpected error: %s (%d)\n",
1683#if COAP_SERVER_SUPPORT
1687#if COAP_ASYNC_SUPPORT
1690 coap_check_async(ctx, now);
1705#if COAP_SERVER_SUPPORT
1716#if COAP_SERVER_SUPPORT
1717 LL_FOREACH(context->
endpoint, ep) {
1728#if COAP_CLIENT_SUPPORT
1744 static char szError[256];
1745 if (FormatMessage(FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS,
1746 NULL, (DWORD)error, MAKELANGID(LANG_NEUTRAL,
1747 SUBLANG_DEFAULT), (LPSTR)szError, (DWORD)
sizeof(szError),
1749 strcpy(szError,
"Unknown error");
1760 return strerror(error);
int coap_is_bcast(const coap_address_t *a)
Checks if given address a denotes a broadcast address.
void coap_address_init(coap_address_t *addr)
Resets the given coap_address_t object addr to its default values.
int coap_is_mcast(const coap_address_t *a)
Checks if given address a denotes a multicast address.
void coap_address_copy(coap_address_t *dst, const coap_address_t *src)
COAP_STATIC_INLINE int coap_address_isany(const coap_address_t *a)
Checks if given address object a denotes the wildcard address.
int coap_debug_send_packet(void)
Check to see whether a packet should be sent or not.
Pulls together all the internal only header files.
#define COAP_IPV4_SUPPORT
const char * coap_socket_format_errno(int error)
ssize_t coap_socket_read(coap_socket_t *sock, uint8_t *data, size_t data_len)
Function interface for data stream receiving off a socket.
void coap_socket_close(coap_socket_t *sock)
Function interface to close off a socket.
ssize_t coap_socket_send(coap_socket_t *sock, const coap_session_t *session, const uint8_t *data, size_t datalen)
Function interface for data transmission.
const char * coap_socket_strerror(void)
ssize_t coap_socket_recv(coap_socket_t *sock, coap_packet_t *packet)
Function interface for reading data.
void coap_packet_get_memmapped(coap_packet_t *packet, unsigned char **address, size_t *length)
Given a packet, set msg and msg_len to an address and length of the packet's data in memory.
ssize_t coap_socket_write(coap_socket_t *sock, const uint8_t *data, size_t data_len)
Function interface for data stream sending off a socket.
int coap_socket_bind_udp(coap_socket_t *sock, const coap_address_t *listen_addr, coap_address_t *bound_addr)
#define COAP_MAX_EPOLL_EVENTS
#define COAP_RXBUFFER_SIZE
#define COAP_SOCKET_ERROR
@ COAP_NACK_NOT_DELIVERABLE
#define COAP_INVALID_SOCKET
#define COAP_SOCKET_MULTICAST
socket is used for multicast communication
void coap_epoll_ctl_add(coap_socket_t *sock, uint32_t events, const char *func)
Epoll specific function to add the state of events that epoll is to track for the appropriate file de...
int coap_socket_connect_udp(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)
#define COAP_SOCKET_WANT_ACCEPT
non blocking server socket is waiting for accept
#define COAP_SOCKET_CAN_WRITE
non blocking socket can now write without blocking
void coap_update_epoll_timer(coap_context_t *context, coap_tick_t delay)
Update the epoll timer fd as to when it is to trigger.
#define COAP_SOCKET_WANT_READ
non blocking socket is waiting for reading
#define COAP_SOCKET_CAN_ACCEPT
non blocking server socket can now accept without blocking
#define COAP_SOCKET_WANT_WRITE
non blocking socket is waiting for writing
#define COAP_SOCKET_CAN_CONNECT
non blocking client socket can now connect without blocking
coap_endpoint_t * coap_malloc_endpoint(void)
void coap_epoll_ctl_mod(coap_socket_t *sock, uint32_t events, const char *func)
Epoll specific function to modify the state of events that epoll is tracking on the appropriate file ...
#define COAP_SOCKET_WANT_CONNECT
non blocking client socket is waiting for connect
void coap_mfree_endpoint(coap_endpoint_t *ep)
#define COAP_SOCKET_CAN_READ
non blocking socket can now read without blocking
#define COAP_SOCKET_CONNECTED
the socket is connected
#define COAP_SOCKET_EMPTY
coap_socket_flags_t values
void * coap_malloc_type(coap_memory_tag_t type, size_t size)
Allocates a chunk of size bytes and returns a pointer to the newly allocated memory.
void coap_free_type(coap_memory_tag_t type, void *p)
Releases the memory that was allocated by coap_malloc_type().
coap_tick_t coap_dtls_get_timeout(coap_session_t *session COAP_UNUSED, coap_tick_t now COAP_UNUSED)
coap_tick_t coap_dtls_get_context_timeout(void *dtls_context COAP_UNUSED)
int coap_dtls_handle_timeout(coap_session_t *session COAP_UNUSED)
coap_mid_t coap_session_send_ping(coap_session_t *session)
Send a ping message for the session.
#define SESSIONS_ITER_SAFE(e, el, rtmp)
#define SESSIONS_ITER(e, el, rtmp)
#define COAP_DEFAULT_SESSION_TIMEOUT
void coap_io_do_io(coap_context_t *ctx, coap_tick_t now)
Processes any outstanding read, write, accept or connect I/O as indicated in the coap_socket_t struct...
unsigned int coap_io_prepare_epoll(coap_context_t *ctx, coap_tick_t now)
Any now timed out delayed packet is transmitted, along with any packets associated with requested obs...
void coap_io_do_epoll(coap_context_t *ctx, struct epoll_event *events, size_t nevents)
Process all the epoll events.
unsigned int coap_io_prepare_io(coap_context_t *ctx, coap_socket_t *sockets[], unsigned int max_sockets, unsigned int *num_sockets, coap_tick_t now)
Iterates through all the coap_socket_t structures embedded in endpoints or sessions associated with t...
int coap_io_process(coap_context_t *ctx, uint32_t timeout_ms)
The main I/O processing function.
int coap_io_process_with_fds(coap_context_t *ctx, uint32_t timeout_ms, int enfds, fd_set *ereadfds, fd_set *ewritefds, fd_set *eexceptfds)
The main message processing loop with additional fds for internal select.
int coap_io_pending(coap_context_t *context)
Check to see if there is any i/o pending for the context.
int coap_block_check_lg_crcv_timeouts(coap_session_t *session, coap_tick_t now, coap_tick_t *tim_rem)
int coap_block_check_lg_srcv_timeouts(coap_session_t *session, coap_tick_t now, coap_tick_t *tim_rem)
int coap_block_check_lg_xmit_timeouts(coap_session_t *session, coap_tick_t now, coap_tick_t *tim_rem)
void coap_expire_cache_entries(coap_context_t *context)
Expire coap_cache_entry_t entries.
uint64_t coap_tick_t
This data type represents internal timer ticks with COAP_TICKS_PER_SECOND resolution.
#define COAP_TICKS_PER_SECOND
Use ms resolution on POSIX systems.
coap_queue_t * coap_peek_next(coap_context_t *context)
Returns the next pdu to send without removing from sendqeue.
coap_queue_t * coap_pop_next(coap_context_t *context)
Returns the next pdu to send and removes it from the sendqeue.
coap_mid_t coap_retransmit(coap_context_t *context, coap_queue_t *node)
Handles retransmissions of confirmable messages.
int coap_handle_event(coap_context_t *context, coap_event_t event, coap_session_t *session)
Invokes the event handler of context for the given event and data.
void coap_ticks(coap_tick_t *)
Returns the current value of an internal tick counter.
int coap_dtls_is_context_timeout(void)
Check if timeout is handled per CoAP session or per CoAP context.
@ COAP_EVENT_SERVER_SESSION_DEL
Called in the CoAP IO loop if a server session is deleted (e.g., due to inactivity or because the max...
@ COAP_EVENT_KEEPALIVE_FAILURE
Triggered when no response to a keep alive (ping) packet.
#define coap_log_debug(...)
#define coap_log_alert(...)
#define coap_log_emerg(...)
const char * coap_session_str(const coap_session_t *session)
Get session description.
#define coap_log_info(...)
#define coap_log_warn(...)
#define coap_log_err(...)
#define coap_log_crit(...)
#define COAP_INVALID_MID
Indicates an invalid message id.
void coap_session_free(coap_session_t *session)
#define COAP_PROTO_RELIABLE(p)
void coap_session_release(coap_session_t *session)
Decrement reference counter on a session.
void coap_session_disconnected(coap_session_t *session, coap_nack_reason_t reason)
Notify session that it has failed.
coap_session_t * coap_session_reference(coap_session_t *session)
Increment reference counter on a session.
@ COAP_SESSION_TYPE_SERVER
server-side
@ COAP_SESSION_TYPE_CLIENT
client-side
@ COAP_SESSION_STATE_HANDSHAKE
@ COAP_SESSION_STATE_ESTABLISHED
@ COAP_SESSION_STATE_NONE
void coap_check_notify(coap_context_t *context)
Checks all known resources to see if they are dirty and then notifies subscribed observers.
coap_address_t remote
remote address and port
coap_address_t local
local address and port
Multi-purpose address abstraction.
socklen_t size
size of addr
struct coap_sockaddr_un cun
union coap_address_t::@0 addr
The CoAP stack's global state is stored in a coap_context_t object.
coap_tick_t sendqueue_basetime
The time stamp in the first element of the sendqeue is relative to sendqueue_basetime.
coap_socket_t * sockets[64]
Track different socket information in coap_io_process_with_fds.
unsigned int csm_timeout
Timeout for waiting for a CSM from the remote side.
unsigned int num_sockets
Number of sockets being tracked.
coap_session_t * sessions
client sessions
fd_set exceptfds
Used for select call in coap_io_process_with_fds()
unsigned int ping_timeout
Minimum inactivity time before sending a ping message.
coap_endpoint_t * endpoint
the endpoints used for listening
unsigned int session_timeout
Number of seconds of inactivity after which an unused session will be closed.
Abstraction of virtual endpoint that can be attached to coap_context_t.
coap_context_t * context
endpoint's context
coap_session_t * sessions
hash table or list of active sessions
coap_address_t bind_addr
local interface address
coap_socket_t sock
socket object for the interface, if any
size_t length
length of payload
coap_addr_tuple_t addr_info
local and remote addresses
unsigned char * payload
payload
int ifindex
the interface index
coap_tick_t t
when to send PDU for the next time
Abstraction of virtual session that can be attached to coap_context_t (client) or coap_endpoint_t (se...
coap_lg_xmit_t * lg_xmit
list of large transmissions
coap_socket_t sock
socket object for the session, if any
coap_session_state_t state
current state of relationship with peer
coap_addr_tuple_t addr_info
remote/local address info
coap_proto_t proto
protocol used
unsigned ref
reference count from queues
void * tls
security parameters
coap_queue_t * delayqueue
list of delayed messages waiting to be sent
coap_mid_t last_ping_mid
the last keepalive message id that was used in this session
coap_lg_srcv_t * lg_srcv
Server list of expected large receives.
coap_lg_crcv_t * lg_crcv
Client list of expected large receives.
coap_session_type_t type
client or server side socket
coap_context_t * context
session's context
int ifindex
interface index
char sun_path[COAP_UNIX_PATH_MAX]
coap_session_t * session
Used to determine session owner.
coap_endpoint_t * endpoint
Used by the epoll logic for a listening endpoint.
coap_address_t mcast_addr
remote address and port (multicast track)
coap_socket_flags_t flags
1 or more of COAP_SOCKET* flag values
struct in6_addr ipi6_addr
unsigned int ipi6_ifindex
struct in_addr ipi_spec_dst