A small memory footprint AMQP implimentation
Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp
cbs.c@5:ae49385aff34, 2016-07-01 (annotated)
- Committer:
- Azure.IoT Build
- Date:
- Fri Jul 01 10:42:48 2016 -0700
- Revision:
- 5:ae49385aff34
- Parent:
- 0:6ae2f7bca550
- Child:
- 6:641a9672db08
1.0.10
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 | #ifdef _CRTDBG_MAP_ALLOC |
Azure.IoT Build | 0:6ae2f7bca550 | 6 | #include <crtdbg.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 7 | #endif |
Azure.IoT Build | 0:6ae2f7bca550 | 8 | |
Azure.IoT Build | 0:6ae2f7bca550 | 9 | #include <stdio.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 10 | #include <string.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 11 | #include "azure_uamqp_c/cbs.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 12 | #include "azure_uamqp_c/amqp_management.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 13 | #include "azure_uamqp_c/amqpalloc.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 14 | #include "azure_uamqp_c/session.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 15 | |
Azure.IoT Build | 0:6ae2f7bca550 | 16 | typedef struct CBS_INSTANCE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 17 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 18 | AMQP_MANAGEMENT_HANDLE amqp_management; |
Azure.IoT Build | 0:6ae2f7bca550 | 19 | } CBS_INSTANCE; |
Azure.IoT Build | 0:6ae2f7bca550 | 20 | |
Azure.IoT Build | 0:6ae2f7bca550 | 21 | static int add_string_key_value_pair_to_map(AMQP_VALUE map, const char* key, const char* value) |
Azure.IoT Build | 0:6ae2f7bca550 | 22 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 23 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 24 | |
Azure.IoT Build | 0:6ae2f7bca550 | 25 | AMQP_VALUE key_value = amqpvalue_create_string(key); |
Azure.IoT Build | 0:6ae2f7bca550 | 26 | if (key == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 27 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 28 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 29 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 30 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 31 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 32 | AMQP_VALUE value_value = amqpvalue_create_string(value); |
Azure.IoT Build | 0:6ae2f7bca550 | 33 | if (value_value == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 34 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 35 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 36 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 37 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 38 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 39 | if (amqpvalue_set_map_value(map, key_value, value_value) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 40 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 41 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 42 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 43 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 44 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 45 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 46 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 47 | |
Azure.IoT Build | 0:6ae2f7bca550 | 48 | amqpvalue_destroy(key_value); |
Azure.IoT Build | 0:6ae2f7bca550 | 49 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 50 | |
Azure.IoT Build | 0:6ae2f7bca550 | 51 | amqpvalue_destroy(value_value); |
Azure.IoT Build | 0:6ae2f7bca550 | 52 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 53 | |
Azure.IoT Build | 0:6ae2f7bca550 | 54 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 55 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 56 | |
Azure.IoT Build | 0:6ae2f7bca550 | 57 | static int set_pending_operation_properties(MESSAGE_HANDLE message) |
Azure.IoT Build | 0:6ae2f7bca550 | 58 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 59 | int result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 60 | |
Azure.IoT Build | 0:6ae2f7bca550 | 61 | PROPERTIES_HANDLE properties = properties_create(); |
Azure.IoT Build | 0:6ae2f7bca550 | 62 | if (properties == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 63 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 64 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 65 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 66 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 67 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 68 | AMQP_VALUE reply_to = amqpvalue_create_address_string("cbs"); |
Azure.IoT Build | 0:6ae2f7bca550 | 69 | if (reply_to == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 70 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 71 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 72 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 73 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 74 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 75 | if (properties_set_reply_to(properties, reply_to) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 76 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 77 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 78 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 79 | |
Azure.IoT Build | 0:6ae2f7bca550 | 80 | amqpvalue_destroy(reply_to); |
Azure.IoT Build | 0:6ae2f7bca550 | 81 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 82 | |
Azure.IoT Build | 0:6ae2f7bca550 | 83 | AMQP_VALUE message_id = amqpvalue_create_message_id_ulong(0x43); |
Azure.IoT Build | 0:6ae2f7bca550 | 84 | if (message_id == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 85 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 86 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 87 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 88 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 89 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 90 | if (properties_set_message_id(properties, message_id) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 91 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 92 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 93 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 94 | |
Azure.IoT Build | 0:6ae2f7bca550 | 95 | amqpvalue_destroy(message_id); |
Azure.IoT Build | 0:6ae2f7bca550 | 96 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 97 | |
Azure.IoT Build | 0:6ae2f7bca550 | 98 | if (message_set_properties(message, properties) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 99 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 100 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 101 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 102 | |
Azure.IoT Build | 0:6ae2f7bca550 | 103 | properties_destroy(properties); |
Azure.IoT Build | 0:6ae2f7bca550 | 104 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 105 | |
Azure.IoT Build | 0:6ae2f7bca550 | 106 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 107 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 108 | |
Azure.IoT Build | 0:6ae2f7bca550 | 109 | CBS_HANDLE cbs_create(SESSION_HANDLE session, ON_AMQP_MANAGEMENT_STATE_CHANGED on_amqp_management_state_changed, void* callback_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 110 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 111 | CBS_INSTANCE* result; |
Azure.IoT Build | 0:6ae2f7bca550 | 112 | |
Azure.IoT Build | 0:6ae2f7bca550 | 113 | if (session == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 114 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 115 | result = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 116 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 117 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 118 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 119 | result = (CBS_INSTANCE*)amqpalloc_malloc(sizeof(CBS_INSTANCE)); |
Azure.IoT Build | 0:6ae2f7bca550 | 120 | if (result != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 121 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 122 | result->amqp_management = amqpmanagement_create(session, "$cbs", on_amqp_management_state_changed, callback_context); |
Azure.IoT Build | 0:6ae2f7bca550 | 123 | if (result->amqp_management == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 124 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 125 | amqpalloc_free(result); |
Azure.IoT Build | 0:6ae2f7bca550 | 126 | result = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 127 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 128 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 129 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 130 | |
Azure.IoT Build | 0:6ae2f7bca550 | 131 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 132 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 133 | |
Azure.IoT Build | 0:6ae2f7bca550 | 134 | void cbs_destroy(CBS_HANDLE cbs) |
Azure.IoT Build | 0:6ae2f7bca550 | 135 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 136 | if (cbs != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 137 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 138 | (void)cbs_close(cbs); |
Azure.IoT Build | 0:6ae2f7bca550 | 139 | amqpmanagement_destroy(cbs->amqp_management); |
Azure.IoT Build | 0:6ae2f7bca550 | 140 | amqpalloc_free(cbs); |
Azure.IoT Build | 0:6ae2f7bca550 | 141 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 142 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 143 | |
Azure.IoT Build | 0:6ae2f7bca550 | 144 | int cbs_open(CBS_HANDLE cbs) |
Azure.IoT Build | 0:6ae2f7bca550 | 145 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 146 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 147 | |
Azure.IoT Build | 0:6ae2f7bca550 | 148 | if (cbs == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 149 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 150 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 151 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 152 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 153 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 154 | if (amqpmanagement_open(cbs->amqp_management) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 155 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 156 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 157 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 158 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 159 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 160 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 161 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 162 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 163 | |
Azure.IoT Build | 0:6ae2f7bca550 | 164 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 165 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 166 | |
Azure.IoT Build | 0:6ae2f7bca550 | 167 | int cbs_close(CBS_HANDLE cbs) |
Azure.IoT Build | 0:6ae2f7bca550 | 168 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 169 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 170 | |
Azure.IoT Build | 0:6ae2f7bca550 | 171 | if (cbs == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 172 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 173 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 174 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 175 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 176 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 177 | if (amqpmanagement_close(cbs->amqp_management) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 178 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 179 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 180 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 181 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 182 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 183 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 184 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 185 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 186 | |
Azure.IoT Build | 0:6ae2f7bca550 | 187 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 188 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 189 | |
Azure.IoT Build | 0:6ae2f7bca550 | 190 | int cbs_put_token(CBS_HANDLE cbs, const char* type, const char* audience, const char* token, ON_CBS_OPERATION_COMPLETE on_operation_complete, void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 191 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 192 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 193 | |
Azure.IoT Build | 0:6ae2f7bca550 | 194 | if ((cbs == NULL) || |
Azure.IoT Build | 0:6ae2f7bca550 | 195 | (token == NULL)) |
Azure.IoT Build | 0:6ae2f7bca550 | 196 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 197 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 198 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 199 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 200 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 201 | MESSAGE_HANDLE message = message_create(); |
Azure.IoT Build | 0:6ae2f7bca550 | 202 | if (message == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 203 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 204 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 205 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 206 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 207 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 208 | AMQP_VALUE token_value = amqpvalue_create_string(token); |
Azure.IoT Build | 0:6ae2f7bca550 | 209 | if (token_value == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 210 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 211 | message_destroy(message); |
Azure.IoT Build | 0:6ae2f7bca550 | 212 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 213 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 214 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 215 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 216 | if (message_set_body_amqp_value(message, token_value) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 217 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 218 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 219 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 220 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 221 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 222 | AMQP_VALUE application_properties = amqpvalue_create_map(); |
Azure.IoT Build | 0:6ae2f7bca550 | 223 | if (application_properties == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 224 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 225 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 226 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 227 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 228 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 229 | if (add_string_key_value_pair_to_map(application_properties, "name", audience) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 230 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 231 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 232 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 233 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 234 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 235 | if (message_set_application_properties(message, application_properties) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 236 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 237 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 238 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 239 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 240 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 241 | if (set_pending_operation_properties(message) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 242 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 243 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 244 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 245 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 246 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 247 | if (amqpmanagement_start_operation(cbs->amqp_management, "put-token", type, NULL, message, (ON_OPERATION_COMPLETE)on_operation_complete, context) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 248 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 249 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 250 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 251 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 252 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 253 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 254 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 255 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 256 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 257 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 258 | |
Azure.IoT Build | 0:6ae2f7bca550 | 259 | amqpvalue_destroy(application_properties); |
Azure.IoT Build | 0:6ae2f7bca550 | 260 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 261 | |
Azure.IoT Build | 0:6ae2f7bca550 | 262 | amqpvalue_destroy(token_value); |
Azure.IoT Build | 0:6ae2f7bca550 | 263 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 264 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 265 | |
Azure.IoT Build | 0:6ae2f7bca550 | 266 | message_destroy(message); |
Azure.IoT Build | 0:6ae2f7bca550 | 267 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 268 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 269 | |
Azure.IoT Build | 0:6ae2f7bca550 | 270 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 271 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 272 | |
Azure.IoT Build | 0:6ae2f7bca550 | 273 | int cbs_delete_token(CBS_HANDLE cbs, const char* type, const char* audience, ON_CBS_OPERATION_COMPLETE on_operation_complete, void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 274 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 275 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 276 | |
Azure.IoT Build | 0:6ae2f7bca550 | 277 | if (cbs == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 278 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 279 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 280 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 281 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 282 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 283 | MESSAGE_HANDLE message = message_create(); |
Azure.IoT Build | 0:6ae2f7bca550 | 284 | if (message == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 285 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 286 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 287 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 288 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 289 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 290 | AMQP_VALUE application_properties = amqpvalue_create_map(); |
Azure.IoT Build | 0:6ae2f7bca550 | 291 | if (application_properties == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 292 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 293 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 294 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 295 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 296 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 297 | if (add_string_key_value_pair_to_map(application_properties, "name", audience) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 298 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 299 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 300 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 301 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 302 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 303 | if (message_set_application_properties(message, application_properties) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 304 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 305 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 306 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 307 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 308 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 309 | if (set_pending_operation_properties(message) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 310 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 311 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 312 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 313 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 314 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 315 | if (amqpmanagement_start_operation(cbs->amqp_management, "delete-token", type, NULL, message, (ON_OPERATION_COMPLETE)on_operation_complete, context) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 316 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 317 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 318 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 319 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 320 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 321 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 322 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 323 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 324 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 325 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 326 | |
Azure.IoT Build | 0:6ae2f7bca550 | 327 | amqpvalue_destroy(application_properties); |
Azure.IoT Build | 0:6ae2f7bca550 | 328 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 329 | |
Azure.IoT Build | 0:6ae2f7bca550 | 330 | message_destroy(message); |
Azure.IoT Build | 0:6ae2f7bca550 | 331 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 332 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 333 | |
Azure.IoT Build | 0:6ae2f7bca550 | 334 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 335 | } |