You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2015/11/19 19:24:19 UTC

qpid-dispatch git commit: NO-JIRA - Protect signal handler from late-arriving signals (hat time Mick Goulish) Replaced pn_connection_free with pn_decref

Repository: qpid-dispatch
Updated Branches:
  refs/heads/master bc2586a61 -> 9aae194f4


NO-JIRA - Protect signal handler from late-arriving signals (hat time Mick Goulish)
          Replaced pn_connection_free with pn_decref


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

Branch: refs/heads/master
Commit: 9aae194f4b1fa23171084407e2c4565709fe782a
Parents: bc2586a
Author: Ted Ross <tr...@redhat.com>
Authored: Thu Nov 19 13:22:54 2015 -0500
Committer: Ted Ross <tr...@redhat.com>
Committed: Thu Nov 19 13:22:54 2015 -0500

----------------------------------------------------------------------
 src/server.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/9aae194f/src/server.c
----------------------------------------------------------------------
diff --git a/src/server.c b/src/server.c
index 3d3b879..c15e871 100644
--- a/src/server.c
+++ b/src/server.c
@@ -716,7 +716,7 @@ static void *thread_run(void *arg)
                 qdpn_connector_free(cxtr);
                 if (conn) {
                     pn_connection_set_context(conn, 0);
-                    pn_connection_free(conn);
+                    pn_decref(conn);
                 }
                 if (ctx->collector)
                     pn_collector_free(ctx->collector);
@@ -1132,6 +1132,9 @@ void qd_server_stop(qd_dispatch_t *qd)
 
 void qd_server_signal(qd_dispatch_t *qd, int signum)
 {
+    if (!qd)
+        return;
+
     qd_server_t *qd_server = qd->server;
 
     qd_server->pending_signal = signum;


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