You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gm...@apache.org on 2016/05/10 13:41:24 UTC

qpid-dispatch git commit: DISPATCH-321 - Removed qdpn_connector_close call from process_connector. This will prevent premature closing of connection

Repository: qpid-dispatch
Updated Branches:
  refs/heads/master 438ffa121 -> e9f1dd495


DISPATCH-321 - Removed qdpn_connector_close call from process_connector. This will prevent premature closing of connection


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

Branch: refs/heads/master
Commit: e9f1dd4951970ff6110229614f312ee5809979ec
Parents: 438ffa1
Author: Ganesh Murthy <gm...@redhat.com>
Authored: Mon May 9 20:08:39 2016 -0400
Committer: Ganesh Murthy <gm...@redhat.com>
Committed: Mon May 9 20:08:39 2016 -0400

----------------------------------------------------------------------
 src/server.c | 2 --
 1 file changed, 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/e9f1dd49/src/server.c
----------------------------------------------------------------------
diff --git a/src/server.c b/src/server.c
index c761720..3ddef99 100644
--- a/src/server.c
+++ b/src/server.c
@@ -730,8 +730,6 @@ static int process_connector(qd_server_t *qd_server, qdpn_connector_t *cxtr)
                                             ctx->context, ce, (qd_connection_t*) qdpn_connector_context(cxtr));
                     events = 1;
                 } else if (pn_event_type(event) == PN_TRANSPORT_ERROR) {
-                    ctx->closed = true;
-                    qdpn_connector_close(cxtr);
                     if (ctx->connector) {
                         const qd_server_config_t *config = ctx->connector->config;
                         qd_log(qd_server->log_source, QD_LOG_TRACE, "Connection to %s:%s failed", config->host, config->port);


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