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) && !defined(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) && !defined(RIOT_VERSION)
91#if COAP_SERVER_SUPPORT
102 struct timeval timeout = {0, 0};
108 sock->
fd = socket(listen_addr->
addr.
sa.sa_family, SOCK_DGRAM, 0);
124 if (setsockopt(sock->
fd, SOL_SOCKET, SO_REUSEADDR, OPTVAL_T(&on),
sizeof(on)) ==
COAP_SOCKET_ERROR)
125 coap_log_warn(
"coap_socket_bind_udp: setsockopt SO_REUSEADDR: %s\n",
128 switch (listen_addr->
addr.
sa.sa_family) {
131 if (setsockopt(sock->
fd, IPPROTO_IP, GEN_IP_PKTINFO, OPTVAL_T(&on),
133 coap_log_alert(
"coap_socket_bind_udp: setsockopt IP_PKTINFO: %s\n",
140 if (setsockopt(sock->
fd, IPPROTO_IPV6, IPV6_V6ONLY, OPTVAL_T(&off),
142 coap_log_alert(
"coap_socket_bind_udp: setsockopt IPV6_V6ONLY: %s\n",
144#if !defined(ESPIDF_VERSION)
145 if (setsockopt(sock->
fd, IPPROTO_IPV6, GEN_IPV6_PKTINFO, OPTVAL_T(&on),
147 coap_log_alert(
"coap_socket_bind_udp: setsockopt IPV6_PKTINFO: %s\n",
151 setsockopt(sock->
fd, IPPROTO_IP, GEN_IP_PKTINFO, OPTVAL_T(&on),
sizeof(on));
155#if COAP_AF_UNIX_SUPPORT
164 if (setsockopt(sock->
fd, SOL_SOCKET, SO_RCVTIMEO, OPTVAL_T(&timeout),
166 coap_log_alert(
"coap_socket_bind_udp: setsockopt SO_RCVTIMEO: %s\n",
170 if (bind(sock->
fd, &listen_addr->
addr.
sa,
172 listen_addr->
addr.
sa.sa_family == AF_INET ?
173 (socklen_t)
sizeof(
struct sockaddr_in) :
181 bound_addr->
size = (socklen_t)
sizeof(*bound_addr);
182 if (getsockname(sock->
fd, &bound_addr->
addr.
sa, &bound_addr->
size) < 0) {
187#if defined(RIOT_VERSION) && defined(COAP_SERVER_SUPPORT)
189 bound_addr->
addr.
sa.sa_family == AF_INET6) {
190 bound_addr->
addr.
sin6.sin6_scope_id =
191 listen_addr->
addr.
sin6.sin6_scope_id;
192 bound_addr->
addr.
sin6.sin6_flowinfo = 0;
204#if COAP_CLIENT_SUPPORT
224 sock->
fd = socket(connect_addr.
addr.
sa.sa_family, SOCK_DGRAM, 0);
238 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);
254 if (setsockopt(sock->
fd, IPPROTO_IPV6, IPV6_V6ONLY, OPTVAL_T(&off),
256 coap_log_warn(
"coap_socket_connect_udp: setsockopt IPV6_V6ONLY: %s\n",
260#if COAP_AF_UNIX_SUPPORT
265 coap_log_alert(
"coap_socket_connect_udp: unsupported sa_family %d\n",
266 connect_addr.
addr.
sa.sa_family);
270 if (local_if && local_if->
addr.
sa.sa_family) {
271 if (local_if->
addr.
sa.sa_family != connect_addr.
addr.
sa.sa_family) {
272 coap_log_warn(
"coap_socket_connect_udp: local address family != "
273 "remote address family\n");
276 if (setsockopt(sock->
fd, SOL_SOCKET, SO_REUSEADDR, OPTVAL_T(&on),
sizeof(on)) ==
COAP_SOCKET_ERROR)
277 coap_log_warn(
"coap_socket_connect_udp: setsockopt SO_REUSEADDR: %s\n",
279 if (bind(sock->
fd, &local_if->
addr.
sa,
281 local_if->
addr.
sa.sa_family == AF_INET ?
282 (socklen_t)
sizeof(
struct sockaddr_in) :
289#if COAP_AF_UNIX_SUPPORT
290 }
else if (connect_addr.
addr.
sa.sa_family == AF_UNIX) {
292 coap_log_warn(
"coap_socket_connect_udp: local address required\n");
299 if (!(local_if && local_if->
addr.
sa.sa_family)) {
304 bind_addr.
addr.
sa.sa_family = connect_addr.
addr.
sa.sa_family;
305 if (bind(sock->
fd, &bind_addr.
addr.
sa,
307 bind_addr.
addr.
sa.sa_family == AF_INET ?
308 (socklen_t)
sizeof(
struct sockaddr_in) :
317 coap_log_warn(
"coap_socket_connect_udp: getsockname for multicast socket: %s\n",
324 setsockopt(sock->
fd, SOL_SOCKET, SO_BROADCAST, OPTVAL_T(&on),
326 coap_log_warn(
"coap_socket_connect_udp: setsockopt SO_BROADCAST: %s\n",
332#if COAP_AF_UNIX_SUPPORT
333 if (connect_addr.
addr.
sa.sa_family == AF_UNIX) {
367#ifdef COAP_EPOLL_SUPPORT
368#if COAP_SERVER_SUPPORT
374 if (context != NULL) {
376 struct epoll_event event;
379 ret = epoll_ctl(context->epfd, EPOLL_CTL_DEL, sock->
fd, &event);
380 if (ret == -1 && errno != ENOENT) {
386#if COAP_SERVER_SUPPORT
387#if COAP_AF_UNIX_SUPPORT
396#if COAP_CLIENT_SUPPORT
397#if COAP_AF_UNIX_SUPPORT
413#ifdef COAP_EPOLL_SUPPORT
419 struct epoll_event event;
422#if COAP_MAX_LOGGING_LEVEL < _COAP_LOG_ERR
429#if COAP_SERVER_SUPPORT
439 memset(&event, 0,
sizeof(event));
440 event.events = events;
441 event.data.ptr = sock;
443 ret = epoll_ctl(context->epfd, EPOLL_CTL_ADD, sock->
fd, &event);
456 struct epoll_event event;
459#if COAP_MAX_LOGGING_LEVEL < _COAP_LOG_ERR
466#if COAP_SERVER_SUPPORT
475 event.events = events;
476 event.data.ptr = sock;
478 ret = epoll_ctl(context->epfd, EPOLL_CTL_MOD, sock->
fd, &event);
480#if (COAP_MAX_LOGGING_LEVEL < COAP_LOG_ERR)
495#if COAP_EPOLL_SUPPORT
496 if (context->eptimerfd != -1) {
500 if (context->next_timeout == 0 || context->next_timeout > now + delay) {
501 struct itimerspec new_value;
504 context->next_timeout = now + delay;
505 memset(&new_value, 0,
sizeof(new_value));
507 new_value.it_value.tv_nsec = 1;
513 ret = timerfd_settime(context->eptimerfd, 0, &new_value, NULL);
516 "coap_resource_notify_observers",
519#ifdef COAP_DEBUG_WAKEUP_TIMES
522 new_value.it_value.tv_sec, new_value.it_value.tv_nsec);
534#if !defined(WITH_CONTIKI) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
538coap_win_error_to_errno(
void) {
539 int w_error = WSAGetLastError();
541 case WSA_NOT_ENOUGH_MEMORY:
544 case WSA_INVALID_PARAMETER:
577 case WSAECONNABORTED:
578 errno = ECONNABORTED;
589 case WSAECONNREFUSED:
590 errno = ECONNREFUSED;
593 coap_log_err(
"WSAGetLastError: %d mapping to errno failed - please fix\n",
613 r = send(sock->
fd, (
const char *)data, (
int)data_len, 0);
616#define MSG_NOSIGNAL 0
622 coap_win_error_to_errno();
625#
if EAGAIN != EWOULDBLOCK
626 errno == EWOULDBLOCK ||
630#ifdef COAP_EPOLL_SUPPORT
639 if (errno == EPIPE || errno == ECONNRESET) {
648 if (r < (ssize_t)data_len) {
650#ifdef COAP_EPOLL_SUPPORT
671 r = recv(sock->
fd, (
char *)data, (
int)data_len, 0);
673 r = recv(sock->
fd, data, data_len, 0);
677 sock->
flags &= ~COAP_SOCKET_CAN_READ;
681 sock->
flags &= ~COAP_SOCKET_CAN_READ;
683 coap_win_error_to_errno();
686#
if EAGAIN != EWOULDBLOCK
687 errno == EWOULDBLOCK ||
692 if (errno != ECONNRESET) {
698 if (r < (ssize_t)data_len)
699 sock->
flags &= ~COAP_SOCKET_CAN_READ;
705#if !defined(WITH_LWIP)
706#if (!defined(WITH_CONTIKI)) != ( defined(HAVE_NETINET_IN_H) || defined(HAVE_WS2TCPIP_H) )
710#if !defined(__MINGW32__) && !defined(RIOT_VERSION)
725#if !defined(WITH_CONTIKI) && !defined(SOL_IP)
727#define SOL_IP IPPROTO_IP
730#define COAP_SOL_IP IPPROTO_IP
732#define COAP_SOL_IP SOL_IP
737#if !defined(__MINGW32__)
738static __declspec(thread) LPFN_WSARECVMSG lpWSARecvMsg = NULL;
741#define msghdr _WSAMSG
743#define msg_namelen namelen
744#define msg_iov lpBuffers
745#define msg_iovlen dwBufferCount
746#define msg_control Control.buf
747#define msg_controllen Control.len
751#define iov_len_t u_long
753#define CMSG_DATA WSA_CMSG_DATA
754#define ipi_spec_dst ipi_addr
755#if !defined(__MINGW32__)
756#pragma warning( disable : 4116 )
759#define iov_len_t size_t
762#if defined(_CYGWIN_ENV) || defined(__QNXNTO__)
763#define ipi_spec_dst ipi_addr
766#if !defined(RIOT_VERSION) && !defined(WITH_LWIP) && !defined(WITH_CONTIKI)
774 const uint8_t *data,
size_t datalen) {
775 ssize_t bytes_written = 0;
778 bytes_written = (ssize_t)datalen;
781 bytes_written = send(sock->
fd, (
const char *)data, (
int)datalen, 0);
783 bytes_written = send(sock->
fd, data, datalen, 0);
786#if defined(_WIN32) && !defined(__MINGW32__)
787 DWORD dwNumberOfBytesSent = 0;
790#ifdef HAVE_STRUCT_CMSGHDR
799 memcpy(&iov[0].iov_base, &data,
sizeof(iov[0].iov_base));
802 memset(buf, 0,
sizeof(buf));
804 memset(&mhdr, 0,
sizeof(
struct msghdr));
805 memcpy(&mhdr.msg_name, &addr,
sizeof(mhdr.msg_name));
807 (socklen_t)
sizeof(
struct sockaddr_in) :
818 struct cmsghdr *cmsg;
822#if defined(IP_PKTINFO)
824 mhdr.msg_control = buf;
825 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_pktinfo));
827 cmsg = CMSG_FIRSTHDR(&mhdr);
829 cmsg->cmsg_type = IP_PKTINFO;
830 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_pktinfo));
832 pktinfo = (
struct in_pktinfo *)CMSG_DATA(cmsg);
838#elif defined(IP_SENDSRCADDR)
839 mhdr.msg_control = buf;
840 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_addr));
842 cmsg = CMSG_FIRSTHDR(&mhdr);
843 cmsg->cmsg_level = IPPROTO_IP;
844 cmsg->cmsg_type = IP_SENDSRCADDR;
845 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_addr));
847 memcpy(CMSG_DATA(cmsg),
849 sizeof(
struct in_addr));
854 mhdr.msg_control = buf;
855 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in6_pktinfo));
857 cmsg = CMSG_FIRSTHDR(&mhdr);
858 cmsg->cmsg_level = IPPROTO_IPV6;
859 cmsg->cmsg_type = IPV6_PKTINFO;
860 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in6_pktinfo));
876#if defined(IP_PKTINFO)
877 struct cmsghdr *cmsg;
880 mhdr.msg_control = buf;
881 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_pktinfo));
883 cmsg = CMSG_FIRSTHDR(&mhdr);
885 cmsg->cmsg_type = IP_PKTINFO;
886 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_pktinfo));
888 pktinfo = (
struct in_pktinfo *)CMSG_DATA(cmsg);
894#elif defined(IP_SENDSRCADDR)
895 struct cmsghdr *cmsg;
896 mhdr.msg_control = buf;
897 mhdr.msg_controllen = CMSG_SPACE(
sizeof(
struct in_addr));
899 cmsg = CMSG_FIRSTHDR(&mhdr);
900 cmsg->cmsg_level = IPPROTO_IP;
901 cmsg->cmsg_type = IP_SENDSRCADDR;
902 cmsg->cmsg_len = CMSG_LEN(
sizeof(
struct in_addr));
904 memcpy(CMSG_DATA(cmsg),
906 sizeof(
struct in_addr));
911#if COAP_AF_UNIX_SUPPORT
923#if defined(_WIN32) && !defined(__MINGW32__)
924 r = WSASendMsg(sock->
fd, &mhdr, 0 , &dwNumberOfBytesSent, NULL ,
927 bytes_written = (ssize_t)dwNumberOfBytesSent;
930 coap_win_error_to_errno();
933#ifdef HAVE_STRUCT_CMSGHDR
934 bytes_written = sendmsg(sock->
fd, &mhdr, 0);
936 bytes_written = sendto(sock->
fd, (
const void *)data, datalen, 0,
943 if (bytes_written < 0)
946 return bytes_written;
950#define SIN6(A) ((struct sockaddr_in6 *)(A))
958#if !defined(WITH_LWIP) && !defined(WITH_CONTIKI) && !defined(RIOT_VERSION)
976 sock->
flags &= ~COAP_SOCKET_CAN_READ;
987 coap_win_error_to_errno();
989 if (errno == ECONNREFUSED || errno == EHOSTUNREACH || errno == ECONNRESET) {
997 if (errno != EAGAIN) {
1004 }
else if (len > 0) {
1005 packet->
length = (size_t)len;
1008#if defined(_WIN32) && !defined(__MINGW32__)
1009 DWORD dwNumberOfBytesRecvd = 0;
1012#ifdef HAVE_STRUCT_CMSGHDR
1015 struct cmsghdr *cmsg;
1017 struct iovec iov[1];
1019 iov[0].iov_base = packet->
payload;
1022 memset(&mhdr, 0,
sizeof(
struct msghdr));
1028 mhdr.msg_iovlen = 1;
1030 mhdr.msg_control = buf;
1031 mhdr.msg_controllen =
sizeof(buf);
1034 cmsg = (
struct cmsghdr *)buf;
1035 cmsg->cmsg_len = CMSG_LEN(
sizeof(buf));
1036 cmsg->cmsg_level = -1;
1037 cmsg->cmsg_type = -1;
1040 if (!lpWSARecvMsg) {
1041 GUID wsaid = WSAID_WSARECVMSG;
1042 DWORD cbBytesReturned = 0;
1043 if (WSAIoctl(sock->
fd, SIO_GET_EXTENSION_FUNCTION_POINTER, &wsaid,
sizeof(wsaid), &lpWSARecvMsg,
1044 sizeof(lpWSARecvMsg), &cbBytesReturned, NULL, NULL) != 0) {
1049 r = lpWSARecvMsg(sock->
fd, &mhdr, &dwNumberOfBytesRecvd, NULL ,
1052 len = (ssize_t)dwNumberOfBytesRecvd;
1054 coap_win_error_to_errno();
1056 len = recvmsg(sock->
fd, &mhdr, 0);
1067 coap_win_error_to_errno();
1069 if (errno == ECONNREFUSED || errno == EHOSTUNREACH || errno == ECONNRESET) {
1077 if (errno != EAGAIN) {
1082#ifdef HAVE_STRUCT_CMSGHDR
1086 packet->
length = (size_t)len;
1090 for (cmsg = CMSG_FIRSTHDR(&mhdr); cmsg; cmsg = CMSG_NXTHDR(&mhdr, cmsg)) {
1092#if COAP_IPV6_SUPPORT
1094 if (cmsg->cmsg_level == IPPROTO_IPV6 && cmsg->cmsg_type == IPV6_PKTINFO) {
1099 u.c = CMSG_DATA(cmsg);
1100 packet->
ifindex = (int)(u.p->ipi6_ifindex);
1102 &u.p->ipi6_addr,
sizeof(
struct in6_addr));
1108#if COAP_IPV4_SUPPORT
1110#if defined(IP_PKTINFO)
1111 if (cmsg->cmsg_level ==
COAP_SOL_IP && cmsg->cmsg_type == IP_PKTINFO) {
1116 u.c = CMSG_DATA(cmsg);
1117 packet->
ifindex = u.p->ipi_ifindex;
1118#if COAP_IPV6_SUPPORT
1124 &u.p->ipi_addr,
sizeof(
struct in_addr));
1129 &u.p->ipi_addr,
sizeof(
struct in_addr));
1135#if defined(IP_RECVDSTADDR)
1136 if (cmsg->cmsg_level == IPPROTO_IP && cmsg->cmsg_type == IP_RECVDSTADDR) {
1139 CMSG_DATA(cmsg),
sizeof(
struct in_addr));
1148 if (cmsg->cmsg_level != -1 && cmsg->cmsg_type != -1) {
1149 coap_log_debug(
"cmsg_level = %d and cmsg_type = %d not supported - fix\n",
1150 cmsg->cmsg_level, cmsg->cmsg_type);
1164 packet->
length = (size_t)len;
1184#ifndef COAP_EPOLL_SUPPORT
1187 coap_log_emerg(
"coap_io_prepare_epoll() requires libcoap compiled for using epoll\n");
1191 unsigned int max_sockets =
sizeof(sockets)/
sizeof(sockets[0]);
1192 unsigned int num_sockets;
1193 unsigned int timeout;
1199 ctx->next_timeout = timeout ? now + timeout : 0;
1200 if (ctx->eptimerfd != -1) {
1201 struct itimerspec new_value;
1204 memset(&new_value, 0,
sizeof(new_value));
1206 if (ctx->next_timeout != 0 && ctx->next_timeout > now) {
1207 coap_tick_t rem_timeout = ctx->next_timeout - now;
1213#ifdef COAP_DEBUG_WAKEUP_TIMES
1215 new_value.it_value.tv_sec, new_value.it_value.tv_nsec);
1218 ret = timerfd_settime(ctx->eptimerfd, 0, &new_value, NULL);
1221 "coap_io_prepare_epoll",
1236 unsigned int max_sockets,
1237 unsigned int *num_sockets,
1243#if COAP_SERVER_SUPPORT
1244 int check_dtls_timeouts = 0;
1246#if defined(COAP_EPOLL_SUPPORT) || defined(WITH_LWIP) || defined(RIOT_VERSION)
1254#if COAP_SERVER_SUPPORT
1258#if COAP_ASYNC_SUPPORT
1260 timeout = coap_check_async(ctx, now);
1271 if (nextpdu && (timeout == 0 ||
1279 if (tls_timeout > 0) {
1284 if (timeout == 0 || tls_timeout - now < timeout)
1285 timeout = tls_timeout - now;
1287#if COAP_SERVER_SUPPORT
1289 check_dtls_timeouts = 1;
1293#if COAP_SERVER_SUPPORT
1303#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
1305 if (*num_sockets < max_sockets)
1306 sockets[(*num_sockets)++] = &ep->
sock;
1320 s_timeout = (s->
last_rx_tx + session_timeout) - now;
1321 if (timeout == 0 || s_timeout < timeout)
1322 timeout = s_timeout;
1330 while (tls_timeout > 0 && tls_timeout <= now) {
1343 if (tls_timeout > 0 && (timeout == 0 || tls_timeout - now < timeout))
1344 timeout = tls_timeout - now;
1349 if (timeout == 0 || s_timeout < timeout)
1350 timeout = s_timeout;
1356 if (timeout == 0 || s_timeout < timeout)
1357 timeout = s_timeout;
1360#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
1362 if (*num_sockets < max_sockets)
1363 sockets[(*num_sockets)++] = &s->
sock;
1366#if COAP_Q_BLOCK_SUPPORT
1372 s_timeout = coap_block_check_q_block2_xmit(s, now);
1373 if (timeout == 0 || s_timeout < timeout)
1374 timeout = s_timeout;
1383#if COAP_CLIENT_SUPPORT
1400 if (timeout == 0 || s_timeout < timeout)
1401 timeout = s_timeout;
1404#if !COAP_DISABLE_TCP
1416 if ((timeout == 0 || s_timeout < timeout) && s_timeout != 0)
1417 timeout = s_timeout;
1427 while (tls_timeout > 0 && tls_timeout <= now) {
1439 if (tls_timeout > 0 && (timeout == 0 || tls_timeout - now < timeout))
1440 timeout = tls_timeout - now;
1446 if (timeout == 0 || s_timeout < timeout)
1447 timeout = s_timeout;
1453 if (timeout == 0 || s_timeout < timeout)
1454 timeout = s_timeout;
1457#if COAP_Q_BLOCK_SUPPORT
1463 s_timeout = coap_block_check_q_block1_xmit(s, now);
1464 if (timeout == 0 || s_timeout < timeout)
1465 timeout = s_timeout;
1469#if !defined(COAP_EPOLL_SUPPORT) && !defined(WITH_LWIP) && !defined(RIOT_VERSION)
1474 if (*num_sockets < max_sockets)
1475 sockets[(*num_sockets)++] = &s->
sock;
1486#if !defined(WITH_LWIP) && !defined(CONTIKI) && !defined(RIOT_VERSION)
1494 int enfds, fd_set *ereadfds, fd_set *ewritefds,
1495 fd_set *eexceptfds) {
1498 unsigned int timeout;
1499#ifndef COAP_EPOLL_SUPPORT
1508#ifndef COAP_EPOLL_SUPPORT
1539#if !COAP_DISABLE_TCP
1553 }
else if (timeout == 0 && timeout_ms ==
COAP_IO_WAIT) {
1556 if (timeout == 0 || (timeout_ms !=
COAP_IO_WAIT && timeout_ms < timeout))
1557 timeout = timeout_ms;
1558 tv.tv_usec = (timeout % 1000) * 1000;
1559 tv.tv_sec = (long)(timeout / 1000);
1566 timeout > 0 ? &tv : NULL);
1572 coap_win_error_to_errno();
1574 if (errno != EINTR) {
1600#if !COAP_DISABLE_TCP
1634 }
else if (timeout == 0 && timeout_ms ==
COAP_IO_WAIT) {
1642 if (timeout == 0 || (timeout_ms !=
COAP_IO_WAIT && timeout_ms < timeout))
1643 etimeout = timeout_ms;
1658 if (errno != EINTR) {
1659 coap_log_err(
"epoll_wait: unexpected error: %s (%d)\n",
1670 if (errno != EINTR) {
1671 coap_log_err(
"epoll_wait: unexpected error: %s (%d)\n",
1693#if COAP_SERVER_SUPPORT
1697#if COAP_ASYNC_SUPPORT
1700 coap_check_async(ctx, now);
1715#if COAP_SERVER_SUPPORT
1727#if COAP_SERVER_SUPPORT
1728 LL_FOREACH(context->
endpoint, ep) {
1739#if COAP_CLIENT_SUPPORT
1755 static char szError[256];
1756 if (FormatMessage(FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS,
1757 NULL, (DWORD)error, MAKELANGID(LANG_NEUTRAL,
1758 SUBLANG_DEFAULT), (LPSTR)szError, (DWORD)
sizeof(szError),
1760 strcpy(szError,
"Unknown error");
1771 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.
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
#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_CAN_WRITE
non blocking socket can now write without blocking
#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
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().
#define coap_lock_check_locked(s)
#define coap_lock_unlock(s)
#define coap_lock_lock(s, failed)
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(...)
void coap_check_notify(coap_context_t *context)
Checks all known resources to see if they are dirty and then notifies subscribed observers.
#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.
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
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 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
uint32_t csm_timeout_ms
Timeout for waiting for a CSM from the remote side.
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