Repository: qpid-dispatch Updated Branches: refs/heads/master 11181b878 -> d11e709ec
DISPATCH-932 Add the line back in that accumultes the ingressHistogram values Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/d11e709e Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/d11e709e Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/d11e709e Branch: refs/heads/master Commit: d11e709eca76bcbb03e05ff3e5c0c4a06589cd77 Parents: 11181b8 Author: Ernest Allen <eal...@redhat.com> Authored: Wed Mar 7 14:20:29 2018 -0500 Committer: Ernest Allen <eal...@redhat.com> Committed: Wed Mar 7 14:20:29 2018 -0500 ---------------------------------------------------------------------- src/router_core/transfer.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/d11e709e/src/router_core/transfer.c ---------------------------------------------------------------------- diff --git a/src/router_core/transfer.c b/src/router_core/transfer.c index 13d7462..b1ba497 100644 --- a/src/router_core/transfer.c +++ b/src/router_core/transfer.c @@ -547,7 +547,9 @@ static void qdr_delete_delivery_internal_CT(qdr_core_t *core, qdr_delivery_t *de if (link->link_direction == QD_INCOMING) core->modified_deliveries++; } - } + + if (qd_bitmask_valid_bit_value(delivery->ingress_index) && link->ingress_histogram) + link->ingress_histogram[delivery->ingress_index]++; } // // Free all the peer qdr_delivery_ref_t references --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org