Repository: qpid-dispatch Updated Branches: refs/heads/master b501cbafa -> f080baabd
DISPATCH-1212 - When a receiver drops off, increment the core->dropped_presettled_deliveries if there are presettled deliveries in the undelivered list. Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/f080baab Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/f080baab Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/f080baab Branch: refs/heads/master Commit: f080baabd1a5eb37f94178b0b54a7a70c6271e73 Parents: b501cba Author: Ganesh Murthy <gmur...@redhat.com> Authored: Wed Dec 5 14:54:23 2018 -0500 Committer: Ganesh Murthy <gmur...@redhat.com> Committed: Thu Dec 6 11:38:13 2018 -0500 ---------------------------------------------------------------------- src/router_core/connections.c | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/f080baab/src/router_core/connections.c ---------------------------------------------------------------------- diff --git a/src/router_core/connections.c b/src/router_core/connections.c index d06bec9..f8e3d51 100644 --- a/src/router_core/connections.c +++ b/src/router_core/connections.c @@ -634,6 +634,8 @@ static void qdr_link_cleanup_deliveries_CT(qdr_core_t *core, qdr_connection_t *c qdr_delivery_t *d = DEQ_HEAD(undelivered); while (d) { assert(d->where == QDR_DELIVERY_IN_UNDELIVERED); + if (d->presettled) + core->dropped_presettled_deliveries++; d->where = QDR_DELIVERY_NOWHERE; d = DEQ_NEXT(d); } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
