diff options
| author | Mike Stitt <mikes@spindance.com> | 2014-06-28 09:12:46 -0400 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2014-07-11 07:53:50 -0700 |
| commit | 357bdb369206eb91fe643b7c275ce15248b4f5f8 (patch) | |
| tree | 2e57874a402a7e138ff4e1b322f588339b3b6f37 | |
| parent | 8ce585dd7d52952b0dc55a7e6db39f636d3075d6 (diff) | |
| download | rabbitmq-c-github-ask-357bdb369206eb91fe643b7c275ce15248b4f5f8.tar.gz | |
Allow INITIAL bufffer and page size configuration
Signed-off-by: Mike Stitt <mikes@spindance.com>
| -rw-r--r-- | librabbitmq/amqp_connection.c | 21 |
1 files changed, 15 insertions, 6 deletions
diff --git a/librabbitmq/amqp_connection.c b/librabbitmq/amqp_connection.c index 5d70b07..ccaa73d 100644 --- a/librabbitmq/amqp_connection.c +++ b/librabbitmq/amqp_connection.c @@ -48,9 +48,18 @@ #include <stdlib.h> #include <string.h> -#define INITIAL_FRAME_POOL_PAGE_SIZE 65536 -#define INITIAL_DECODING_POOL_PAGE_SIZE 131072 -#define INITIAL_INBOUND_SOCK_BUFFER_SIZE 131072 +#ifndef AMQP_INITIAL_FRAME_POOL_PAGE_SIZE +#define AMQP_INITIAL_FRAME_POOL_PAGE_SIZE 65536 +#endif + +#ifndef AMQP_INITIAL_DECODING_POOL_PAGE_SIZE +#define AMQP_INITIAL_DECODING_POOL_PAGE_SIZE 131072 +#endif + +#ifndef AMQP_INITIAL_INBOUND_SOCK_BUFFER_SIZE +#define AMQP_INITIAL_INBOUND_SOCK_BUFFER_SIZE 131072 +#endif + #define ENFORCE_STATE(statevec, statenum) \ { \ @@ -72,7 +81,7 @@ amqp_connection_state_t amqp_new_connection(void) return NULL; } - res = amqp_tune_connection(state, 0, INITIAL_FRAME_POOL_PAGE_SIZE, 0); + res = amqp_tune_connection(state, 0, AMQP_INITIAL_FRAME_POOL_PAGE_SIZE, 0); if (0 != res) { goto out_nomem; } @@ -85,8 +94,8 @@ amqp_connection_state_t amqp_new_connection(void) is also the minimum frame size */ state->target_size = 8; - state->sock_inbound_buffer.len = INITIAL_INBOUND_SOCK_BUFFER_SIZE; - state->sock_inbound_buffer.bytes = malloc(INITIAL_INBOUND_SOCK_BUFFER_SIZE); + state->sock_inbound_buffer.len = AMQP_INITIAL_INBOUND_SOCK_BUFFER_SIZE; + state->sock_inbound_buffer.bytes = malloc(AMQP_INITIAL_INBOUND_SOCK_BUFFER_SIZE); if (state->sock_inbound_buffer.bytes == NULL) { goto out_nomem; } |