Repository: qpid-dispatch Updated Branches: refs/heads/tross-dispatch-781-1 85a89965a -> 2633a18eb
DISPATCH-781 - Take credit_deficit into account when calculating a new delta. Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/2633a18e Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/2633a18e Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/2633a18e Branch: refs/heads/tross-dispatch-781-1 Commit: 2633a18eb3a0621482a6b1982fab98a6dfabaef0 Parents: 85a8996 Author: Ted Ross <tr...@redhat.com> Authored: Fri Jun 2 12:40:54 2017 -0400 Committer: Ted Ross <tr...@redhat.com> Committed: Fri Jun 2 12:40:54 2017 -0400 ---------------------------------------------------------------------- src/router_core/transfer.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/2633a18e/src/router_core/transfer.c ---------------------------------------------------------------------- diff --git a/src/router_core/transfer.c b/src/router_core/transfer.c index d7e8d52..7262bdd 100644 --- a/src/router_core/transfer.c +++ b/src/router_core/transfer.c @@ -840,7 +840,11 @@ void qdr_addr_visit_inlinks_CT(qdr_core_t *core, qdr_address_t *addr) // Target credit is not to exceed the link capacity. // uint32_t target_credit = (addr->target_in_credit < link->capacity) ? addr->target_in_credit : link->capacity; - int32_t diff = (int32_t) target_credit - (int32_t) link->credit_window; + + // + // Calculate the change in credit from current to target. + // + int32_t diff = (int32_t) target_credit - (int32_t) link->credit_window - (int32_t) link->credit_deficit; link->credit_window = target_credit; if (diff > 0) { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
