summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp_table.c
diff options
context:
space:
mode:
authorTony Garnock-Jones <tonyg@kcbbs.gen.nz>2009-04-26 23:21:23 +0100
committerTony Garnock-Jones <tonyg@kcbbs.gen.nz>2009-04-26 23:21:23 +0100
commite1dec49d13caa05af05984af12f3e8354387f33f (patch)
tree8e83237174c0db0c7fd4e1b42ce7c8b3afb8b3ee /librabbitmq/amqp_table.c
parentaf9315c575b8788b28bb3c5d959a9462b12b9a15 (diff)
downloadrabbitmq-c-github-ask-e1dec49d13caa05af05984af12f3e8354387f33f.tar.gz
Publication works!
Diffstat (limited to 'librabbitmq/amqp_table.c')
-rw-r--r--librabbitmq/amqp_table.c15
1 files changed, 6 insertions, 9 deletions
diff --git a/librabbitmq/amqp_table.c b/librabbitmq/amqp_table.c
index fac42d9..d8200e4 100644
--- a/librabbitmq/amqp_table.c
+++ b/librabbitmq/amqp_table.c
@@ -5,7 +5,6 @@
#include <errno.h>
#include "amqp.h"
-#include "../config.h"
#include "amqp_private.h"
#define INITIAL_TABLE_SIZE 16
@@ -66,10 +65,9 @@ int amqp_decode_table(amqp_bytes_t encoded,
entry->value.u64 = D_64(encoded, offset);
offset += 8;
break;
- case 'F': {
- int table_result = amqp_decode_table(encoded, pool, &(entry->value.table), &offset);
- if (table_result != 0) return table_result;
- }
+ case 'F':
+ AMQP_CHECK_RESULT(amqp_decode_table(encoded, pool, &(entry->value.table), &offset));
+ break;
default:
return -EINVAL;
}
@@ -128,10 +126,9 @@ int amqp_encode_table(amqp_bytes_t encoded,
E_64(encoded, offset, entry->value.u64);
offset += 8;
break;
- case 'F': {
- int table_result = amqp_encode_table(encoded, &(entry->value.table), &offset);
- if (table_result != 0) return table_result;
- }
+ case 'F':
+ AMQP_CHECK_RESULT(amqp_encode_table(encoded, &(entry->value.table), &offset));
+ break;
default:
return -EINVAL;
}