Mark Radbourne / Mbed 2 deprecated iothub_client_sample_amqp

Demo using MBED TLS

Dependencies:   EthernetInterface NTPClient iothub_amqp_transport iothub_client mbed-rtos mbed

Fork of iothub_client_sample_amqp by Azure IoT

azure_uamqp_c/frame_codec.c@58:f50b97b08851, 2017-01-05 (annotated)

Committer:
markrad
Date:
Thu Jan 05 00:20:03 2017 +0000
Revision:
58:f50b97b08851
Sample using MBED TLS

Who changed what in which revision?

UserRevisionLine numberNew contents of line
markrad 58:f50b97b08851 1 // Copyright (c) Microsoft. All rights reserved.
markrad 58:f50b97b08851 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
markrad 58:f50b97b08851 3
markrad 58:f50b97b08851 4 #include <stdlib.h>
markrad 58:f50b97b08851 5 #ifdef _CRTDBG_MAP_ALLOC
markrad 58:f50b97b08851 6 #include <crtdbg.h>
markrad 58:f50b97b08851 7 #endif
markrad 58:f50b97b08851 8 #include <stdint.h>
markrad 58:f50b97b08851 9 #include <stdbool.h>
markrad 58:f50b97b08851 10 #include <string.h>
markrad 58:f50b97b08851 11 #include "azure_c_shared_utility/xlogging.h"
markrad 58:f50b97b08851 12 #include "azure_c_shared_utility/xio.h"
markrad 58:f50b97b08851 13 #include "azure_c_shared_utility/singlylinkedlist.h"
markrad 58:f50b97b08851 14 #include "azure_uamqp_c/frame_codec.h"
markrad 58:f50b97b08851 15 #include "azure_uamqp_c/amqpvalue.h"
markrad 58:f50b97b08851 16 #include "azure_uamqp_c/amqpalloc.h"
markrad 58:f50b97b08851 17
markrad 58:f50b97b08851 18 #define FRAME_HEADER_SIZE 8
markrad 58:f50b97b08851 19 #define MAX_TYPE_SPECIFIC_SIZE ((255 * 4) - 6)
markrad 58:f50b97b08851 20
markrad 58:f50b97b08851 21 typedef enum RECEIVE_FRAME_STATE_TAG
markrad 58:f50b97b08851 22 {
markrad 58:f50b97b08851 23 RECEIVE_FRAME_STATE_FRAME_SIZE,
markrad 58:f50b97b08851 24 RECEIVE_FRAME_STATE_DOFF,
markrad 58:f50b97b08851 25 RECEIVE_FRAME_STATE_FRAME_TYPE,
markrad 58:f50b97b08851 26 RECEIVE_FRAME_STATE_TYPE_SPECIFIC,
markrad 58:f50b97b08851 27 RECEIVE_FRAME_STATE_FRAME_BODY,
markrad 58:f50b97b08851 28 RECEIVE_FRAME_STATE_ERROR
markrad 58:f50b97b08851 29 } RECEIVE_FRAME_STATE;
markrad 58:f50b97b08851 30
markrad 58:f50b97b08851 31 typedef enum ENCODE_FRAME_STATE_TAG
markrad 58:f50b97b08851 32 {
markrad 58:f50b97b08851 33 ENCODE_FRAME_STATE_IDLE,
markrad 58:f50b97b08851 34 ENCODE_FRAME_STATE_ERROR
markrad 58:f50b97b08851 35 } ENCODE_FRAME_STATE;
markrad 58:f50b97b08851 36
markrad 58:f50b97b08851 37 typedef struct SUBSCRIPTION_TAG
markrad 58:f50b97b08851 38 {
markrad 58:f50b97b08851 39 uint8_t frame_type;
markrad 58:f50b97b08851 40 ON_FRAME_RECEIVED on_frame_received;
markrad 58:f50b97b08851 41 void* callback_context;
markrad 58:f50b97b08851 42 } SUBSCRIPTION;
markrad 58:f50b97b08851 43
markrad 58:f50b97b08851 44 typedef struct FRAME_CODEC_INSTANCE_TAG
markrad 58:f50b97b08851 45 {
markrad 58:f50b97b08851 46 /* subscriptions */
markrad 58:f50b97b08851 47 SINGLYLINKEDLIST_HANDLE subscription_list;
markrad 58:f50b97b08851 48
markrad 58:f50b97b08851 49 /* decode frame */
markrad 58:f50b97b08851 50 RECEIVE_FRAME_STATE receive_frame_state;
markrad 58:f50b97b08851 51 size_t receive_frame_pos;
markrad 58:f50b97b08851 52 uint32_t receive_frame_size;
markrad 58:f50b97b08851 53 uint32_t type_specific_size;
markrad 58:f50b97b08851 54 uint8_t receive_frame_doff;
markrad 58:f50b97b08851 55 uint8_t receive_frame_type;
markrad 58:f50b97b08851 56 SUBSCRIPTION* receive_frame_subscription;
markrad 58:f50b97b08851 57 unsigned char* receive_frame_bytes;
markrad 58:f50b97b08851 58 ON_FRAME_CODEC_ERROR on_frame_codec_error;
markrad 58:f50b97b08851 59 void* on_frame_codec_error_callback_context;
markrad 58:f50b97b08851 60
markrad 58:f50b97b08851 61 /* encode frame */
markrad 58:f50b97b08851 62 ENCODE_FRAME_STATE encode_frame_state;
markrad 58:f50b97b08851 63
markrad 58:f50b97b08851 64 /* configuration */
markrad 58:f50b97b08851 65 uint32_t max_frame_size;
markrad 58:f50b97b08851 66 } FRAME_CODEC_INSTANCE;
markrad 58:f50b97b08851 67
markrad 58:f50b97b08851 68 static bool find_subscription_by_frame_type(LIST_ITEM_HANDLE list_item, const void* match_context)
markrad 58:f50b97b08851 69 {
markrad 58:f50b97b08851 70 bool result;
markrad 58:f50b97b08851 71 SUBSCRIPTION* subscription = (SUBSCRIPTION*)singlylinkedlist_item_get_value(list_item);
markrad 58:f50b97b08851 72
markrad 58:f50b97b08851 73 if (subscription == NULL)
markrad 58:f50b97b08851 74 {
markrad 58:f50b97b08851 75 result = false;
markrad 58:f50b97b08851 76 }
markrad 58:f50b97b08851 77 else
markrad 58:f50b97b08851 78 {
markrad 58:f50b97b08851 79 result = subscription->frame_type == *((uint8_t*)match_context) ? true : false;
markrad 58:f50b97b08851 80 }
markrad 58:f50b97b08851 81
markrad 58:f50b97b08851 82 return result;
markrad 58:f50b97b08851 83 }
markrad 58:f50b97b08851 84
markrad 58:f50b97b08851 85 FRAME_CODEC_HANDLE frame_codec_create(ON_FRAME_CODEC_ERROR on_frame_codec_error, void* callback_context)
markrad 58:f50b97b08851 86 {
markrad 58:f50b97b08851 87 FRAME_CODEC_INSTANCE* result;
markrad 58:f50b97b08851 88
markrad 58:f50b97b08851 89 /* Codes_SRS_FRAME_CODEC_01_020: [If the on_frame_codec_error argument is NULL, frame_codec_create shall return NULL.] */
markrad 58:f50b97b08851 90 /* Codes_SRS_FRAME_CODEC_01_104: [The callback_context shall be allowed to be NULL.] */
markrad 58:f50b97b08851 91 if (on_frame_codec_error == NULL)
markrad 58:f50b97b08851 92 {
markrad 58:f50b97b08851 93 result = NULL;
markrad 58:f50b97b08851 94 }
markrad 58:f50b97b08851 95 else
markrad 58:f50b97b08851 96 {
markrad 58:f50b97b08851 97 result = amqpalloc_malloc(sizeof(FRAME_CODEC_INSTANCE));
markrad 58:f50b97b08851 98 /* Codes_SRS_FRAME_CODEC_01_022: [If allocating memory for the frame_codec instance fails, frame_codec_create shall return NULL.] */
markrad 58:f50b97b08851 99 if (result != NULL)
markrad 58:f50b97b08851 100 {
markrad 58:f50b97b08851 101 /* Codes_SRS_FRAME_CODEC_01_021: [frame_codec_create shall create a new instance of frame_codec and return a non-NULL handle to it on success.] */
markrad 58:f50b97b08851 102 result->encode_frame_state = ENCODE_FRAME_STATE_IDLE;
markrad 58:f50b97b08851 103 result->receive_frame_state = RECEIVE_FRAME_STATE_FRAME_SIZE;
markrad 58:f50b97b08851 104 result->on_frame_codec_error = on_frame_codec_error;
markrad 58:f50b97b08851 105 result->on_frame_codec_error_callback_context = callback_context;
markrad 58:f50b97b08851 106 result->receive_frame_pos = 0;
markrad 58:f50b97b08851 107 result->receive_frame_size = 0;
markrad 58:f50b97b08851 108 result->receive_frame_bytes = NULL;
markrad 58:f50b97b08851 109 result->subscription_list = singlylinkedlist_create();
markrad 58:f50b97b08851 110
markrad 58:f50b97b08851 111 /* Codes_SRS_FRAME_CODEC_01_082: [The initial max_frame_size_shall be 512.] */
markrad 58:f50b97b08851 112 result->max_frame_size = 512;
markrad 58:f50b97b08851 113 }
markrad 58:f50b97b08851 114 }
markrad 58:f50b97b08851 115
markrad 58:f50b97b08851 116 return result;
markrad 58:f50b97b08851 117 }
markrad 58:f50b97b08851 118
markrad 58:f50b97b08851 119 void frame_codec_destroy(FRAME_CODEC_HANDLE frame_codec)
markrad 58:f50b97b08851 120 {
markrad 58:f50b97b08851 121 /* Codes_SRS_FRAME_CODEC_01_024: [If frame_codec is NULL, frame_codec_destroy shall do nothing.] */
markrad 58:f50b97b08851 122 if (frame_codec != NULL)
markrad 58:f50b97b08851 123 {
markrad 58:f50b97b08851 124 FRAME_CODEC_INSTANCE* frame_codec_data = (FRAME_CODEC_INSTANCE*)frame_codec;
markrad 58:f50b97b08851 125
markrad 58:f50b97b08851 126 singlylinkedlist_destroy(frame_codec_data->subscription_list);
markrad 58:f50b97b08851 127 if (frame_codec_data->receive_frame_bytes != NULL)
markrad 58:f50b97b08851 128 {
markrad 58:f50b97b08851 129 amqpalloc_free(frame_codec_data->receive_frame_bytes);
markrad 58:f50b97b08851 130 }
markrad 58:f50b97b08851 131
markrad 58:f50b97b08851 132 /* Codes_SRS_FRAME_CODEC_01_023: [frame_codec_destroy shall free all resources associated with a frame_codec instance.] */
markrad 58:f50b97b08851 133 amqpalloc_free(frame_codec);
markrad 58:f50b97b08851 134 }
markrad 58:f50b97b08851 135 }
markrad 58:f50b97b08851 136
markrad 58:f50b97b08851 137 int frame_codec_set_max_frame_size(FRAME_CODEC_HANDLE frame_codec, uint32_t max_frame_size)
markrad 58:f50b97b08851 138 {
markrad 58:f50b97b08851 139 int result;
markrad 58:f50b97b08851 140 FRAME_CODEC_INSTANCE* frame_codec_data = (FRAME_CODEC_INSTANCE*)frame_codec;
markrad 58:f50b97b08851 141
markrad 58:f50b97b08851 142 /* Codes_SRS_FRAME_CODEC_01_077: [If frame_codec is NULL, frame_codec_set_max_frame_size shall return a non-zero value.] */
markrad 58:f50b97b08851 143 if ((frame_codec == NULL) ||
markrad 58:f50b97b08851 144 /* Codes_SRS_FRAME_CODEC_01_078: [If max_frame_size is invalid according to the AMQP standard, frame_codec_set_max_frame_size shall return a non-zero value.] */
markrad 58:f50b97b08851 145 (max_frame_size < FRAME_HEADER_SIZE) ||
markrad 58:f50b97b08851 146 /* Codes_SRS_FRAME_CODEC_01_081: [If a frame being decoded already has a size bigger than the max_frame_size argument then frame_codec_set_max_frame_size shall return a non-zero value and the previous frame size shall be kept.] */
markrad 58:f50b97b08851 147 ((max_frame_size < frame_codec_data->receive_frame_size) && (frame_codec_data->receive_frame_state != RECEIVE_FRAME_STATE_FRAME_SIZE)) ||
markrad 58:f50b97b08851 148 /* Codes_SRS_FRAME_CODEC_01_097: [Setting a frame size on a frame_codec that had a decode error shall fail.] */
markrad 58:f50b97b08851 149 (frame_codec_data->receive_frame_state == RECEIVE_FRAME_STATE_ERROR) ||
markrad 58:f50b97b08851 150 /* Codes_SRS_FRAME_CODEC_01_098: [Setting a frame size on a frame_codec that had an encode error shall fail.] */
markrad 58:f50b97b08851 151 (frame_codec_data->encode_frame_state == ENCODE_FRAME_STATE_ERROR))
markrad 58:f50b97b08851 152 {
markrad 58:f50b97b08851 153 result = __LINE__;
markrad 58:f50b97b08851 154 }
markrad 58:f50b97b08851 155 else
markrad 58:f50b97b08851 156 {
markrad 58:f50b97b08851 157 /* Codes_SRS_FRAME_CODEC_01_075: [frame_codec_set_max_frame_size shall set the maximum frame size for a frame_codec.] */
markrad 58:f50b97b08851 158 /* Codes_SRS_FRAME_CODEC_01_079: [The new frame size shall take effect immediately, even for a frame that is being decoded at the time of the call.] */
markrad 58:f50b97b08851 159 frame_codec_data->max_frame_size = max_frame_size;
markrad 58:f50b97b08851 160
markrad 58:f50b97b08851 161 /* Codes_SRS_FRAME_CODEC_01_076: [On success, frame_codec_set_max_frame_size shall return 0.] */
markrad 58:f50b97b08851 162 result = 0;
markrad 58:f50b97b08851 163 }
markrad 58:f50b97b08851 164 return result;
markrad 58:f50b97b08851 165 }
markrad 58:f50b97b08851 166
markrad 58:f50b97b08851 167 /* Codes_SRS_FRAME_CODEC_01_001: [Frames are divided into three distinct areas: a fixed width frame header, a variable width extended header, and a variable width frame body.] */
markrad 58:f50b97b08851 168 /* Codes_SRS_FRAME_CODEC_01_002: [frame header The frame header is a fixed size (8 byte) structure that precedes each frame.] */
markrad 58:f50b97b08851 169 /* Codes_SRS_FRAME_CODEC_01_003: [The frame header includes mandatory information necessary to parse the rest of the frame including size and type information.] */
markrad 58:f50b97b08851 170 /* Codes_SRS_FRAME_CODEC_01_004: [extended header The extended header is a variable width area preceding the frame body.] */
markrad 58:f50b97b08851 171 /* Codes_SRS_FRAME_CODEC_01_007: [frame body The frame body is a variable width sequence of bytes the format of which depends on the frame type.] */
markrad 58:f50b97b08851 172 /* Codes_SRS_FRAME_CODEC_01_028: [The sequence of bytes shall be decoded according to the AMQP ISO.] */
markrad 58:f50b97b08851 173 /* Codes_SRS_FRAME_CODEC_01_029: [The sequence of bytes does not have to be a complete frame, frame_codec shall be responsible for maintaining decoding state between frame_codec_receive_bytes calls.] */
markrad 58:f50b97b08851 174 int frame_codec_receive_bytes(FRAME_CODEC_HANDLE frame_codec, const unsigned char* buffer, size_t size)
markrad 58:f50b97b08851 175 {
markrad 58:f50b97b08851 176 int result = __LINE__;
markrad 58:f50b97b08851 177 FRAME_CODEC_INSTANCE* frame_codec_data = (FRAME_CODEC_INSTANCE*)frame_codec;
markrad 58:f50b97b08851 178
markrad 58:f50b97b08851 179 /* Codes_SRS_FRAME_CODEC_01_026: [If frame_codec or buffer are NULL, frame_codec_receive_bytes shall return a non-zero value.] */
markrad 58:f50b97b08851 180 if ((frame_codec == NULL) ||
markrad 58:f50b97b08851 181 (buffer == NULL) ||
markrad 58:f50b97b08851 182 /* Codes_SRS_FRAME_CODEC_01_027: [If size is zero, frame_codec_receive_bytes shall return a non-zero value.] */
markrad 58:f50b97b08851 183 (size == 0))
markrad 58:f50b97b08851 184 {
markrad 58:f50b97b08851 185 result = __LINE__;
markrad 58:f50b97b08851 186 }
markrad 58:f50b97b08851 187 else
markrad 58:f50b97b08851 188 {
markrad 58:f50b97b08851 189 while (size > 0)
markrad 58:f50b97b08851 190 {
markrad 58:f50b97b08851 191 switch (frame_codec_data->receive_frame_state)
markrad 58:f50b97b08851 192 {
markrad 58:f50b97b08851 193 default:
markrad 58:f50b97b08851 194 case RECEIVE_FRAME_STATE_ERROR:
markrad 58:f50b97b08851 195 /* Codes_SRS_FRAME_CODEC_01_074: [If a decoding error is detected, any subsequent calls on frame_codec_data_receive_bytes shall fail.] */
markrad 58:f50b97b08851 196 result = __LINE__;
markrad 58:f50b97b08851 197 size = 0;
markrad 58:f50b97b08851 198 break;
markrad 58:f50b97b08851 199
markrad 58:f50b97b08851 200 /* Codes_SRS_FRAME_CODEC_01_008: [SIZE Bytes 0-3 of the frame header contain the frame size.] */
markrad 58:f50b97b08851 201 case RECEIVE_FRAME_STATE_FRAME_SIZE:
markrad 58:f50b97b08851 202 /* Codes_SRS_FRAME_CODEC_01_009: [This is an unsigned 32-bit integer that MUST contain the total frame size of the frame header, extended header, and frame body.] */
markrad 58:f50b97b08851 203 frame_codec_data->receive_frame_size += buffer[0] << (24 - frame_codec_data->receive_frame_pos * 8);
markrad 58:f50b97b08851 204 buffer++;
markrad 58:f50b97b08851 205 size--;
markrad 58:f50b97b08851 206 frame_codec_data->receive_frame_pos++;
markrad 58:f50b97b08851 207
markrad 58:f50b97b08851 208 if (frame_codec_data->receive_frame_pos == 4)
markrad 58:f50b97b08851 209 {
markrad 58:f50b97b08851 210 /* Codes_SRS_FRAME_CODEC_01_010: [The frame is malformed if the size is less than the size of the frame header (8 bytes).] */
markrad 58:f50b97b08851 211 if ((frame_codec_data->receive_frame_size < FRAME_HEADER_SIZE) ||
markrad 58:f50b97b08851 212 /* Codes_SRS_FRAME_CODEC_01_096: [If a frame bigger than the current max frame size is received, frame_codec_receive_bytes shall fail and return a non-zero value.] */
markrad 58:f50b97b08851 213 (frame_codec_data->receive_frame_size > frame_codec_data->max_frame_size))
markrad 58:f50b97b08851 214 {
markrad 58:f50b97b08851 215 /* Codes_SRS_FRAME_CODEC_01_074: [If a decoding error is detected, any subsequent calls on frame_codec_data_receive_bytes shall fail.] */
markrad 58:f50b97b08851 216 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_ERROR;
markrad 58:f50b97b08851 217 /* Codes_SRS_FRAME_CODEC_01_103: [Upon any decode error, if an error callback has been passed to frame_codec_create, then the error callback shall be called with the context argument being the on_frame_codec_error_callback_context argument passed to frame_codec_create.] */
markrad 58:f50b97b08851 218 frame_codec_data->on_frame_codec_error(frame_codec_data->on_frame_codec_error_callback_context);
markrad 58:f50b97b08851 219
markrad 58:f50b97b08851 220 result = __LINE__;
markrad 58:f50b97b08851 221 }
markrad 58:f50b97b08851 222 else
markrad 58:f50b97b08851 223 {
markrad 58:f50b97b08851 224 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_DOFF;
markrad 58:f50b97b08851 225 result = 0;
markrad 58:f50b97b08851 226 }
markrad 58:f50b97b08851 227 }
markrad 58:f50b97b08851 228 else
markrad 58:f50b97b08851 229 {
markrad 58:f50b97b08851 230 result = 0;
markrad 58:f50b97b08851 231 }
markrad 58:f50b97b08851 232
markrad 58:f50b97b08851 233 break;
markrad 58:f50b97b08851 234
markrad 58:f50b97b08851 235 case RECEIVE_FRAME_STATE_DOFF:
markrad 58:f50b97b08851 236 /* Codes_SRS_FRAME_CODEC_01_011: [DOFF Byte 4 of the frame header is the data offset.] */
markrad 58:f50b97b08851 237 /* Codes_SRS_FRAME_CODEC_01_013: [The value of the data offset is an unsigned, 8-bit integer specifying a count of 4-byte words.] */
markrad 58:f50b97b08851 238 /* Codes_SRS_FRAME_CODEC_01_012: [This gives the position of the body within the frame.] */
markrad 58:f50b97b08851 239 frame_codec_data->receive_frame_doff = buffer[0];
markrad 58:f50b97b08851 240 buffer++;
markrad 58:f50b97b08851 241 size--;
markrad 58:f50b97b08851 242
markrad 58:f50b97b08851 243 /* Codes_SRS_FRAME_CODEC_01_014: [Due to the mandatory 8-byte frame header, the frame is malformed if the value is less than 2.] */
markrad 58:f50b97b08851 244 if (frame_codec_data->receive_frame_doff < 2)
markrad 58:f50b97b08851 245 {
markrad 58:f50b97b08851 246 /* Codes_SRS_FRAME_CODEC_01_074: [If a decoding error is detected, any subsequent calls on frame_codec_data_receive_bytes shall fail.] */
markrad 58:f50b97b08851 247 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_ERROR;
markrad 58:f50b97b08851 248
markrad 58:f50b97b08851 249 /* Codes_SRS_FRAME_CODEC_01_103: [Upon any decode error, if an error callback has been passed to frame_codec_create, then the error callback shall be called with the context argument being the on_frame_codec_error_callback_context argument passed to frame_codec_create.] */
markrad 58:f50b97b08851 250 frame_codec_data->on_frame_codec_error(frame_codec_data->on_frame_codec_error_callback_context);
markrad 58:f50b97b08851 251
markrad 58:f50b97b08851 252 result = __LINE__;
markrad 58:f50b97b08851 253 }
markrad 58:f50b97b08851 254 else
markrad 58:f50b97b08851 255 {
markrad 58:f50b97b08851 256 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_FRAME_TYPE;
markrad 58:f50b97b08851 257 result = 0;
markrad 58:f50b97b08851 258 }
markrad 58:f50b97b08851 259
markrad 58:f50b97b08851 260 break;
markrad 58:f50b97b08851 261
markrad 58:f50b97b08851 262 case RECEIVE_FRAME_STATE_FRAME_TYPE:
markrad 58:f50b97b08851 263 {
markrad 58:f50b97b08851 264 LIST_ITEM_HANDLE item_handle;
markrad 58:f50b97b08851 265 frame_codec_data->type_specific_size = (frame_codec_data->receive_frame_doff * 4) - 6;
markrad 58:f50b97b08851 266
markrad 58:f50b97b08851 267 /* Codes_SRS_FRAME_CODEC_01_015: [TYPE Byte 5 of the frame header is a type code.] */
markrad 58:f50b97b08851 268 frame_codec_data->receive_frame_type = buffer[0];
markrad 58:f50b97b08851 269 buffer++;
markrad 58:f50b97b08851 270 size--;
markrad 58:f50b97b08851 271
markrad 58:f50b97b08851 272 /* Codes_SRS_FRAME_CODEC_01_035: [After successfully registering a callback for a certain frame type, when subsequently that frame type is received the callbacks shall be invoked, passing to it the received frame and the callback_context value.] */
markrad 58:f50b97b08851 273 item_handle = singlylinkedlist_find(frame_codec_data->subscription_list, find_subscription_by_frame_type, &frame_codec_data->receive_frame_type);
markrad 58:f50b97b08851 274 if (item_handle == NULL)
markrad 58:f50b97b08851 275 {
markrad 58:f50b97b08851 276 frame_codec_data->receive_frame_subscription = NULL;
markrad 58:f50b97b08851 277 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_TYPE_SPECIFIC;
markrad 58:f50b97b08851 278 result = 0;
markrad 58:f50b97b08851 279 break;
markrad 58:f50b97b08851 280 }
markrad 58:f50b97b08851 281 else
markrad 58:f50b97b08851 282 {
markrad 58:f50b97b08851 283 frame_codec_data->receive_frame_subscription = (SUBSCRIPTION*)singlylinkedlist_item_get_value(item_handle);
markrad 58:f50b97b08851 284 if (frame_codec_data->receive_frame_subscription == NULL)
markrad 58:f50b97b08851 285 {
markrad 58:f50b97b08851 286 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_TYPE_SPECIFIC;
markrad 58:f50b97b08851 287 result = 0;
markrad 58:f50b97b08851 288 break;
markrad 58:f50b97b08851 289 }
markrad 58:f50b97b08851 290 else
markrad 58:f50b97b08851 291 {
markrad 58:f50b97b08851 292 frame_codec_data->receive_frame_pos = 0;
markrad 58:f50b97b08851 293
markrad 58:f50b97b08851 294 /* Codes_SRS_FRAME_CODEC_01_102: [frame_codec_receive_bytes shall allocate memory to hold the frame_body bytes.] */
markrad 58:f50b97b08851 295 frame_codec_data->receive_frame_bytes = (unsigned char*)amqpalloc_malloc(frame_codec_data->receive_frame_size - 6);
markrad 58:f50b97b08851 296 if (frame_codec_data->receive_frame_bytes == NULL)
markrad 58:f50b97b08851 297 {
markrad 58:f50b97b08851 298 /* Codes_SRS_FRAME_CODEC_01_101: [If the memory for the frame_body bytes cannot be allocated, frame_codec_receive_bytes shall fail and return a non-zero value.] */
markrad 58:f50b97b08851 299 /* Codes_SRS_FRAME_CODEC_01_030: [If a decoding error occurs, frame_codec_data_receive_bytes shall return a non-zero value.] */
markrad 58:f50b97b08851 300 /* Codes_SRS_FRAME_CODEC_01_074: [If a decoding error is detected, any subsequent calls on frame_codec_data_receive_bytes shall fail.] */
markrad 58:f50b97b08851 301 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_ERROR;
markrad 58:f50b97b08851 302
markrad 58:f50b97b08851 303 /* Codes_SRS_FRAME_CODEC_01_103: [Upon any decode error, if an error callback has been passed to frame_codec_create, then the error callback shall be called with the context argument being the on_frame_codec_error_callback_context argument passed to frame_codec_create.] */
markrad 58:f50b97b08851 304 frame_codec_data->on_frame_codec_error(frame_codec_data->on_frame_codec_error_callback_context);
markrad 58:f50b97b08851 305
markrad 58:f50b97b08851 306 result = __LINE__;
markrad 58:f50b97b08851 307 break;
markrad 58:f50b97b08851 308 }
markrad 58:f50b97b08851 309 else
markrad 58:f50b97b08851 310 {
markrad 58:f50b97b08851 311 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_TYPE_SPECIFIC;
markrad 58:f50b97b08851 312 result = 0;
markrad 58:f50b97b08851 313 break;
markrad 58:f50b97b08851 314 }
markrad 58:f50b97b08851 315 }
markrad 58:f50b97b08851 316 }
markrad 58:f50b97b08851 317 }
markrad 58:f50b97b08851 318
markrad 58:f50b97b08851 319 case RECEIVE_FRAME_STATE_TYPE_SPECIFIC:
markrad 58:f50b97b08851 320 {
markrad 58:f50b97b08851 321 size_t to_copy = frame_codec_data->type_specific_size - frame_codec_data->receive_frame_pos;
markrad 58:f50b97b08851 322 if (to_copy > size)
markrad 58:f50b97b08851 323 {
markrad 58:f50b97b08851 324 to_copy = size;
markrad 58:f50b97b08851 325 }
markrad 58:f50b97b08851 326
markrad 58:f50b97b08851 327 if (frame_codec_data->receive_frame_subscription != NULL)
markrad 58:f50b97b08851 328 {
markrad 58:f50b97b08851 329 (void)memcpy(&frame_codec_data->receive_frame_bytes[frame_codec_data->receive_frame_pos], buffer, to_copy);
markrad 58:f50b97b08851 330 frame_codec_data->receive_frame_pos += to_copy;
markrad 58:f50b97b08851 331 buffer += to_copy;
markrad 58:f50b97b08851 332 size -= to_copy;
markrad 58:f50b97b08851 333 }
markrad 58:f50b97b08851 334 else
markrad 58:f50b97b08851 335 {
markrad 58:f50b97b08851 336 frame_codec_data->receive_frame_pos += to_copy;
markrad 58:f50b97b08851 337 buffer += to_copy;
markrad 58:f50b97b08851 338 size -= to_copy;
markrad 58:f50b97b08851 339 }
markrad 58:f50b97b08851 340
markrad 58:f50b97b08851 341 if (frame_codec_data->receive_frame_pos == frame_codec_data->type_specific_size)
markrad 58:f50b97b08851 342 {
markrad 58:f50b97b08851 343 if (frame_codec_data->receive_frame_size == FRAME_HEADER_SIZE)
markrad 58:f50b97b08851 344 {
markrad 58:f50b97b08851 345 if (frame_codec_data->receive_frame_subscription != NULL)
markrad 58:f50b97b08851 346 {
markrad 58:f50b97b08851 347 /* Codes_SRS_FRAME_CODEC_01_031: [When a complete frame is successfully decoded it shall be indicated to the upper layer by invoking the on_frame_received passed to frame_codec_subscribe.] */
markrad 58:f50b97b08851 348 /* Codes_SRS_FRAME_CODEC_01_032: [Besides passing the frame information, the callback_context value passed to frame_codec_data_subscribe shall be passed to the on_frame_received function.] */
markrad 58:f50b97b08851 349 /* Codes_SRS_FRAME_CODEC_01_005: [This is an extension point defined for future expansion.] */
markrad 58:f50b97b08851 350 /* Codes_SRS_FRAME_CODEC_01_006: [The treatment of this area depends on the frame type.] */
markrad 58:f50b97b08851 351 /* Codes_SRS_FRAME_CODEC_01_100: [If the frame body size is 0, the frame_body pointer passed to on_frame_received shall be NULL.] */
markrad 58:f50b97b08851 352 frame_codec_data->receive_frame_subscription->on_frame_received(frame_codec_data->receive_frame_subscription->callback_context, frame_codec_data->receive_frame_bytes, frame_codec_data->type_specific_size, NULL, 0);
markrad 58:f50b97b08851 353 amqpalloc_free(frame_codec_data->receive_frame_bytes);
markrad 58:f50b97b08851 354 frame_codec_data->receive_frame_bytes = NULL;
markrad 58:f50b97b08851 355 }
markrad 58:f50b97b08851 356
markrad 58:f50b97b08851 357 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_FRAME_SIZE;
markrad 58:f50b97b08851 358 frame_codec_data->receive_frame_size = 0;
markrad 58:f50b97b08851 359 }
markrad 58:f50b97b08851 360 else
markrad 58:f50b97b08851 361 {
markrad 58:f50b97b08851 362 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_FRAME_BODY;
markrad 58:f50b97b08851 363 }
markrad 58:f50b97b08851 364
markrad 58:f50b97b08851 365 frame_codec_data->receive_frame_pos = 0;
markrad 58:f50b97b08851 366 }
markrad 58:f50b97b08851 367
markrad 58:f50b97b08851 368 result = 0;
markrad 58:f50b97b08851 369 break;
markrad 58:f50b97b08851 370 }
markrad 58:f50b97b08851 371
markrad 58:f50b97b08851 372 case RECEIVE_FRAME_STATE_FRAME_BODY:
markrad 58:f50b97b08851 373 {
markrad 58:f50b97b08851 374 uint32_t frame_body_size = frame_codec_data->receive_frame_size - (frame_codec_data->receive_frame_doff * 4);
markrad 58:f50b97b08851 375 size_t to_copy = frame_body_size - frame_codec_data->receive_frame_pos;
markrad 58:f50b97b08851 376
markrad 58:f50b97b08851 377 if (to_copy > size)
markrad 58:f50b97b08851 378 {
markrad 58:f50b97b08851 379 to_copy = size;
markrad 58:f50b97b08851 380 }
markrad 58:f50b97b08851 381
markrad 58:f50b97b08851 382 (void)memcpy(frame_codec_data->receive_frame_bytes + frame_codec_data->receive_frame_pos + frame_codec_data->type_specific_size, buffer, to_copy);
markrad 58:f50b97b08851 383
markrad 58:f50b97b08851 384 buffer += to_copy;
markrad 58:f50b97b08851 385 size -= to_copy;
markrad 58:f50b97b08851 386 frame_codec_data->receive_frame_pos += to_copy;
markrad 58:f50b97b08851 387
markrad 58:f50b97b08851 388 if (frame_codec_data->receive_frame_pos == frame_body_size)
markrad 58:f50b97b08851 389 {
markrad 58:f50b97b08851 390 if (frame_codec_data->receive_frame_subscription != NULL)
markrad 58:f50b97b08851 391 {
markrad 58:f50b97b08851 392 /* Codes_SRS_FRAME_CODEC_01_031: [When a complete frame is successfully decoded it shall be indicated to the upper layer by invoking the on_frame_received passed to frame_codec_subscribe.] */
markrad 58:f50b97b08851 393 /* Codes_SRS_FRAME_CODEC_01_032: [Besides passing the frame information, the callback_context value passed to frame_codec_data_subscribe shall be passed to the on_frame_received function.] */
markrad 58:f50b97b08851 394 /* Codes_SRS_FRAME_CODEC_01_005: [This is an extension point defined for future expansion.] */
markrad 58:f50b97b08851 395 /* Codes_SRS_FRAME_CODEC_01_006: [The treatment of this area depends on the frame type.] */
markrad 58:f50b97b08851 396 /* Codes_SRS_FRAME_CODEC_01_099: [A pointer to the frame_body bytes shall also be passed to the on_frame_received.] */
markrad 58:f50b97b08851 397 frame_codec_data->receive_frame_subscription->on_frame_received(frame_codec_data->receive_frame_subscription->callback_context, frame_codec_data->receive_frame_bytes, frame_codec_data->type_specific_size, frame_codec_data->receive_frame_bytes + frame_codec_data->type_specific_size, frame_body_size);
markrad 58:f50b97b08851 398 amqpalloc_free(frame_codec_data->receive_frame_bytes);
markrad 58:f50b97b08851 399 frame_codec_data->receive_frame_bytes = NULL;
markrad 58:f50b97b08851 400 }
markrad 58:f50b97b08851 401
markrad 58:f50b97b08851 402 frame_codec_data->receive_frame_state = RECEIVE_FRAME_STATE_FRAME_SIZE;
markrad 58:f50b97b08851 403 frame_codec_data->receive_frame_pos = 0;
markrad 58:f50b97b08851 404 frame_codec_data->receive_frame_size = 0;
markrad 58:f50b97b08851 405 }
markrad 58:f50b97b08851 406 result = 0;
markrad 58:f50b97b08851 407
markrad 58:f50b97b08851 408 break;
markrad 58:f50b97b08851 409 }
markrad 58:f50b97b08851 410 }
markrad 58:f50b97b08851 411 }
markrad 58:f50b97b08851 412 }
markrad 58:f50b97b08851 413
markrad 58:f50b97b08851 414 return result;
markrad 58:f50b97b08851 415 }
markrad 58:f50b97b08851 416
markrad 58:f50b97b08851 417 /* Codes_SRS_FRAME_CODEC_01_033: [frame_codec_subscribe subscribes for a certain type of frame received by the frame_codec instance identified by frame_codec.] */
markrad 58:f50b97b08851 418 int frame_codec_subscribe(FRAME_CODEC_HANDLE frame_codec, uint8_t type, ON_FRAME_RECEIVED on_frame_received, void* callback_context)
markrad 58:f50b97b08851 419 {
markrad 58:f50b97b08851 420 int result;
markrad 58:f50b97b08851 421
markrad 58:f50b97b08851 422 /* Codes_SRS_FRAME_CODEC_01_034: [If any of the frame_codec or on_frame_received arguments is NULL, frame_codec_subscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 423 if ((frame_codec == NULL) ||
markrad 58:f50b97b08851 424 (on_frame_received == NULL))
markrad 58:f50b97b08851 425 {
markrad 58:f50b97b08851 426 result = __LINE__;
markrad 58:f50b97b08851 427 }
markrad 58:f50b97b08851 428 else
markrad 58:f50b97b08851 429 {
markrad 58:f50b97b08851 430 FRAME_CODEC_INSTANCE* frame_codec_data = (FRAME_CODEC_INSTANCE*)frame_codec;
markrad 58:f50b97b08851 431 SUBSCRIPTION* subscription;
markrad 58:f50b97b08851 432
markrad 58:f50b97b08851 433 /* Codes_SRS_FRAME_CODEC_01_036: [Only one callback pair shall be allowed to be registered for a given frame type.] */
markrad 58:f50b97b08851 434 /* find the subscription for this frame type */
markrad 58:f50b97b08851 435 LIST_ITEM_HANDLE list_item = singlylinkedlist_find(frame_codec_data->subscription_list, find_subscription_by_frame_type, &type);
markrad 58:f50b97b08851 436 if (list_item != NULL)
markrad 58:f50b97b08851 437 {
markrad 58:f50b97b08851 438 subscription = (SUBSCRIPTION*)singlylinkedlist_item_get_value(list_item);
markrad 58:f50b97b08851 439 if (subscription == NULL)
markrad 58:f50b97b08851 440 {
markrad 58:f50b97b08851 441 /* Codes_SRS_FRAME_CODEC_01_037: [If any failure occurs while performing the subscribe operation, frame_codec_subscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 442 result = __LINE__;
markrad 58:f50b97b08851 443 }
markrad 58:f50b97b08851 444 else
markrad 58:f50b97b08851 445 {
markrad 58:f50b97b08851 446 /* a subscription was found */
markrad 58:f50b97b08851 447 subscription->on_frame_received = on_frame_received;
markrad 58:f50b97b08851 448 subscription->callback_context = callback_context;
markrad 58:f50b97b08851 449
markrad 58:f50b97b08851 450 /* Codes_SRS_FRAME_CODEC_01_087: [On success, frame_codec_subscribe shall return zero.] */
markrad 58:f50b97b08851 451 result = 0;
markrad 58:f50b97b08851 452 }
markrad 58:f50b97b08851 453 }
markrad 58:f50b97b08851 454 else
markrad 58:f50b97b08851 455 {
markrad 58:f50b97b08851 456 /* add a new subscription */
markrad 58:f50b97b08851 457 subscription = (SUBSCRIPTION*)amqpalloc_malloc(sizeof(SUBSCRIPTION));
markrad 58:f50b97b08851 458 /* Codes_SRS_FRAME_CODEC_01_037: [If any failure occurs while performing the subscribe operation, frame_codec_subscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 459 if (subscription == NULL)
markrad 58:f50b97b08851 460 {
markrad 58:f50b97b08851 461 result = __LINE__;
markrad 58:f50b97b08851 462 }
markrad 58:f50b97b08851 463 else
markrad 58:f50b97b08851 464 {
markrad 58:f50b97b08851 465 subscription->on_frame_received = on_frame_received;
markrad 58:f50b97b08851 466 subscription->callback_context = callback_context;
markrad 58:f50b97b08851 467 subscription->frame_type = type;
markrad 58:f50b97b08851 468
markrad 58:f50b97b08851 469 /* Codes_SRS_FRAME_CODEC_01_037: [If any failure occurs while performing the subscribe operation, frame_codec_subscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 470 if (singlylinkedlist_add(frame_codec_data->subscription_list, subscription) == NULL)
markrad 58:f50b97b08851 471 {
markrad 58:f50b97b08851 472 amqpalloc_free(subscription);
markrad 58:f50b97b08851 473 result = __LINE__;
markrad 58:f50b97b08851 474 }
markrad 58:f50b97b08851 475 else
markrad 58:f50b97b08851 476 {
markrad 58:f50b97b08851 477 /* Codes_SRS_FRAME_CODEC_01_087: [On success, frame_codec_subscribe shall return zero.] */
markrad 58:f50b97b08851 478 result = 0;
markrad 58:f50b97b08851 479 }
markrad 58:f50b97b08851 480 }
markrad 58:f50b97b08851 481 }
markrad 58:f50b97b08851 482 }
markrad 58:f50b97b08851 483
markrad 58:f50b97b08851 484 return result;
markrad 58:f50b97b08851 485 }
markrad 58:f50b97b08851 486
markrad 58:f50b97b08851 487 int frame_codec_unsubscribe(FRAME_CODEC_HANDLE frame_codec, uint8_t type)
markrad 58:f50b97b08851 488 {
markrad 58:f50b97b08851 489 int result;
markrad 58:f50b97b08851 490
markrad 58:f50b97b08851 491 /* Codes_SRS_FRAME_CODEC_01_039: [If frame_codec is NULL, frame_codec_unsubscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 492 if (frame_codec == NULL)
markrad 58:f50b97b08851 493 {
markrad 58:f50b97b08851 494 result = __LINE__;
markrad 58:f50b97b08851 495 }
markrad 58:f50b97b08851 496 else
markrad 58:f50b97b08851 497 {
markrad 58:f50b97b08851 498 FRAME_CODEC_INSTANCE* frame_codec_data = (FRAME_CODEC_INSTANCE*)frame_codec;
markrad 58:f50b97b08851 499 LIST_ITEM_HANDLE list_item = singlylinkedlist_find(frame_codec_data->subscription_list, find_subscription_by_frame_type, &type);
markrad 58:f50b97b08851 500
markrad 58:f50b97b08851 501 if (list_item == NULL)
markrad 58:f50b97b08851 502 {
markrad 58:f50b97b08851 503 /* Codes_SRS_FRAME_CODEC_01_040: [If no subscription for the type frame type exists, frame_codec_unsubscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 504 /* Codes_SRS_FRAME_CODEC_01_041: [If any failure occurs while performing the unsubscribe operation, frame_codec_unsubscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 505 result = __LINE__;
markrad 58:f50b97b08851 506 }
markrad 58:f50b97b08851 507 else
markrad 58:f50b97b08851 508 {
markrad 58:f50b97b08851 509 SUBSCRIPTION* subscription = (SUBSCRIPTION*)singlylinkedlist_item_get_value(list_item);
markrad 58:f50b97b08851 510 if (subscription == NULL)
markrad 58:f50b97b08851 511 {
markrad 58:f50b97b08851 512 /* Codes_SRS_FRAME_CODEC_01_041: [If any failure occurs while performing the unsubscribe operation, frame_codec_unsubscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 513 result = __LINE__;
markrad 58:f50b97b08851 514 }
markrad 58:f50b97b08851 515 else
markrad 58:f50b97b08851 516 {
markrad 58:f50b97b08851 517 amqpalloc_free(subscription);
markrad 58:f50b97b08851 518 if (singlylinkedlist_remove(frame_codec_data->subscription_list, list_item) != 0)
markrad 58:f50b97b08851 519 {
markrad 58:f50b97b08851 520 /* Codes_SRS_FRAME_CODEC_01_041: [If any failure occurs while performing the unsubscribe operation, frame_codec_unsubscribe shall return a non-zero value.] */
markrad 58:f50b97b08851 521 result = __LINE__;
markrad 58:f50b97b08851 522 }
markrad 58:f50b97b08851 523 else
markrad 58:f50b97b08851 524 {
markrad 58:f50b97b08851 525 /* Codes_SRS_FRAME_CODEC_01_038: [frame_codec_unsubscribe removes a previous subscription for frames of type type and on success it shall return 0.] */
markrad 58:f50b97b08851 526 result = 0;
markrad 58:f50b97b08851 527 }
markrad 58:f50b97b08851 528 }
markrad 58:f50b97b08851 529 }
markrad 58:f50b97b08851 530 }
markrad 58:f50b97b08851 531
markrad 58:f50b97b08851 532 return result;
markrad 58:f50b97b08851 533 }
markrad 58:f50b97b08851 534
markrad 58:f50b97b08851 535 int frame_codec_encode_frame(FRAME_CODEC_HANDLE frame_codec, uint8_t type, const PAYLOAD* payloads, size_t payload_count, const unsigned char* type_specific_bytes, uint32_t type_specific_size, ON_BYTES_ENCODED on_bytes_encoded, void* callback_context)
markrad 58:f50b97b08851 536 {
markrad 58:f50b97b08851 537 int result;
markrad 58:f50b97b08851 538
markrad 58:f50b97b08851 539 FRAME_CODEC_INSTANCE* frame_codec_data = (FRAME_CODEC_INSTANCE*)frame_codec;
markrad 58:f50b97b08851 540
markrad 58:f50b97b08851 541 /* Codes_SRS_FRAME_CODEC_01_044: [If the argument frame_codec is NULL, frame_codec_encode_frame shall return a non-zero value.] */
markrad 58:f50b97b08851 542 if ((frame_codec == NULL) ||
markrad 58:f50b97b08851 543 /* Codes_SRS_FRAME_CODEC_01_091: [If the argument type_specific_size is greater than 0 and type_specific_bytes is NULL, frame_codec_encode_frame shall return a non-zero value.] */
markrad 58:f50b97b08851 544 ((type_specific_size > 0) && (type_specific_bytes == NULL)) ||
markrad 58:f50b97b08851 545 /* Codes_SRS_FRAME_CODEC_01_092: [If type_specific_size is too big to allow encoding the frame according to the AMQP ISO then frame_codec_encode_frame shall return a non-zero value.] */
markrad 58:f50b97b08851 546 (type_specific_size > MAX_TYPE_SPECIFIC_SIZE) ||
markrad 58:f50b97b08851 547 (frame_codec_data->encode_frame_state == ENCODE_FRAME_STATE_ERROR))
markrad 58:f50b97b08851 548 {
markrad 58:f50b97b08851 549 result = __LINE__;
markrad 58:f50b97b08851 550 }
markrad 58:f50b97b08851 551 else
markrad 58:f50b97b08851 552 {
markrad 58:f50b97b08851 553 /* round up to the 4 bytes for doff */
markrad 58:f50b97b08851 554 /* Codes_SRS_FRAME_CODEC_01_067: [The value of the data offset is an unsigned, 8-bit integer specifying a count of 4-byte words.] */
markrad 58:f50b97b08851 555 /* Codes_SRS_FRAME_CODEC_01_068: [Due to the mandatory 8-byte frame header, the frame is malformed if the value is less than 2.] */
markrad 58:f50b97b08851 556 uint8_t padding_byte_count;
markrad 58:f50b97b08851 557 uint32_t frame_body_offset = type_specific_size + 6;
markrad 58:f50b97b08851 558 uint8_t doff = (uint8_t)((frame_body_offset + 3) / 4);
markrad 58:f50b97b08851 559 size_t i;
markrad 58:f50b97b08851 560 size_t frame_size;
markrad 58:f50b97b08851 561 size_t frame_body_size = 0;
markrad 58:f50b97b08851 562 frame_body_offset = doff * 4;
markrad 58:f50b97b08851 563 padding_byte_count = (uint8_t)(frame_body_offset - type_specific_size - 6);
markrad 58:f50b97b08851 564
markrad 58:f50b97b08851 565 for (i = 0; i < payload_count; i++)
markrad 58:f50b97b08851 566 {
markrad 58:f50b97b08851 567 frame_body_size += payloads[i].length;
markrad 58:f50b97b08851 568 }
markrad 58:f50b97b08851 569
markrad 58:f50b97b08851 570 /* Codes_SRS_FRAME_CODEC_01_063: [This is an unsigned 32-bit integer that MUST contain the total frame size of the frame header, extended header, and frame body.] */
markrad 58:f50b97b08851 571 frame_size = frame_body_size + frame_body_offset;
markrad 58:f50b97b08851 572
markrad 58:f50b97b08851 573 if (frame_size > frame_codec_data->max_frame_size)
markrad 58:f50b97b08851 574 {
markrad 58:f50b97b08851 575 /* Codes_SRS_FRAME_CODEC_01_095: [If the frame_size needed for the frame is bigger than the maximum frame size, frame_codec_encode_frame shall fail and return a non-zero value.] */
markrad 58:f50b97b08851 576 result = __LINE__;
markrad 58:f50b97b08851 577 }
markrad 58:f50b97b08851 578 else
markrad 58:f50b97b08851 579 {
markrad 58:f50b97b08851 580 /* Codes_SRS_FRAME_CODEC_01_042: [frame_codec_encode_frame encodes the header and type specific bytes of a frame that has frame_payload_size bytes.] */
markrad 58:f50b97b08851 581 /* Codes_SRS_FRAME_CODEC_01_055: [Frames are divided into three distinct areas: a fixed width frame header, a variable width extended header, and a variable width frame body.] */
markrad 58:f50b97b08851 582 /* Codes_SRS_FRAME_CODEC_01_056: [frame header The frame header is a fixed size (8 byte) structure that precedes each frame.] */
markrad 58:f50b97b08851 583 /* Codes_SRS_FRAME_CODEC_01_057: [The frame header includes mandatory information necessary to parse the rest of the frame including size and type information.] */
markrad 58:f50b97b08851 584 /* Codes_SRS_FRAME_CODEC_01_058: [extended header The extended header is a variable width area preceding the frame body.] */
markrad 58:f50b97b08851 585 /* Codes_SRS_FRAME_CODEC_01_059: [This is an extension point defined for future expansion.] */
markrad 58:f50b97b08851 586 /* Codes_SRS_FRAME_CODEC_01_060: [The treatment of this area depends on the frame type.]*/
markrad 58:f50b97b08851 587 /* Codes_SRS_FRAME_CODEC_01_062: [SIZE Bytes 0-3 of the frame header contain the frame size.] */
markrad 58:f50b97b08851 588 /* Codes_SRS_FRAME_CODEC_01_063: [This is an unsigned 32-bit integer that MUST contain the total frame size of the frame header, extended header, and frame body.] */
markrad 58:f50b97b08851 589 /* Codes_SRS_FRAME_CODEC_01_064: [The frame is malformed if the size is less than the size of the frame header (8 bytes).] */
markrad 58:f50b97b08851 590 unsigned char frame_header[6];
markrad 58:f50b97b08851 591
markrad 58:f50b97b08851 592 frame_header[0] = (frame_size >> 24) & 0xFF;
markrad 58:f50b97b08851 593 frame_header[1] = (frame_size >> 16) & 0xFF;
markrad 58:f50b97b08851 594 frame_header[2] = (frame_size >> 8) & 0xFF;
markrad 58:f50b97b08851 595 frame_header[3] = frame_size & 0xFF;
markrad 58:f50b97b08851 596 /* Codes_SRS_FRAME_CODEC_01_065: [DOFF Byte 4 of the frame header is the data offset.] */
markrad 58:f50b97b08851 597 frame_header[4] = doff;
markrad 58:f50b97b08851 598 /* Codes_SRS_FRAME_CODEC_01_069: [TYPE Byte 5 of the frame header is a type code.] */
markrad 58:f50b97b08851 599 frame_header[5] = type;
markrad 58:f50b97b08851 600
markrad 58:f50b97b08851 601 /* Codes_SRS_FRAME_CODEC_01_088: [Encoded bytes shall be passed to the on_bytes_encoded callback.] */
markrad 58:f50b97b08851 602 on_bytes_encoded(callback_context, frame_header, sizeof(frame_header), ((frame_body_size + type_specific_bytes + padding_byte_count) == 0) ? true : false);
markrad 58:f50b97b08851 603
markrad 58:f50b97b08851 604 /* Codes_SRS_FRAME_CODEC_01_088: [Encoded bytes shall be passed to the on_bytes_encoded callback.] */
markrad 58:f50b97b08851 605 if (type_specific_size > 0)
markrad 58:f50b97b08851 606 {
markrad 58:f50b97b08851 607 on_bytes_encoded(callback_context, type_specific_bytes, type_specific_size, ((frame_body_size + padding_byte_count) == 0) ? true : false);
markrad 58:f50b97b08851 608 }
markrad 58:f50b97b08851 609
markrad 58:f50b97b08851 610 /* send padding bytes */
markrad 58:f50b97b08851 611 /* Codes_SRS_FRAME_CODEC_01_090: [If the type_specific_size – 2 does not divide by 4, frame_codec_encode_frame shall pad the type_specific bytes with zeroes so that type specific data is according to the AMQP ISO.] */
markrad 58:f50b97b08851 612 unsigned char padding_bytes[] = { 0x00, 0x00, 0x00 };
markrad 58:f50b97b08851 613
markrad 58:f50b97b08851 614 /* Codes_SRS_FRAME_CODEC_01_088: [Encoded bytes shall be passed to the on_bytes_encoded callback.] */
markrad 58:f50b97b08851 615 if (padding_byte_count > 0)
markrad 58:f50b97b08851 616 {
markrad 58:f50b97b08851 617 on_bytes_encoded(callback_context, padding_bytes, padding_byte_count, (payload_count == 0) ? true : false);
markrad 58:f50b97b08851 618 }
markrad 58:f50b97b08851 619
markrad 58:f50b97b08851 620 for (i = 0; i < payload_count; i++)
markrad 58:f50b97b08851 621 {
markrad 58:f50b97b08851 622 /* Codes_SRS_FRAME_CODEC_01_088: [Encoded bytes shall be passed to the on_bytes_encoded callback.] */
markrad 58:f50b97b08851 623 on_bytes_encoded(callback_context, payloads[i].bytes, payloads[i].length, (i == payload_count - 1) ? true : false);
markrad 58:f50b97b08851 624 }
markrad 58:f50b97b08851 625
markrad 58:f50b97b08851 626 /* Codes_SRS_FRAME_CODEC_01_043: [On success it shall return 0.] */
markrad 58:f50b97b08851 627 result = 0;
markrad 58:f50b97b08851 628 }
markrad 58:f50b97b08851 629 }
markrad 58:f50b97b08851 630
markrad 58:f50b97b08851 631 return result;
markrad 58:f50b97b08851 632 }