You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2012/06/01 11:40:40 UTC

svn commit: r1345028 - /qpid/proton/trunk/proton-c/src/engine/engine.c

Author: rhs
Date: Fri Jun  1 09:40:40 2012
New Revision: 1345028

URL: http://svn.apache.org/viewvc?rev=1345028&view=rev
Log:
only log EOS when trace is enabled

Modified:
    qpid/proton/trunk/proton-c/src/engine/engine.c

Modified: qpid/proton/trunk/proton-c/src/engine/engine.c
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/engine/engine.c?rev=1345028&r1=1345027&r2=1345028&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/src/engine/engine.c (original)
+++ qpid/proton/trunk/proton-c/src/engine/engine.c Fri Jun  1 09:40:40 2012
@@ -1323,19 +1323,22 @@ ssize_t pn_input(pn_transport_t *transpo
 {
   if (!available) {
     pn_do_error(transport, "amqp:connection:framing-error", "connection aborted");
-    fprintf(stderr, "    <- EOS\n");
+    if (transport->disp->trace & PN_TRACE_RAW)
+      fprintf(stderr, "    <- EOS\n");
     return PN_ERR;
   }
 
   if (transport->close_rcvd) {
     pn_do_error(transport, "amqp:connection:framing-error", "data after close");
-    fprintf(stderr, "    <- EOS\n");
+    if (transport->disp->trace & PN_TRACE_RAW)
+      fprintf(stderr, "    <- EOS\n");
     return PN_ERR;
   }
 
   ssize_t n = pn_dispatcher_input(transport->disp, bytes, available);
   if (n >= 0 && transport->close_rcvd) {
-    fprintf(stderr, "    <- EOS\n");
+    if (transport->disp->trace & PN_TRACE_RAW)
+      fprintf(stderr, "    <- EOS\n");
     return PN_EOS;
   } else if (n < 0) {
     transport->error = n;
@@ -1686,7 +1689,8 @@ ssize_t pn_output(pn_transport_t *transp
     transport->error = pn_process(transport);
 
   if (!transport->disp->available && (transport->close_sent || transport->error)) {
-    fprintf(stderr, "    -> EOS\n");
+    if (transport->disp->trace & PN_TRACE_RAW)
+      fprintf(stderr, "    -> EOS\n");
     if (transport->error)
       return transport->error;
     else



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org