Formatted source code with astyle utilty

11 files changed, 217 insertions, 177 deletions

diff --git a/examples/amqp_bind.c b/examples/amqp_bind.c
index 7864871..3c9a863 100644
--- a/examples/amqp_bind.c
+++ b/examples/amqp_bind.c
@@ -41,7 +41,8 @@
 
 #include "utils.h"
 
-int main(int argc, char const * const *argv) {
+int main(int argc, char const *const *argv)
+{
   char const *hostname;
   int port;
   char const *exchange;
@@ -67,15 +68,15 @@ int main(int argc, char const * const *argv) {
   die_on_error(sockfd = amqp_open_socket(hostname, port), "Opening socket");
   amqp_set_sockfd(conn, sockfd);
   die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
-		    "Logging in");
+                    "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   amqp_queue_bind(conn, 1,
-		  amqp_cstring_bytes(queue),
-		  amqp_cstring_bytes(exchange),
-		  amqp_cstring_bytes(bindingkey),
-		  amqp_empty_table);
+                  amqp_cstring_bytes(queue),
+                  amqp_cstring_bytes(exchange),
+                  amqp_cstring_bytes(bindingkey),
+                  amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Unbinding");
 
   die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
diff --git a/examples/amqp_consumer.c b/examples/amqp_consumer.c
index c1c0873..aa63346 100644
--- a/examples/amqp_consumer.c
+++ b/examples/amqp_consumer.c
@@ -66,7 +66,7 @@ static void run(amqp_connection_state_t conn)
       int countOverInterval = received - previous_received;
       double intervalRate = countOverInterval / ((now - previous_report_time) / 1000000.0);
       printf("%d ms: Received %d - %d since last report (%d Hz)\n",
-	     (int)(now - start_time) / 1000, received, countOverInterval, (int) intervalRate);
+             (int)(now - start_time) / 1000, received, countOverInterval, (int) intervalRate);
 
       previous_received = received;
       previous_report_time = now;
@@ -75,18 +75,22 @@ static void run(amqp_connection_state_t conn)
 
     amqp_maybe_release_buffers(conn);
     result = amqp_simple_wait_frame(conn, &frame);
-    if (result < 0)
+    if (result < 0) {
       return;
+    }
 
-    if (frame.frame_type != AMQP_FRAME_METHOD)
+    if (frame.frame_type != AMQP_FRAME_METHOD) {
       continue;
+    }
 
-    if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD)
+    if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD) {
       continue;
+    }
 
     result = amqp_simple_wait_frame(conn, &frame);
-    if (result < 0)
+    if (result < 0) {
       return;
+    }
 
     if (frame.frame_type != AMQP_FRAME_HEADER) {
       fprintf(stderr, "Expected header!");
@@ -98,12 +102,13 @@ static void run(amqp_connection_state_t conn)
 
     while (body_received < body_target) {
       result = amqp_simple_wait_frame(conn, &frame);
-      if (result < 0)
-	return;
+      if (result < 0) {
+        return;
+      }
 
       if (frame.frame_type != AMQP_FRAME_BODY) {
-	fprintf(stderr, "Expected body!");
-	abort();
+        fprintf(stderr, "Expected body!");
+        abort();
       }
 
       body_received += frame.payload.body_fragment.len;
@@ -114,7 +119,8 @@ static void run(amqp_connection_state_t conn)
   }
 }
 
-int main(int argc, char const * const *argv) {
+int main(int argc, char const *const *argv)
+{
   char const *hostname;
   int port;
   char const *exchange;
@@ -140,13 +146,13 @@ int main(int argc, char const * const *argv) {
   die_on_error(sockfd = amqp_open_socket(hostname, port), "Opening socket");
   amqp_set_sockfd(conn, sockfd);
   die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
-		    "Logging in");
+                    "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   {
     amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, amqp_empty_bytes, 0, 0, 0, 1,
-						    amqp_empty_table);
+                                 amqp_empty_table);
     die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
     queuename = amqp_bytes_malloc_dup(r->queue);
     if (queuename.bytes == NULL) {
@@ -156,7 +162,7 @@ int main(int argc, char const * const *argv) {
   }
 
   amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey),
-		  amqp_empty_table);
+                  amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Binding queue");
 
   amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
diff --git a/examples/amqp_exchange_declare.c b/examples/amqp_exchange_declare.c
index 74f7465..749109c 100644
--- a/examples/amqp_exchange_declare.c
+++ b/examples/amqp_exchange_declare.c
@@ -41,7 +41,8 @@
 
 #include "utils.h"
 
-int main(int argc, char const * const *argv) {
+int main(int argc, char const *const *argv)
+{
   char const *hostname;
   int port;
   char const *exchange;
@@ -65,12 +66,12 @@ int main(int argc, char const * const *argv) {
   die_on_error(sockfd = amqp_open_socket(hostname, port), "Opening socket");
   amqp_set_sockfd(conn, sockfd);
   die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
-		    "Logging in");
+                    "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   amqp_exchange_declare(conn, 1, amqp_cstring_bytes(exchange), amqp_cstring_bytes(exchangetype),
-			0, 0, amqp_empty_table);
+                        0, 0, amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring exchange");
 
   die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
diff --git a/examples/amqp_listen.c b/examples/amqp_listen.c
index a589fa5..0347375 100644
--- a/examples/amqp_listen.c
+++ b/examples/amqp_listen.c
@@ -43,7 +43,8 @@
 
 #include "utils.h"
 
-int main(int argc, char const * const *argv) {
+int main(int argc, char const *const *argv)
+{
   char const *hostname;
   int port;
   char const *exchange;
@@ -69,13 +70,13 @@ int main(int argc, char const * const *argv) {
   die_on_error(sockfd = amqp_open_socket(hostname, port), "Opening socket");
   amqp_set_sockfd(conn, sockfd);
   die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
-		    "Logging in");
+                    "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   {
     amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, amqp_empty_bytes, 0, 0, 0, 1,
-						    amqp_empty_table);
+                                 amqp_empty_table);
     die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
     queuename = amqp_bytes_malloc_dup(r->queue);
     if (queuename.bytes == NULL) {
@@ -85,7 +86,7 @@ int main(int argc, char const * const *argv) {
   }
 
   amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey),
-		  amqp_empty_table);
+                  amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Binding queue");
 
   amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
@@ -104,35 +105,39 @@ int main(int argc, char const * const *argv) {
       amqp_maybe_release_buffers(conn);
       result = amqp_simple_wait_frame(conn, &frame);
       printf("Result %d\n", result);
-      if (result < 0)
-	break;
+      if (result < 0) {
+        break;
+      }
 
       printf("Frame type %d, channel %d\n", frame.frame_type, frame.channel);
-      if (frame.frame_type != AMQP_FRAME_METHOD)
-	continue;
+      if (frame.frame_type != AMQP_FRAME_METHOD) {
+        continue;
+      }
 
       printf("Method %s\n", amqp_method_name(frame.payload.method.id));
-      if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD)
-	continue;
+      if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD) {
+        continue;
+      }
 
       d = (amqp_basic_deliver_t *) frame.payload.method.decoded;
       printf("Delivery %u, exchange %.*s routingkey %.*s\n",
-	     (unsigned) d->delivery_tag,
-	     (int) d->exchange.len, (char *) d->exchange.bytes,
-	     (int) d->routing_key.len, (char *) d->routing_key.bytes);
+             (unsigned) d->delivery_tag,
+             (int) d->exchange.len, (char *) d->exchange.bytes,
+             (int) d->routing_key.len, (char *) d->routing_key.bytes);
 
       result = amqp_simple_wait_frame(conn, &frame);
-      if (result < 0)
-	break;
+      if (result < 0) {
+        break;
+      }
 
       if (frame.frame_type != AMQP_FRAME_HEADER) {
-	fprintf(stderr, "Expected header!");
-	abort();
+        fprintf(stderr, "Expected header!");
+        abort();
       }
       p = (amqp_basic_properties_t *) frame.payload.properties.decoded;
       if (p->_flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
-	printf("Content-type: %.*s\n",
-	       (int) p->content_type.len, (char *) p->content_type.bytes);
+        printf("Content-type: %.*s\n",
+               (int) p->content_type.len, (char *) p->content_type.bytes);
       }
       printf("----\n");
 
@@ -140,26 +145,27 @@ int main(int argc, char const * const *argv) {
       body_received = 0;
 
       while (body_received < body_target) {
-	result = amqp_simple_wait_frame(conn, &frame);
-	if (result < 0)
-	  break;
+        result = amqp_simple_wait_frame(conn, &frame);
+        if (result < 0) {
+          break;
+        }
 
-	if (frame.frame_type != AMQP_FRAME_BODY) {
-	  fprintf(stderr, "Expected body!");
-	  abort();
-	}
+        if (frame.frame_type != AMQP_FRAME_BODY) {
+          fprintf(stderr, "Expected body!");
+          abort();
+        }
 
-	body_received += frame.payload.body_fragment.len;
-	assert(body_received <= body_target);
+        body_received += frame.payload.body_fragment.len;
+        assert(body_received <= body_target);
 
-	amqp_dump(frame.payload.body_fragment.bytes,
-		  frame.payload.body_fragment.len);
+        amqp_dump(frame.payload.body_fragment.bytes,
+                  frame.payload.body_fragment.len);
       }
 
       if (body_received != body_target) {
-	/* Can only happen when amqp_simple_wait_frame returns <= 0 */
-	/* We break here to close the connection */
-	break;
+        /* Can only happen when amqp_simple_wait_frame returns <= 0 */
+        /* We break here to close the connection */
+        break;
       }
     }
   }
diff --git a/examples/amqp_listenq.c b/examples/amqp_listenq.c
index 8af0f08..762831d 100644
--- a/examples/amqp_listenq.c
+++ b/examples/amqp_listenq.c
@@ -43,7 +43,8 @@
 
 #include "utils.h"
 
-int main(int argc, char const * const *argv) {
+int main(int argc, char const *const *argv)
+{
   char const *hostname;
   int port;
   char const *queuename;
@@ -65,7 +66,7 @@ int main(int argc, char const * const *argv) {
   die_on_error(sockfd = amqp_open_socket(hostname, port), "Opening socket");
   amqp_set_sockfd(conn, sockfd);
   die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
-		    "Logging in");
+                    "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
@@ -85,35 +86,39 @@ int main(int argc, char const * const *argv) {
       amqp_maybe_release_buffers(conn);
       result = amqp_simple_wait_frame(conn, &frame);
       printf("Result %d\n", result);
-      if (result < 0)
-	break;
+      if (result < 0) {
+        break;
+      }
 
       printf("Frame type %d, channel %d\n", frame.frame_type, frame.channel);
-      if (frame.frame_type != AMQP_FRAME_METHOD)
-	continue;
+      if (frame.frame_type != AMQP_FRAME_METHOD) {
+        continue;
+      }
 
       printf("Method %s\n", amqp_method_name(frame.payload.method.id));
-      if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD)
-	continue;
+      if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD) {
+        continue;
+      }
 
       d = (amqp_basic_deliver_t *) frame.payload.method.decoded;
       printf("Delivery %u, exchange %.*s routingkey %.*s\n",
-	     (unsigned) d->delivery_tag,
-	     (int) d->exchange.len, (char *) d->exchange.bytes,
-	     (int) d->routing_key.len, (char *) d->routing_key.bytes);
+             (unsigned) d->delivery_tag,
+             (int) d->exchange.len, (char *) d->exchange.bytes,
+             (int) d->routing_key.len, (char *) d->routing_key.bytes);
 
       result = amqp_simple_wait_frame(conn, &frame);
-      if (result < 0)
-	break;
+      if (result < 0) {
+        break;
+      }
 
       if (frame.frame_type != AMQP_FRAME_HEADER) {
-	fprintf(stderr, "Expected header!");
-	abort();
+        fprintf(stderr, "Expected header!");
+        abort();
       }
       p = (amqp_basic_properties_t *) frame.payload.properties.decoded;
       if (p->_flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
-	printf("Content-type: %.*s\n",
-	       (int) p->content_type.len, (char *) p->content_type.bytes);
+        printf("Content-type: %.*s\n",
+               (int) p->content_type.len, (char *) p->content_type.bytes);
       }
       printf("----\n");
 
@@ -121,26 +126,27 @@ int main(int argc, char const * const *argv) {
       body_received = 0;
 
       while (body_received < body_target) {
-	result = amqp_simple_wait_frame(conn, &frame);
-	if (result < 0)
-	  break;
+        result = amqp_simple_wait_frame(conn, &frame);
+        if (result < 0) {
+          break;
+        }
 
-	if (frame.frame_type != AMQP_FRAME_BODY) {
-	  fprintf(stderr, "Expected body!");
-	  abort();
-	}
+        if (frame.frame_type != AMQP_FRAME_BODY) {
+          fprintf(stderr, "Expected body!");
+          abort();
+        }
 
-	body_received += frame.payload.body_fragment.len;
-	assert(body_received <= body_target);
+        body_received += frame.payload.body_fragment.len;
+        assert(body_received <= body_target);
 
-	amqp_dump(frame.payload.body_fragment.bytes,
-		  frame.payload.body_fragment.len);
+        amqp_dump(frame.payload.body_fragment.bytes,
+                  frame.payload.body_fragment.len);
       }
 
       if (body_received != body_target) {
-	/* Can only happen when amqp_simple_wait_frame returns <= 0 */
-	/* We break here to close the connection */
-	break;
+        /* Can only happen when amqp_simple_wait_frame returns <= 0 */
+        /* We break here to close the connection */
+        break;
       }
 
       amqp_basic_ack(conn, 1, d->delivery_tag, 0);
diff --git a/examples/amqp_producer.c b/examples/amqp_producer.c
index d85b944..4a1cd68 100644
--- a/examples/amqp_producer.c
+++ b/examples/amqp_producer.c
@@ -44,9 +44,9 @@
 #define SUMMARY_EVERY_US 1000000
 
 static void send_batch(amqp_connection_state_t conn,
-		       char const *queue_name,
-		       int rate_limit,
-		       int message_count)
+                       char const *queue_name,
+                       int rate_limit,
+                       int message_count)
 {
   uint64_t start_time = now_microseconds();
   int i;
@@ -69,20 +69,20 @@ static void send_batch(amqp_connection_state_t conn,
     uint64_t now = now_microseconds();
 
     die_on_error(amqp_basic_publish(conn,
-				    1,
-				    amqp_cstring_bytes("amq.direct"),
-				    amqp_cstring_bytes(queue_name),
-				    0,
-				    0,
-				    NULL,
-				    message_bytes),
-		 "Publishing");
+                                    1,
+                                    amqp_cstring_bytes("amq.direct"),
+                                    amqp_cstring_bytes(queue_name),
+                                    0,
+                                    0,
+                                    NULL,
+                                    message_bytes),
+                 "Publishing");
     sent++;
     if (now > next_summary_time) {
       int countOverInterval = sent - previous_sent;
       double intervalRate = countOverInterval / ((now - previous_report_time) / 1000000.0);
       printf("%d ms: Sent %d - %d since last report (%d Hz)\n",
-	     (int)(now - start_time) / 1000, sent, countOverInterval, (int) intervalRate);
+             (int)(now - start_time) / 1000, sent, countOverInterval, (int) intervalRate);
 
       previous_sent = sent;
       previous_report_time = now;
@@ -105,7 +105,8 @@ static void send_batch(amqp_connection_state_t conn,
   }
 }
 
-int main(int argc, char const * const *argv) {
+int main(int argc, char const *const *argv)
+{
   char const *hostname;
   int port;
   int rate_limit;
@@ -129,7 +130,7 @@ int main(int argc, char const * const *argv) {
   die_on_error(sockfd = amqp_open_socket(hostname, port), "Opening socket");
   amqp_set_sockfd(conn, sockfd);
   die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
-		    "Logging in");
+                    "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
diff --git a/examples/amqp_rpc_sendstring_client.c b/examples/amqp_rpc_sendstring_client.c
index 04c073e..7914e2c 100644
--- a/examples/amqp_rpc_sendstring_client.c
+++ b/examples/amqp_rpc_sendstring_client.c
@@ -43,7 +43,8 @@
 
 #include "utils.h"
 
-int main(int argc, char* argv[]) {
+int main(int argc, char *argv[])
+{
   char const *hostname;
   int port;
   char const *exchange;
@@ -152,16 +153,19 @@ int main(int argc, char* argv[]) {
         amqp_maybe_release_buffers(conn);
         result = amqp_simple_wait_frame(conn, &frame);
         printf("Result: %d\n", result);
-        if (result < 0)
+        if (result < 0) {
           break;
+        }
 
         printf("Frame type: %d channel: %d\n", frame.frame_type, frame.channel);
-        if (frame.frame_type != AMQP_FRAME_METHOD)
+        if (frame.frame_type != AMQP_FRAME_METHOD) {
           continue;
+        }
 
         printf("Method: %s\n", amqp_method_name(frame.payload.method.id));
-        if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD)
+        if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD) {
           continue;
+        }
 
         d = (amqp_basic_deliver_t *) frame.payload.method.decoded;
         printf("Delivery: %u exchange: %.*s routingkey: %.*s\n",
@@ -170,8 +174,9 @@ int main(int argc, char* argv[]) {
                (int) d->routing_key.len, (char *) d->routing_key.bytes);
 
         result = amqp_simple_wait_frame(conn, &frame);
-        if (result < 0)
+        if (result < 0) {
           break;
+        }
 
         if (frame.frame_type != AMQP_FRAME_HEADER) {
           fprintf(stderr, "Expected header!");
@@ -189,8 +194,9 @@ int main(int argc, char* argv[]) {
 
         while (body_received < body_target) {
           result = amqp_simple_wait_frame(conn, &frame);
-          if (result < 0)
+          if (result < 0) {
             break;
+          }
 
           if (frame.frame_type != AMQP_FRAME_BODY) {
             fprintf(stderr, "Expected body!");
diff --git a/examples/amqp_sendstring.c b/examples/amqp_sendstring.c
index e108ea7..f1456c9 100644
--- a/examples/amqp_sendstring.c
+++ b/examples/amqp_sendstring.c
@@ -41,7 +41,8 @@
 
 #include "utils.h"
 
-int main(int argc, char const * const *argv) {
+int main(int argc, char const *const *argv)
+{
   char const *hostname;
   int port;
   char const *exchange;
@@ -67,7 +68,7 @@ int main(int argc, char const * const *argv) {
   die_on_error(sockfd = amqp_open_socket(hostname, port), "Opening socket");
   amqp_set_sockfd(conn, sockfd);
   die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
-		    "Logging in");
+                    "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
@@ -77,14 +78,14 @@ int main(int argc, char const * const *argv) {
     props.content_type = amqp_cstring_bytes("text/plain");
     props.delivery_mode = 2; /* persistent delivery mode */
     die_on_error(amqp_basic_publish(conn,
-				    1,
-				    amqp_cstring_bytes(exchange),
-				    amqp_cstring_bytes(routingkey),
-				    0,
-				    0,
-				    &props,
-				    amqp_cstring_bytes(messagebody)),
-		 "Publishing");
+                                    1,
+                                    amqp_cstring_bytes(exchange),
+                                    amqp_cstring_bytes(routingkey),
+                                    0,
+                                    0,
+                                    &props,
+                                    amqp_cstring_bytes(messagebody)),
+                 "Publishing");
   }
 
   die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
diff --git a/examples/amqp_unbind.c b/examples/amqp_unbind.c
index 546b356..011f561 100644
--- a/examples/amqp_unbind.c
+++ b/examples/amqp_unbind.c
@@ -41,7 +41,8 @@
 
 #include "utils.h"
 
-int main(int argc, char const * const *argv) {
+int main(int argc, char const *const *argv)
+{
   char const *hostname;
   int port;
   char const *exchange;
@@ -67,15 +68,15 @@ int main(int argc, char const * const *argv) {
   die_on_error(sockfd = amqp_open_socket(hostname, port), "Opening socket");
   amqp_set_sockfd(conn, sockfd);
   die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
-		    "Logging in");
+                    "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   amqp_queue_unbind(conn, 1,
-		    amqp_cstring_bytes(queue),
-		    amqp_cstring_bytes(exchange),
-		    amqp_cstring_bytes(bindingkey),
-		    amqp_empty_table);
+                    amqp_cstring_bytes(queue),
+                    amqp_cstring_bytes(exchange),
+                    amqp_cstring_bytes(bindingkey),
+                    amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Unbinding");
 
   die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
diff --git a/examples/utils.c b/examples/utils.c
index 691f14a..328a5e5 100644
--- a/examples/utils.c
+++ b/examples/utils.c
@@ -42,7 +42,8 @@
 
 #include "utils.h"
 
-void die_on_error(int x, char const *context) {
+void die_on_error(int x, char const *context)
+{
   if (x < 0) {
     char *errstr = amqp_error_string(-x);
     fprintf(stderr, "%s: %s\n", context, errstr);
@@ -51,85 +52,93 @@ void die_on_error(int x, char const *context) {
   }
 }
 
-void die_on_amqp_error(amqp_rpc_reply_t x, char const *context) {
+void die_on_amqp_error(amqp_rpc_reply_t x, char const *context)
+{
   switch (x.reply_type) {
-    case AMQP_RESPONSE_NORMAL:
-      return;
-
-    case AMQP_RESPONSE_NONE:
-      fprintf(stderr, "%s: missing RPC reply type!\n", context);
+  case AMQP_RESPONSE_NORMAL:
+    return;
+
+  case AMQP_RESPONSE_NONE:
+    fprintf(stderr, "%s: missing RPC reply type!\n", context);
+    break;
+
+  case AMQP_RESPONSE_LIBRARY_EXCEPTION:
+    fprintf(stderr, "%s: %s\n", context, amqp_error_string(x.library_error));
+    break;
+
+  case AMQP_RESPONSE_SERVER_EXCEPTION:
+    switch (x.reply.id) {
+    case AMQP_CONNECTION_CLOSE_METHOD: {
+      amqp_connection_close_t *m = (amqp_connection_close_t *) x.reply.decoded;
+      fprintf(stderr, "%s: server connection error %d, message: %.*s\n",
+              context,
+              m->reply_code,
+              (int) m->reply_text.len, (char *) m->reply_text.bytes);
       break;
-
-    case AMQP_RESPONSE_LIBRARY_EXCEPTION:
-      fprintf(stderr, "%s: %s\n", context, amqp_error_string(x.library_error));
+    }
+    case AMQP_CHANNEL_CLOSE_METHOD: {
+      amqp_channel_close_t *m = (amqp_channel_close_t *) x.reply.decoded;
+      fprintf(stderr, "%s: server channel error %d, message: %.*s\n",
+              context,
+              m->reply_code,
+              (int) m->reply_text.len, (char *) m->reply_text.bytes);
       break;
-
-    case AMQP_RESPONSE_SERVER_EXCEPTION:
-      switch (x.reply.id) {
-	case AMQP_CONNECTION_CLOSE_METHOD: {
-	  amqp_connection_close_t *m = (amqp_connection_close_t *) x.reply.decoded;
-	  fprintf(stderr, "%s: server connection error %d, message: %.*s\n",
-		  context,
-		  m->reply_code,
-		  (int) m->reply_text.len, (char *) m->reply_text.bytes);
-	  break;
-	}
-	case AMQP_CHANNEL_CLOSE_METHOD: {
-	  amqp_channel_close_t *m = (amqp_channel_close_t *) x.reply.decoded;
-	  fprintf(stderr, "%s: server channel error %d, message: %.*s\n",
-		  context,
-		  m->reply_code,
-		  (int) m->reply_text.len, (char *) m->reply_text.bytes);
-	  break;
-	}
-	default:
-	  fprintf(stderr, "%s: unknown server error, method id 0x%08X\n", context, x.reply.id);
-	  break;
-      }
+    }
+    default:
+      fprintf(stderr, "%s: unknown server error, method id 0x%08X\n", context, x.reply.id);
       break;
+    }
+    break;
   }
 
   exit(1);
 }
 
-static void dump_row(long count, int numinrow, int *chs) {
+static void dump_row(long count, int numinrow, int *chs)
+{
   int i;
 
   printf("%08lX:", count - numinrow);
 
   if (numinrow > 0) {
     for (i = 0; i < numinrow; i++) {
-      if (i == 8)
-	printf(" :");
+      if (i == 8) {
+        printf(" :");
+      }
       printf(" %02X", chs[i]);
     }
     for (i = numinrow; i < 16; i++) {
-      if (i == 8)
-	printf(" :");
+      if (i == 8) {
+        printf(" :");
+      }
       printf("   ");
     }
     printf("  ");
     for (i = 0; i < numinrow; i++) {
-      if (isprint(chs[i]))
-	printf("%c", chs[i]);
-      else
-	printf(".");
+      if (isprint(chs[i])) {
+        printf("%c", chs[i]);
+      } else {
+        printf(".");
+      }
     }
   }
   printf("\n");
 }
 
-static int rows_eq(int *a, int *b) {
+static int rows_eq(int *a, int *b)
+{
   int i;
 
   for (i=0; i<16; i++)
-    if (a[i] != b[i])
+    if (a[i] != b[i]) {
       return 0;
+    }
 
   return 1;
 }
 
-void amqp_dump(void const *buffer, size_t len) {
+void amqp_dump(void const *buffer, size_t len)
+{
   unsigned char *buf = (unsigned char *) buffer;
   long count = 0;
   int numinrow = 0;
@@ -145,17 +154,18 @@ void amqp_dump(void const *buffer, size_t len) {
       int i;
 
       if (rows_eq(oldchs, chs)) {
-	if (!showed_dots) {
-	  showed_dots = 1;
-	  printf("          .. .. .. .. .. .. .. .. : .. .. .. .. .. .. .. ..\n");
-	}
+        if (!showed_dots) {
+          showed_dots = 1;
+          printf("          .. .. .. .. .. .. .. .. : .. .. .. .. .. .. .. ..\n");
+        }
       } else {
-	showed_dots = 0;
-	dump_row(count, numinrow, chs);
+        showed_dots = 0;
+        dump_row(count, numinrow, chs);
       }
 
-      for (i=0; i<16; i++)
-	oldchs[i] = chs[i];
+      for (i=0; i<16; i++) {
+        oldchs[i] = chs[i];
+      }
 
       numinrow = 0;
     }
@@ -166,6 +176,7 @@ void amqp_dump(void const *buffer, size_t len) {
 
   dump_row(count, numinrow, chs);
 
-  if (numinrow != 0)
+  if (numinrow != 0) {
     printf("%08lX:\n", count);
+  }
 }
diff --git a/examples/win32/platform_utils.c b/examples/win32/platform_utils.c
index c7807f9..dff6243 100644
--- a/examples/win32/platform_utils.c
+++ b/examples/win32/platform_utils.c
@@ -40,7 +40,7 @@ uint64_t now_microseconds(void)
   FILETIME ft;
   GetSystemTimeAsFileTime(&ft);
   return (((uint64_t)ft.dwHighDateTime << 32) | (uint64_t)ft.dwLowDateTime)
-                                                                   / 10;
+         / 10;
 }
 
 void microsleep(int usec)