|
@@ -1,2102 +0,0 @@
|
|
|
-/* Generated code. Do not edit. Edit and re-run codegen.py instead.
|
|
|
- *
|
|
|
- * ***** BEGIN LICENSE BLOCK *****
|
|
|
- * Version: MIT
|
|
|
- *
|
|
|
- * Portions created by Alan Antonuk are Copyright (c) 2012-2013
|
|
|
- * Alan Antonuk. All Rights Reserved.
|
|
|
- *
|
|
|
- * Portions created by VMware are Copyright (c) 2007-2012 VMware, Inc.
|
|
|
- * All Rights Reserved.
|
|
|
- *
|
|
|
- * Portions created by Tony Garnock-Jones are Copyright (c) 2009-2010
|
|
|
- * VMware, Inc. and Tony Garnock-Jones. All Rights Reserved.
|
|
|
- *
|
|
|
- * Permission is hereby granted, free of charge, to any person
|
|
|
- * obtaining a copy of this software and associated documentation
|
|
|
- * files (the "Software"), to deal in the Software without
|
|
|
- * restriction, including without limitation the rights to use, copy,
|
|
|
- * modify, merge, publish, distribute, sublicense, and/or sell copies
|
|
|
- * of the Software, and to permit persons to whom the Software is
|
|
|
- * furnished to do so, subject to the following conditions:
|
|
|
- *
|
|
|
- * The above copyright notice and this permission notice shall be
|
|
|
- * included in all copies or substantial portions of the Software.
|
|
|
- *
|
|
|
- * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
|
|
- * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
|
|
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
|
|
- * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
|
|
|
- * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
|
|
|
- * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
|
|
- * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
|
- * SOFTWARE.
|
|
|
- * ***** END LICENSE BLOCK *****
|
|
|
- */
|
|
|
-
|
|
|
-#ifdef HAVE_CONFIG_H
|
|
|
-#include "config.h"
|
|
|
-#endif
|
|
|
-
|
|
|
-#include "amqp_private.h"
|
|
|
-#include <stdint.h>
|
|
|
-#include <stdio.h>
|
|
|
-#include <stdlib.h>
|
|
|
-#include <string.h>
|
|
|
-
|
|
|
-
|
|
|
-char const *amqp_constant_name(int constantNumber) {
|
|
|
- switch (constantNumber) {
|
|
|
- case AMQP_FRAME_METHOD: return "AMQP_FRAME_METHOD";
|
|
|
- case AMQP_FRAME_HEADER: return "AMQP_FRAME_HEADER";
|
|
|
- case AMQP_FRAME_BODY: return "AMQP_FRAME_BODY";
|
|
|
- case AMQP_FRAME_HEARTBEAT: return "AMQP_FRAME_HEARTBEAT";
|
|
|
- case AMQP_FRAME_MIN_SIZE: return "AMQP_FRAME_MIN_SIZE";
|
|
|
- case AMQP_FRAME_END: return "AMQP_FRAME_END";
|
|
|
- case AMQP_REPLY_SUCCESS: return "AMQP_REPLY_SUCCESS";
|
|
|
- case AMQP_CONTENT_TOO_LARGE: return "AMQP_CONTENT_TOO_LARGE";
|
|
|
- case AMQP_NO_ROUTE: return "AMQP_NO_ROUTE";
|
|
|
- case AMQP_NO_CONSUMERS: return "AMQP_NO_CONSUMERS";
|
|
|
- case AMQP_ACCESS_REFUSED: return "AMQP_ACCESS_REFUSED";
|
|
|
- case AMQP_NOT_FOUND: return "AMQP_NOT_FOUND";
|
|
|
- case AMQP_RESOURCE_LOCKED: return "AMQP_RESOURCE_LOCKED";
|
|
|
- case AMQP_PRECONDITION_FAILED: return "AMQP_PRECONDITION_FAILED";
|
|
|
- case AMQP_CONNECTION_FORCED: return "AMQP_CONNECTION_FORCED";
|
|
|
- case AMQP_INVALID_PATH: return "AMQP_INVALID_PATH";
|
|
|
- case AMQP_FRAME_ERROR: return "AMQP_FRAME_ERROR";
|
|
|
- case AMQP_SYNTAX_ERROR: return "AMQP_SYNTAX_ERROR";
|
|
|
- case AMQP_COMMAND_INVALID: return "AMQP_COMMAND_INVALID";
|
|
|
- case AMQP_CHANNEL_ERROR: return "AMQP_CHANNEL_ERROR";
|
|
|
- case AMQP_UNEXPECTED_FRAME: return "AMQP_UNEXPECTED_FRAME";
|
|
|
- case AMQP_RESOURCE_ERROR: return "AMQP_RESOURCE_ERROR";
|
|
|
- case AMQP_NOT_ALLOWED: return "AMQP_NOT_ALLOWED";
|
|
|
- case AMQP_NOT_IMPLEMENTED: return "AMQP_NOT_IMPLEMENTED";
|
|
|
- case AMQP_INTERNAL_ERROR: return "AMQP_INTERNAL_ERROR";
|
|
|
- default: return "(unknown)";
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-amqp_boolean_t amqp_constant_is_hard_error(int constantNumber) {
|
|
|
- switch (constantNumber) {
|
|
|
- case AMQP_CONNECTION_FORCED: return 1;
|
|
|
- case AMQP_INVALID_PATH: return 1;
|
|
|
- case AMQP_FRAME_ERROR: return 1;
|
|
|
- case AMQP_SYNTAX_ERROR: return 1;
|
|
|
- case AMQP_COMMAND_INVALID: return 1;
|
|
|
- case AMQP_CHANNEL_ERROR: return 1;
|
|
|
- case AMQP_UNEXPECTED_FRAME: return 1;
|
|
|
- case AMQP_RESOURCE_ERROR: return 1;
|
|
|
- case AMQP_NOT_ALLOWED: return 1;
|
|
|
- case AMQP_NOT_IMPLEMENTED: return 1;
|
|
|
- case AMQP_INTERNAL_ERROR: return 1;
|
|
|
- default: return 0;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-char const *amqp_method_name(amqp_method_number_t methodNumber) {
|
|
|
- switch (methodNumber) {
|
|
|
- case AMQP_CONNECTION_START_METHOD: return "AMQP_CONNECTION_START_METHOD";
|
|
|
- case AMQP_CONNECTION_START_OK_METHOD: return "AMQP_CONNECTION_START_OK_METHOD";
|
|
|
- case AMQP_CONNECTION_SECURE_METHOD: return "AMQP_CONNECTION_SECURE_METHOD";
|
|
|
- case AMQP_CONNECTION_SECURE_OK_METHOD: return "AMQP_CONNECTION_SECURE_OK_METHOD";
|
|
|
- case AMQP_CONNECTION_TUNE_METHOD: return "AMQP_CONNECTION_TUNE_METHOD";
|
|
|
- case AMQP_CONNECTION_TUNE_OK_METHOD: return "AMQP_CONNECTION_TUNE_OK_METHOD";
|
|
|
- case AMQP_CONNECTION_OPEN_METHOD: return "AMQP_CONNECTION_OPEN_METHOD";
|
|
|
- case AMQP_CONNECTION_OPEN_OK_METHOD: return "AMQP_CONNECTION_OPEN_OK_METHOD";
|
|
|
- case AMQP_CONNECTION_CLOSE_METHOD: return "AMQP_CONNECTION_CLOSE_METHOD";
|
|
|
- case AMQP_CONNECTION_CLOSE_OK_METHOD: return "AMQP_CONNECTION_CLOSE_OK_METHOD";
|
|
|
- case AMQP_CONNECTION_BLOCKED_METHOD: return "AMQP_CONNECTION_BLOCKED_METHOD";
|
|
|
- case AMQP_CONNECTION_UNBLOCKED_METHOD: return "AMQP_CONNECTION_UNBLOCKED_METHOD";
|
|
|
- case AMQP_CHANNEL_OPEN_METHOD: return "AMQP_CHANNEL_OPEN_METHOD";
|
|
|
- case AMQP_CHANNEL_OPEN_OK_METHOD: return "AMQP_CHANNEL_OPEN_OK_METHOD";
|
|
|
- case AMQP_CHANNEL_FLOW_METHOD: return "AMQP_CHANNEL_FLOW_METHOD";
|
|
|
- case AMQP_CHANNEL_FLOW_OK_METHOD: return "AMQP_CHANNEL_FLOW_OK_METHOD";
|
|
|
- case AMQP_CHANNEL_CLOSE_METHOD: return "AMQP_CHANNEL_CLOSE_METHOD";
|
|
|
- case AMQP_CHANNEL_CLOSE_OK_METHOD: return "AMQP_CHANNEL_CLOSE_OK_METHOD";
|
|
|
- case AMQP_ACCESS_REQUEST_METHOD: return "AMQP_ACCESS_REQUEST_METHOD";
|
|
|
- case AMQP_ACCESS_REQUEST_OK_METHOD: return "AMQP_ACCESS_REQUEST_OK_METHOD";
|
|
|
- case AMQP_EXCHANGE_DECLARE_METHOD: return "AMQP_EXCHANGE_DECLARE_METHOD";
|
|
|
- case AMQP_EXCHANGE_DECLARE_OK_METHOD: return "AMQP_EXCHANGE_DECLARE_OK_METHOD";
|
|
|
- case AMQP_EXCHANGE_DELETE_METHOD: return "AMQP_EXCHANGE_DELETE_METHOD";
|
|
|
- case AMQP_EXCHANGE_DELETE_OK_METHOD: return "AMQP_EXCHANGE_DELETE_OK_METHOD";
|
|
|
- case AMQP_EXCHANGE_BIND_METHOD: return "AMQP_EXCHANGE_BIND_METHOD";
|
|
|
- case AMQP_EXCHANGE_BIND_OK_METHOD: return "AMQP_EXCHANGE_BIND_OK_METHOD";
|
|
|
- case AMQP_EXCHANGE_UNBIND_METHOD: return "AMQP_EXCHANGE_UNBIND_METHOD";
|
|
|
- case AMQP_EXCHANGE_UNBIND_OK_METHOD: return "AMQP_EXCHANGE_UNBIND_OK_METHOD";
|
|
|
- case AMQP_QUEUE_DECLARE_METHOD: return "AMQP_QUEUE_DECLARE_METHOD";
|
|
|
- case AMQP_QUEUE_DECLARE_OK_METHOD: return "AMQP_QUEUE_DECLARE_OK_METHOD";
|
|
|
- case AMQP_QUEUE_BIND_METHOD: return "AMQP_QUEUE_BIND_METHOD";
|
|
|
- case AMQP_QUEUE_BIND_OK_METHOD: return "AMQP_QUEUE_BIND_OK_METHOD";
|
|
|
- case AMQP_QUEUE_PURGE_METHOD: return "AMQP_QUEUE_PURGE_METHOD";
|
|
|
- case AMQP_QUEUE_PURGE_OK_METHOD: return "AMQP_QUEUE_PURGE_OK_METHOD";
|
|
|
- case AMQP_QUEUE_DELETE_METHOD: return "AMQP_QUEUE_DELETE_METHOD";
|
|
|
- case AMQP_QUEUE_DELETE_OK_METHOD: return "AMQP_QUEUE_DELETE_OK_METHOD";
|
|
|
- case AMQP_QUEUE_UNBIND_METHOD: return "AMQP_QUEUE_UNBIND_METHOD";
|
|
|
- case AMQP_QUEUE_UNBIND_OK_METHOD: return "AMQP_QUEUE_UNBIND_OK_METHOD";
|
|
|
- case AMQP_BASIC_QOS_METHOD: return "AMQP_BASIC_QOS_METHOD";
|
|
|
- case AMQP_BASIC_QOS_OK_METHOD: return "AMQP_BASIC_QOS_OK_METHOD";
|
|
|
- case AMQP_BASIC_CONSUME_METHOD: return "AMQP_BASIC_CONSUME_METHOD";
|
|
|
- case AMQP_BASIC_CONSUME_OK_METHOD: return "AMQP_BASIC_CONSUME_OK_METHOD";
|
|
|
- case AMQP_BASIC_CANCEL_METHOD: return "AMQP_BASIC_CANCEL_METHOD";
|
|
|
- case AMQP_BASIC_CANCEL_OK_METHOD: return "AMQP_BASIC_CANCEL_OK_METHOD";
|
|
|
- case AMQP_BASIC_PUBLISH_METHOD: return "AMQP_BASIC_PUBLISH_METHOD";
|
|
|
- case AMQP_BASIC_RETURN_METHOD: return "AMQP_BASIC_RETURN_METHOD";
|
|
|
- case AMQP_BASIC_DELIVER_METHOD: return "AMQP_BASIC_DELIVER_METHOD";
|
|
|
- case AMQP_BASIC_GET_METHOD: return "AMQP_BASIC_GET_METHOD";
|
|
|
- case AMQP_BASIC_GET_OK_METHOD: return "AMQP_BASIC_GET_OK_METHOD";
|
|
|
- case AMQP_BASIC_GET_EMPTY_METHOD: return "AMQP_BASIC_GET_EMPTY_METHOD";
|
|
|
- case AMQP_BASIC_ACK_METHOD: return "AMQP_BASIC_ACK_METHOD";
|
|
|
- case AMQP_BASIC_REJECT_METHOD: return "AMQP_BASIC_REJECT_METHOD";
|
|
|
- case AMQP_BASIC_RECOVER_ASYNC_METHOD: return "AMQP_BASIC_RECOVER_ASYNC_METHOD";
|
|
|
- case AMQP_BASIC_RECOVER_METHOD: return "AMQP_BASIC_RECOVER_METHOD";
|
|
|
- case AMQP_BASIC_RECOVER_OK_METHOD: return "AMQP_BASIC_RECOVER_OK_METHOD";
|
|
|
- case AMQP_BASIC_NACK_METHOD: return "AMQP_BASIC_NACK_METHOD";
|
|
|
- case AMQP_TX_SELECT_METHOD: return "AMQP_TX_SELECT_METHOD";
|
|
|
- case AMQP_TX_SELECT_OK_METHOD: return "AMQP_TX_SELECT_OK_METHOD";
|
|
|
- case AMQP_TX_COMMIT_METHOD: return "AMQP_TX_COMMIT_METHOD";
|
|
|
- case AMQP_TX_COMMIT_OK_METHOD: return "AMQP_TX_COMMIT_OK_METHOD";
|
|
|
- case AMQP_TX_ROLLBACK_METHOD: return "AMQP_TX_ROLLBACK_METHOD";
|
|
|
- case AMQP_TX_ROLLBACK_OK_METHOD: return "AMQP_TX_ROLLBACK_OK_METHOD";
|
|
|
- case AMQP_CONFIRM_SELECT_METHOD: return "AMQP_CONFIRM_SELECT_METHOD";
|
|
|
- case AMQP_CONFIRM_SELECT_OK_METHOD: return "AMQP_CONFIRM_SELECT_OK_METHOD";
|
|
|
- default: return NULL;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-amqp_boolean_t amqp_method_has_content(amqp_method_number_t methodNumber) {
|
|
|
- switch (methodNumber) {
|
|
|
- case AMQP_BASIC_PUBLISH_METHOD: return 1;
|
|
|
- case AMQP_BASIC_RETURN_METHOD: return 1;
|
|
|
- case AMQP_BASIC_DELIVER_METHOD: return 1;
|
|
|
- case AMQP_BASIC_GET_OK_METHOD: return 1;
|
|
|
- default: return 0;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-int amqp_decode_method(amqp_method_number_t methodNumber,
|
|
|
- amqp_pool_t *pool,
|
|
|
- amqp_bytes_t encoded,
|
|
|
- void **decoded)
|
|
|
-{
|
|
|
- size_t offset = 0;
|
|
|
- uint8_t bit_buffer;
|
|
|
-
|
|
|
- switch (methodNumber) {
|
|
|
- case AMQP_CONNECTION_START_METHOD: {
|
|
|
- amqp_connection_start_t *m = (amqp_connection_start_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_start_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &m->version_major)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &m->version_minor)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->server_properties), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- {
|
|
|
- uint32_t len;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->mechanisms, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint32_t len;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->locales, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_START_OK_METHOD: {
|
|
|
- amqp_connection_start_ok_t *m = (amqp_connection_start_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_start_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->client_properties), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->mechanism, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint32_t len;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->response, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->locale, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_SECURE_METHOD: {
|
|
|
- amqp_connection_secure_t *m = (amqp_connection_secure_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_secure_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint32_t len;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->challenge, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_SECURE_OK_METHOD: {
|
|
|
- amqp_connection_secure_ok_t *m = (amqp_connection_secure_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_secure_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint32_t len;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->response, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_TUNE_METHOD: {
|
|
|
- amqp_connection_tune_t *m = (amqp_connection_tune_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_tune_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->channel_max)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &m->frame_max)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->heartbeat)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_TUNE_OK_METHOD: {
|
|
|
- amqp_connection_tune_ok_t *m = (amqp_connection_tune_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_tune_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->channel_max)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &m->frame_max)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->heartbeat)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_OPEN_METHOD: {
|
|
|
- amqp_connection_open_t *m = (amqp_connection_open_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_open_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->virtual_host, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->capabilities, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->insist = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_OPEN_OK_METHOD: {
|
|
|
- amqp_connection_open_ok_t *m = (amqp_connection_open_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_open_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->known_hosts, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_CLOSE_METHOD: {
|
|
|
- amqp_connection_close_t *m = (amqp_connection_close_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_close_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->reply_code)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->reply_text, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->class_id)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->method_id)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_CLOSE_OK_METHOD: {
|
|
|
- amqp_connection_close_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_BLOCKED_METHOD: {
|
|
|
- amqp_connection_blocked_t *m = (amqp_connection_blocked_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_blocked_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->reason, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_UNBLOCKED_METHOD: {
|
|
|
- amqp_connection_unblocked_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_OPEN_METHOD: {
|
|
|
- amqp_channel_open_t *m = (amqp_channel_open_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_open_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->out_of_band, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_OPEN_OK_METHOD: {
|
|
|
- amqp_channel_open_ok_t *m = (amqp_channel_open_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_open_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint32_t len;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->channel_id, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_FLOW_METHOD: {
|
|
|
- amqp_channel_flow_t *m = (amqp_channel_flow_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_flow_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->active = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_FLOW_OK_METHOD: {
|
|
|
- amqp_channel_flow_ok_t *m = (amqp_channel_flow_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_flow_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->active = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_CLOSE_METHOD: {
|
|
|
- amqp_channel_close_t *m = (amqp_channel_close_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_close_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->reply_code)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->reply_text, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->class_id)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->method_id)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_CLOSE_OK_METHOD: {
|
|
|
- amqp_channel_close_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_ACCESS_REQUEST_METHOD: {
|
|
|
- amqp_access_request_t *m = (amqp_access_request_t *) amqp_pool_alloc(pool, sizeof(amqp_access_request_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->realm, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->exclusive = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- m->passive = (bit_buffer & (1 << 1)) ? 1 : 0;
|
|
|
- m->active = (bit_buffer & (1 << 2)) ? 1 : 0;
|
|
|
- m->write = (bit_buffer & (1 << 3)) ? 1 : 0;
|
|
|
- m->read = (bit_buffer & (1 << 4)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_ACCESS_REQUEST_OK_METHOD: {
|
|
|
- amqp_access_request_ok_t *m = (amqp_access_request_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_access_request_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_DECLARE_METHOD: {
|
|
|
- amqp_exchange_declare_t *m = (amqp_exchange_declare_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_declare_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->type, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->passive = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- m->durable = (bit_buffer & (1 << 1)) ? 1 : 0;
|
|
|
- m->auto_delete = (bit_buffer & (1 << 2)) ? 1 : 0;
|
|
|
- m->internal = (bit_buffer & (1 << 3)) ? 1 : 0;
|
|
|
- m->nowait = (bit_buffer & (1 << 4)) ? 1 : 0;
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_DECLARE_OK_METHOD: {
|
|
|
- amqp_exchange_declare_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_DELETE_METHOD: {
|
|
|
- amqp_exchange_delete_t *m = (amqp_exchange_delete_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_delete_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->if_unused = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- m->nowait = (bit_buffer & (1 << 1)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_DELETE_OK_METHOD: {
|
|
|
- amqp_exchange_delete_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_BIND_METHOD: {
|
|
|
- amqp_exchange_bind_t *m = (amqp_exchange_bind_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_bind_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->destination, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->source, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_BIND_OK_METHOD: {
|
|
|
- amqp_exchange_bind_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_UNBIND_METHOD: {
|
|
|
- amqp_exchange_unbind_t *m = (amqp_exchange_unbind_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_unbind_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->destination, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->source, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_UNBIND_OK_METHOD: {
|
|
|
- amqp_exchange_unbind_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_DECLARE_METHOD: {
|
|
|
- amqp_queue_declare_t *m = (amqp_queue_declare_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_declare_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->queue, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->passive = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- m->durable = (bit_buffer & (1 << 1)) ? 1 : 0;
|
|
|
- m->exclusive = (bit_buffer & (1 << 2)) ? 1 : 0;
|
|
|
- m->auto_delete = (bit_buffer & (1 << 3)) ? 1 : 0;
|
|
|
- m->nowait = (bit_buffer & (1 << 4)) ? 1 : 0;
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_DECLARE_OK_METHOD: {
|
|
|
- amqp_queue_declare_ok_t *m = (amqp_queue_declare_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_declare_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->queue, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_32(encoded, &offset, &m->message_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_32(encoded, &offset, &m->consumer_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_BIND_METHOD: {
|
|
|
- amqp_queue_bind_t *m = (amqp_queue_bind_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_bind_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->queue, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_BIND_OK_METHOD: {
|
|
|
- amqp_queue_bind_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_PURGE_METHOD: {
|
|
|
- amqp_queue_purge_t *m = (amqp_queue_purge_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_purge_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->queue, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_PURGE_OK_METHOD: {
|
|
|
- amqp_queue_purge_ok_t *m = (amqp_queue_purge_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_purge_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_32(encoded, &offset, &m->message_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_DELETE_METHOD: {
|
|
|
- amqp_queue_delete_t *m = (amqp_queue_delete_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_delete_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->queue, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->if_unused = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- m->if_empty = (bit_buffer & (1 << 1)) ? 1 : 0;
|
|
|
- m->nowait = (bit_buffer & (1 << 2)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_DELETE_OK_METHOD: {
|
|
|
- amqp_queue_delete_ok_t *m = (amqp_queue_delete_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_delete_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_32(encoded, &offset, &m->message_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_UNBIND_METHOD: {
|
|
|
- amqp_queue_unbind_t *m = (amqp_queue_unbind_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_unbind_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->queue, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_UNBIND_OK_METHOD: {
|
|
|
- amqp_queue_unbind_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_QOS_METHOD: {
|
|
|
- amqp_basic_qos_t *m = (amqp_basic_qos_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_qos_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_32(encoded, &offset, &m->prefetch_size)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->prefetch_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->global = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_QOS_OK_METHOD: {
|
|
|
- amqp_basic_qos_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_CONSUME_METHOD: {
|
|
|
- amqp_basic_consume_t *m = (amqp_basic_consume_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_consume_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->queue, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->no_local = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- m->no_ack = (bit_buffer & (1 << 1)) ? 1 : 0;
|
|
|
- m->exclusive = (bit_buffer & (1 << 2)) ? 1 : 0;
|
|
|
- m->nowait = (bit_buffer & (1 << 3)) ? 1 : 0;
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_CONSUME_OK_METHOD: {
|
|
|
- amqp_basic_consume_ok_t *m = (amqp_basic_consume_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_consume_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_CANCEL_METHOD: {
|
|
|
- amqp_basic_cancel_t *m = (amqp_basic_cancel_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_cancel_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_CANCEL_OK_METHOD: {
|
|
|
- amqp_basic_cancel_ok_t *m = (amqp_basic_cancel_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_cancel_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_PUBLISH_METHOD: {
|
|
|
- amqp_basic_publish_t *m = (amqp_basic_publish_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_publish_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->mandatory = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- m->immediate = (bit_buffer & (1 << 1)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_RETURN_METHOD: {
|
|
|
- amqp_basic_return_t *m = (amqp_basic_return_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_return_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->reply_code)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->reply_text, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_DELIVER_METHOD: {
|
|
|
- amqp_basic_deliver_t *m = (amqp_basic_deliver_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_deliver_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->redelivered = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_GET_METHOD: {
|
|
|
- amqp_basic_get_t *m = (amqp_basic_get_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_get_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_16(encoded, &offset, &m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->queue, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->no_ack = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_GET_OK_METHOD: {
|
|
|
- amqp_basic_get_ok_t *m = (amqp_basic_get_ok_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_get_ok_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->redelivered = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (!amqp_decode_32(encoded, &offset, &m->message_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_GET_EMPTY_METHOD: {
|
|
|
- amqp_basic_get_empty_t *m = (amqp_basic_get_empty_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_get_empty_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &m->cluster_id, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_ACK_METHOD: {
|
|
|
- amqp_basic_ack_t *m = (amqp_basic_ack_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_ack_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->multiple = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_REJECT_METHOD: {
|
|
|
- amqp_basic_reject_t *m = (amqp_basic_reject_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_reject_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_RECOVER_ASYNC_METHOD: {
|
|
|
- amqp_basic_recover_async_t *m = (amqp_basic_recover_async_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_recover_async_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_RECOVER_METHOD: {
|
|
|
- amqp_basic_recover_t *m = (amqp_basic_recover_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_recover_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_RECOVER_OK_METHOD: {
|
|
|
- amqp_basic_recover_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_BASIC_NACK_METHOD: {
|
|
|
- amqp_basic_nack_t *m = (amqp_basic_nack_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_nack_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->multiple = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- m->requeue = (bit_buffer & (1 << 1)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_TX_SELECT_METHOD: {
|
|
|
- amqp_tx_select_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_TX_SELECT_OK_METHOD: {
|
|
|
- amqp_tx_select_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_TX_COMMIT_METHOD: {
|
|
|
- amqp_tx_commit_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_TX_COMMIT_OK_METHOD: {
|
|
|
- amqp_tx_commit_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_TX_ROLLBACK_METHOD: {
|
|
|
- amqp_tx_rollback_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_TX_ROLLBACK_OK_METHOD: {
|
|
|
- amqp_tx_rollback_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONFIRM_SELECT_METHOD: {
|
|
|
- amqp_confirm_select_t *m = (amqp_confirm_select_t *) amqp_pool_alloc(pool, sizeof(amqp_confirm_select_t));
|
|
|
- if (m == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- if (!amqp_decode_8(encoded, &offset, &bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case AMQP_CONFIRM_SELECT_OK_METHOD: {
|
|
|
- amqp_confirm_select_ok_t *m = NULL; /* no fields */
|
|
|
- *decoded = m;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- default: return AMQP_STATUS_UNKNOWN_METHOD;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-int amqp_decode_properties(uint16_t class_id,
|
|
|
- amqp_pool_t *pool,
|
|
|
- amqp_bytes_t encoded,
|
|
|
- void **decoded)
|
|
|
-{
|
|
|
- size_t offset = 0;
|
|
|
-
|
|
|
- amqp_flags_t flags = 0;
|
|
|
- int flagword_index = 0;
|
|
|
- uint16_t partial_flags;
|
|
|
-
|
|
|
- do {
|
|
|
- if (!amqp_decode_16(encoded, &offset, &partial_flags))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- flags |= (partial_flags << (flagword_index * 16));
|
|
|
- flagword_index++;
|
|
|
- } while (partial_flags & 1);
|
|
|
-
|
|
|
- switch (class_id) {
|
|
|
- case 10: {
|
|
|
- amqp_connection_properties_t *p = (amqp_connection_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_connection_properties_t));
|
|
|
- if (p == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- p->_flags = flags;
|
|
|
- *decoded = p;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case 20: {
|
|
|
- amqp_channel_properties_t *p = (amqp_channel_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_channel_properties_t));
|
|
|
- if (p == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- p->_flags = flags;
|
|
|
- *decoded = p;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case 30: {
|
|
|
- amqp_access_properties_t *p = (amqp_access_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_access_properties_t));
|
|
|
- if (p == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- p->_flags = flags;
|
|
|
- *decoded = p;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case 40: {
|
|
|
- amqp_exchange_properties_t *p = (amqp_exchange_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_exchange_properties_t));
|
|
|
- if (p == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- p->_flags = flags;
|
|
|
- *decoded = p;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case 50: {
|
|
|
- amqp_queue_properties_t *p = (amqp_queue_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_queue_properties_t));
|
|
|
- if (p == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- p->_flags = flags;
|
|
|
- *decoded = p;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case 60: {
|
|
|
- amqp_basic_properties_t *p = (amqp_basic_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_basic_properties_t));
|
|
|
- if (p == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- p->_flags = flags;
|
|
|
- if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->content_type, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->content_encoding, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_HEADERS_FLAG) {
|
|
|
- {
|
|
|
- int res = amqp_decode_table(encoded, pool, &(p->headers), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) {
|
|
|
- if (!amqp_decode_8(encoded, &offset, &p->delivery_mode)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_PRIORITY_FLAG) {
|
|
|
- if (!amqp_decode_8(encoded, &offset, &p->priority)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->correlation_id, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_REPLY_TO_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->reply_to, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_EXPIRATION_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->expiration, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->message_id, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_TIMESTAMP_FLAG) {
|
|
|
- if (!amqp_decode_64(encoded, &offset, &p->timestamp)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_TYPE_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->type, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_USER_ID_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->user_id, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_APP_ID_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->app_id, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) {
|
|
|
- {
|
|
|
- uint8_t len;
|
|
|
- if (!amqp_decode_8(encoded, &offset, &len)
|
|
|
- || !amqp_decode_bytes(encoded, &offset, &p->cluster_id, len))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- }
|
|
|
- *decoded = p;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case 90: {
|
|
|
- amqp_tx_properties_t *p = (amqp_tx_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_tx_properties_t));
|
|
|
- if (p == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- p->_flags = flags;
|
|
|
- *decoded = p;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- case 85: {
|
|
|
- amqp_confirm_properties_t *p = (amqp_confirm_properties_t *) amqp_pool_alloc(pool, sizeof(amqp_confirm_properties_t));
|
|
|
- if (p == NULL) { return AMQP_STATUS_NO_MEMORY; }
|
|
|
- p->_flags = flags;
|
|
|
- *decoded = p;
|
|
|
- return 0;
|
|
|
- }
|
|
|
- default: return AMQP_STATUS_UNKNOWN_CLASS;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-int amqp_encode_method(amqp_method_number_t methodNumber,
|
|
|
- void *decoded,
|
|
|
- amqp_bytes_t encoded)
|
|
|
-{
|
|
|
- size_t offset = 0;
|
|
|
- uint8_t bit_buffer;
|
|
|
-
|
|
|
- switch (methodNumber) {
|
|
|
- case AMQP_CONNECTION_START_METHOD: {
|
|
|
- amqp_connection_start_t *m = (amqp_connection_start_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->version_major)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->version_minor)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->server_properties), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->mechanisms.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->mechanisms))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->locales.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->locales))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_START_OK_METHOD: {
|
|
|
- amqp_connection_start_ok_t *m = (amqp_connection_start_ok_t *) decoded;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->client_properties), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->mechanism.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->mechanism))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->response.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->response))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->locale.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->locale))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_SECURE_METHOD: {
|
|
|
- amqp_connection_secure_t *m = (amqp_connection_secure_t *) decoded;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->challenge.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->challenge))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_SECURE_OK_METHOD: {
|
|
|
- amqp_connection_secure_ok_t *m = (amqp_connection_secure_ok_t *) decoded;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->response.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->response))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_TUNE_METHOD: {
|
|
|
- amqp_connection_tune_t *m = (amqp_connection_tune_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->channel_max)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->frame_max)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->heartbeat)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_TUNE_OK_METHOD: {
|
|
|
- amqp_connection_tune_ok_t *m = (amqp_connection_tune_ok_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->channel_max)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->frame_max)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->heartbeat)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_OPEN_METHOD: {
|
|
|
- amqp_connection_open_t *m = (amqp_connection_open_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->virtual_host.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->virtual_host))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->capabilities.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->capabilities))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->insist) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_OPEN_OK_METHOD: {
|
|
|
- amqp_connection_open_ok_t *m = (amqp_connection_open_ok_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->known_hosts.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->known_hosts))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_CLOSE_METHOD: {
|
|
|
- amqp_connection_close_t *m = (amqp_connection_close_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->reply_code)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->reply_text.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->reply_text))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->class_id)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->method_id)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_CLOSE_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_BLOCKED_METHOD: {
|
|
|
- amqp_connection_blocked_t *m = (amqp_connection_blocked_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->reason.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->reason))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONNECTION_UNBLOCKED_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_OPEN_METHOD: {
|
|
|
- amqp_channel_open_t *m = (amqp_channel_open_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->out_of_band.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->out_of_band))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_OPEN_OK_METHOD: {
|
|
|
- amqp_channel_open_ok_t *m = (amqp_channel_open_ok_t *) decoded;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->channel_id.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->channel_id))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_FLOW_METHOD: {
|
|
|
- amqp_channel_flow_t *m = (amqp_channel_flow_t *) decoded;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->active) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_FLOW_OK_METHOD: {
|
|
|
- amqp_channel_flow_ok_t *m = (amqp_channel_flow_ok_t *) decoded;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->active) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_CLOSE_METHOD: {
|
|
|
- amqp_channel_close_t *m = (amqp_channel_close_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->reply_code)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->reply_text.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->reply_text))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->class_id)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->method_id)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CHANNEL_CLOSE_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_ACCESS_REQUEST_METHOD: {
|
|
|
- amqp_access_request_t *m = (amqp_access_request_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->realm.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->realm))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->exclusive) bit_buffer |= (1 << 0);
|
|
|
- if (m->passive) bit_buffer |= (1 << 1);
|
|
|
- if (m->active) bit_buffer |= (1 << 2);
|
|
|
- if (m->write) bit_buffer |= (1 << 3);
|
|
|
- if (m->read) bit_buffer |= (1 << 4);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_ACCESS_REQUEST_OK_METHOD: {
|
|
|
- amqp_access_request_ok_t *m = (amqp_access_request_ok_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_DECLARE_METHOD: {
|
|
|
- amqp_exchange_declare_t *m = (amqp_exchange_declare_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->exchange.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->exchange))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->type.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->type))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->passive) bit_buffer |= (1 << 0);
|
|
|
- if (m->durable) bit_buffer |= (1 << 1);
|
|
|
- if (m->auto_delete) bit_buffer |= (1 << 2);
|
|
|
- if (m->internal) bit_buffer |= (1 << 3);
|
|
|
- if (m->nowait) bit_buffer |= (1 << 4);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_DECLARE_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_DELETE_METHOD: {
|
|
|
- amqp_exchange_delete_t *m = (amqp_exchange_delete_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->exchange.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->exchange))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->if_unused) bit_buffer |= (1 << 0);
|
|
|
- if (m->nowait) bit_buffer |= (1 << 1);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_DELETE_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_BIND_METHOD: {
|
|
|
- amqp_exchange_bind_t *m = (amqp_exchange_bind_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->destination.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->destination))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->source.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->source))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->routing_key.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->routing_key))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->nowait) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_BIND_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_UNBIND_METHOD: {
|
|
|
- amqp_exchange_unbind_t *m = (amqp_exchange_unbind_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->destination.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->destination))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->source.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->source))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->routing_key.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->routing_key))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->nowait) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_EXCHANGE_UNBIND_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_DECLARE_METHOD: {
|
|
|
- amqp_queue_declare_t *m = (amqp_queue_declare_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->queue.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->queue))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->passive) bit_buffer |= (1 << 0);
|
|
|
- if (m->durable) bit_buffer |= (1 << 1);
|
|
|
- if (m->exclusive) bit_buffer |= (1 << 2);
|
|
|
- if (m->auto_delete) bit_buffer |= (1 << 3);
|
|
|
- if (m->nowait) bit_buffer |= (1 << 4);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_DECLARE_OK_METHOD: {
|
|
|
- amqp_queue_declare_ok_t *m = (amqp_queue_declare_ok_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->queue.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->queue))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->message_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->consumer_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_BIND_METHOD: {
|
|
|
- amqp_queue_bind_t *m = (amqp_queue_bind_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->queue.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->queue))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->exchange.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->exchange))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->routing_key.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->routing_key))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->nowait) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_BIND_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_PURGE_METHOD: {
|
|
|
- amqp_queue_purge_t *m = (amqp_queue_purge_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->queue.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->queue))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->nowait) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_PURGE_OK_METHOD: {
|
|
|
- amqp_queue_purge_ok_t *m = (amqp_queue_purge_ok_t *) decoded;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->message_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_DELETE_METHOD: {
|
|
|
- amqp_queue_delete_t *m = (amqp_queue_delete_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->queue.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->queue))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->if_unused) bit_buffer |= (1 << 0);
|
|
|
- if (m->if_empty) bit_buffer |= (1 << 1);
|
|
|
- if (m->nowait) bit_buffer |= (1 << 2);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_DELETE_OK_METHOD: {
|
|
|
- amqp_queue_delete_ok_t *m = (amqp_queue_delete_ok_t *) decoded;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->message_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_UNBIND_METHOD: {
|
|
|
- amqp_queue_unbind_t *m = (amqp_queue_unbind_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->queue.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->queue))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->exchange.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->exchange))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->routing_key.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->routing_key))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_QUEUE_UNBIND_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_QOS_METHOD: {
|
|
|
- amqp_basic_qos_t *m = (amqp_basic_qos_t *) decoded;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->prefetch_size)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->prefetch_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->global) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_QOS_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_CONSUME_METHOD: {
|
|
|
- amqp_basic_consume_t *m = (amqp_basic_consume_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->queue.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->queue))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->consumer_tag.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->no_local) bit_buffer |= (1 << 0);
|
|
|
- if (m->no_ack) bit_buffer |= (1 << 1);
|
|
|
- if (m->exclusive) bit_buffer |= (1 << 2);
|
|
|
- if (m->nowait) bit_buffer |= (1 << 3);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(m->arguments), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_CONSUME_OK_METHOD: {
|
|
|
- amqp_basic_consume_ok_t *m = (amqp_basic_consume_ok_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->consumer_tag.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_CANCEL_METHOD: {
|
|
|
- amqp_basic_cancel_t *m = (amqp_basic_cancel_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->consumer_tag.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->nowait) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_CANCEL_OK_METHOD: {
|
|
|
- amqp_basic_cancel_ok_t *m = (amqp_basic_cancel_ok_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->consumer_tag.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_PUBLISH_METHOD: {
|
|
|
- amqp_basic_publish_t *m = (amqp_basic_publish_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->exchange.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->exchange))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->routing_key.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->routing_key))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->mandatory) bit_buffer |= (1 << 0);
|
|
|
- if (m->immediate) bit_buffer |= (1 << 1);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_RETURN_METHOD: {
|
|
|
- amqp_basic_return_t *m = (amqp_basic_return_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->reply_code)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->reply_text.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->reply_text))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->exchange.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->exchange))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->routing_key.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->routing_key))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_DELIVER_METHOD: {
|
|
|
- amqp_basic_deliver_t *m = (amqp_basic_deliver_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->consumer_tag.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->redelivered) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->exchange.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->exchange))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->routing_key.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->routing_key))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_GET_METHOD: {
|
|
|
- amqp_basic_get_t *m = (amqp_basic_get_t *) decoded;
|
|
|
- if (!amqp_encode_16(encoded, &offset, m->ticket)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->queue.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->queue))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->no_ack) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_GET_OK_METHOD: {
|
|
|
- amqp_basic_get_ok_t *m = (amqp_basic_get_ok_t *) decoded;
|
|
|
- if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->redelivered) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->exchange.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->exchange))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->routing_key.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->routing_key))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- if (!amqp_encode_32(encoded, &offset, m->message_count)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_GET_EMPTY_METHOD: {
|
|
|
- amqp_basic_get_empty_t *m = (amqp_basic_get_empty_t *) decoded;
|
|
|
- if (!amqp_encode_8(encoded, &offset, m->cluster_id.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, m->cluster_id))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_ACK_METHOD: {
|
|
|
- amqp_basic_ack_t *m = (amqp_basic_ack_t *) decoded;
|
|
|
- if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->multiple) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_REJECT_METHOD: {
|
|
|
- amqp_basic_reject_t *m = (amqp_basic_reject_t *) decoded;
|
|
|
- if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->requeue) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_RECOVER_ASYNC_METHOD: {
|
|
|
- amqp_basic_recover_async_t *m = (amqp_basic_recover_async_t *) decoded;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->requeue) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_RECOVER_METHOD: {
|
|
|
- amqp_basic_recover_t *m = (amqp_basic_recover_t *) decoded;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->requeue) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_RECOVER_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_BASIC_NACK_METHOD: {
|
|
|
- amqp_basic_nack_t *m = (amqp_basic_nack_t *) decoded;
|
|
|
- if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->multiple) bit_buffer |= (1 << 0);
|
|
|
- if (m->requeue) bit_buffer |= (1 << 1);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_TX_SELECT_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_TX_SELECT_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_TX_COMMIT_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_TX_COMMIT_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_TX_ROLLBACK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_TX_ROLLBACK_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONFIRM_SELECT_METHOD: {
|
|
|
- amqp_confirm_select_t *m = (amqp_confirm_select_t *) decoded;
|
|
|
- bit_buffer = 0;
|
|
|
- if (m->nowait) bit_buffer |= (1 << 0);
|
|
|
- if (!amqp_encode_8(encoded, &offset, bit_buffer)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case AMQP_CONFIRM_SELECT_OK_METHOD: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- default: return AMQP_STATUS_UNKNOWN_METHOD;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-int amqp_encode_properties(uint16_t class_id,
|
|
|
- void *decoded,
|
|
|
- amqp_bytes_t encoded)
|
|
|
-{
|
|
|
- size_t offset = 0;
|
|
|
-
|
|
|
- /* Cheat, and get the flags out generically, relying on the
|
|
|
- similarity of structure between classes */
|
|
|
- amqp_flags_t flags = * (amqp_flags_t *) decoded; /* cheating! */
|
|
|
-
|
|
|
- {
|
|
|
- /* We take a copy of flags to avoid destroying it, as it is used
|
|
|
- in the autogenerated code below. */
|
|
|
- amqp_flags_t remaining_flags = flags;
|
|
|
- do {
|
|
|
- amqp_flags_t remainder = remaining_flags >> 16;
|
|
|
- uint16_t partial_flags = remaining_flags & 0xFFFE;
|
|
|
- if (remainder != 0) { partial_flags |= 1; }
|
|
|
- if (!amqp_encode_16(encoded, &offset, partial_flags))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- remaining_flags = remainder;
|
|
|
- } while (remaining_flags != 0);
|
|
|
- }
|
|
|
-
|
|
|
- switch (class_id) {
|
|
|
- case 10: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case 20: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case 30: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case 40: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case 50: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case 60: {
|
|
|
- amqp_basic_properties_t *p = (amqp_basic_properties_t *) decoded;
|
|
|
- if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->content_type.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->content_type))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->content_encoding.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->content_encoding))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_HEADERS_FLAG) {
|
|
|
- {
|
|
|
- int res = amqp_encode_table(encoded, &(p->headers), &offset);
|
|
|
- if (res < 0) return res;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->delivery_mode)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_PRIORITY_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->priority)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->correlation_id.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->correlation_id))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_REPLY_TO_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->reply_to.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->reply_to))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_EXPIRATION_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->expiration.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->expiration))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->message_id.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->message_id))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_TIMESTAMP_FLAG) {
|
|
|
- if (!amqp_encode_64(encoded, &offset, p->timestamp)) return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_TYPE_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->type.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->type))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_USER_ID_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->user_id.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->user_id))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_APP_ID_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->app_id.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->app_id))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) {
|
|
|
- if (!amqp_encode_8(encoded, &offset, p->cluster_id.len)
|
|
|
- || !amqp_encode_bytes(encoded, &offset, p->cluster_id))
|
|
|
- return AMQP_STATUS_BAD_AMQP_DATA;
|
|
|
- }
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case 90: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- case 85: {
|
|
|
- return offset;
|
|
|
- }
|
|
|
- default: return AMQP_STATUS_UNKNOWN_CLASS;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_channel_open_ok_t * AMQP_CALL amqp_channel_open(amqp_connection_state_t state, amqp_channel_t channel)
|
|
|
-{
|
|
|
- amqp_channel_open_t req;
|
|
|
- req.out_of_band = amqp_empty_bytes;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_CHANNEL_OPEN_METHOD, AMQP_CHANNEL_OPEN_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_channel_flow_ok_t * AMQP_CALL amqp_channel_flow(amqp_connection_state_t state, amqp_channel_t channel, amqp_boolean_t active)
|
|
|
-{
|
|
|
- amqp_channel_flow_t req;
|
|
|
- req.active = active;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_CHANNEL_FLOW_METHOD, AMQP_CHANNEL_FLOW_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_exchange_declare_ok_t * AMQP_CALL amqp_exchange_declare(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t exchange, amqp_bytes_t type, amqp_boolean_t passive, amqp_boolean_t durable, amqp_table_t arguments)
|
|
|
-{
|
|
|
- amqp_exchange_declare_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.exchange = exchange;
|
|
|
- req.type = type;
|
|
|
- req.passive = passive;
|
|
|
- req.durable = durable;
|
|
|
- req.auto_delete = 0;
|
|
|
- req.internal = 0;
|
|
|
- req.nowait = 0;
|
|
|
- req.arguments = arguments;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_EXCHANGE_DECLARE_METHOD, AMQP_EXCHANGE_DECLARE_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_exchange_delete_ok_t * AMQP_CALL amqp_exchange_delete(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t exchange, amqp_boolean_t if_unused)
|
|
|
-{
|
|
|
- amqp_exchange_delete_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.exchange = exchange;
|
|
|
- req.if_unused = if_unused;
|
|
|
- req.nowait = 0;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_EXCHANGE_DELETE_METHOD, AMQP_EXCHANGE_DELETE_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_exchange_bind_ok_t * AMQP_CALL amqp_exchange_bind(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t destination, amqp_bytes_t source, amqp_bytes_t routing_key, amqp_table_t arguments)
|
|
|
-{
|
|
|
- amqp_exchange_bind_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.destination = destination;
|
|
|
- req.source = source;
|
|
|
- req.routing_key = routing_key;
|
|
|
- req.nowait = 0;
|
|
|
- req.arguments = arguments;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_EXCHANGE_BIND_METHOD, AMQP_EXCHANGE_BIND_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_exchange_unbind_ok_t * AMQP_CALL amqp_exchange_unbind(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t destination, amqp_bytes_t source, amqp_bytes_t routing_key, amqp_table_t arguments)
|
|
|
-{
|
|
|
- amqp_exchange_unbind_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.destination = destination;
|
|
|
- req.source = source;
|
|
|
- req.routing_key = routing_key;
|
|
|
- req.nowait = 0;
|
|
|
- req.arguments = arguments;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_EXCHANGE_UNBIND_METHOD, AMQP_EXCHANGE_UNBIND_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_queue_declare_ok_t * AMQP_CALL amqp_queue_declare(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_boolean_t passive, amqp_boolean_t durable, amqp_boolean_t exclusive, amqp_boolean_t auto_delete, amqp_table_t arguments)
|
|
|
-{
|
|
|
- amqp_queue_declare_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.queue = queue;
|
|
|
- req.passive = passive;
|
|
|
- req.durable = durable;
|
|
|
- req.exclusive = exclusive;
|
|
|
- req.auto_delete = auto_delete;
|
|
|
- req.nowait = 0;
|
|
|
- req.arguments = arguments;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_DECLARE_METHOD, AMQP_QUEUE_DECLARE_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_queue_bind_ok_t * AMQP_CALL amqp_queue_bind(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_bytes_t exchange, amqp_bytes_t routing_key, amqp_table_t arguments)
|
|
|
-{
|
|
|
- amqp_queue_bind_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.queue = queue;
|
|
|
- req.exchange = exchange;
|
|
|
- req.routing_key = routing_key;
|
|
|
- req.nowait = 0;
|
|
|
- req.arguments = arguments;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_BIND_METHOD, AMQP_QUEUE_BIND_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_queue_purge_ok_t * AMQP_CALL amqp_queue_purge(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue)
|
|
|
-{
|
|
|
- amqp_queue_purge_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.queue = queue;
|
|
|
- req.nowait = 0;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_PURGE_METHOD, AMQP_QUEUE_PURGE_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_queue_delete_ok_t * AMQP_CALL amqp_queue_delete(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_boolean_t if_unused, amqp_boolean_t if_empty)
|
|
|
-{
|
|
|
- amqp_queue_delete_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.queue = queue;
|
|
|
- req.if_unused = if_unused;
|
|
|
- req.if_empty = if_empty;
|
|
|
- req.nowait = 0;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_DELETE_METHOD, AMQP_QUEUE_DELETE_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_queue_unbind_ok_t * AMQP_CALL amqp_queue_unbind(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_bytes_t exchange, amqp_bytes_t routing_key, amqp_table_t arguments)
|
|
|
-{
|
|
|
- amqp_queue_unbind_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.queue = queue;
|
|
|
- req.exchange = exchange;
|
|
|
- req.routing_key = routing_key;
|
|
|
- req.arguments = arguments;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_UNBIND_METHOD, AMQP_QUEUE_UNBIND_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_basic_qos_ok_t * AMQP_CALL amqp_basic_qos(amqp_connection_state_t state, amqp_channel_t channel, uint32_t prefetch_size, uint16_t prefetch_count, amqp_boolean_t global)
|
|
|
-{
|
|
|
- amqp_basic_qos_t req;
|
|
|
- req.prefetch_size = prefetch_size;
|
|
|
- req.prefetch_count = prefetch_count;
|
|
|
- req.global = global;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_QOS_METHOD, AMQP_BASIC_QOS_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_basic_consume_ok_t * AMQP_CALL amqp_basic_consume(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_bytes_t consumer_tag, amqp_boolean_t no_local, amqp_boolean_t no_ack, amqp_boolean_t exclusive, amqp_table_t arguments)
|
|
|
-{
|
|
|
- amqp_basic_consume_t req;
|
|
|
- req.ticket = 0;
|
|
|
- req.queue = queue;
|
|
|
- req.consumer_tag = consumer_tag;
|
|
|
- req.no_local = no_local;
|
|
|
- req.no_ack = no_ack;
|
|
|
- req.exclusive = exclusive;
|
|
|
- req.nowait = 0;
|
|
|
- req.arguments = arguments;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_CONSUME_METHOD, AMQP_BASIC_CONSUME_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_basic_cancel_ok_t * AMQP_CALL amqp_basic_cancel(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t consumer_tag)
|
|
|
-{
|
|
|
- amqp_basic_cancel_t req;
|
|
|
- req.consumer_tag = consumer_tag;
|
|
|
- req.nowait = 0;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_CANCEL_METHOD, AMQP_BASIC_CANCEL_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_basic_recover_ok_t * AMQP_CALL amqp_basic_recover(amqp_connection_state_t state, amqp_channel_t channel, amqp_boolean_t requeue)
|
|
|
-{
|
|
|
- amqp_basic_recover_t req;
|
|
|
- req.requeue = requeue;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_RECOVER_METHOD, AMQP_BASIC_RECOVER_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_tx_select_ok_t * AMQP_CALL amqp_tx_select(amqp_connection_state_t state, amqp_channel_t channel)
|
|
|
-{
|
|
|
- amqp_tx_select_t req;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_TX_SELECT_METHOD, AMQP_TX_SELECT_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_tx_commit_ok_t * AMQP_CALL amqp_tx_commit(amqp_connection_state_t state, amqp_channel_t channel)
|
|
|
-{
|
|
|
- amqp_tx_commit_t req;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_TX_COMMIT_METHOD, AMQP_TX_COMMIT_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_tx_rollback_ok_t * AMQP_CALL amqp_tx_rollback(amqp_connection_state_t state, amqp_channel_t channel)
|
|
|
-{
|
|
|
- amqp_tx_rollback_t req;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_TX_ROLLBACK_METHOD, AMQP_TX_ROLLBACK_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-AMQP_PUBLIC_FUNCTION amqp_confirm_select_ok_t * AMQP_CALL amqp_confirm_select(amqp_connection_state_t state, amqp_channel_t channel)
|
|
|
-{
|
|
|
- amqp_confirm_select_t req;
|
|
|
- req.nowait = 0;
|
|
|
-
|
|
|
- return amqp_simple_rpc_decoded(state, channel, AMQP_CONFIRM_SELECT_METHOD, AMQP_CONFIRM_SELECT_OK_METHOD, &req);
|
|
|
-}
|
|
|
-
|