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
52#ifdef COAP_EPOLL_SUPPORT
54#include <sys/timerfd.h>
60#if !defined(WITH_CONTIKI) && !defined(RIOT_VERSION) && !defined(WITH_LWIP)
62#if defined(IP_PKTINFO)
63# define GEN_IP_PKTINFO IP_PKTINFO
64#elif defined(IP_RECVDSTADDR)
65# define GEN_IP_PKTINFO IP_RECVDSTADDR
67# error "Need IP_PKTINFO or IP_RECVDSTADDR to request ancillary data from OS."
71#ifdef IPV6_RECVPKTINFO
72# define GEN_IPV6_PKTINFO IPV6_RECVPKTINFO
73#elif defined(IPV6_PKTINFO)
74# define GEN_IPV6_PKTINFO IPV6_PKTINFO
76# error "Need IPV6_PKTINFO or IPV6_RECVPKTINFO to request ancillary data from OS."
80#if COAP_SERVER_SUPPORT
92#if defined(__MINGW32__)
93#if(_WIN32_WINNT >= 0x0600)
94#define CMSG_FIRSTHDR WSA_CMSG_FIRSTHDR
95#define CMSG_NXTHDR WSA_CMSG_NXTHDR
96#define CMSG_LEN WSA_CMSG_LEN
97#define CMSG_SPACE WSA_CMSG_SPACE
98#define cmsghdr _WSACMSGHDR
102#if !defined(WITH_CONTIKI) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
104#if COAP_SERVER_SUPPORT
115 struct timeval timeout = {0, 0};
121 sock->
fd = socket(listen_addr->
addr.
sa.sa_family, SOCK_DGRAM, 0);
137 if (setsockopt(sock->
fd, SOL_SOCKET, SO_REUSEADDR, OPTVAL_T(&on),
sizeof(on)) ==
COAP_SOCKET_ERROR)
138 coap_log_warn(
"coap_socket_bind_udp: setsockopt SO_REUSEADDR: %s\n",
141 switch (listen_addr->
addr.
sa.sa_family) {
144 if (setsockopt(sock->
fd, IPPROTO_IP, GEN_IP_PKTINFO, OPTVAL_T(&on),
146 coap_log_alert(
"coap_socket_bind_udp: setsockopt IP_PKTINFO: %s\n",
153 if (setsockopt(sock->
fd, IPPROTO_IPV6, IPV6_V6ONLY, OPTVAL_T(&off),
155 coap_log_alert(
"coap_socket_bind_udp: setsockopt IPV6_V6ONLY: %s\n",
157#if !defined(ESPIDF_VERSION)
158 if (setsockopt(sock->
fd, IPPROTO_IPV6, GEN_IPV6_PKTINFO, OPTVAL_T(&on),
160 coap_log_alert(
"coap_socket_bind_udp: setsockopt IPV6_PKTINFO: %s\n",
164 setsockopt(sock->
fd, IPPROTO_IP, GEN_IP_PKTINFO, OPTVAL_T(&on),
sizeof(on));
168#if COAP_AF_UNIX_SUPPORT
177 if (setsockopt(sock->
fd, SOL_SOCKET, SO_RCVTIMEO, OPTVAL_T(&timeout),
179 coap_log_alert(
"coap_socket_bind_udp: setsockopt SO_RCVTIMEO: %s\n",
183 if (bind(sock->
fd, &listen_addr->
addr.
sa,
185 listen_addr->
addr.
sa.sa_family == AF_INET ?
186 (socklen_t)
sizeof(
struct sockaddr_in) :
194 bound_addr->
size = (socklen_t)
sizeof(*bound_addr);
195 if (getsockname(sock->
fd, &bound_addr->
addr.
sa, &bound_addr->
size) < 0) {
200#if defined(RIOT_VERSION) && defined(COAP_SERVER_SUPPORT)
202 bound_addr->
addr.
sa.sa_family == AF_INET6) {
203 bound_addr->
addr.
sin6.sin6_scope_id =
204 listen_addr->
addr.
sin6.sin6_scope_id;
205 bound_addr->
addr.
sin6.sin6_flowinfo = 0;
217#if COAP_CLIENT_SUPPORT
237 sock->
fd = socket(connect_addr.
addr.
sa.sa_family, SOCK_DGRAM, 0);
251 coap_log_warn(
"coap_socket_connect_udp: ioctl FIONBIO: %s\n",
255 switch (connect_addr.
addr.
sa.sa_family) {
258 if (connect_addr.
addr.
sin.sin_port == 0)
259 connect_addr.
addr.
sin.sin_port = htons(default_port);
264 if (connect_addr.
addr.
sin6.sin6_port == 0)
265 connect_addr.
addr.
sin6.sin6_port = htons(default_port);
267 if (setsockopt(sock->
fd, IPPROTO_IPV6, IPV6_V6ONLY, OPTVAL_T(&off),
269 if (errno != ENOSYS) {
270 coap_log_warn(
"coap_socket_connect_udp: setsockopt IPV6_V6ONLY: %s\n",
275#if COAP_AF_UNIX_SUPPORT
280 coap_log_alert(
"coap_socket_connect_udp: unsupported sa_family %d\n",
281 connect_addr.
addr.
sa.sa_family);
285 if (local_if && local_if->
addr.
sa.sa_family) {
286 if (local_if->
addr.
sa.sa_family != connect_addr.
addr.
sa.sa_family) {
287 coap_log_warn(
"coap_socket_connect_udp: local address family != "
288 "remote address family\n");
291 if (setsockopt(sock->
fd, SOL_SOCKET, SO_REUSEADDR, OPTVAL_T(&on),
sizeof(on)) ==
COAP_SOCKET_ERROR)
292 coap_log_warn(
"coap_socket_connect_udp: setsockopt SO_REUSEADDR: %s\n",
294 if (bind(sock->
fd, &local_if->
addr.
sa,
296 local_if->
addr.
sa.sa_family == AF_INET ?
297 (socklen_t)
sizeof(
struct sockaddr_in) :
304#if COAP_AF_UNIX_SUPPORT
305 }
else if (connect_addr.
addr.
sa.sa_family == AF_UNIX) {
307 coap_log_warn(
"coap_socket_connect_udp: local address required\n");
314 if (!(local_if && local_if->
addr.
sa.sa_family)) {
319 bind_addr.
addr.
sa.sa_family = connect_addr.
addr.
sa.sa_family;
320 if (bind(sock->
fd, &bind_addr.
addr.
sa,
322 bind_addr.
addr.
sa.sa_family == AF_INET ?
323 (socklen_t)
sizeof(
struct sockaddr_in) :
332 coap_log_warn(
"coap_socket_connect_udp: getsockname for multicast socket: %s\n",
339 setsockopt(sock->
fd, SOL_SOCKET, SO_BROADCAST, OPTVAL_T(&on),
341 coap_log_warn(
"coap_socket_connect_udp: setsockopt SO_BROADCAST: %s\n",
347#if COAP_AF_UNIX_SUPPORT
348 if (connect_addr.
addr.
sa.sa_family == AF_UNIX) {
382#ifdef COAP_EPOLL_SUPPORT
383#if COAP_SERVER_SUPPORT
389 if (context != NULL) {
391 struct epoll_event event;
394 ret = epoll_ctl(context->epfd, EPOLL_CTL_DEL, sock->
fd, &event);
395 if (ret == -1 && errno != ENOENT) {
402#if COAP_SERVER_SUPPORT
403#if COAP_AF_UNIX_SUPPORT
416#if COAP_CLIENT_SUPPORT
417#if COAP_AF_UNIX_SUPPORT
436#ifdef COAP_EPOLL_SUPPORT
442 struct epoll_event event;
445#if COAP_MAX_LOGGING_LEVEL < _COAP_LOG_ERR
452#if COAP_SERVER_SUPPORT
462 memset(&event, 0,
sizeof(event));
463 event.events = events;
464 event.data.ptr = sock;
466 ret = epoll_ctl(context->epfd, EPOLL_CTL_ADD, sock->
fd, &event);
479 struct epoll_event event;
482#if COAP_MAX_LOGGING_LEVEL < _COAP_LOG_ERR
489#if COAP_SERVER_SUPPORT
498 event.events = events;
499 event.data.ptr = sock;
501 ret = epoll_ctl(context->epfd, EPOLL_CTL_MOD, sock->
fd, &event);
503#if (COAP_MAX_LOGGING_LEVEL < COAP_LOG_ERR)
518#if COAP_EPOLL_SUPPORT
519 if (context->eptimerfd != -1) {
524 struct itimerspec new_value;
528 memset(&new_value, 0,
sizeof(new_value));
530 new_value.it_value.tv_nsec = 1;
536 ret = timerfd_settime(context->eptimerfd, 0, &new_value, NULL);
539 "coap_update_io_timer",
542#ifdef COAP_DEBUG_WAKEUP_TIMES
545 new_value.it_value.tv_sec, new_value.it_value.tv_nsec);
561#if !defined(WITH_CONTIKI) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
565coap_win_error_to_errno(
void) {
566 int w_error = WSAGetLastError();
568 case WSA_NOT_ENOUGH_MEMORY:
571 case WSA_INVALID_PARAMETER:
604 case WSAECONNABORTED:
605 errno = ECONNABORTED;
616 case WSAECONNREFUSED:
617 errno = ECONNREFUSED;
620 coap_log_err(
"WSAGetLastError: %d mapping to errno failed - please fix\n",
640 r = send(sock->
fd, (
const char *)data, (
int)data_len, 0);
643#define MSG_NOSIGNAL 0
649 coap_win_error_to_errno();
652#
if EAGAIN != EWOULDBLOCK
653 errno == EWOULDBLOCK ||
657#ifdef COAP_EPOLL_SUPPORT
666 if (errno == EPIPE || errno == ECONNRESET) {
675 if (r < (ssize_t)data_len) {
677#ifdef COAP_EPOLL_SUPPORT
698 r = recv(sock->
fd, (
char *)data, (
int)data_len, 0);
700 r = recv(sock->
fd, data, data_len, 0);
704 sock->
flags &= ~COAP_SOCKET_CAN_READ;
708 sock->
flags &= ~COAP_SOCKET_CAN_READ;
710 coap_win_error_to_errno();
713#
if EAGAIN != EWOULDBLOCK
714 errno == EWOULDBLOCK ||
719 if (errno != ECONNRESET) {
725 if (r < (ssize_t)data_len)
726 sock->
flags &= ~COAP_SOCKET_CAN_READ;
732#if !defined(WITH_LWIP)
733#if (!defined(WITH_CONTIKI)) != ( defined(HAVE_NETINET_IN_H) || defined(HAVE_WS2TCPIP_H) )
737#if !defined(__MINGW32__) && !defined(RIOT_VERSION)
752#if !defined(WITH_CONTIKI) && !defined(SOL_IP)
754#define SOL_IP IPPROTO_IP
757#define COAP_SOL_IP IPPROTO_IP
759#define COAP_SOL_IP SOL_IP
764#if defined(__MINGW32__)
765static __thread LPFN_WSARECVMSG lpWSARecvMsg = NULL;
767static __declspec(thread) LPFN_WSARECVMSG lpWSARecvMsg = NULL;
770#define msghdr _WSAMSG
772#define msg_namelen namelen
773#define msg_iov lpBuffers
774#define msg_iovlen dwBufferCount
775#define msg_control Control.buf
776#define msg_controllen Control.len
780#define iov_len_t u_long
782#define CMSG_DATA WSA_CMSG_DATA
783#define ipi_spec_dst ipi_addr
784#if !defined(__MINGW32__)
785#pragma warning( disable : 4116 )
788#define iov_len_t size_t
791#if defined(_CYGWIN_ENV) || defined(__QNXNTO__)
792#define ipi_spec_dst ipi_addr
795#if !defined(RIOT_VERSION) && !defined(WITH_LWIP) && !defined(WITH_CONTIKI)
796#if COAP_CLIENT_SUPPORT
797static uint32_t cid_track_counter;
820#ifdef COAP_EPOLL_SUPPORT
842 const uint8_t *data,
size_t datalen) {
843 ssize_t bytes_written = 0;
845#if COAP_CLIENT_SUPPORT
846 coap_test_cid_tuple_change(session);
850 bytes_written = (ssize_t)datalen;
853 bytes_written = send(sock->
fd, (
const char *)data, (
int)datalen, 0);
855 bytes_written = send(sock->
fd, data, datalen, 0);
859 DWORD dwNumberOfBytesSent = 0;
862#ifdef HAVE_STRUCT_CMSGHDR
871 memcpy(&iov[0].iov_base, &data,
sizeof(iov[0].iov_base));
874 memset(buf, 0,
sizeof(buf));
876 memset(&mhdr, 0,
sizeof(
struct msghdr));
877 memcpy(&mhdr.msg_name, &addr,
sizeof(mhdr.msg_name));
879 (socklen_t)
sizeof(
struct sockaddr_in) :
890 struct cmsghdr *cmsg;
894#if defined(IP_PKTINFO)
896 mhdr.msg_control = buf;
897 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_pktinfo));
899 cmsg = CMSG_FIRSTHDR(&mhdr);
901 cmsg->cmsg_type = IP_PKTINFO;
902 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_pktinfo));
904 pktinfo = (
struct in_pktinfo *)CMSG_DATA(cmsg);
910#elif defined(IP_SENDSRCADDR)
911 mhdr.msg_control = buf;
912 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_addr));
914 cmsg = CMSG_FIRSTHDR(&mhdr);
915 cmsg->cmsg_level = IPPROTO_IP;
916 cmsg->cmsg_type = IP_SENDSRCADDR;
917 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_addr));
919 memcpy(CMSG_DATA(cmsg),
921 sizeof(
struct in_addr));
926 mhdr.msg_control = buf;
927 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in6_pktinfo));
929 cmsg = CMSG_FIRSTHDR(&mhdr);
930 cmsg->cmsg_level = IPPROTO_IPV6;
931 cmsg->cmsg_type = IPV6_PKTINFO;
932 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in6_pktinfo));
952#if defined(IP_PKTINFO)
953 struct cmsghdr *cmsg;
956 mhdr.msg_control = buf;
957 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_pktinfo));
959 cmsg = CMSG_FIRSTHDR(&mhdr);
961 cmsg->cmsg_type = IP_PKTINFO;
962 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_pktinfo));
964 pktinfo = (
struct in_pktinfo *)CMSG_DATA(cmsg);
970#elif defined(IP_SENDSRCADDR)
971 struct cmsghdr *cmsg;
972 mhdr.msg_control = buf;
973 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_addr));
975 cmsg = CMSG_FIRSTHDR(&mhdr);
976 cmsg->cmsg_level = IPPROTO_IP;
977 cmsg->cmsg_type = IP_SENDSRCADDR;
978 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_addr));
980 memcpy(CMSG_DATA(cmsg),
982 sizeof(
struct in_addr));
987#if COAP_AF_UNIX_SUPPORT
1000 r = WSASendMsg(sock->
fd, &mhdr, 0 , &dwNumberOfBytesSent, NULL ,
1003 bytes_written = (ssize_t)dwNumberOfBytesSent;
1006 coap_win_error_to_errno();
1009#ifdef HAVE_STRUCT_CMSGHDR
1010 bytes_written = sendmsg(sock->
fd, &mhdr, 0);
1012 bytes_written = sendto(sock->
fd, (
const void *)data, datalen, 0,
1019 if (bytes_written < 0)
1022 return bytes_written;
1026#define SIN6(A) ((struct sockaddr_in6 *)(A))
1031 *length = packet->
length;
1034#if !defined(WITH_LWIP) && !defined(WITH_CONTIKI) && !defined(RIOT_VERSION)
1052 sock->
flags &= ~COAP_SOCKET_CAN_READ;
1063 coap_win_error_to_errno();
1065 if (errno == ECONNREFUSED || errno == EHOSTUNREACH || errno == ECONNRESET) {
1073 if (errno != EAGAIN) {
1080 }
else if (len > 0) {
1081 packet->
length = (size_t)len;
1085 DWORD dwNumberOfBytesRecvd = 0;
1088#ifdef HAVE_STRUCT_CMSGHDR
1091 struct cmsghdr *cmsg;
1093 struct iovec iov[1];
1095#if defined(__MINGW32__)
1096 iov[0].iov_base = (
char *) packet->
payload;
1098 iov[0].iov_base = packet->
payload;
1102 memset(&mhdr, 0,
sizeof(
struct msghdr));
1108 mhdr.msg_iovlen = 1;
1110 mhdr.msg_control = buf;
1111 mhdr.msg_controllen =
sizeof(buf);
1114 cmsg = (
struct cmsghdr *)buf;
1115 cmsg->cmsg_len = CMSG_LEN(
sizeof(buf));
1116 cmsg->cmsg_level = -1;
1117 cmsg->cmsg_type = -1;
1120 if (!lpWSARecvMsg) {
1121 GUID wsaid = WSAID_WSARECVMSG;
1122 DWORD cbBytesReturned = 0;
1123 if (WSAIoctl(sock->
fd, SIO_GET_EXTENSION_FUNCTION_POINTER, &wsaid,
sizeof(wsaid), &lpWSARecvMsg,
1124 sizeof(lpWSARecvMsg), &cbBytesReturned, NULL, NULL) != 0) {
1129 r = lpWSARecvMsg(sock->
fd, &mhdr, &dwNumberOfBytesRecvd, NULL ,
1132 len = (ssize_t)dwNumberOfBytesRecvd;
1134 coap_win_error_to_errno();
1136 len = recvmsg(sock->
fd, &mhdr, 0);
1147 coap_win_error_to_errno();
1149 if (errno == ECONNREFUSED || errno == EHOSTUNREACH || errno == ECONNRESET) {
1157 if (errno != EAGAIN) {
1162#ifdef HAVE_STRUCT_CMSGHDR
1166 packet->
length = (size_t)len;
1170 for (cmsg = CMSG_FIRSTHDR(&mhdr); cmsg; cmsg = CMSG_NXTHDR(&mhdr, cmsg)) {
1172#if COAP_IPV6_SUPPORT
1174 if (cmsg->cmsg_level == IPPROTO_IPV6 && cmsg->cmsg_type == IPV6_PKTINFO) {
1179 u.c = CMSG_DATA(cmsg);
1180 packet->
ifindex = (int)(u.p->ipi6_ifindex);
1182 &u.p->ipi6_addr,
sizeof(
struct in6_addr));
1188#if COAP_IPV4_SUPPORT
1190#if defined(IP_PKTINFO)
1191 if (cmsg->cmsg_level ==
COAP_SOL_IP && cmsg->cmsg_type == IP_PKTINFO) {
1196 u.c = CMSG_DATA(cmsg);
1197 packet->
ifindex = u.p->ipi_ifindex;
1198#if COAP_IPV6_SUPPORT
1204 &u.p->ipi_addr,
sizeof(
struct in_addr));
1209 &u.p->ipi_addr,
sizeof(
struct in_addr));
1215#if defined(IP_RECVDSTADDR)
1216 if (cmsg->cmsg_level == IPPROTO_IP && cmsg->cmsg_type == IP_RECVDSTADDR) {
1219 CMSG_DATA(cmsg),
sizeof(
struct in_addr));
1228 if (cmsg->cmsg_level != -1 && cmsg->cmsg_type != -1) {
1229 coap_log_debug(
"cmsg_level = %d and cmsg_type = %d not supported - fix\n",
1230 cmsg->cmsg_level, cmsg->cmsg_type);
1244 packet->
length = (size_t)len;
1274#ifndef COAP_EPOLL_SUPPORT
1277 coap_log_emerg(
"coap_io_prepare_epoll() requires libcoap compiled for using epoll\n");
1281 unsigned int max_sockets =
sizeof(sockets)/
sizeof(sockets[0]);
1282 unsigned int num_sockets;
1283 unsigned int timeout;
1290 if (ctx->eptimerfd != -1) {
1291 struct itimerspec new_value;
1294 memset(&new_value, 0,
sizeof(new_value));
1303#ifdef COAP_DEBUG_WAKEUP_TIMES
1305 new_value.it_value.tv_sec, new_value.it_value.tv_nsec);
1308 ret = timerfd_settime(ctx->eptimerfd, 0, &new_value, NULL);
1311 "coap_io_prepare_epoll",
1326 unsigned int max_sockets,
1327 unsigned int *num_sockets,
1344 unsigned int max_sockets,
1345 unsigned int *num_sockets,
1351#if COAP_SERVER_SUPPORT
1352 int check_dtls_timeouts = 0;
1354#if defined(COAP_EPOLL_SUPPORT) || defined(WITH_LWIP) || defined(RIOT_VERSION)
1362#if COAP_SERVER_SUPPORT
1366#if COAP_ASYNC_SUPPORT
1368 if (coap_check_async(ctx, now, &s_timeout)) {
1369 if (s_timeout < timeout)
1370 timeout = s_timeout;
1390 if (tls_timeout > 0) {
1395 if (tls_timeout - now < timeout)
1396 timeout = tls_timeout - now;
1398#if COAP_SERVER_SUPPORT
1400 check_dtls_timeouts = 1;
1404#if COAP_PROXY_SUPPORT
1406 if (s_timeout < timeout)
1407 timeout = s_timeout;
1410#if COAP_SERVER_SUPPORT
1420#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
1422 if (*num_sockets < max_sockets)
1423 sockets[(*num_sockets)++] = &ep->
sock;
1439 s_timeout = (s->
last_rx_tx + session_timeout) - now;
1440 if (s_timeout < timeout)
1441 timeout = s_timeout;
1449 while (tls_timeout > 0 && tls_timeout <= now) {
1462 if (tls_timeout > 0 && tls_timeout - now < timeout)
1463 timeout = tls_timeout - now;
1468 if (s_timeout < timeout)
1469 timeout = s_timeout;
1475 if (s_timeout < timeout)
1476 timeout = s_timeout;
1479#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
1481 if (*num_sockets < max_sockets)
1482 sockets[(*num_sockets)++] = &s->
sock;
1485#if COAP_Q_BLOCK_SUPPORT
1491 if (coap_block_check_q_block2_xmit(s, now, &s_timeout)) {
1492 if (s_timeout < timeout)
1493 timeout = s_timeout;
1525 if (s_timeout < timeout)
1526 timeout = s_timeout;
1532#if COAP_CLIENT_SUPPORT
1556 if (s_timeout < timeout)
1557 timeout = s_timeout;
1567 if (timeout == 0 || s_timeout < timeout)
1568 timeout = s_timeout;
1573 if (s_timeout < timeout)
1574 timeout = s_timeout;
1578#if !COAP_DISABLE_TCP
1590 if (s_timeout < timeout)
1591 timeout = s_timeout;
1601 while (tls_timeout > 0 && tls_timeout <= now) {
1613 if (tls_timeout > 0 && tls_timeout - now < timeout)
1614 timeout = tls_timeout - now;
1620 if (s_timeout < timeout)
1621 timeout = s_timeout;
1627 if (s_timeout < timeout)
1628 timeout = s_timeout;
1631#if COAP_Q_BLOCK_SUPPORT
1637 if (coap_block_check_q_block1_xmit(s, now, &s_timeout)) {
1638 if (s_timeout < timeout)
1639 timeout = s_timeout;
1644#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
1649 if (*num_sockets < max_sockets)
1650 sockets[(*num_sockets)++] = &s->
sock;
1668 unsigned int *have_read_fds,
1669 unsigned int max_read_fds,
1671 unsigned int *have_write_fds,
1672 unsigned int max_write_fds,
1673 unsigned int *rem_timeout_ms) {
1678 have_write_fds, max_write_fds, rem_timeout_ms);
1683#if !defined(WITH_LWIP) && !defined(WITH_CONTIKI)
1686 unsigned int max_this_fds) {
1687 if (*have_this_fds < max_this_fds) {
1688 this_fds[(*have_this_fds)++] = fd;
1691 coap_log_warn(
"coap_io_get_fds: Insufficient space for new fd (%u >= %u)\n", *have_this_fds,
1703 unsigned int *have_read_fds,
1704 unsigned int max_read_fds,
1706 unsigned int *have_write_fds,
1707 unsigned int max_write_fds,
1708 unsigned int *rem_timeout_ms) {
1710 *have_write_fds = 0;
1712#ifdef COAP_EPOLL_SUPPORT
1714 (void)max_write_fds;;
1716 if (!
coap_add_fd(ctx->epfd, read_fds, have_read_fds, max_read_fds))
1719 *rem_timeout_ms = 0;
1724 unsigned int timeout_ms;
1725#if COAP_SERVER_SUPPORT
1750#if COAP_CLIENT_SUPPORT
1767 *rem_timeout_ms = timeout_ms;
1781 unsigned int *have_read_fds,
1782 unsigned int max_read_fds,
1784 unsigned int *have_write_fds,
1785 unsigned int max_write_fds,
1786 unsigned int *rem_timeout_ms) {
1791 (void)max_write_fds;
1794 *have_write_fds = 0;
1795 *rem_timeout_ms = 0;
1802#if !defined(WITH_LWIP) && !defined(CONTIKI) && !defined(RIOT_VERSION)
1820 int enfds, fd_set *ereadfds, fd_set *ewritefds,
1821 fd_set *eexceptfds) {
1831#if !defined(COAP_EPOLL_SUPPORT) && COAP_THREAD_SAFE
1834 int enfds, fd_set *ereadfds, fd_set *ewritefds,
1835 fd_set *eexceptfds) {
1837 unsigned int max_sockets =
sizeof(ctx->
sockets) /
sizeof(ctx->
sockets[0]);
1842#if COAP_SERVER_SUPPORT
1858#if COAP_CLIENT_SUPPORT
1893#if !COAP_DISABLE_TCP
1908 int enfds, fd_set *ereadfds, fd_set *ewritefds,
1909 fd_set *eexceptfds) {
1912 unsigned int timeout;
1913#ifndef COAP_EPOLL_SUPPORT
1922#ifndef COAP_EPOLL_SUPPORT
1954#if !COAP_DISABLE_TCP
1968 }
else if (timeout == 0 && timeout_ms ==
COAP_IO_WAIT) {
1971 if (timeout == 0 || (timeout_ms !=
COAP_IO_WAIT && timeout_ms < timeout))
1972 timeout = timeout_ms;
1973 tv.tv_usec = (timeout % 1000) * 1000;
1974 tv.tv_sec = (long)(timeout / 1000);
1983 timeout > 0 ? &tv : NULL);
1992 coap_win_error_to_errno();
1994 if (errno != EINTR) {
1996 if (errno == EBADF) {
2008 nfds = coap_io_prepare_fds(ctx, enfds, ereadfds, ewritefds, eexceptfds);
2014 coap_win_error_to_errno();
2016 if (errno != EINTR) {
2017 if (errno == EBADF) {
2042#if !COAP_DISABLE_TCP
2081 }
else if (timeout == 0 && timeout_ms ==
COAP_IO_WAIT) {
2089 if (timeout == 0 || (timeout_ms !=
COAP_IO_WAIT && timeout_ms < timeout))
2090 etimeout = timeout_ms;
2105 if (errno != EINTR) {
2106 coap_log_err(
"epoll_wait: unexpected error: %s (%d)\n",
2118 if (errno != EINTR) {
2119 coap_log_err(
"epoll_wait: unexpected error: %s (%d)\n",
2139#if COAP_SERVER_SUPPORT
2142#if COAP_ASYNC_SUPPORT
2146 coap_check_async(ctx, now, NULL);
2149#ifndef COAP_EPOLL_SUPPORT
2167 void *main_loop_code_arg, uint32_t timeout_ms,
2168 uint32_t thread_count) {
2175 main_loop_code_arg, timeout_ms,
2184 void *main_loop_code_arg, uint32_t timeout_ms,
2185 uint32_t thread_count) {
2189 if (thread_count > 1) {
2197 if (main_loop_code) {
2218 }
else if (timeout_ms > used_ms) {
2221 unsigned int next_sec_us;
2222 unsigned int next_sec_ms;
2226 next_sec_ms = (next_sec_us + 999) / 1000;
2227 if (next_sec_ms > timeout_ms && next_sec_ms > 1000)
2228 next_sec_ms -= 1000;
2235 if (thread_count == 1) {
2243 if (timeout_ms > 0 && timeout_ms < used_ms) {
2287#if COAP_SERVER_SUPPORT
2299#if COAP_SERVER_SUPPORT
2300 LL_FOREACH(context->
endpoint, ep) {
2311#if COAP_CLIENT_SUPPORT
2326 return strerror(error);
2331 coap_win_error_to_errno();
2343#if !defined(WITH_LWIP) && !defined(WITH_CONTIKI)
2358 sock->
flags = flags;
void coap_address_set_port(coap_address_t *addr, uint16_t port)
Set the port field of addr to port (in host byte order).
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.
uint16_t coap_address_get_port(const coap_address_t *addr)
Returns the port from addr in host byte order.
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.
#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.
static int coap_add_fd(coap_fd_t fd, coap_fd_t this_fds[], unsigned int *have_this_fds, unsigned int max_this_fds)
void coap_socket_close(coap_socket_t *sock)
Function interface to close off a socket.
const char * coap_socket_strerror(void)
ssize_t coap_socket_recv(coap_socket_t *sock, coap_packet_t *packet)
Function interface for reading data.
ssize_t coap_socket_send(coap_socket_t *sock, coap_session_t *session, const uint8_t *data, size_t datalen)
Function interface for data transmission.
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.
volatile int coap_thread_quit
void coap_update_io_timer(coap_context_t *context, coap_tick_t delay)
Update when to continue with I/O processing, unless packets come in in the meantime.
#define COAP_MAX_EPOLL_EVENTS
uint16_t coap_socket_flags_t
#define COAP_RXBUFFER_SIZE
#define COAP_SOCKET_ERROR
#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_NOT_EMPTY
the socket is not empty
#define COAP_SOCKET_CAN_WRITE
non blocking socket can now write without blocking
#define COAP_SOCKET_BOUND
the socket is bound
#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
int coap_socket_bind_udp(coap_socket_t *sock, const coap_address_t *listen_addr, coap_address_t *bound_addr)
#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
Library specific build wrapper for coap_internal.h.
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)
#define SESSIONS_ITER_SAFE(e, el, rtmp)
#define SESSIONS_ITER(e, el, rtmp)
#define COAP_DEFAULT_SESSION_TIMEOUT
int coap_proxy_check_timeouts(coap_context_t *context, coap_tick_t now, coap_tick_t *tim_rem)
Idle timeout inactive proxy sessions as well as return in tim_rem the time to remaining to timeout th...
void coap_io_do_epoll_lkd(coap_context_t *ctx, struct epoll_event *events, size_t nevents)
Process all the epoll events.
int coap_io_process_loop_lkd(coap_context_t *context, coap_io_process_thread_t main_loop_code, void *main_loop_code_arg, uint32_t timeout_ms, uint32_t thread_count)
Do the coap_io_process() across thread_count threads.
int coap_io_pending_lkd(coap_context_t *context)
Check to see if there is any i/o pending for the context.
void coap_io_do_io_lkd(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_get_fds_lkd(coap_context_t *ctx, coap_fd_t read_fds[], unsigned int *have_read_fds, unsigned int max_read_fds, coap_fd_t write_fds[], unsigned int *have_write_fds, unsigned int max_write_fds, unsigned int *rem_timeout_ms)
int coap_io_process_lkd(coap_context_t *ctx, uint32_t timeout_ms)
The main I/O processing function.
int coap_io_process_with_fds_lkd(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.
unsigned int coap_io_prepare_io_lkd(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...
unsigned int coap_io_prepare_epoll_lkd(coap_context_t *ctx, coap_tick_t now)
Any now timed out delayed packet is transmitted, along with any packets associated with requested obs...
COAP_API int coap_io_process(coap_context_t *ctx, uint32_t timeout_ms)
The main I/O processing function.
COAP_API int coap_io_pending(coap_context_t *context)
Check to see if there is any i/o pending for the context.
int coap_io_process_configure_threads(coap_context_t *context, uint32_t thread_count)
Configure a defined number of threads to do the alternate coap_io_process() work with traffic load ba...
void coap_io_process_terminate_loop(void)
Terminate all the additional threads created by coap_io_process_loop() and break out of the main thre...
void coap_io_process_remove_threads(coap_context_t *context)
Release the coap_io_process() worker threads.
COAP_API int coap_io_process_loop(coap_context_t *context, coap_io_process_thread_t main_loop_code, void *main_loop_code_arg, uint32_t timeout_ms, uint32_t thread_count)
Do the coap_io_process() across thread_count threads.
COAP_API unsigned int coap_io_get_fds(coap_context_t *ctx, coap_fd_t read_fds[], unsigned int *have_read_fds, unsigned int max_read_fds, coap_fd_t write_fds[], unsigned int *have_write_fds, unsigned int max_write_fds, unsigned int *rem_timeout_ms)
COAP_API 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...
COAP_API void coap_socket_set_flags(coap_socket_t *sock, coap_socket_flags_t flags)
Set the libcoap internal flags for a socket.
COAP_API 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...
COAP_API coap_fd_t coap_socket_get_fd(coap_socket_t *sock)
Get the libcoap internal file descriptor for a socket.
COAP_API 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.
void(* coap_io_process_thread_t)(void *arg)
Main thread coap_io_process_loop activity.
COAP_API coap_socket_flags_t coap_socket_get_flags(coap_socket_t *sock)
Get the libcoap internal flags for a socket.
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.
#define COAP_MAX_DELAY_TICKS
uint64_t coap_ticks_to_rt_us(coap_tick_t t)
Helper function that converts coap ticks to POSIX wallclock time in us.
int coap_handle_event_lkd(coap_context_t *context, coap_event_t event, coap_session_t *session)
Invokes the event handler of context for the given event and data.
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.
void coap_send_recv_terminate(void)
Terminate any active coap_send_recv() sessions.
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_lock_callback_release(c, func, failed)
Dummy for no thread-safe code.
#define coap_lock_unlock(c)
Dummy for no thread-safe code.
#define coap_lock_lock(c, failed)
Dummy for no thread-safe code.
#define coap_lock_check_locked(c)
Dummy for no thread-safe code.
#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(...)
int coap_mid_t
coap_mid_t is used to store the CoAP Message ID of a CoAP PDU.
#define COAP_INVALID_MID
Indicates an invalid message id.
int coap_session_reconnect(coap_session_t *session)
Close the current session (if not already closed) and reconnect to server (client session only).
void coap_session_server_keepalive_failed(coap_session_t *session)
Clear down a session following a keepalive failure.
void coap_session_failed(coap_session_t *session)
Session has failed due to a socket error.
coap_mid_t coap_session_send_ping_lkd(coap_session_t *session)
Send a ping message for the session.
void coap_session_free(coap_session_t *session)
void coap_session_release_lkd(coap_session_t *session)
Decrement reference counter on a session.
coap_session_t * coap_session_reference_lkd(coap_session_t *session)
Increment reference counter on a session.
#define COAP_PROTO_RELIABLE(p)
@ 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_lkd(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_lkd()
unsigned int reconnect_time
Time to wait before reconnecting a failed client session.
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_lkd()
unsigned int ping_timeout
Minimum inactivity time before sending a ping message.
uint8_t testing_cids
Change client's source port every testing_cids.
coap_endpoint_t * endpoint
the endpoints used for listening
uint32_t csm_timeout_ms
Timeout for waiting for a CSM from the remote side.
coap_tick_t next_timeout
When the next timeout is to occur.
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
unsigned ref_subscriptions
reference count of current subscriptions
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
uint8_t negotiated_cid
Set for a client if CID negotiated.
void * tls
security parameters
uint8_t con_active
Active CON request sent.
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
uint8_t session_failed
Set if session failed and can try re-connect.
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