summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDavid Wragg <david@rabbitmq.com>2010-10-21 17:49:04 +0100
committerDavid Wragg <david@rabbitmq.com>2010-10-21 17:49:04 +0100
commit5518f4b04bc747b0b82836187a08e2af3e3f1178 (patch)
tree431038067a4cc5d090620eb69b405ebaffcc7557
parentb7b614ae3fe0c450c71fcef6fc5812a158619783 (diff)
downloadrabbitmq-c-github-ask-5518f4b04bc747b0b82836187a08e2af3e3f1178.tar.gz
Eliminate C99-style initializers in librabbitmq .c files
-rw-r--r--librabbitmq/amqp_api.c14
-rw-r--r--librabbitmq/amqp_socket.c63
2 files changed, 41 insertions, 36 deletions
diff --git a/librabbitmq/amqp_api.c b/librabbitmq/amqp_api.c
index a489bea..6c35da7 100644
--- a/librabbitmq/amqp_api.c
+++ b/librabbitmq/amqp_api.c
@@ -135,16 +135,14 @@ int amqp_basic_publish(amqp_connection_state_t state,
size_t usable_body_payload_size = state->frame_max - (HEADER_SIZE + FOOTER_SIZE);
int res;
- amqp_basic_publish_t m =
- (amqp_basic_publish_t) {
- .exchange = exchange,
- .routing_key = routing_key,
- .mandatory = mandatory,
- .immediate = immediate
- };
-
+ amqp_basic_publish_t m;
amqp_basic_properties_t default_properties;
+ m.exchange = exchange;
+ m.routing_key = routing_key;
+ m.mandatory = mandatory;
+ m.immediate = immediate;
+
res = amqp_send_method(state, channel, AMQP_BASIC_PUBLISH_METHOD, &m);
if (res < 0)
return res;
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c
index dfce2d8..a29f5c3 100644
--- a/librabbitmq/amqp_socket.c
+++ b/librabbitmq/amqp_socket.c
@@ -114,12 +114,19 @@ int amqp_send_header(amqp_connection_state_t state) {
}
static amqp_bytes_t sasl_method_name(amqp_sasl_method_enum method) {
+ amqp_bytes_t res;
+
switch (method) {
- case AMQP_SASL_METHOD_PLAIN: return (amqp_bytes_t) {.len = 5, .bytes = "PLAIN"};
- default:
- amqp_abort("Invalid SASL method: %d", (int) method);
+ case AMQP_SASL_METHOD_PLAIN:
+ res.bytes = "PLAIN";
+ res.len = 5;
+ break;
+
+ default:
+ amqp_abort("Invalid SASL method: %d", (int) method);
}
- abort(); /* unreachable */
+
+ return res;
}
static amqp_bytes_t sasl_response(amqp_pool_t *pool,
@@ -386,18 +393,20 @@ static int amqp_login_inner(amqp_connection_state_t state,
}
{
- amqp_bytes_t response_bytes = sasl_response(&state->decoding_pool, sasl_method, vl);
amqp_connection_start_ok_t s;
- if (response_bytes.bytes == NULL) {
+ amqp_bytes_t response_bytes = sasl_response(&state->decoding_pool,
+ sasl_method, vl);
+
+ if (response_bytes.bytes == NULL)
return -ERROR_NO_MEMORY;
- }
- s =
- (amqp_connection_start_ok_t) {
- .client_properties = {.num_entries = 0, .entries = NULL},
- .mechanism = sasl_method_name(sasl_method),
- .response = response_bytes,
- .locale = {.len = 5, .bytes = "en_US"}
- };
+
+ s.client_properties.num_entries = 0;
+ s.client_properties.entries = NULL;
+ s.mechanism = sasl_method_name(sasl_method);
+ s.response = response_bytes;
+ s.locale.bytes = "en_US";
+ s.locale.len = 5;
+
res = amqp_send_method(state, 0, AMQP_CONNECTION_START_OK_METHOD, &s);
if (res < 0)
return res;
@@ -431,12 +440,11 @@ static int amqp_login_inner(amqp_connection_state_t state,
return res;
{
- amqp_connection_tune_ok_t s =
- (amqp_connection_tune_ok_t) {
- .channel_max = channel_max,
- .frame_max = frame_max,
- .heartbeat = heartbeat
- };
+ amqp_connection_tune_ok_t s;
+ s.frame_max = frame_max;
+ s.channel_max = channel_max;
+ s.heartbeat = heartbeat;
+
res = amqp_send_method(state, 0, AMQP_CONNECTION_TUNE_OK_METHOD, &s);
if (res < 0)
return res;
@@ -471,21 +479,20 @@ amqp_rpc_reply_t amqp_login(amqp_connection_state_t state,
}
{
- amqp_connection_open_t s =
- (amqp_connection_open_t) {
- .virtual_host = amqp_cstring_bytes(vhost),
- .capabilities = {.len = 0, .bytes = NULL},
- .insist = 1
- };
amqp_method_number_t replies[] = { AMQP_CONNECTION_OPEN_OK_METHOD, 0 };
+ amqp_connection_open_t s;
+ s.virtual_host = amqp_cstring_bytes(vhost);
+ s.capabilities.len = 0;
+ s.capabilities.bytes = NULL;
+ s.insist = 1;
+
result = amqp_simple_rpc(state,
0,
AMQP_CONNECTION_OPEN_METHOD,
(amqp_method_number_t *) &replies,
&s);
- if (result.reply_type != AMQP_RESPONSE_NORMAL) {
+ if (result.reply_type != AMQP_RESPONSE_NORMAL)
return result;
- }
}
amqp_maybe_release_buffers(state);