You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kg...@apache.org on 2014/02/07 16:25:07 UTC
svn commit: r1565689 - /qpid/proton/trunk/proton-c/src/transport/transport.c
Author: kgiusti
Date: Fri Feb 7 15:25:07 2014
New Revision: 1565689
URL: http://svn.apache.org/r1565689
Log:
NO-JIRA: add comment
Modified:
qpid/proton/trunk/proton-c/src/transport/transport.c
Modified: qpid/proton/trunk/proton-c/src/transport/transport.c
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/transport/transport.c?rev=1565689&r1=1565688&r2=1565689&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/src/transport/transport.c (original)
+++ qpid/proton/trunk/proton-c/src/transport/transport.c Fri Feb 7 15:25:07 2014
@@ -1663,6 +1663,9 @@ static ssize_t pn_output_write_amqp(pn_i
pn_error_set(transport->error, pn_process(transport), "process error");
}
+ // write out any buffered data _before_ returning an error code,
+ // else we could truncate an outgoing Close frame containing a
+ // useful error status
if (!transport->disp->available && (transport->close_sent || pn_error_code(transport->error))) {
if (pn_error_code(transport->error))
return pn_error_code(transport->error);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org