You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ch...@apache.org on 2017/09/15 21:09:57 UTC
qpid-dispatch git commit: DISPATCH-827: Increase size of message
discard buffer
Repository: qpid-dispatch
Updated Branches:
refs/heads/master fd545d4b0 -> d9f0f0849
DISPATCH-827: Increase size of message discard buffer
Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/d9f0f084
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/d9f0f084
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/d9f0f084
Branch: refs/heads/master
Commit: d9f0f0849940e8f77a6de251800cc6ce0d9da1de
Parents: fd545d4
Author: Chuck Rolke <cr...@redhat.com>
Authored: Fri Sep 15 17:08:39 2017 -0400
Committer: Chuck Rolke <cr...@redhat.com>
Committed: Fri Sep 15 17:08:39 2017 -0400
----------------------------------------------------------------------
src/message.c | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/d9f0f084/src/message.c
----------------------------------------------------------------------
diff --git a/src/message.c b/src/message.c
index 16ced8c..e7e57ab 100644
--- a/src/message.c
+++ b/src/message.c
@@ -1104,8 +1104,9 @@ qd_message_t *discard_receive(pn_delivery_t *delivery,
qd_message_pvt_t *msg = (qd_message_pvt_t*)msg_in;
while (1) {
- char dummy[BUFFER_SIZE];
- ssize_t rc = pn_link_recv(link, dummy, BUFFER_SIZE);
+#define DISCARD_BUFFER_SIZE (128 * 1024)
+ char dummy[DISCARD_BUFFER_SIZE];
+ ssize_t rc = pn_link_recv(link, dummy, DISCARD_BUFFER_SIZE);
if (rc == 0) {
// have read all available pn_link incoming bytes
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org