Repository: qpid-dispatch Updated Branches: refs/heads/crolke-DISPATCH-188-1 795bea38f -> 93b5450f2
Initialize stall flag in all constructors; Activate the server connector when coming out of stall. Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/93b5450f Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/93b5450f Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/93b5450f Branch: refs/heads/crolke-DISPATCH-188-1 Commit: 93b5450f29c09bd1722f3b54255299b53518bf24 Parents: 795bea3 Author: Chuck Rolke <[email protected]> Authored: Mon Nov 9 16:09:31 2015 -0500 Committer: Chuck Rolke <[email protected]> Committed: Mon Nov 9 16:09:31 2015 -0500 ---------------------------------------------------------------------- src/server.c | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/93b5450f/src/server.c ---------------------------------------------------------------------- diff --git a/src/server.c b/src/server.c index 8203c33..569faaa 100644 --- a/src/server.c +++ b/src/server.c @@ -268,6 +268,7 @@ static void thread_process_listeners_LH(qd_server_t *qd_server) ctx->connection_id = qd_server->next_connection_id++; // Increment the connection id so the next connection can use it DEQ_INIT(ctx->deferred_calls); ctx->deferred_call_lock = sys_mutex(); + ctx->event_stall = false; pn_connection_t *conn = pn_connection(); ctx->collector = pn_collector(); @@ -819,6 +820,7 @@ static void cxtr_try_open(void *context) DEQ_INIT(ctx->deferred_calls); ctx->deferred_call_lock = sys_mutex(); + ctx->event_stall = false; qd_log(ct->server->log_source, QD_LOG_TRACE, "Connecting to %s:%s", ct->config->host, ct->config->port); @@ -1270,6 +1272,8 @@ void qd_connection_invoke_deferred(qd_connection_t *conn, qd_deferred_t call, vo void qd_connection_set_event_stall(qd_connection_t *conn, bool stall) { conn->event_stall = stall; + if (!stall) + qd_server_activate(conn); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
