summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp_table.c
diff options
context:
space:
mode:
Diffstat (limited to 'librabbitmq/amqp_table.c')
-rw-r--r--librabbitmq/amqp_table.c326
1 files changed, 265 insertions, 61 deletions
diff --git a/librabbitmq/amqp_table.c b/librabbitmq/amqp_table.c
index 16d85ff..5ffadc4 100644
--- a/librabbitmq/amqp_table.c
+++ b/librabbitmq/amqp_table.c
@@ -9,8 +9,67 @@
#include <assert.h>
+#define INITIAL_ARRAY_SIZE 16
#define INITIAL_TABLE_SIZE 16
+static int amqp_decode_field_value(amqp_bytes_t encoded,
+ amqp_pool_t *pool,
+ amqp_field_value_t *entry,
+ int *offsetptr); /* forward */
+
+static int amqp_encode_field_value(amqp_bytes_t encoded,
+ amqp_field_value_t *entry,
+ int *offsetptr); /* forward */
+
+/*---------------------------------------------------------------------------*/
+
+static int amqp_decode_array(amqp_bytes_t encoded,
+ amqp_pool_t *pool,
+ amqp_array_t *output,
+ int *offsetptr)
+{
+ int offset = *offsetptr;
+ uint32_t arraysize = D_32(encoded, offset);
+ int num_entries = 0;
+ amqp_field_value_t *entries = malloc(INITIAL_ARRAY_SIZE * sizeof(amqp_field_value_t));
+ int allocated_entries = INITIAL_ARRAY_SIZE;
+ int limit;
+
+ if (entries == NULL) {
+ return -ENOMEM;
+ }
+
+ offset += 4;
+ limit = offset + arraysize;
+
+ while (offset < limit) {
+ if (num_entries >= allocated_entries) {
+ void *newentries;
+ allocated_entries = allocated_entries * 2;
+ newentries = realloc(entries, allocated_entries * sizeof(amqp_field_value_t));
+ if (newentries == NULL) {
+ free(entries);
+ return -ENOMEM;
+ }
+ entries = newentries;
+ }
+
+ AMQP_CHECK_RESULT_CLEANUP(amqp_decode_field_value(encoded,
+ pool,
+ &entries[num_entries],
+ &offset),
+ free(entries));
+ num_entries++;
+ }
+
+ output->num_entries = num_entries;
+ output->entries = amqp_pool_alloc(pool, num_entries * sizeof(amqp_field_value_t));
+ memcpy(output->entries, entries, num_entries * sizeof(amqp_field_value_t));
+
+ *offsetptr = offset;
+ return 0;
+}
+
int amqp_decode_table(amqp_bytes_t encoded,
amqp_pool_t *pool,
amqp_table_t *output,
@@ -53,37 +112,11 @@ int amqp_decode_table(amqp_bytes_t encoded,
entry->key.bytes = D_BYTES(encoded, offset, keylen);
offset += keylen;
- entry->kind = D_8(encoded, offset);
- offset++;
-
- switch (entry->kind) {
- case 'S':
- entry->value.bytes.len = D_32(encoded, offset);
- offset += 4;
- entry->value.bytes.bytes = D_BYTES(encoded, offset, entry->value.bytes.len);
- offset += entry->value.bytes.len;
- break;
- case 'I':
- entry->value.i32 = (int32_t) D_32(encoded, offset);
- offset += 4;
- break;
- case 'D':
- entry->value.decimal.decimals = D_8(encoded, offset);
- offset++;
- entry->value.decimal.value = D_32(encoded, offset);
- offset += 4;
- break;
- case 'T':
- entry->value.u64 = D_64(encoded, offset);
- offset += 8;
- break;
- case 'F':
- AMQP_CHECK_RESULT(amqp_decode_table(encoded, pool, &(entry->value.table), &offset));
- break;
- default:
- return -EINVAL;
- }
-
+ AMQP_CHECK_RESULT_CLEANUP(amqp_decode_field_value(encoded,
+ pool,
+ &entry->value,
+ &offset),
+ free(entries));
num_entries++;
}
@@ -95,6 +128,116 @@ int amqp_decode_table(amqp_bytes_t encoded,
return 0;
}
+static int amqp_decode_field_value(amqp_bytes_t encoded,
+ amqp_pool_t *pool,
+ amqp_field_value_t *entry,
+ int *offsetptr)
+{
+ int offset = *offsetptr;
+
+ entry->kind = D_8(encoded, offset);
+ offset++;
+
+ switch (entry->kind) {
+ case AMQP_FIELD_KIND_BOOLEAN:
+ entry->value.boolean = D_8(encoded, offset) ? 1 : 0;
+ offset++;
+ break;
+ case AMQP_FIELD_KIND_I8:
+ entry->value.i8 = (int8_t) D_8(encoded, offset);
+ offset++;
+ break;
+ case AMQP_FIELD_KIND_U8:
+ entry->value.u8 = D_8(encoded, offset);
+ offset++;
+ break;
+ case AMQP_FIELD_KIND_I16:
+ entry->value.i16 = (int16_t) D_16(encoded, offset);
+ offset += 2;
+ break;
+ case AMQP_FIELD_KIND_U16:
+ entry->value.u16 = D_16(encoded, offset);
+ offset += 2;
+ break;
+ case AMQP_FIELD_KIND_I32:
+ entry->value.i32 = (int32_t) D_32(encoded, offset);
+ offset += 4;
+ break;
+ case AMQP_FIELD_KIND_U32:
+ entry->value.u32 = D_32(encoded, offset);
+ offset += 4;
+ break;
+ case AMQP_FIELD_KIND_I64:
+ entry->value.i64 = (int64_t) D_64(encoded, offset);
+ offset += 8;
+ break;
+ case AMQP_FIELD_KIND_F32:
+ entry->value.u32 = D_32(encoded, offset);
+ /* and by punning, f32 magically gets the right value...! */
+ offset += 4;
+ break;
+ case AMQP_FIELD_KIND_F64:
+ entry->value.u64 = D_64(encoded, offset);
+ /* and by punning, f64 magically gets the right value...! */
+ offset += 8;
+ break;
+ case AMQP_FIELD_KIND_DECIMAL:
+ entry->value.decimal.decimals = D_8(encoded, offset);
+ offset++;
+ entry->value.decimal.value = D_32(encoded, offset);
+ offset += 4;
+ break;
+ case AMQP_FIELD_KIND_UTF8:
+ /* AMQP_FIELD_KIND_UTF8 and AMQP_FIELD_KIND_BYTES have the
+ same implementation, but different interpretations. */
+ /* fall through */
+ case AMQP_FIELD_KIND_BYTES:
+ entry->value.bytes.len = D_32(encoded, offset);
+ offset += 4;
+ entry->value.bytes.bytes = D_BYTES(encoded, offset, entry->value.bytes.len);
+ offset += entry->value.bytes.len;
+ break;
+ case AMQP_FIELD_KIND_ARRAY:
+ AMQP_CHECK_RESULT(amqp_decode_array(encoded, pool, &(entry->value.array), &offset));
+ break;
+ case AMQP_FIELD_KIND_TIMESTAMP:
+ entry->value.u64 = D_64(encoded, offset);
+ offset += 8;
+ break;
+ case AMQP_FIELD_KIND_TABLE:
+ AMQP_CHECK_RESULT(amqp_decode_table(encoded, pool, &(entry->value.table), &offset));
+ break;
+ case AMQP_FIELD_KIND_VOID:
+ break;
+ default:
+ return -EINVAL;
+ }
+
+ *offsetptr = offset;
+ return 0;
+}
+
+/*---------------------------------------------------------------------------*/
+
+static int amqp_encode_array(amqp_bytes_t encoded,
+ amqp_array_t *input,
+ int *offsetptr)
+{
+ int offset = *offsetptr;
+ int arraysize_offset = offset;
+ int i;
+
+ offset += 4; /* skip space for the size of the array to be filled in later */
+
+ for (i = 0; i < input->num_entries; i++) {
+ AMQP_CHECK_RESULT(amqp_encode_field_value(encoded, &(input->entries[i]), &offset));
+ }
+
+ E_32(encoded, arraysize_offset, (offset - *offsetptr - 4));
+ *offsetptr = offset;
+ return 0;
+}
+
int amqp_encode_table(amqp_bytes_t encoded,
amqp_table_t *input,
int *offsetptr)
@@ -114,36 +257,7 @@ int amqp_encode_table(amqp_bytes_t encoded,
E_BYTES(encoded, offset, entry->key.len, entry->key.bytes);
offset += entry->key.len;
- E_8(encoded, offset, entry->kind);
- offset++;
-
- switch (entry->kind) {
- case 'S':
- E_32(encoded, offset, entry->value.bytes.len);
- offset += 4;
- E_BYTES(encoded, offset, entry->value.bytes.len, entry->value.bytes.bytes);
- offset += entry->value.bytes.len;
- break;
- case 'I':
- E_32(encoded, offset, (uint32_t) entry->value.i32);
- offset += 4;
- break;
- case 'D':
- E_8(encoded, offset, entry->value.decimal.decimals);
- offset++;
- E_32(encoded, offset, entry->value.decimal.value);
- offset += 4;
- break;
- case 'T':
- E_64(encoded, offset, entry->value.u64);
- offset += 8;
- break;
- case 'F':
- AMQP_CHECK_RESULT(amqp_encode_table(encoded, &(entry->value.table), &offset));
- break;
- default:
- return -EINVAL;
- }
+ AMQP_CHECK_RESULT(amqp_encode_field_value(encoded, &(entry->value), &offset));
}
E_32(encoded, tablesize_offset, (offset - *offsetptr - 4));
@@ -151,6 +265,96 @@ int amqp_encode_table(amqp_bytes_t encoded,
return 0;
}
+static int amqp_encode_field_value(amqp_bytes_t encoded,
+ amqp_field_value_t *entry,
+ int *offsetptr)
+{
+ int offset = *offsetptr;
+
+ E_8(encoded, offset, entry->kind);
+ offset++;
+
+ switch (entry->kind) {
+ case AMQP_FIELD_KIND_BOOLEAN:
+ E_8(encoded, offset, entry->value.boolean ? 1 : 0);
+ offset++;
+ break;
+ case AMQP_FIELD_KIND_I8:
+ E_8(encoded, offset, (uint8_t) entry->value.i8);
+ offset++;
+ break;
+ case AMQP_FIELD_KIND_U8:
+ E_8(encoded, offset, entry->value.u8);
+ offset++;
+ break;
+ case AMQP_FIELD_KIND_I16:
+ E_16(encoded, offset, (uint16_t) entry->value.i16);
+ offset += 2;
+ break;
+ case AMQP_FIELD_KIND_U16:
+ E_16(encoded, offset, entry->value.u16);
+ offset += 2;
+ break;
+ case AMQP_FIELD_KIND_I32:
+ E_32(encoded, offset, (uint32_t) entry->value.i32);
+ offset += 4;
+ break;
+ case AMQP_FIELD_KIND_U32:
+ E_32(encoded, offset, entry->value.u32);
+ offset += 4;
+ break;
+ case AMQP_FIELD_KIND_I64:
+ E_64(encoded, offset, (uint64_t) entry->value.i64);
+ offset += 8;
+ break;
+ case AMQP_FIELD_KIND_F32:
+ /* by punning, u32 magically gets the right value...! */
+ E_32(encoded, offset, entry->value.u32);
+ offset += 4;
+ break;
+ case AMQP_FIELD_KIND_F64:
+ /* by punning, u64 magically gets the right value...! */
+ E_64(encoded, offset, entry->value.u64);
+ offset += 8;
+ break;
+ case AMQP_FIELD_KIND_DECIMAL:
+ E_8(encoded, offset, entry->value.decimal.decimals);
+ offset++;
+ E_32(encoded, offset, entry->value.decimal.value);
+ offset += 4;
+ break;
+ case AMQP_FIELD_KIND_UTF8:
+ /* AMQP_FIELD_KIND_UTF8 and AMQP_FIELD_KIND_BYTES have the
+ same implementation, but different interpretations. */
+ /* fall through */
+ case AMQP_FIELD_KIND_BYTES:
+ E_32(encoded, offset, entry->value.bytes.len);
+ offset += 4;
+ E_BYTES(encoded, offset, entry->value.bytes.len, entry->value.bytes.bytes);
+ offset += entry->value.bytes.len;
+ break;
+ case AMQP_FIELD_KIND_ARRAY:
+ AMQP_CHECK_RESULT(amqp_encode_array(encoded, &(entry->value.array), &offset));
+ break;
+ case AMQP_FIELD_KIND_TIMESTAMP:
+ E_64(encoded, offset, entry->value.u64);
+ offset += 8;
+ break;
+ case AMQP_FIELD_KIND_TABLE:
+ AMQP_CHECK_RESULT(amqp_encode_table(encoded, &(entry->value.table), &offset));
+ break;
+ case AMQP_FIELD_KIND_VOID:
+ break;
+ default:
+ return -EINVAL;
+ }
+
+ *offsetptr = offset;
+ return 0;
+}
+
+/*---------------------------------------------------------------------------*/
+
int amqp_table_entry_cmp(void const *entry1, void const *entry2) {
amqp_table_entry_t const *p1 = (amqp_table_entry_t const *) entry1;
amqp_table_entry_t const *p2 = (amqp_table_entry_t const *) entry2;
View Lorry Controller Status