1 files changed, 65 insertions, 54 deletions

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);
+  }
 }