/* * Copyright (C) 2011, 2012, 2013 Citrix Systems * * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * 3. Neither the name of the project nor the names of its contributors * may be used to endorse or promote products derived from this software * without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. */ #ifndef __IOADEFS__ #define __IOADEFS__ #define TURN_SERVER_VERSION "4.6.2" #define TURN_SERVER_VERSION_NAME "Gorst" #ifndef TURN_SERVER_BUILD_INFO #define TURN_SERVER_BUILD_INFO "" #endif #define TURN_SOFTWARE "Coturn-" TURN_SERVER_VERSION " '" TURN_SERVER_VERSION_NAME "'" TURN_SERVER_BUILD_INFO #if (defined(__unix__) || defined(unix)) && !defined(USG) #include #endif #if defined(__APPLE__) || defined(__DARWIN__) || defined(__MACH__) #define __APPLE_USE_RFC_3542 #endif #if defined(WINDOWS) #include #include #else #include #include #include #include #include #include #include #endif #include #include #include #include #include #include #include #include #include #include #ifdef __cplusplus extern "C" { #endif #define nswap16(s) ntohs(s) #define nswap32(ul) ntohl(ul) #define nswap64(ull) ioa_ntoh64(ull) static inline uint64_t _ioa_ntoh64(uint64_t v) { #if BYTE_ORDER == LITTLE_ENDIAN uint8_t *src = (uint8_t *)&v; uint8_t *dst = src + 7; while (src < dst) { uint8_t vdst = *dst; *(dst--) = *src; *(src++) = vdst; } #elif BYTE_ORDER == BIG_ENDIAN /* OK */ #else #error WRONG BYTE_ORDER SETTING #endif return v; } /* TTL */ #define TTL_IGNORE ((int)(-1)) #define TTL_DEFAULT (64) /* TOS */ #define TOS_IGNORE ((int)(-1)) #define TOS_DEFAULT (0) #define ioa_ntoh64 _ioa_ntoh64 #define ioa_hton64 _ioa_ntoh64 #if defined(WINDOWS) static inline int socket_errno(void) { return WSAGetLastError(); } static inline int socket_enomem(void) { return socket_errno() == WSA_NOT_ENOUGH_MEMORY; } static inline int socket_eintr(void) { return socket_errno() == WSAEINTR; } static inline int socket_ebadf(void) { return socket_errno() == WSAEBADF; } static inline int socket_eacces(void) { return socket_errno() == WSAEACCES; } static inline int socket_enobufs(void) { return socket_errno() == WSAENOBUFS; } static inline int socket_eagain(void) { return socket_errno() == WSATRY_AGAIN; } static inline int socket_ewouldblock(void) { return socket_errno() == WSAEWOULDBLOCK; } static inline int socket_einprogress(void) { return socket_errno() == WSAEINPROGRESS; } static inline int socket_econnreset(void) { return socket_errno() == WSAECONNRESET; } static inline int socket_econnrefused(void) { return socket_errno() == WSAECONNREFUSED; } static inline int socket_ehostdown(void) { return socket_errno() == WSAEHOSTDOWN; } static inline int socket_emsgsize(void) { return socket_errno() == WSAEMSGSIZE; } #else static inline int socket_errno(void) { return errno; } static inline int socket_eperm(void) { return socket_errno() == EPERM; } static inline int socket_enomem(void) { return socket_errno() == ENOMEM; } static inline int socket_eintr(void) { return socket_errno() == EINTR; } static inline int socket_ebadf(void) { return socket_errno() == EBADF; } static inline int socket_eacces(void) { return socket_errno() == EACCES; } static inline int socket_enobufs(void) { return socket_errno() == ENOBUFS; } static inline int socket_eagain(void) { return socket_errno() == EAGAIN; } #if defined(EWOULDBLOCK) static inline int socket_ewouldblock(void) { return socket_errno() == EWOULDBLOCK; } #else static inline int socket_ewouldblock(void) { return socket_errno() == EAGAIN; } #endif static inline int socket_einprogress(void) { return socket_errno() == EINPROGRESS; } static inline int socket_econnreset(void) { return socket_errno() == ECONNRESET; } static inline int socket_econnrefused(void) { return socket_errno() == ECONNREFUSED; } static inline int socket_ehostdown(void) { return socket_errno() == EHOSTDOWN; } static inline int socket_emsgsize(void) { return socket_errno() == EMSGSIZE; } #endif #define BUFFEREVENT_FREE(be) \ do { \ if (be) { \ bufferevent_flush(be, EV_READ | EV_WRITE, BEV_FLUSH); \ bufferevent_disable(be, EV_READ | EV_WRITE); \ bufferevent_free(be); \ be = NULL; \ } \ } while (0) #define turn_time() ((turn_time_t)time(NULL)) typedef int vint; typedef vint *vintp; typedef uint32_t turn_time_t; #define turn_time_before(t1, t2) ((((int32_t)(t1)) - ((int32_t)(t2))) < 0) #if !defined(UNUSED_ARG) #define UNUSED_ARG(A) \ do { \ A = A; \ } while (0) #endif #define MAX_STUN_MESSAGE_SIZE (65507) #define STUN_BUFFER_SIZE (MAX_STUN_MESSAGE_SIZE) #define UDP_STUN_BUFFER_SIZE (1024 << 4) #define NONCE_LENGTH_32BITS (4) #define DEFAULT_STUN_PORT 3478 #define DEFAULT_STUN_TLS_PORT 5349 #if BYTE_ORDER == LITTLE_ENDIAN #define DEFAULT_STUN_PORT_NBO (0x960D) #elif BYTE_ORDER == BIG_ENDIAN #define DEFAULT_STUN_PORT_NBO (0x0D96) #else #error WRONG BYTE_ORDER SETTING #endif #define STRCPY(dst, src) \ do { \ if ((const char *)(dst) != (const char *)(src)) { \ if (sizeof(dst) == sizeof(char *)) \ strcpy(((char *)(dst)), (const char *)(src)); \ else { \ size_t szdst = sizeof((dst)); \ strncpy((char *)(dst), (const char *)(src), szdst); \ ((char *)(dst))[szdst - 1] = 0; \ } \ } \ } while (0) //////////////// Bufferevents ///////////////////// #define TURN_BUFFEREVENTS_OPTIONS (BEV_OPT_DEFER_CALLBACKS | BEV_OPT_THREADSAFE | BEV_OPT_UNLOCK_CALLBACKS) //////////////// KERNEL-LEVEL CHANNEL HANDLERS ///////// #if !defined(TURN_CHANNEL_HANDLER_KERNEL) #define TURN_CHANNEL_HANDLER_KERNEL void * #endif #if !defined(CREATE_TURN_CHANNEL_KERNEL) #define CREATE_TURN_CHANNEL_KERNEL(channel_number, address_family_client, address_family_peer, protocol_client, \ client_addr, local_addr, local_relay_addr, peer_addr) \ ((TURN_CHANNEL_HANDLER_KERNEL)(1)) #endif #if !defined(DELETE_TURN_CHANNEL_KERNEL) #define DELETE_TURN_CHANNEL_KERNEL(handler) #endif //////////////////////////////////////////////////////// #if !defined(IPPROTO_SCTP) #define TURN_NO_SCTP #endif #define CLIENT_DGRAM_SOCKET_TYPE SOCK_DGRAM #define CLIENT_DGRAM_SOCKET_PROTOCOL IPPROTO_IP #define CLIENT_STREAM_SOCKET_TYPE SOCK_STREAM #define CLIENT_STREAM_SOCKET_PROTOCOL IPPROTO_IP #define SCTP_CLIENT_STREAM_SOCKET_TYPE SOCK_STREAM #if !defined(TURN_NO_SCTP) #define SCTP_CLIENT_STREAM_SOCKET_PROTOCOL IPPROTO_SCTP #else #define SCTP_CLIENT_STREAM_SOCKET_PROTOCOL IPPROTO_IP #endif #define RELAY_DGRAM_SOCKET_TYPE SOCK_DGRAM #define RELAY_DGRAM_SOCKET_PROTOCOL IPPROTO_IP #define RELAY_STREAM_SOCKET_TYPE SOCK_STREAM #define RELAY_STREAM_SOCKET_PROTOCOL IPPROTO_IP #define ADMIN_STREAM_SOCKET_TYPE SOCK_STREAM #define ADMIN_STREAM_SOCKET_PROTOCOL IPPROTO_IP //////////////////////////////////////////////////////// #ifdef __cplusplus } #endif #endif /* __IODEFS__ */