Reverting 346525 due to accidental patch against trunk instead of 1.8

git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@346563 65c4cc65-6c06-0410-ace0-fbb531ad65f3

diff --git a/channels/chan_sip.c b/channels/chan_sip.c
index 75b207e1b99691e1aec345f8e7321ebf6f48dfc0..3b3a3460a9b87a6f02bd9f06e577c9665072f277 100644 (file)
--- a/channels/chan_sip.c
+++ b/channels/chan_sip.c
@@ -2813,7 +2813,14 @@ cleanup:
 
        if (tcptls_session) {
                ast_mutex_lock(&tcptls_session->lock);
-               ast_tcptls_close_session_file(tcptls_session);
+               if (tcptls_session->f) {
+                       fclose(tcptls_session->f);
+                       tcptls_session->f = NULL;
+               }
+               if (tcptls_session->fd != -1) {
+                       close(tcptls_session->fd);
+                       tcptls_session->fd = -1;
+               }
                tcptls_session->parent = NULL;
                ast_mutex_unlock(&tcptls_session->lock);
 
@@ -26012,8 +26019,8 @@ create_tcptls_session_fail:
                ao2_t_ref(ca, -1, "failed to create client, getting rid of client tcptls_session arguments");
        }
        if (s->tcptls_session) {
-               ast_tcptls_close_session_file(tcptls_session);
-               s->fd = -1;
+               close(tcptls_session->fd);
+               s->fd = tcptls_session->fd = -1;
                ao2_ref(s->tcptls_session, -1);
                s->tcptls_session = NULL;
        }

diff --git a/include/asterisk/tcptls.h b/include/asterisk/tcptls.h
index e9b2371fbf96c8593e51f67571f316c6cd6c6feb..6f187b20be332a0eb9ff70a4dfd2a5858f67c787 100644 (file)
--- a/include/asterisk/tcptls.h
+++ b/include/asterisk/tcptls.h
@@ -176,13 +176,6 @@ struct ast_tcptls_session_instance *ast_tcptls_client_create(struct ast_tcptls_s
 
 void *ast_tcptls_server_root(void *);
 
-/*!
- * \brief Closes a tcptls session instance's file and/or file descriptor.
- * The tcptls_session will be set to NULL and it's file descriptor will be set to -1
- * by this function.
- */
-void ast_tcptls_close_session_file(struct ast_tcptls_session_instance *tcptls_session);
-
 /*!
  * \brief This is a generic (re)start routine for a TCP server,
  * which does the socket/bind/listen and starts a thread for handling

diff --git a/main/tcptls.c b/main/tcptls.c
index 71d527c5badbe576a45d09ec5c2a14b469b87698..5a177a884afd79f14cc8c69eb10d522bd0838c52 100644 (file)
--- a/main/tcptls.c
+++ b/main/tcptls.c
@@ -78,23 +78,9 @@ static HOOK_T ssl_write(void *cookie, const char *buf, LEN_T len)
 
 static int ssl_close(void *cookie)
 {
-       int cookie_fd = SSL_get_fd(cookie);
-       int ret;
-       if (cookie_fd > -1) {
-               /*
-                * According to the TLS standard, it is acceptable for an application to only send its shutdown
-                * alert and then close the underlying connection without waiting for the peer's response (this
-                * way resources can be saved, as the process can already terminate or serve another connection).
-                */
-               if ((ret = SSL_shutdown(cookie)) < 0) {
-                       ast_log(LOG_ERROR, "SSL_shutdown() failed: %d\n", SSL_get_error(cookie, ret));
-               }
-               SSL_free(cookie);
-               /* adding shutdown(2) here has no added benefit */
-               if (close(cookie_fd)) {
-                       ast_log(LOG_ERROR, "close() failed: %s\n", strerror(errno));
-               }
-       }
+       close(SSL_get_fd(cookie));
+       SSL_shutdown(cookie);
+       SSL_free(cookie);
        return 0;
 }
 #endif /* DO_SSL */
@@ -159,7 +145,8 @@ static void *handle_tcptls_connection(void *data)
        if (!tcptls_session->parent->tls_cfg) {
                if ((tcptls_session->f = fdopen(tcptls_session->fd, "w+"))) {
                        if(setvbuf(tcptls_session->f, NULL, _IONBF, 0)) {
-                               ast_tcptls_close_session_file(tcptls_session);
+                               fclose(tcptls_session->f);
+                               tcptls_session->f = NULL;
                        }
                }
        }
@@ -225,7 +212,8 @@ static void *handle_tcptls_connection(void *data)
                                                if (peer) {
                                                        X509_free(peer);
                                                }
-                                               ast_tcptls_close_session_file(tcptls_session);
+                                               close(tcptls_session->fd);
+                                               fclose(tcptls_session->f);
                                                ao2_ref(tcptls_session, -1);
                                                return NULL;
                                        }
@@ -242,7 +230,7 @@ static void *handle_tcptls_connection(void *data)
 #endif /* DO_SSL */
 
        if (!tcptls_session->f) {
-               ast_tcptls_close_session_file(tcptls_session);
+               close(tcptls_session->fd);
                ast_log(LOG_WARNING, "FILE * open failed!\n");
 #ifndef DO_SSL
                if (tcptls_session->parent->tls_cfg) {
@@ -288,9 +276,7 @@ void *ast_tcptls_server_root(void *data)
                tcptls_session = ao2_alloc(sizeof(*tcptls_session), session_instance_destructor);
                if (!tcptls_session) {
                        ast_log(LOG_WARNING, "No memory for new session: %s\n", strerror(errno));
-                       if (close(fd)) {
-                               ast_log(LOG_ERROR, "close() failed: %s\n", strerror(errno));
-                       }
+                       close(fd);
                        continue;
                }
 
@@ -307,7 +293,7 @@ void *ast_tcptls_server_root(void *data)
                /* This thread is now the only place that controls the single ref to tcptls_session */
                if (ast_pthread_create_detached_background(&launched, NULL, handle_tcptls_connection, tcptls_session)) {
                        ast_log(LOG_WARNING, "Unable to launch helper thread: %s\n", strerror(errno));
-                       ast_tcptls_close_session_file(tcptls_session);
+                       close(tcptls_session->fd);
                        ao2_ref(tcptls_session, -1);
                }
        }
@@ -572,24 +558,6 @@ error:
        desc->accept_fd = -1;
 }
 
-void ast_tcptls_close_session_file(struct ast_tcptls_session_instance *tcptls_session)
-{
-       if (tcptls_session->f) {
-               if (fclose(tcptls_session->f)) {
-                       ast_log(LOG_ERROR, "fclose() failed: %s\n", strerror(errno));
-               }
-               tcptls_session->f = NULL;
-               tcptls_session->fd = -1;
-       } else if (tcptls_session->fd != -1) {
-               if (close(tcptls_session->fd)) {
-                       ast_log(LOG_ERROR, "close() failed: %s\n", strerror(errno));
-               }
-               tcptls_session->fd = -1;
-       } else {
-               ast_log(LOG_ERROR, "ast_tcptls_close_session_file invoked on session instance without file or file descriptor\n");
-       }
-}
-
 void ast_tcptls_server_stop(struct ast_tcptls_session_args *desc)
 {
        if (desc->master != AST_PTHREADT_NULL) {