A small memory footprint AMQP implimentation
Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp
messaging.c@28:add19eb7defa, 2017-06-30 (annotated)
- Committer:
- AzureIoTClient
- Date:
- Fri Jun 30 10:41:22 2017 -0700
- Revision:
- 28:add19eb7defa
- Parent:
- 17:923575db8b2d
- Child:
- 34:6be9c2058664
1.1.18
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Azure.IoT Build | 0:6ae2f7bca550 | 1 | // Copyright (c) Microsoft. All rights reserved. |
Azure.IoT Build | 0:6ae2f7bca550 | 2 | // Licensed under the MIT license. See LICENSE file in the project root for full license information. |
Azure.IoT Build | 0:6ae2f7bca550 | 3 | |
Azure.IoT Build | 0:6ae2f7bca550 | 4 | #include <stdlib.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 5 | #include <stdbool.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 6 | #include "azure_uamqp_c/amqpvalue.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 7 | #include "azure_uamqp_c/amqp_definitions.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 8 | |
Azure.IoT Build | 0:6ae2f7bca550 | 9 | AMQP_VALUE messaging_create_source(const char* address) |
Azure.IoT Build | 0:6ae2f7bca550 | 10 | { |
AzureIoTClient | 28:add19eb7defa | 11 | AMQP_VALUE result; |
AzureIoTClient | 28:add19eb7defa | 12 | SOURCE_HANDLE source = source_create(); |
AzureIoTClient | 28:add19eb7defa | 13 | if (source == NULL) |
AzureIoTClient | 28:add19eb7defa | 14 | { |
AzureIoTClient | 28:add19eb7defa | 15 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 16 | } |
AzureIoTClient | 28:add19eb7defa | 17 | else |
AzureIoTClient | 28:add19eb7defa | 18 | { |
AzureIoTClient | 28:add19eb7defa | 19 | AMQP_VALUE address_value = amqpvalue_create_string(address); |
AzureIoTClient | 28:add19eb7defa | 20 | if (address_value == NULL) |
AzureIoTClient | 28:add19eb7defa | 21 | { |
AzureIoTClient | 28:add19eb7defa | 22 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 23 | } |
AzureIoTClient | 28:add19eb7defa | 24 | else |
AzureIoTClient | 28:add19eb7defa | 25 | { |
AzureIoTClient | 28:add19eb7defa | 26 | if (source_set_address(source, address_value) != 0) |
AzureIoTClient | 28:add19eb7defa | 27 | { |
AzureIoTClient | 28:add19eb7defa | 28 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 29 | } |
AzureIoTClient | 28:add19eb7defa | 30 | else |
AzureIoTClient | 28:add19eb7defa | 31 | { |
AzureIoTClient | 28:add19eb7defa | 32 | result = amqpvalue_create_source(source); |
AzureIoTClient | 28:add19eb7defa | 33 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 34 | |
AzureIoTClient | 28:add19eb7defa | 35 | amqpvalue_destroy(address_value); |
AzureIoTClient | 28:add19eb7defa | 36 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 37 | |
AzureIoTClient | 28:add19eb7defa | 38 | source_destroy(source); |
AzureIoTClient | 28:add19eb7defa | 39 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 40 | |
AzureIoTClient | 28:add19eb7defa | 41 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 42 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 43 | |
Azure.IoT Build | 0:6ae2f7bca550 | 44 | AMQP_VALUE messaging_create_target(const char* address) |
Azure.IoT Build | 0:6ae2f7bca550 | 45 | { |
AzureIoTClient | 28:add19eb7defa | 46 | AMQP_VALUE result; |
AzureIoTClient | 28:add19eb7defa | 47 | TARGET_HANDLE target = target_create(); |
AzureIoTClient | 28:add19eb7defa | 48 | if (target == NULL) |
AzureIoTClient | 28:add19eb7defa | 49 | { |
AzureIoTClient | 28:add19eb7defa | 50 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 51 | } |
AzureIoTClient | 28:add19eb7defa | 52 | else |
AzureIoTClient | 28:add19eb7defa | 53 | { |
AzureIoTClient | 28:add19eb7defa | 54 | AMQP_VALUE address_value = amqpvalue_create_string(address); |
AzureIoTClient | 28:add19eb7defa | 55 | if (address_value == NULL) |
AzureIoTClient | 28:add19eb7defa | 56 | { |
AzureIoTClient | 28:add19eb7defa | 57 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 58 | } |
AzureIoTClient | 28:add19eb7defa | 59 | else |
AzureIoTClient | 28:add19eb7defa | 60 | { |
AzureIoTClient | 28:add19eb7defa | 61 | if (target_set_address(target, address_value) != 0) |
AzureIoTClient | 28:add19eb7defa | 62 | { |
AzureIoTClient | 28:add19eb7defa | 63 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 64 | } |
AzureIoTClient | 28:add19eb7defa | 65 | else |
AzureIoTClient | 28:add19eb7defa | 66 | { |
AzureIoTClient | 28:add19eb7defa | 67 | result = amqpvalue_create_target(target); |
AzureIoTClient | 28:add19eb7defa | 68 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 69 | |
AzureIoTClient | 28:add19eb7defa | 70 | amqpvalue_destroy(address_value); |
AzureIoTClient | 28:add19eb7defa | 71 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 72 | |
AzureIoTClient | 28:add19eb7defa | 73 | target_destroy(target); |
AzureIoTClient | 28:add19eb7defa | 74 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 75 | |
AzureIoTClient | 28:add19eb7defa | 76 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 77 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 78 | |
Azure.IoT Build | 0:6ae2f7bca550 | 79 | AMQP_VALUE messaging_delivery_received(uint32_t section_number, uint64_t section_offset) |
Azure.IoT Build | 0:6ae2f7bca550 | 80 | { |
AzureIoTClient | 28:add19eb7defa | 81 | AMQP_VALUE result; |
AzureIoTClient | 28:add19eb7defa | 82 | RECEIVED_HANDLE received = received_create(section_number, section_offset); |
AzureIoTClient | 28:add19eb7defa | 83 | if (received == NULL) |
AzureIoTClient | 28:add19eb7defa | 84 | { |
AzureIoTClient | 28:add19eb7defa | 85 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 86 | } |
AzureIoTClient | 28:add19eb7defa | 87 | else |
AzureIoTClient | 28:add19eb7defa | 88 | { |
AzureIoTClient | 28:add19eb7defa | 89 | result = amqpvalue_create_received(received); |
AzureIoTClient | 28:add19eb7defa | 90 | received_destroy(received); |
AzureIoTClient | 28:add19eb7defa | 91 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 92 | |
AzureIoTClient | 28:add19eb7defa | 93 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 94 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 95 | |
Azure.IoT Build | 0:6ae2f7bca550 | 96 | AMQP_VALUE messaging_delivery_accepted(void) |
Azure.IoT Build | 0:6ae2f7bca550 | 97 | { |
AzureIoTClient | 28:add19eb7defa | 98 | AMQP_VALUE result; |
AzureIoTClient | 28:add19eb7defa | 99 | ACCEPTED_HANDLE accepted = accepted_create(); |
AzureIoTClient | 28:add19eb7defa | 100 | if (accepted == NULL) |
AzureIoTClient | 28:add19eb7defa | 101 | { |
AzureIoTClient | 28:add19eb7defa | 102 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 103 | } |
AzureIoTClient | 28:add19eb7defa | 104 | else |
AzureIoTClient | 28:add19eb7defa | 105 | { |
AzureIoTClient | 28:add19eb7defa | 106 | result = amqpvalue_create_accepted(accepted); |
AzureIoTClient | 28:add19eb7defa | 107 | accepted_destroy(accepted); |
AzureIoTClient | 28:add19eb7defa | 108 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 109 | |
AzureIoTClient | 28:add19eb7defa | 110 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 111 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 112 | |
Azure.IoT Build | 0:6ae2f7bca550 | 113 | AMQP_VALUE messaging_delivery_rejected(const char* error_condition, const char* error_description) |
Azure.IoT Build | 0:6ae2f7bca550 | 114 | { |
AzureIoTClient | 28:add19eb7defa | 115 | AMQP_VALUE result; |
AzureIoTClient | 28:add19eb7defa | 116 | REJECTED_HANDLE rejected = rejected_create(); |
AzureIoTClient | 28:add19eb7defa | 117 | if (rejected == NULL) |
AzureIoTClient | 28:add19eb7defa | 118 | { |
AzureIoTClient | 28:add19eb7defa | 119 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 120 | } |
AzureIoTClient | 28:add19eb7defa | 121 | else |
AzureIoTClient | 28:add19eb7defa | 122 | { |
AzureIoTClient | 28:add19eb7defa | 123 | ERROR_HANDLE error_handle = NULL; |
AzureIoTClient | 28:add19eb7defa | 124 | bool error_constructing = false; |
Azure.IoT Build | 0:6ae2f7bca550 | 125 | |
AzureIoTClient | 28:add19eb7defa | 126 | if (error_condition != NULL) |
AzureIoTClient | 28:add19eb7defa | 127 | { |
AzureIoTClient | 28:add19eb7defa | 128 | error_handle = error_create(error_condition); |
AzureIoTClient | 28:add19eb7defa | 129 | if (error_handle == NULL) |
AzureIoTClient | 28:add19eb7defa | 130 | { |
AzureIoTClient | 28:add19eb7defa | 131 | error_constructing = true; |
AzureIoTClient | 28:add19eb7defa | 132 | } |
AzureIoTClient | 28:add19eb7defa | 133 | else |
AzureIoTClient | 28:add19eb7defa | 134 | { |
AzureIoTClient | 28:add19eb7defa | 135 | if ((error_description != NULL) && |
AzureIoTClient | 28:add19eb7defa | 136 | (error_set_description(error_handle, error_description) != 0)) |
AzureIoTClient | 28:add19eb7defa | 137 | { |
AzureIoTClient | 28:add19eb7defa | 138 | error_constructing = true; |
AzureIoTClient | 28:add19eb7defa | 139 | } |
AzureIoTClient | 28:add19eb7defa | 140 | else |
AzureIoTClient | 28:add19eb7defa | 141 | { |
AzureIoTClient | 28:add19eb7defa | 142 | if (rejected_set_error(rejected, error_handle) != 0) |
AzureIoTClient | 28:add19eb7defa | 143 | { |
AzureIoTClient | 28:add19eb7defa | 144 | error_constructing = true; |
AzureIoTClient | 28:add19eb7defa | 145 | } |
AzureIoTClient | 28:add19eb7defa | 146 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 147 | |
AzureIoTClient | 28:add19eb7defa | 148 | error_destroy(error_handle); |
AzureIoTClient | 28:add19eb7defa | 149 | } |
AzureIoTClient | 28:add19eb7defa | 150 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 151 | |
AzureIoTClient | 28:add19eb7defa | 152 | if (error_constructing) |
AzureIoTClient | 28:add19eb7defa | 153 | { |
AzureIoTClient | 28:add19eb7defa | 154 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 155 | } |
AzureIoTClient | 28:add19eb7defa | 156 | else |
AzureIoTClient | 28:add19eb7defa | 157 | { |
AzureIoTClient | 28:add19eb7defa | 158 | result = amqpvalue_create_rejected(rejected); |
AzureIoTClient | 28:add19eb7defa | 159 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 160 | |
AzureIoTClient | 28:add19eb7defa | 161 | rejected_destroy(rejected); |
AzureIoTClient | 28:add19eb7defa | 162 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 163 | |
AzureIoTClient | 28:add19eb7defa | 164 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 165 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 166 | |
Azure.IoT Build | 0:6ae2f7bca550 | 167 | AMQP_VALUE messaging_delivery_released(void) |
Azure.IoT Build | 0:6ae2f7bca550 | 168 | { |
AzureIoTClient | 28:add19eb7defa | 169 | AMQP_VALUE result; |
AzureIoTClient | 28:add19eb7defa | 170 | RELEASED_HANDLE released = released_create(); |
AzureIoTClient | 28:add19eb7defa | 171 | if (released == NULL) |
AzureIoTClient | 28:add19eb7defa | 172 | { |
AzureIoTClient | 28:add19eb7defa | 173 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 174 | } |
AzureIoTClient | 28:add19eb7defa | 175 | else |
AzureIoTClient | 28:add19eb7defa | 176 | { |
AzureIoTClient | 28:add19eb7defa | 177 | result = amqpvalue_create_released(released); |
AzureIoTClient | 28:add19eb7defa | 178 | released_destroy(released); |
AzureIoTClient | 28:add19eb7defa | 179 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 180 | |
AzureIoTClient | 28:add19eb7defa | 181 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 182 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 183 | |
Azure.IoT Build | 0:6ae2f7bca550 | 184 | AMQP_VALUE messaging_delivery_modified(bool delivery_failed, bool undeliverable_here, fields message_annotations) |
Azure.IoT Build | 0:6ae2f7bca550 | 185 | { |
AzureIoTClient | 28:add19eb7defa | 186 | AMQP_VALUE result; |
AzureIoTClient | 28:add19eb7defa | 187 | MODIFIED_HANDLE modified = modified_create(); |
AzureIoTClient | 28:add19eb7defa | 188 | if (modified == NULL) |
AzureIoTClient | 28:add19eb7defa | 189 | { |
AzureIoTClient | 28:add19eb7defa | 190 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 191 | } |
AzureIoTClient | 28:add19eb7defa | 192 | else |
AzureIoTClient | 28:add19eb7defa | 193 | { |
AzureIoTClient | 28:add19eb7defa | 194 | if ((modified_set_delivery_failed(modified, delivery_failed) != 0) || |
AzureIoTClient | 28:add19eb7defa | 195 | (modified_set_undeliverable_here(modified, undeliverable_here) != 0) || |
AzureIoTClient | 28:add19eb7defa | 196 | ((message_annotations != NULL) && (modified_set_message_annotations(modified, message_annotations) != 0))) |
AzureIoTClient | 28:add19eb7defa | 197 | { |
AzureIoTClient | 28:add19eb7defa | 198 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 199 | } |
AzureIoTClient | 28:add19eb7defa | 200 | else |
AzureIoTClient | 28:add19eb7defa | 201 | { |
AzureIoTClient | 28:add19eb7defa | 202 | result = amqpvalue_create_modified(modified); |
AzureIoTClient | 28:add19eb7defa | 203 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 204 | |
AzureIoTClient | 28:add19eb7defa | 205 | modified_destroy(modified); |
AzureIoTClient | 28:add19eb7defa | 206 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 207 | |
AzureIoTClient | 28:add19eb7defa | 208 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 209 | } |