PROTON-1378: only generate a single PN_REACTOR_FINAL in reactor.c
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/673c75e7 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/673c75e7 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/673c75e7 Branch: refs/heads/go1 Commit: 673c75e71af00bf56e0e977c46be572144dbb578 Parents: 9377d85 Author: Clifford Jansen <cliffjan...@apache.org> Authored: Wed Dec 21 10:37:31 2016 -0800 Committer: Clifford Jansen <cliffjan...@apache.org> Committed: Wed Dec 21 10:37:31 2016 -0800 ---------------------------------------------------------------------- proton-c/src/reactor/reactor.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/673c75e7/proton-c/src/reactor/reactor.c ---------------------------------------------------------------------- diff --git a/proton-c/src/reactor/reactor.c b/proton-c/src/reactor/reactor.c index abf5d1e..bbf94f1 100644 --- a/proton-c/src/reactor/reactor.c +++ b/proton-c/src/reactor/reactor.c @@ -436,7 +436,8 @@ bool pn_reactor_process(pn_reactor_t *reactor) { pn_reactor_update(reactor, reactor->selectable); reactor->selectable = NULL; } else { - pn_collector_put(reactor->collector, PN_OBJECT, reactor, PN_REACTOR_FINAL); + if (reactor->previous != PN_REACTOR_FINAL) + pn_collector_put(reactor->collector, PN_OBJECT, reactor, PN_REACTOR_FINAL); return false; } } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
