Use non-blocking socket() and pipe() wrappers

Change-Id: I050ceffe5a133d5add2dab46687209813d58f597

diff --git a/main/tcptls.c b/main/tcptls.c
index c5ab0b6036ff103117fcf0bd9f8b2b04d48930cb..d32b91fd4a550cb8f2c71286defadcd6e73f8060 100644 (file)
--- a/main/tcptls.c
+++ b/main/tcptls.c
@@ -1277,7 +1277,7 @@ void ast_tcptls_server_start(struct ast_tcptls_session_args *desc)
                return;
        }
 
-       desc->accept_fd = socket(ast_sockaddr_is_ipv6(&desc->local_address) ?
+       desc->accept_fd = ast_socket_nonblock(ast_sockaddr_is_ipv6(&desc->local_address) ?
                                 AF_INET6 : AF_INET, SOCK_STREAM, 0);
        if (desc->accept_fd < 0) {
                ast_log(LOG_ERROR, "Unable to allocate socket for %s: %s\n", desc->name, strerror(errno));
@@ -1296,7 +1296,6 @@ void ast_tcptls_server_start(struct ast_tcptls_session_args *desc)
                ast_log(LOG_ERROR, "Unable to listen for %s!\n", desc->name);
                goto error;
        }
-       ast_fd_set_flags(desc->accept_fd, O_NONBLOCK);
        if (ast_pthread_create_background(&desc->master, NULL, desc->accept_fn, desc)) {
                ast_log(LOG_ERROR, "Unable to launch thread for %s on %s: %s\n",
                        desc->name,

diff --git a/main/udptl.c b/main/udptl.c
index 83989f7388f50bb307cd7e8eb52494d87ab901fa..59fccf4d2637ba2f914f9401cbca46f75d64b7cc 100644 (file)
--- a/main/udptl.c
+++ b/main/udptl.c
@@ -1038,13 +1038,12 @@ struct ast_udptl *ast_udptl_new_with_bindaddr(struct ast_sched_context *sched, s
                udptl->tx[i].buf_len = -1;
        }
 
-       if ((udptl->fd = socket(ast_sockaddr_is_ipv6(addr) ?
+       if ((udptl->fd = ast_socket_nonblock(ast_sockaddr_is_ipv6(addr) ?
                                        AF_INET6 : AF_INET, SOCK_DGRAM, 0)) < 0) {
                ast_free(udptl);
                ast_log(LOG_WARNING, "Unable to allocate socket: %s\n", strerror(errno));
                return NULL;
        }
-       ast_fd_set_flags(udptl->fd, O_NONBLOCK);
 
 #ifdef SO_NO_CHECK
        if (cfg->general->nochecksums)

diff --git a/res/res_agi.c b/res/res_agi.c
index f19303f4dca90acbe6aeb9c7c6fed1c2740b3df0..270c26942f2f6f175450216ad11b569ea3bfcc24 100644 (file)
--- a/res/res_agi.c
+++ b/res/res_agi.c
@@ -2073,16 +2073,11 @@ static enum agi_result launch_netscript(char *agiurl, char *argv[], int *fds)
                        ast_sockaddr_set_port(&addrs[i], AGI_PORT);
                }
 
-               if ((s = socket(addrs[i].ss.ss_family, SOCK_STREAM, IPPROTO_TCP)) < 0) {
+               if ((s = ast_socket_nonblock(addrs[i].ss.ss_family, SOCK_STREAM, IPPROTO_TCP)) < 0) {
                        ast_log(LOG_WARNING, "Unable to create socket: %s\n", strerror(errno));
                        continue;
                }
 
-               if (ast_fd_set_flags(s, O_NONBLOCK)) {
-                       close(s);
-                       continue;
-               }
-
                if (ast_connect(s, &addrs[i]) && errno == EINPROGRESS) {
 
                        if (handle_connection(agiurl, addrs[i], s)) {

diff --git a/res/res_rtp_asterisk.c b/res/res_rtp_asterisk.c
index 4586ca67f6c7cef930612a571b614c8cb563e665..d94dd1698e5696f570b9307d541ba3099f4ab225 100644 (file)
--- a/res/res_rtp_asterisk.c
+++ b/res/res_rtp_asterisk.c
@@ -2792,21 +2792,18 @@ static double stddev_compute(double stddev, double sample, double normdev, doubl
 
 static int create_new_socket(const char *type, int af)
 {
-       int sock = socket(af, SOCK_DGRAM, 0);
+       int sock = ast_socket_nonblock(af, SOCK_DGRAM, 0);
 
        if (sock < 0) {
-               if (!type) {
-                       type = "RTP/RTCP";
-               }
                ast_log(LOG_WARNING, "Unable to allocate %s socket: %s\n", type, strerror(errno));
-       } else {
-               ast_fd_set_flags(sock, O_NONBLOCK);
+               return sock;
+       }
+
 #ifdef SO_NO_CHECK
-               if (nochecksums) {
-                       setsockopt(sock, SOL_SOCKET, SO_NO_CHECK, &nochecksums, sizeof(nochecksums));
-               }
-#endif
+       if (nochecksums) {
+               setsockopt(sock, SOL_SOCKET, SO_NO_CHECK, &nochecksums, sizeof(nochecksums));
        }
+#endif
 
        return sock;
 }

diff --git a/res/res_timing_pthread.c b/res/res_timing_pthread.c
index eee0749442ba9e9835219400420483e31c084a22..cefe6a7820f3f2e3d8b5e3e28b5ee8b72d5962f6 100644 (file)
--- a/res/res_timing_pthread.c
+++ b/res/res_timing_pthread.c
@@ -116,7 +116,6 @@ static struct {
 static void *pthread_timer_open(void)
 {
        struct pthread_timer *timer;
-       int i;
 
        if (!(timer = ao2_alloc(sizeof(*timer), pthread_timer_destructor))) {
                errno = ENOMEM;
@@ -126,15 +125,11 @@ static void *pthread_timer_open(void)
        timer->pipe[PIPE_READ] = timer->pipe[PIPE_WRITE] = -1;
        timer->state = TIMER_STATE_IDLE;
 
-       if (pipe(timer->pipe)) {
+       if (ast_pipe_nonblock(timer->pipe)) {
                ao2_ref(timer, -1);
                return NULL;
        }
 
-       for (i = 0; i < ARRAY_LEN(timer->pipe); ++i) {
-               ast_fd_set_flags(timer->pipe[i], O_NONBLOCK);
-       }
-
        ao2_lock(pthread_timers);
        if (!ao2_container_count(pthread_timers)) {
                ast_mutex_lock(&timing_thread.lock);