You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2018/03/14 22:11:46 UTC

[3/3] qpid-dispatch git commit: DISPATCH-944: Ensure socket is closed

DISPATCH-944: Ensure socket is closed


Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/0f05f836
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/0f05f836
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/0f05f836

Branch: refs/heads/master
Commit: 0f05f836f12390e898babcac234f176778670493
Parents: 9bcf083
Author: Gordon Sim <gs...@redhat.com>
Authored: Wed Mar 14 22:04:21 2018 +0000
Committer: Gordon Sim <gs...@redhat.com>
Committed: Wed Mar 14 22:06:07 2018 +0000

----------------------------------------------------------------------
 src/remote_sasl.c | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/0f05f836/src/remote_sasl.c
----------------------------------------------------------------------
diff --git a/src/remote_sasl.c b/src/remote_sasl.c
index 65dcab4..54fd7c8 100644
--- a/src/remote_sasl.c
+++ b/src/remote_sasl.c
@@ -376,6 +376,8 @@ static void remote_sasl_process_outcome(pn_transport_t *transport)
             //only consider complete if failed; if successful wait for the open frame
             if (impl->outcome != PN_SASL_OK && !notify_upstream(impl, DOWNSTREAM_OUTCOME_RECEIVED)) {
                 pnx_sasl_set_desired_state(transport, SASL_ERROR);
+                pn_transport_close_tail(transport);
+                pn_transport_close_head(transport);
             }
         }
     }
@@ -641,6 +643,8 @@ void qdr_handle_authentication_service_connection_event(pn_event_t *e)
 
         //close downstream connection
         pn_connection_close(conn);
+        pn_transport_close_tail(transport);
+        pn_transport_close_head(transport);
     } else if (pn_event_type(e) == PN_CONNECTION_REMOTE_CLOSE) {
         qd_log(auth_service_log, QD_LOG_DEBUG, "authentication service closed connection");
         pn_connection_close(conn);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org