mirrors/coturn
1
0
Fork 0
mirror of https://github.com/coturn/coturn.git synced 2025-10-29 14:01:01 +01:00
Code Issues Projects Releases Wiki Activity

working on sctp

Browse Source
This commit is contained in:
mom040267 2015-03-16 07:10:07 +00:00
parent b824384faa
commit 2958c8ec73
2 changed files with 13 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/apps/relay/ns_ioalib_engine_impl.c
View File

@ -50,6 +50,13 @@
#include "hiredis_libevent2.h" #include "hiredis_libevent2.h"
#endif #endif
#if defined(__linux__) || defined(__LINUX__) || defined(__linux) || defined(linux__) || defined(LINUX) || defined(__LINUX) || defined(LINUX__)
#include <linux/sctp.h>
#else
#include <netinet/sctp.h>
#endif
/* Compilation test: /* Compilation test:
#if defined(IP_RECVTTL) #if defined(IP_RECVTTL)
#undef IP_RECVTTL #undef IP_RECVTTL
@ -870,6 +877,12 @@ int set_socket_options_fd(evutil_socket_t fd, int tcp, int family)
(char*)&flag, /* value */ (char*)&flag, /* value */
sizeof(int)); /* length of option value */ sizeof(int)); /* length of option value */
setsockopt(fd, /* socket affected */
IPPROTO_SCTP, /* set option at TCP level */
SCTP_NODELAY, /* name of option */
(char*)&flag, /* value */
sizeof(int)); /* length of option value */
socket_tcp_set_keepalive(fd); socket_tcp_set_keepalive(fd);
} }

30
src/apps/relay/tls_listener.c
View File

@ -38,12 +38,6 @@
#include <event2/listener.h> #include <event2/listener.h>
#if defined(__linux__) || defined(__LINUX__) || defined(__linux) || defined(linux__) || defined(LINUX) || defined(__LINUX) || defined(LINUX__)
#include <linux/sctp.h>
#else
#include <netinet/sctp.h>
#endif
/////////////////////////////////////////////////// ///////////////////////////////////////////////////
#define FUNCSTART if(server && eve(server->verbose)) TURN_LOG_FUNC(TURN_LOG_LEVEL_INFO,"%s:%d:start\n",__FUNCTION__,__LINE__) #define FUNCSTART if(server && eve(server->verbose)) TURN_LOG_FUNC(TURN_LOG_LEVEL_INFO,"%s:%d:start\n",__FUNCTION__,__LINE__)
@ -284,30 +278,6 @@ static int sctp_create_server_listener(tls_listener_relay_server_type* server) {
socket_set_nonblocking(tls_listen_fd); socket_set_nonblocking(tls_listen_fd);
{
struct sctp_paddrparams heartbeat;
ns_bzero(&heartbeat, sizeof(struct sctp_paddrparams));
heartbeat.spp_flags = SPP_HB_ENABLE;
heartbeat.spp_hbinterval = 5000;
heartbeat.spp_pathmaxrxt = 5;
/*Set Heartbeats*/
if(setsockopt(tls_listen_fd, IPPROTO_SCTP, SCTP_PEER_ADDR_PARAMS , &heartbeat, sizeof(heartbeat)) != 0)
perror("setsockopt");
}
{
struct sctp_rtoinfo rtoinfo;
ns_bzero(&rtoinfo, sizeof(struct sctp_rtoinfo));
rtoinfo.srto_max = 5000;
/*Set rto_max*/
if(setsockopt(tls_listen_fd, IPPROTO_SCTP, SCTP_RTOINFO , &rtoinfo, sizeof(rtoinfo)) != 0)
perror("setsockopt");
}
server->sctp_l = evconnlistener_new(server->e->event_base, server->sctp_l = evconnlistener_new(server->e->event_base,
sctp_server_input_handler, server, sctp_server_input_handler, server,
LEV_OPT_CLOSE_ON_FREE | LEV_OPT_REUSEABLE, LEV_OPT_CLOSE_ON_FREE | LEV_OPT_REUSEABLE,