diff options
| author | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-04-29 23:04:07 +0100 |
|---|---|---|
| committer | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-04-29 23:04:07 +0100 |
| commit | 617e6b54a2a0772671b6e4402adc193d74755dd1 (patch) | |
| tree | 5e9b91e718cbd38d84b8a58c0078c5138aa299b0 | |
| parent | 65a1eeef3ab553e5cdb98b775aa0d6842990ed7c (diff) | |
| download | rabbitmq-c-github-ask-617e6b54a2a0772671b6e4402adc193d74755dd1.tar.gz | |
Don't print debug on every received block.
| -rw-r--r-- | librabbitmq/amqp_connection.c | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/librabbitmq/amqp_connection.c b/librabbitmq/amqp_connection.c index baaff87..e0c2f11 100644 --- a/librabbitmq/amqp_connection.c +++ b/librabbitmq/amqp_connection.c @@ -152,8 +152,10 @@ int amqp_handle_input(amqp_connection_state_t state, case CONNECTION_STATE_WAITING_FOR_BODY: { int frame_type = D_8(state->inbound_buffer, 0); +#if 0 printf("recving:\n"); amqp_dump(state->inbound_buffer.bytes, state->target_size); +#endif /* Check frame end marker (footer) */ if (D_8(state->inbound_buffer, state->target_size - 1) != AMQP_FRAME_END) { @@ -290,19 +292,22 @@ int amqp_send_frame(amqp_connection_state_t state, if (separate_body) { char frame_end_byte = AMQP_FRAME_END; +#if 0 printf("sending body frame (header):\n"); amqp_dump(state->outbound_buffer.bytes, HEADER_SIZE); - AMQP_CHECK_RESULT(write(state->sockfd, state->outbound_buffer.bytes, HEADER_SIZE)); printf("sending body frame (payload):\n"); amqp_dump(encoded.bytes, payload_len); +#endif + AMQP_CHECK_RESULT(write(state->sockfd, state->outbound_buffer.bytes, HEADER_SIZE)); AMQP_CHECK_RESULT(write(state->sockfd, encoded.bytes, payload_len)); - printf("sending body frame (footer).\n"); assert(FOOTER_SIZE == 1); AMQP_CHECK_RESULT(write(state->sockfd, &frame_end_byte, FOOTER_SIZE)); } else { E_8(state->outbound_buffer, payload_len + HEADER_SIZE, AMQP_FRAME_END); +#if 0 printf("sending:\n"); amqp_dump(state->outbound_buffer.bytes, payload_len + HEADER_SIZE + FOOTER_SIZE); +#endif AMQP_CHECK_RESULT(write(state->sockfd, state->outbound_buffer.bytes, payload_len + (HEADER_SIZE + FOOTER_SIZE))); |