You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2016/01/30 02:34:39 UTC
[3/3] qpid-dispatch git commit: DISPATCH-179 Fixed counting of
processing events - solved latency issue.
DISPATCH-179 Fixed counting of processing events - solved latency issue.
Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/43065ad8
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/43065ad8
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/43065ad8
Branch: refs/heads/tross-DISPATCH-179-1
Commit: 43065ad88a7a20bce096b9a5d47473bf41f4d3ef
Parents: 5748a2c
Author: Ted Ross <tr...@redhat.com>
Authored: Fri Jan 29 20:23:22 2016 -0500
Committer: Ted Ross <tr...@redhat.com>
Committed: Fri Jan 29 20:23:22 2016 -0500
----------------------------------------------------------------------
src/router_core/connections.c | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/43065ad8/src/router_core/connections.c
----------------------------------------------------------------------
diff --git a/src/router_core/connections.c b/src/router_core/connections.c
index be07f6f..6892506 100644
--- a/src/router_core/connections.c
+++ b/src/router_core/connections.c
@@ -159,8 +159,10 @@ int qdr_connection_process(qdr_connection_t *conn)
link = 0;
sys_mutex_unlock(conn->work_lock);
- if (link)
+ if (link) {
core->push_handler(core->user_context, link);
+ event_count++;
+ }
} while (link);
do {
@@ -176,6 +178,7 @@ int qdr_connection_process(qdr_connection_t *conn)
if (link) {
core->flow_handler(core->user_context, link, link->incremental_credit);
link->incremental_credit = 0;
+ event_count++;
}
} while (link);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org