A small memory footprint AMQP implimentation
Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp
header_detect_io.c@30:0407b2db334c, 2017-07-28 (annotated)
- Committer:
- AzureIoTClient
- Date:
- Fri Jul 28 09:52:29 2017 -0700
- Revision:
- 30:0407b2db334c
- Parent:
- 29:4a11413cf217
- Child:
- 38:7631b92cc772
1.1.20
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 | |
AzureIoTClient | 21:f9c433d8e6ca | 4 | #include <stdlib.h> |
AzureIoTClient | 29:4a11413cf217 | 5 | #include <stddef.h> |
AzureIoTClient | 29:4a11413cf217 | 6 | #include <stdbool.h> |
AzureIoTClient | 19:000ab4e6a2c1 | 7 | #include "azure_c_shared_utility/optimize_size.h" |
AzureIoTClient | 21:f9c433d8e6ca | 8 | #include "azure_c_shared_utility/gballoc.h" |
AzureIoTClient | 27:d74f1cea23e1 | 9 | #include "azure_c_shared_utility/xlogging.h" |
AzureIoTClient | 29:4a11413cf217 | 10 | #include "azure_c_shared_utility/singlylinkedlist.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 11 | #include "azure_uamqp_c/header_detect_io.h" |
AzureIoTClient | 29:4a11413cf217 | 12 | #include "azure_uamqp_c/server_protocol_io.h" |
AzureIoTClient | 29:4a11413cf217 | 13 | |
AzureIoTClient | 29:4a11413cf217 | 14 | static const unsigned char amqp_header_bytes[] = { 'A', 'M', 'Q', 'P', 0, 1, 0, 0 }; |
AzureIoTClient | 29:4a11413cf217 | 15 | static const unsigned char sasl_amqp_header_bytes[] = { 'A', 'M', 'Q', 'P', 3, 1, 0, 0 }; |
Azure.IoT Build | 0:6ae2f7bca550 | 16 | |
Azure.IoT Build | 0:6ae2f7bca550 | 17 | typedef enum IO_STATE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 18 | { |
AzureIoTClient | 28:add19eb7defa | 19 | IO_STATE_NOT_OPEN, |
AzureIoTClient | 28:add19eb7defa | 20 | IO_STATE_OPENING_UNDERLYING_IO, |
AzureIoTClient | 28:add19eb7defa | 21 | IO_STATE_WAIT_FOR_HEADER, |
AzureIoTClient | 29:4a11413cf217 | 22 | IO_STATE_OPENING_DETECTED_IO, |
AzureIoTClient | 28:add19eb7defa | 23 | IO_STATE_OPEN, |
AzureIoTClient | 28:add19eb7defa | 24 | IO_STATE_CLOSING, |
AzureIoTClient | 28:add19eb7defa | 25 | IO_STATE_ERROR |
Azure.IoT Build | 0:6ae2f7bca550 | 26 | } IO_STATE; |
Azure.IoT Build | 0:6ae2f7bca550 | 27 | |
AzureIoTClient | 29:4a11413cf217 | 28 | typedef struct INTERNAL_HEADER_DETECT_ENTRY_TAG |
AzureIoTClient | 29:4a11413cf217 | 29 | { |
AzureIoTClient | 29:4a11413cf217 | 30 | unsigned char* header_bytes; |
AzureIoTClient | 29:4a11413cf217 | 31 | size_t header_size; |
AzureIoTClient | 29:4a11413cf217 | 32 | const IO_INTERFACE_DESCRIPTION* io_interface_description; |
AzureIoTClient | 29:4a11413cf217 | 33 | } INTERNAL_HEADER_DETECT_ENTRY; |
AzureIoTClient | 29:4a11413cf217 | 34 | |
AzureIoTClient | 29:4a11413cf217 | 35 | typedef struct CHAINED_IO_TAG |
AzureIoTClient | 29:4a11413cf217 | 36 | { |
AzureIoTClient | 29:4a11413cf217 | 37 | XIO_HANDLE detected_io; |
AzureIoTClient | 29:4a11413cf217 | 38 | ON_BYTES_RECEIVED on_bytes_received; |
AzureIoTClient | 29:4a11413cf217 | 39 | void* on_bytes_received_context; |
AzureIoTClient | 29:4a11413cf217 | 40 | } CHAINED_IO; |
AzureIoTClient | 29:4a11413cf217 | 41 | |
Azure.IoT Build | 0:6ae2f7bca550 | 42 | typedef struct HEADER_DETECT_IO_INSTANCE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 43 | { |
AzureIoTClient | 28:add19eb7defa | 44 | XIO_HANDLE underlying_io; |
AzureIoTClient | 29:4a11413cf217 | 45 | IO_STATE io_state; |
AzureIoTClient | 28:add19eb7defa | 46 | size_t header_pos; |
AzureIoTClient | 28:add19eb7defa | 47 | ON_IO_OPEN_COMPLETE on_io_open_complete; |
AzureIoTClient | 28:add19eb7defa | 48 | ON_IO_CLOSE_COMPLETE on_io_close_complete; |
AzureIoTClient | 28:add19eb7defa | 49 | ON_IO_ERROR on_io_error; |
AzureIoTClient | 28:add19eb7defa | 50 | ON_BYTES_RECEIVED on_bytes_received; |
AzureIoTClient | 28:add19eb7defa | 51 | void* on_io_open_complete_context; |
AzureIoTClient | 28:add19eb7defa | 52 | void* on_io_close_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 53 | void* on_io_error_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 54 | void* on_bytes_received_context; |
AzureIoTClient | 29:4a11413cf217 | 55 | INTERNAL_HEADER_DETECT_ENTRY* header_detect_entries; |
AzureIoTClient | 29:4a11413cf217 | 56 | size_t header_detect_entry_count; |
AzureIoTClient | 29:4a11413cf217 | 57 | SINGLYLINKEDLIST_HANDLE chained_io_list; |
AzureIoTClient | 29:4a11413cf217 | 58 | XIO_HANDLE* last_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 59 | } HEADER_DETECT_IO_INSTANCE; |
Azure.IoT Build | 0:6ae2f7bca550 | 60 | |
AzureIoTClient | 29:4a11413cf217 | 61 | static void destroy_io_chain(HEADER_DETECT_IO_INSTANCE* header_detect_io) |
AzureIoTClient | 29:4a11413cf217 | 62 | { |
AzureIoTClient | 29:4a11413cf217 | 63 | LIST_ITEM_HANDLE list_item = singlylinkedlist_get_head_item(header_detect_io->chained_io_list); |
AzureIoTClient | 29:4a11413cf217 | 64 | while (list_item != NULL) |
AzureIoTClient | 29:4a11413cf217 | 65 | { |
AzureIoTClient | 29:4a11413cf217 | 66 | CHAINED_IO* chained_io = (CHAINED_IO*)singlylinkedlist_item_get_value(list_item); |
AzureIoTClient | 29:4a11413cf217 | 67 | |
AzureIoTClient | 29:4a11413cf217 | 68 | if (singlylinkedlist_remove(header_detect_io->chained_io_list, list_item) != 0) |
AzureIoTClient | 29:4a11413cf217 | 69 | { |
AzureIoTClient | 29:4a11413cf217 | 70 | LogError("Cannot remove detected IO from list"); |
AzureIoTClient | 29:4a11413cf217 | 71 | } |
AzureIoTClient | 29:4a11413cf217 | 72 | |
AzureIoTClient | 29:4a11413cf217 | 73 | xio_destroy(chained_io->detected_io); |
AzureIoTClient | 29:4a11413cf217 | 74 | free(chained_io); |
AzureIoTClient | 29:4a11413cf217 | 75 | |
AzureIoTClient | 29:4a11413cf217 | 76 | list_item = singlylinkedlist_get_head_item(header_detect_io->chained_io_list); |
AzureIoTClient | 29:4a11413cf217 | 77 | } |
AzureIoTClient | 29:4a11413cf217 | 78 | |
AzureIoTClient | 29:4a11413cf217 | 79 | header_detect_io->last_io = &header_detect_io->underlying_io; |
AzureIoTClient | 29:4a11413cf217 | 80 | } |
AzureIoTClient | 29:4a11413cf217 | 81 | |
AzureIoTClient | 29:4a11413cf217 | 82 | static void internal_close(HEADER_DETECT_IO_INSTANCE* header_detect_io) |
AzureIoTClient | 29:4a11413cf217 | 83 | { |
AzureIoTClient | 29:4a11413cf217 | 84 | // close the last underlying IO (the one that we're talking to) |
AzureIoTClient | 29:4a11413cf217 | 85 | if (xio_close(*header_detect_io->last_io, NULL, NULL) != 0) |
AzureIoTClient | 29:4a11413cf217 | 86 | { |
AzureIoTClient | 29:4a11413cf217 | 87 | LogError("Cannot close underlying IO"); |
AzureIoTClient | 29:4a11413cf217 | 88 | } |
AzureIoTClient | 29:4a11413cf217 | 89 | |
AzureIoTClient | 29:4a11413cf217 | 90 | destroy_io_chain(header_detect_io); |
AzureIoTClient | 29:4a11413cf217 | 91 | |
AzureIoTClient | 29:4a11413cf217 | 92 | header_detect_io->io_state = IO_STATE_NOT_OPEN; |
AzureIoTClient | 29:4a11413cf217 | 93 | } |
AzureIoTClient | 29:4a11413cf217 | 94 | |
AzureIoTClient | 29:4a11413cf217 | 95 | static void on_underlying_io_open_complete(void* context, IO_OPEN_RESULT open_result); |
AzureIoTClient | 29:4a11413cf217 | 96 | static void on_underlying_io_bytes_received(void* context, const unsigned char* buffer, size_t size); |
AzureIoTClient | 29:4a11413cf217 | 97 | static void on_underlying_io_error(void* context); |
Azure.IoT Build | 0:6ae2f7bca550 | 98 | |
Azure.IoT Build | 0:6ae2f7bca550 | 99 | static void indicate_error(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance) |
Azure.IoT Build | 0:6ae2f7bca550 | 100 | { |
AzureIoTClient | 28:add19eb7defa | 101 | if (header_detect_io_instance->on_io_error != NULL) |
AzureIoTClient | 28:add19eb7defa | 102 | { |
AzureIoTClient | 28:add19eb7defa | 103 | header_detect_io_instance->on_io_error(header_detect_io_instance->on_io_error_context); |
AzureIoTClient | 28:add19eb7defa | 104 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 105 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 106 | |
Azure.IoT Build | 0:6ae2f7bca550 | 107 | static void indicate_open_complete(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance, IO_OPEN_RESULT open_result) |
Azure.IoT Build | 0:6ae2f7bca550 | 108 | { |
AzureIoTClient | 28:add19eb7defa | 109 | if (header_detect_io_instance->on_io_open_complete != NULL) |
AzureIoTClient | 28:add19eb7defa | 110 | { |
AzureIoTClient | 28:add19eb7defa | 111 | header_detect_io_instance->on_io_open_complete(header_detect_io_instance->on_io_open_complete_context, open_result); |
AzureIoTClient | 28:add19eb7defa | 112 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 113 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 114 | |
Azure.IoT Build | 0:6ae2f7bca550 | 115 | static void indicate_close_complete(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance) |
Azure.IoT Build | 0:6ae2f7bca550 | 116 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 117 | if (header_detect_io_instance->on_io_close_complete != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 118 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 119 | header_detect_io_instance->on_io_close_complete(header_detect_io_instance->on_io_close_complete_context); |
Azure.IoT Build | 0:6ae2f7bca550 | 120 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 121 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 122 | |
AzureIoTClient | 29:4a11413cf217 | 123 | static void on_send_complete(void* context, IO_SEND_RESULT send_result) |
Azure.IoT Build | 0:6ae2f7bca550 | 124 | { |
AzureIoTClient | 29:4a11413cf217 | 125 | // able to send the header |
AzureIoTClient | 29:4a11413cf217 | 126 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
AzureIoTClient | 29:4a11413cf217 | 127 | |
AzureIoTClient | 29:4a11413cf217 | 128 | if (send_result != IO_SEND_OK) |
AzureIoTClient | 29:4a11413cf217 | 129 | { |
AzureIoTClient | 29:4a11413cf217 | 130 | // signal error |
AzureIoTClient | 29:4a11413cf217 | 131 | indicate_error(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 132 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 133 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 134 | |
Azure.IoT Build | 0:6ae2f7bca550 | 135 | static void on_underlying_io_bytes_received(void* context, const unsigned char* buffer, size_t size) |
Azure.IoT Build | 0:6ae2f7bca550 | 136 | { |
AzureIoTClient | 29:4a11413cf217 | 137 | if (context == NULL) |
AzureIoTClient | 29:4a11413cf217 | 138 | { |
AzureIoTClient | 29:4a11413cf217 | 139 | /* Codes_SRS_HEADER_DETECT_IO_01_050: [ If `context` is NULL, `on_underlying_io_bytes_received` shall do nothing. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 140 | LogError("NULL context"); |
AzureIoTClient | 29:4a11413cf217 | 141 | } |
AzureIoTClient | 29:4a11413cf217 | 142 | else |
AzureIoTClient | 29:4a11413cf217 | 143 | { |
AzureIoTClient | 29:4a11413cf217 | 144 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 145 | |
AzureIoTClient | 29:4a11413cf217 | 146 | if ((buffer == NULL) || |
AzureIoTClient | 29:4a11413cf217 | 147 | (size == 0)) |
AzureIoTClient | 29:4a11413cf217 | 148 | { |
AzureIoTClient | 29:4a11413cf217 | 149 | switch (header_detect_io_instance->io_state) |
AzureIoTClient | 29:4a11413cf217 | 150 | { |
AzureIoTClient | 29:4a11413cf217 | 151 | default: |
AzureIoTClient | 29:4a11413cf217 | 152 | break; |
AzureIoTClient | 29:4a11413cf217 | 153 | |
AzureIoTClient | 29:4a11413cf217 | 154 | case IO_STATE_OPEN: |
AzureIoTClient | 29:4a11413cf217 | 155 | /* Codes_SRS_HEADER_DETECT_IO_01_051: [ If `buffer` is NULL or `size` is 0 while the IO is OPEN an error shall be indicated by calling `on_io_error`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 156 | indicate_error(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 157 | break; |
AzureIoTClient | 29:4a11413cf217 | 158 | } |
AzureIoTClient | 29:4a11413cf217 | 159 | } |
AzureIoTClient | 29:4a11413cf217 | 160 | else |
AzureIoTClient | 28:add19eb7defa | 161 | { |
AzureIoTClient | 29:4a11413cf217 | 162 | while (size > 0) |
AzureIoTClient | 29:4a11413cf217 | 163 | { |
AzureIoTClient | 29:4a11413cf217 | 164 | switch (header_detect_io_instance->io_state) |
AzureIoTClient | 29:4a11413cf217 | 165 | { |
AzureIoTClient | 29:4a11413cf217 | 166 | default: |
AzureIoTClient | 29:4a11413cf217 | 167 | break; |
AzureIoTClient | 29:4a11413cf217 | 168 | |
AzureIoTClient | 29:4a11413cf217 | 169 | case IO_STATE_OPENING_UNDERLYING_IO: |
AzureIoTClient | 29:4a11413cf217 | 170 | /* Codes_SRS_HEADER_DETECT_IO_01_049: [ When `on_underlying_io_bytes_received` is called while opening the underlying IO (before the underlying open complete is received), an error shall be indicated by calling `on_io_open_complete` with `IO_OPEN_ERROR`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 171 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 172 | size = 0; |
AzureIoTClient | 29:4a11413cf217 | 173 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 174 | |
AzureIoTClient | 29:4a11413cf217 | 175 | case IO_STATE_OPENING_DETECTED_IO: |
AzureIoTClient | 29:4a11413cf217 | 176 | { |
AzureIoTClient | 29:4a11413cf217 | 177 | /* Codes_SRS_HEADER_DETECT_IO_01_087: [ If `on_underlying_io_bytes_received` is called while waiting for the detected IO to complete its open, the bytes shall be given to the last created IO by calling its `on_bytes_received` callback that was filled into the `on_bytes_received` member of `SERVER_PROTOCOL_IO_CONFIG`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 178 | CHAINED_IO* chained_io = (CHAINED_IO*)(((unsigned char*)header_detect_io_instance->last_io) - offsetof(CHAINED_IO, detected_io)); |
AzureIoTClient | 29:4a11413cf217 | 179 | (chained_io->on_bytes_received)(chained_io->on_bytes_received_context, buffer, size); |
AzureIoTClient | 29:4a11413cf217 | 180 | size = 0; |
AzureIoTClient | 29:4a11413cf217 | 181 | break; |
AzureIoTClient | 29:4a11413cf217 | 182 | } |
AzureIoTClient | 29:4a11413cf217 | 183 | |
AzureIoTClient | 29:4a11413cf217 | 184 | case IO_STATE_WAIT_FOR_HEADER: |
AzureIoTClient | 29:4a11413cf217 | 185 | { |
AzureIoTClient | 29:4a11413cf217 | 186 | size_t i; |
AzureIoTClient | 29:4a11413cf217 | 187 | bool has_one_match = false; |
AzureIoTClient | 29:4a11413cf217 | 188 | |
AzureIoTClient | 29:4a11413cf217 | 189 | /* check if any of the headers matches */ |
AzureIoTClient | 29:4a11413cf217 | 190 | for (i = 0; i < header_detect_io_instance->header_detect_entry_count; i++) |
AzureIoTClient | 29:4a11413cf217 | 191 | { |
AzureIoTClient | 29:4a11413cf217 | 192 | /* Codes_SRS_HEADER_DETECT_IO_01_067: [ When `on_underlying_io_bytes_received` is called while waiting for header bytes (after the underlying IO was open), the bytes shall be matched against the entries provided in the configuration passed to `header_detect_io_create`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 193 | /* Codes_SRS_HEADER_DETECT_IO_01_068: [ Header bytes shall be accepted in multiple `on_underlying_io_bytes_received` calls. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 194 | if ((header_detect_io_instance->header_pos < header_detect_io_instance->header_detect_entries[i].header_size) && |
AzureIoTClient | 29:4a11413cf217 | 195 | (header_detect_io_instance->header_detect_entries[i].header_bytes[header_detect_io_instance->header_pos] == buffer[0])) |
AzureIoTClient | 29:4a11413cf217 | 196 | { |
AzureIoTClient | 29:4a11413cf217 | 197 | has_one_match = true; |
Azure.IoT Build | 0:6ae2f7bca550 | 198 | |
AzureIoTClient | 29:4a11413cf217 | 199 | if (header_detect_io_instance->header_pos + 1 == header_detect_io_instance->header_detect_entries[i].header_size) |
AzureIoTClient | 29:4a11413cf217 | 200 | { |
AzureIoTClient | 29:4a11413cf217 | 201 | /* recognized one header */ |
AzureIoTClient | 29:4a11413cf217 | 202 | if (xio_send(*header_detect_io_instance->last_io, header_detect_io_instance->header_detect_entries[i].header_bytes, header_detect_io_instance->header_detect_entries[i].header_size, on_send_complete, header_detect_io_instance) != 0) |
AzureIoTClient | 29:4a11413cf217 | 203 | { |
AzureIoTClient | 29:4a11413cf217 | 204 | LogError("Failed sending header"); |
AzureIoTClient | 29:4a11413cf217 | 205 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
AzureIoTClient | 29:4a11413cf217 | 206 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 207 | } |
AzureIoTClient | 29:4a11413cf217 | 208 | else |
AzureIoTClient | 29:4a11413cf217 | 209 | { |
AzureIoTClient | 29:4a11413cf217 | 210 | // wait for send complete and then start the detected IO open |
AzureIoTClient | 29:4a11413cf217 | 211 | if (header_detect_io_instance->header_detect_entries[i].io_interface_description == NULL) |
AzureIoTClient | 29:4a11413cf217 | 212 | { |
AzureIoTClient | 29:4a11413cf217 | 213 | header_detect_io_instance->io_state = IO_STATE_OPEN; |
AzureIoTClient | 29:4a11413cf217 | 214 | indicate_open_complete(header_detect_io_instance, IO_OPEN_OK); |
AzureIoTClient | 29:4a11413cf217 | 215 | } |
AzureIoTClient | 29:4a11413cf217 | 216 | else |
AzureIoTClient | 29:4a11413cf217 | 217 | { |
AzureIoTClient | 29:4a11413cf217 | 218 | SERVER_PROTOCOL_IO_CONFIG server_protocol_io_config; |
AzureIoTClient | 29:4a11413cf217 | 219 | CHAINED_IO* chained_io = (CHAINED_IO*)malloc(sizeof(CHAINED_IO)); |
AzureIoTClient | 29:4a11413cf217 | 220 | if (chained_io == NULL) |
AzureIoTClient | 29:4a11413cf217 | 221 | { |
AzureIoTClient | 29:4a11413cf217 | 222 | LogError("Cannot allocate memory for chained IO"); |
AzureIoTClient | 29:4a11413cf217 | 223 | internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 224 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 225 | } |
AzureIoTClient | 29:4a11413cf217 | 226 | else |
AzureIoTClient | 29:4a11413cf217 | 227 | { |
AzureIoTClient | 29:4a11413cf217 | 228 | /* Codes_SRS_HEADER_DETECT_IO_01_076: [ If no detected IO was created then the underlying IO in the `SERVER_PROTOCOL_IO_CONFIG` structure shall be set to the `underlying_io` passed in the create arguments. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 229 | /* Codes_SRS_HEADER_DETECT_IO_01_075: [ The underlying IO in the `SERVER_PROTOCOL_IO_CONFIG` structure shall be set to the last detected IO that was created if any. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 230 | server_protocol_io_config.underlying_io = *header_detect_io_instance->last_io; |
AzureIoTClient | 29:4a11413cf217 | 231 | server_protocol_io_config.on_bytes_received = &chained_io->on_bytes_received; |
AzureIoTClient | 29:4a11413cf217 | 232 | server_protocol_io_config.on_bytes_received_context = &chained_io->on_bytes_received_context; |
AzureIoTClient | 29:4a11413cf217 | 233 | |
AzureIoTClient | 29:4a11413cf217 | 234 | /* Codes_SRS_HEADER_DETECT_IO_01_069: [ If a header match was detected on an entry with a non-NULL io handle, a new IO associated shall be created by calling `xio_create`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 235 | /* Codes_SRS_HEADER_DETECT_IO_01_073: [ The interface description passed to `xio_create` shall be the interface description associated with the detected header. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 236 | /* Codes_SRS_HEADER_DETECT_IO_01_074: [ The IO create parameters shall be a `SERVER_PROTOCOL_IO_CONFIG` structure. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 237 | chained_io->detected_io = xio_create(header_detect_io_instance->header_detect_entries[i].io_interface_description, &server_protocol_io_config); |
AzureIoTClient | 29:4a11413cf217 | 238 | if (chained_io->detected_io == NULL) |
AzureIoTClient | 29:4a11413cf217 | 239 | { |
AzureIoTClient | 29:4a11413cf217 | 240 | /* Codes_SRS_HEADER_DETECT_IO_01_077: [ If `xio_create` fails the header detect IO shall be closed and an error shall be indicated by calling `on_io_open_complete` with `IO_OPEN_ERROR`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 241 | LogError("Creating detected IO failed"); |
AzureIoTClient | 29:4a11413cf217 | 242 | free(chained_io); |
AzureIoTClient | 29:4a11413cf217 | 243 | internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 244 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 245 | } |
AzureIoTClient | 29:4a11413cf217 | 246 | else |
AzureIoTClient | 29:4a11413cf217 | 247 | { |
AzureIoTClient | 29:4a11413cf217 | 248 | /* Codes_SRS_HEADER_DETECT_IO_01_086: [ The newly created IO shall be added to the chain of IOs by calling `singlylinkedlist_add`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 249 | LIST_ITEM_HANDLE new_list_item = singlylinkedlist_add(header_detect_io_instance->chained_io_list, chained_io); |
AzureIoTClient | 29:4a11413cf217 | 250 | if (new_list_item == NULL) |
AzureIoTClient | 29:4a11413cf217 | 251 | { |
AzureIoTClient | 29:4a11413cf217 | 252 | /* Codes_SRS_HEADER_DETECT_IO_01_084: [ If `singlylinkedlist_add` fails the newly created IO shall be destroyed and an error shall be indicated by calling `on_io_open_complete` with `IO_OPEN_ERROR`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 253 | LogError("Cannot add detected IO to list"); |
AzureIoTClient | 29:4a11413cf217 | 254 | xio_destroy(chained_io->detected_io); |
AzureIoTClient | 29:4a11413cf217 | 255 | free(chained_io); |
AzureIoTClient | 29:4a11413cf217 | 256 | internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 257 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 258 | } |
AzureIoTClient | 29:4a11413cf217 | 259 | else |
AzureIoTClient | 29:4a11413cf217 | 260 | { |
AzureIoTClient | 29:4a11413cf217 | 261 | /* Codes_SRS_HEADER_DETECT_IO_01_063: [ `header_detect_io_close_async` shall close the last detected IO that was created as a result of matching a header. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 262 | XIO_HANDLE* previous_last_io = header_detect_io_instance->last_io; |
AzureIoTClient | 29:4a11413cf217 | 263 | header_detect_io_instance->last_io = &chained_io->detected_io; |
AzureIoTClient | 29:4a11413cf217 | 264 | |
AzureIoTClient | 29:4a11413cf217 | 265 | /* Codes_SRS_HEADER_DETECT_IO_01_083: [ The header detect IO shall wait for opening of the detected IO (signaled by the `on_underlying_io_open_complete`). ]*/ |
AzureIoTClient | 29:4a11413cf217 | 266 | header_detect_io_instance->io_state = IO_STATE_OPENING_DETECTED_IO; |
AzureIoTClient | 29:4a11413cf217 | 267 | |
AzureIoTClient | 29:4a11413cf217 | 268 | /* Codes_SRS_HEADER_DETECT_IO_01_078: [ The newly create IO shall be open by calling `xio_open`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 269 | /* Codes_SRS_HEADER_DETECT_IO_01_079: [ The `on_io_open_complete` callback passed to `xio_open` shall be `on_underlying_io_open_complete`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 270 | /* Codes_SRS_HEADER_DETECT_IO_01_080: [ The `on_bytes_received` callback passed to `xio_open` shall be `on_underlying_io_bytes_received`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 271 | /* Codes_SRS_HEADER_DETECT_IO_01_081: [ The `on_io_error` callback passed to `xio_open` shall be `on_underlying_io_error`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 272 | if (xio_open(chained_io->detected_io, on_underlying_io_open_complete, header_detect_io_instance, on_underlying_io_bytes_received, header_detect_io_instance, on_underlying_io_error, header_detect_io_instance) != 0) |
AzureIoTClient | 29:4a11413cf217 | 273 | { |
AzureIoTClient | 29:4a11413cf217 | 274 | /* Codes_SRS_HEADER_DETECT_IO_01_082: [ If `xio_open` fails the header detect IO shall be closed and an error shall be indicated by calling `on_io_open_complete` with `IO_OPEN_ERROR`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 275 | LogError("Opening detected IO failed"); |
AzureIoTClient | 29:4a11413cf217 | 276 | if (singlylinkedlist_remove(header_detect_io_instance->chained_io_list, new_list_item) != 0) |
AzureIoTClient | 29:4a11413cf217 | 277 | { |
AzureIoTClient | 29:4a11413cf217 | 278 | LogError("Cannot remove chained IO from list"); |
AzureIoTClient | 29:4a11413cf217 | 279 | } |
AzureIoTClient | 29:4a11413cf217 | 280 | |
AzureIoTClient | 29:4a11413cf217 | 281 | xio_destroy(chained_io->detected_io); |
AzureIoTClient | 29:4a11413cf217 | 282 | free(chained_io); |
AzureIoTClient | 29:4a11413cf217 | 283 | header_detect_io_instance->last_io = previous_last_io; |
AzureIoTClient | 29:4a11413cf217 | 284 | internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 285 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 286 | } |
AzureIoTClient | 29:4a11413cf217 | 287 | else |
AzureIoTClient | 29:4a11413cf217 | 288 | { |
AzureIoTClient | 29:4a11413cf217 | 289 | // all OK |
AzureIoTClient | 29:4a11413cf217 | 290 | } |
AzureIoTClient | 29:4a11413cf217 | 291 | } |
AzureIoTClient | 29:4a11413cf217 | 292 | } |
AzureIoTClient | 29:4a11413cf217 | 293 | } |
AzureIoTClient | 29:4a11413cf217 | 294 | } |
AzureIoTClient | 29:4a11413cf217 | 295 | } |
AzureIoTClient | 29:4a11413cf217 | 296 | |
AzureIoTClient | 29:4a11413cf217 | 297 | break; |
AzureIoTClient | 29:4a11413cf217 | 298 | } |
AzureIoTClient | 29:4a11413cf217 | 299 | } |
AzureIoTClient | 29:4a11413cf217 | 300 | } |
AzureIoTClient | 29:4a11413cf217 | 301 | |
AzureIoTClient | 29:4a11413cf217 | 302 | if (has_one_match) |
AzureIoTClient | 28:add19eb7defa | 303 | { |
AzureIoTClient | 29:4a11413cf217 | 304 | if (header_detect_io_instance->io_state == IO_STATE_OPENING_DETECTED_IO) |
AzureIoTClient | 29:4a11413cf217 | 305 | { |
AzureIoTClient | 29:4a11413cf217 | 306 | header_detect_io_instance->header_pos = 0; |
AzureIoTClient | 29:4a11413cf217 | 307 | } |
AzureIoTClient | 29:4a11413cf217 | 308 | else |
AzureIoTClient | 29:4a11413cf217 | 309 | { |
AzureIoTClient | 29:4a11413cf217 | 310 | header_detect_io_instance->header_pos++; |
AzureIoTClient | 29:4a11413cf217 | 311 | } |
AzureIoTClient | 29:4a11413cf217 | 312 | |
AzureIoTClient | 29:4a11413cf217 | 313 | size--; |
AzureIoTClient | 29:4a11413cf217 | 314 | buffer++; |
AzureIoTClient | 28:add19eb7defa | 315 | } |
AzureIoTClient | 28:add19eb7defa | 316 | else |
AzureIoTClient | 28:add19eb7defa | 317 | { |
AzureIoTClient | 29:4a11413cf217 | 318 | /* all header matches failed, we can't proceed, send back to the peer the first header we know of, */ |
AzureIoTClient | 29:4a11413cf217 | 319 | /* then close as per spec. We do not care if we fail sending */ |
AzureIoTClient | 29:4a11413cf217 | 320 | if (xio_send(header_detect_io_instance->underlying_io, header_detect_io_instance->header_detect_entries[0].header_bytes, header_detect_io_instance->header_detect_entries[0].header_size, NULL, NULL) != 0) |
AzureIoTClient | 29:4a11413cf217 | 321 | { |
AzureIoTClient | 29:4a11413cf217 | 322 | LogError("Failed sending header"); |
AzureIoTClient | 29:4a11413cf217 | 323 | } |
AzureIoTClient | 29:4a11413cf217 | 324 | |
AzureIoTClient | 29:4a11413cf217 | 325 | internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 326 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 327 | size = 0; |
AzureIoTClient | 28:add19eb7defa | 328 | } |
AzureIoTClient | 29:4a11413cf217 | 329 | |
AzureIoTClient | 29:4a11413cf217 | 330 | break; |
AzureIoTClient | 29:4a11413cf217 | 331 | } |
AzureIoTClient | 29:4a11413cf217 | 332 | |
AzureIoTClient | 29:4a11413cf217 | 333 | case IO_STATE_OPEN: |
AzureIoTClient | 29:4a11413cf217 | 334 | /* Codes_SRS_HEADER_DETECT_IO_01_089: [ If `on_underlying_io_bytes_received` is called while header detect IO is OPEN the bytes shall be given to the user via the `on_bytes_received` callback that was the `on_bytes_received` callback passed to `header_detect_io_open_async`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 335 | /* Codes_SRS_HEADER_DETECT_IO_01_090: [ If no detected IOs were created and `on_underlying_io_bytes_received` is called while header detect IO is OPEN, the `on_bytes_received` callback passed to `header_detect_io_open_async` shall be called to indicate the bytes as received. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 336 | header_detect_io_instance->on_bytes_received(header_detect_io_instance->on_bytes_received_context, buffer, size); |
AzureIoTClient | 29:4a11413cf217 | 337 | size = 0; |
AzureIoTClient | 29:4a11413cf217 | 338 | break; |
AzureIoTClient | 28:add19eb7defa | 339 | } |
AzureIoTClient | 28:add19eb7defa | 340 | } |
AzureIoTClient | 28:add19eb7defa | 341 | } |
AzureIoTClient | 28:add19eb7defa | 342 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 343 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 344 | |
Azure.IoT Build | 0:6ae2f7bca550 | 345 | static void on_underlying_io_close_complete(void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 346 | { |
AzureIoTClient | 28:add19eb7defa | 347 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 348 | |
AzureIoTClient | 28:add19eb7defa | 349 | switch (header_detect_io_instance->io_state) |
AzureIoTClient | 28:add19eb7defa | 350 | { |
AzureIoTClient | 28:add19eb7defa | 351 | default: |
AzureIoTClient | 28:add19eb7defa | 352 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 353 | |
Azure.IoT Build | 0:6ae2f7bca550 | 354 | case IO_STATE_CLOSING: |
AzureIoTClient | 29:4a11413cf217 | 355 | /* Codes_SRS_HEADER_DETECT_IO_01_095: [ When `on_underlying_io_open_complete` is called when the IO is closing, it shall destroy all the detected IOs that were created. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 356 | destroy_io_chain(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 357 | |
Azure.IoT Build | 0:6ae2f7bca550 | 358 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 359 | indicate_close_complete(header_detect_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 360 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 361 | |
AzureIoTClient | 28:add19eb7defa | 362 | case IO_STATE_WAIT_FOR_HEADER: |
AzureIoTClient | 29:4a11413cf217 | 363 | case IO_STATE_OPENING_DETECTED_IO: |
AzureIoTClient | 28:add19eb7defa | 364 | case IO_STATE_OPENING_UNDERLYING_IO: |
AzureIoTClient | 28:add19eb7defa | 365 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
AzureIoTClient | 28:add19eb7defa | 366 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 28:add19eb7defa | 367 | break; |
AzureIoTClient | 28:add19eb7defa | 368 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 369 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 370 | |
Azure.IoT Build | 0:6ae2f7bca550 | 371 | static void on_underlying_io_open_complete(void* context, IO_OPEN_RESULT open_result) |
Azure.IoT Build | 0:6ae2f7bca550 | 372 | { |
AzureIoTClient | 29:4a11413cf217 | 373 | if (context == NULL) |
AzureIoTClient | 28:add19eb7defa | 374 | { |
AzureIoTClient | 29:4a11413cf217 | 375 | /* Codes_SRS_HEADER_DETECT_IO_01_048: [ If `context` is NULL, `on_underlying_io_open_complete` shall do nothing. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 376 | LogError("NULL context"); |
AzureIoTClient | 29:4a11413cf217 | 377 | } |
AzureIoTClient | 29:4a11413cf217 | 378 | else |
AzureIoTClient | 29:4a11413cf217 | 379 | { |
AzureIoTClient | 29:4a11413cf217 | 380 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 381 | |
AzureIoTClient | 28:add19eb7defa | 382 | if (open_result == IO_OPEN_OK) |
AzureIoTClient | 28:add19eb7defa | 383 | { |
AzureIoTClient | 29:4a11413cf217 | 384 | switch (header_detect_io_instance->io_state) |
AzureIoTClient | 29:4a11413cf217 | 385 | { |
AzureIoTClient | 29:4a11413cf217 | 386 | default: |
AzureIoTClient | 29:4a11413cf217 | 387 | LogError("on_io_open_complete called in unexpected state: %d", (int)header_detect_io_instance->io_state); |
AzureIoTClient | 29:4a11413cf217 | 388 | break; |
AzureIoTClient | 29:4a11413cf217 | 389 | |
AzureIoTClient | 29:4a11413cf217 | 390 | case IO_STATE_OPENING_DETECTED_IO: |
AzureIoTClient | 29:4a11413cf217 | 391 | case IO_STATE_OPENING_UNDERLYING_IO: |
AzureIoTClient | 29:4a11413cf217 | 392 | /* Codes_SRS_HEADER_DETECT_IO_01_046: [ When `on_underlying_io_open_complete` is called with `open_result` being `IO_OPEN_OK` while OPENING, the IO shall start monitoring received bytes in order to detect headers. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 393 | header_detect_io_instance->io_state = IO_STATE_WAIT_FOR_HEADER; |
AzureIoTClient | 29:4a11413cf217 | 394 | break; |
AzureIoTClient | 29:4a11413cf217 | 395 | } |
AzureIoTClient | 28:add19eb7defa | 396 | } |
AzureIoTClient | 28:add19eb7defa | 397 | else |
AzureIoTClient | 28:add19eb7defa | 398 | { |
AzureIoTClient | 29:4a11413cf217 | 399 | switch (header_detect_io_instance->io_state) |
AzureIoTClient | 28:add19eb7defa | 400 | { |
AzureIoTClient | 29:4a11413cf217 | 401 | default: |
AzureIoTClient | 29:4a11413cf217 | 402 | LogError("on_io_open_complete called in unexpected state: %d", (int)header_detect_io_instance->io_state); |
AzureIoTClient | 29:4a11413cf217 | 403 | break; |
AzureIoTClient | 29:4a11413cf217 | 404 | |
AzureIoTClient | 29:4a11413cf217 | 405 | case IO_STATE_OPENING_DETECTED_IO: |
AzureIoTClient | 29:4a11413cf217 | 406 | case IO_STATE_OPENING_UNDERLYING_IO: |
AzureIoTClient | 29:4a11413cf217 | 407 | /* Codes_SRS_HEADER_DETECT_IO_01_047: [ When `on_underlying_io_open_complete` is called with `open_result` being `IO_OPEN_ERROR` while OPENING, the `on_io_open_complete` callback passed to `header_detect_io_open` shall be called with `IO_OPEN_ERROR`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 408 | internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 409 | |
AzureIoTClient | 28:add19eb7defa | 410 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
AzureIoTClient | 28:add19eb7defa | 411 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 412 | break; |
AzureIoTClient | 28:add19eb7defa | 413 | } |
AzureIoTClient | 28:add19eb7defa | 414 | } |
AzureIoTClient | 28:add19eb7defa | 415 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 416 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 417 | |
Azure.IoT Build | 0:6ae2f7bca550 | 418 | static void on_underlying_io_error(void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 419 | { |
AzureIoTClient | 29:4a11413cf217 | 420 | if (context == NULL) |
AzureIoTClient | 29:4a11413cf217 | 421 | { |
AzureIoTClient | 29:4a11413cf217 | 422 | /* Codes_SRS_HEADER_DETECT_IO_01_058: [ If `context` is NULL, `on_underlying_io_error` shall do nothing. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 423 | LogError("NULL context"); |
AzureIoTClient | 29:4a11413cf217 | 424 | } |
AzureIoTClient | 29:4a11413cf217 | 425 | else |
AzureIoTClient | 29:4a11413cf217 | 426 | { |
AzureIoTClient | 29:4a11413cf217 | 427 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 428 | |
AzureIoTClient | 29:4a11413cf217 | 429 | switch (header_detect_io_instance->io_state) |
AzureIoTClient | 29:4a11413cf217 | 430 | { |
AzureIoTClient | 29:4a11413cf217 | 431 | default: |
AzureIoTClient | 29:4a11413cf217 | 432 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 433 | |
AzureIoTClient | 29:4a11413cf217 | 434 | case IO_STATE_WAIT_FOR_HEADER: |
AzureIoTClient | 29:4a11413cf217 | 435 | case IO_STATE_OPENING_DETECTED_IO: |
AzureIoTClient | 29:4a11413cf217 | 436 | case IO_STATE_OPENING_UNDERLYING_IO: |
AzureIoTClient | 29:4a11413cf217 | 437 | /* Tests_SRS_HEADER_DETECT_IO_01_057: [ When `on_underlying_io_error` is called while OPENING, the IO shall indicate an error by calling `on_io_open_complete` with `IO_OPEN_ERROR` and it shall close the underlying IOs. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 438 | internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 439 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
AzureIoTClient | 29:4a11413cf217 | 440 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 441 | |
AzureIoTClient | 29:4a11413cf217 | 442 | case IO_STATE_OPEN: |
AzureIoTClient | 29:4a11413cf217 | 443 | /* Codes_SRS_HEADER_DETECT_IO_01_059: [ When `on_underlying_io_error` is called while OPEN, the error should be indicated to the consumer by calling `on_io_error` and passing the `on_io_error_context` to it. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 444 | header_detect_io_instance->io_state = IO_STATE_ERROR; |
AzureIoTClient | 29:4a11413cf217 | 445 | indicate_error(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 446 | break; |
AzureIoTClient | 29:4a11413cf217 | 447 | } |
AzureIoTClient | 28:add19eb7defa | 448 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 449 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 450 | |
AzureIoTClient | 29:4a11413cf217 | 451 | static CONCRETE_IO_HANDLE header_detect_io_create(void* io_create_parameters) |
Azure.IoT Build | 0:6ae2f7bca550 | 452 | { |
AzureIoTClient | 28:add19eb7defa | 453 | HEADER_DETECT_IO_INSTANCE* result; |
Azure.IoT Build | 0:6ae2f7bca550 | 454 | |
AzureIoTClient | 28:add19eb7defa | 455 | if (io_create_parameters == NULL) |
AzureIoTClient | 28:add19eb7defa | 456 | { |
AzureIoTClient | 29:4a11413cf217 | 457 | /* Codes_SRS_HEADER_DETECT_IO_01_003: [ If `io_create_parameters` is NULL, `header_detect_io_create` shall fail and return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 458 | LogError("NULL io_create_parameters"); |
AzureIoTClient | 28:add19eb7defa | 459 | result = NULL; |
AzureIoTClient | 28:add19eb7defa | 460 | } |
AzureIoTClient | 28:add19eb7defa | 461 | else |
AzureIoTClient | 28:add19eb7defa | 462 | { |
AzureIoTClient | 29:4a11413cf217 | 463 | /* Codes_SRS_HEADER_DETECT_IO_01_004: [ `io_create_parameters` shall be used as `HEADER_DETECT_IO_CONFIG*`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 464 | HEADER_DETECT_IO_CONFIG* header_detect_io_config = (HEADER_DETECT_IO_CONFIG*)io_create_parameters; |
AzureIoTClient | 29:4a11413cf217 | 465 | |
AzureIoTClient | 29:4a11413cf217 | 466 | /* Codes_SRS_HEADER_DETECT_IO_01_005: [ If the member `header_detect_entry_count` of `HEADER_DETECT_IO_CONFIG` is 0 then `header_detect_io_create` shall fail and return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 467 | if ((header_detect_io_config->header_detect_entry_count == 0) || |
AzureIoTClient | 29:4a11413cf217 | 468 | /* Codes_SRS_HEADER_DETECT_IO_01_006: [ If the member `header_detect_entries` is NULL then `header_detect_io_create` shall fail and return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 469 | (header_detect_io_config->header_detect_entries == NULL) || |
AzureIoTClient | 29:4a11413cf217 | 470 | /* Codes_SRS_HEADER_DETECT_IO_01_007: [ If the member `underlying_io` is NULL then `header_detect_io_create` shall fail and return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 471 | (header_detect_io_config->underlying_io == NULL)) |
AzureIoTClient | 29:4a11413cf217 | 472 | { |
AzureIoTClient | 29:4a11413cf217 | 473 | LogError("Bad create parameters: header_detect_entry_count = %u, header_detect_entries = %p, underlying_io = %p", |
AzureIoTClient | 29:4a11413cf217 | 474 | header_detect_io_config->header_detect_entry_count, |
AzureIoTClient | 29:4a11413cf217 | 475 | header_detect_io_config->header_detect_entries, |
AzureIoTClient | 29:4a11413cf217 | 476 | header_detect_io_config->underlying_io); |
AzureIoTClient | 29:4a11413cf217 | 477 | result = NULL; |
AzureIoTClient | 29:4a11413cf217 | 478 | } |
AzureIoTClient | 29:4a11413cf217 | 479 | else |
AzureIoTClient | 28:add19eb7defa | 480 | { |
AzureIoTClient | 29:4a11413cf217 | 481 | size_t i; |
AzureIoTClient | 29:4a11413cf217 | 482 | bool null_io_found = false; |
AzureIoTClient | 29:4a11413cf217 | 483 | |
AzureIoTClient | 29:4a11413cf217 | 484 | for (i = 0; i < header_detect_io_config->header_detect_entry_count; i++) |
AzureIoTClient | 29:4a11413cf217 | 485 | { |
AzureIoTClient | 29:4a11413cf217 | 486 | /* Codes_SRS_HEADER_DETECT_IO_01_052: [ The `io` member in the in each of the `header_detect_entries` shall be allowed to be NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 487 | if (header_detect_io_config->header_detect_entries[i].header.header_bytes == NULL) |
AzureIoTClient | 29:4a11413cf217 | 488 | { |
AzureIoTClient | 29:4a11413cf217 | 489 | LogError("header detect entry %u is invalid", (unsigned int)i); |
AzureIoTClient | 29:4a11413cf217 | 490 | break; |
AzureIoTClient | 29:4a11413cf217 | 491 | } |
AzureIoTClient | 29:4a11413cf217 | 492 | |
AzureIoTClient | 29:4a11413cf217 | 493 | if (header_detect_io_config->header_detect_entries[i].io_interface_description == NULL) |
AzureIoTClient | 29:4a11413cf217 | 494 | { |
AzureIoTClient | 29:4a11413cf217 | 495 | null_io_found = true; |
AzureIoTClient | 29:4a11413cf217 | 496 | } |
AzureIoTClient | 29:4a11413cf217 | 497 | } |
AzureIoTClient | 29:4a11413cf217 | 498 | |
AzureIoTClient | 29:4a11413cf217 | 499 | if (i < header_detect_io_config->header_detect_entry_count) |
AzureIoTClient | 29:4a11413cf217 | 500 | { |
AzureIoTClient | 29:4a11413cf217 | 501 | result = NULL; |
AzureIoTClient | 29:4a11413cf217 | 502 | } |
AzureIoTClient | 29:4a11413cf217 | 503 | else if (!null_io_found) |
AzureIoTClient | 29:4a11413cf217 | 504 | { |
AzureIoTClient | 29:4a11413cf217 | 505 | /* Codes_SRS_HEADER_DETECT_IO_01_054: [ At least one entry in `header_detect_entries` shall have IO set to NULL, otherwise `header_detect_io_create` shall fail and return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 506 | LogError("No default header found"); |
AzureIoTClient | 29:4a11413cf217 | 507 | result = NULL; |
AzureIoTClient | 29:4a11413cf217 | 508 | } |
AzureIoTClient | 29:4a11413cf217 | 509 | else |
AzureIoTClient | 29:4a11413cf217 | 510 | { |
AzureIoTClient | 29:4a11413cf217 | 511 | /* Codes_SRS_HEADER_DETECT_IO_01_001: [ `header_detect_io_create` shall create a new header detect IO instance and on success it shall return a non-NULL handle to the newly created instance. ] */ |
AzureIoTClient | 29:4a11413cf217 | 512 | result = (HEADER_DETECT_IO_INSTANCE*)malloc(sizeof(HEADER_DETECT_IO_INSTANCE)); |
AzureIoTClient | 29:4a11413cf217 | 513 | if (result == NULL) |
AzureIoTClient | 29:4a11413cf217 | 514 | { |
AzureIoTClient | 29:4a11413cf217 | 515 | /* Codes_SRS_HEADER_DETECT_IO_01_002: [ If allocating memory for the header detect IO instance fails, `header_detect_io_create` shall fail and return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 516 | LogError("Cannot allocate memory for header detect IO"); |
AzureIoTClient | 29:4a11413cf217 | 517 | } |
AzureIoTClient | 29:4a11413cf217 | 518 | else |
AzureIoTClient | 29:4a11413cf217 | 519 | { |
AzureIoTClient | 29:4a11413cf217 | 520 | /* Codes_SRS_HEADER_DETECT_IO_01_009: [ The `header_detect_entries` array shall be copied so that it can be later used when detecting which header was received. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 521 | result->header_detect_entries = (INTERNAL_HEADER_DETECT_ENTRY*)malloc(header_detect_io_config->header_detect_entry_count * sizeof(INTERNAL_HEADER_DETECT_ENTRY)); |
AzureIoTClient | 29:4a11413cf217 | 522 | if (result->header_detect_entries == NULL) |
AzureIoTClient | 29:4a11413cf217 | 523 | { |
AzureIoTClient | 29:4a11413cf217 | 524 | free(result); |
AzureIoTClient | 29:4a11413cf217 | 525 | result = NULL; |
AzureIoTClient | 29:4a11413cf217 | 526 | } |
AzureIoTClient | 29:4a11413cf217 | 527 | else |
AzureIoTClient | 29:4a11413cf217 | 528 | { |
AzureIoTClient | 29:4a11413cf217 | 529 | result->header_detect_entry_count = header_detect_io_config->header_detect_entry_count; |
Azure.IoT Build | 0:6ae2f7bca550 | 530 | |
AzureIoTClient | 29:4a11413cf217 | 531 | /* Codes_SRS_HEADER_DETECT_IO_01_009: [ The `header_detect_entries` array shall be copied so that it can be later used when detecting which header was received. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 532 | for (i = 0; i < header_detect_io_config->header_detect_entry_count; i++) |
AzureIoTClient | 29:4a11413cf217 | 533 | { |
AzureIoTClient | 29:4a11413cf217 | 534 | result->header_detect_entries[i].header_size = header_detect_io_config->header_detect_entries[i].header.header_size; |
AzureIoTClient | 29:4a11413cf217 | 535 | result->header_detect_entries[i].header_bytes = (unsigned char*)malloc(result->header_detect_entries[i].header_size); |
AzureIoTClient | 29:4a11413cf217 | 536 | if (result->header_detect_entries[i].header_bytes == NULL) |
AzureIoTClient | 29:4a11413cf217 | 537 | { |
AzureIoTClient | 29:4a11413cf217 | 538 | /* Codes_SRS_HEADER_DETECT_IO_01_010: [ If allocating memory for the `header_detect_entries` or its constituents fails then `header_detect_io_create` shall fail and return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 539 | break; |
AzureIoTClient | 29:4a11413cf217 | 540 | } |
AzureIoTClient | 29:4a11413cf217 | 541 | else |
AzureIoTClient | 29:4a11413cf217 | 542 | { |
AzureIoTClient | 29:4a11413cf217 | 543 | /* Codes_SRS_HEADER_DETECT_IO_01_014: [ For each entry in `header_detect_entries` the `header` field shall also be copied. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 544 | (void)memcpy(result->header_detect_entries[i].header_bytes, header_detect_io_config->header_detect_entries[i].header.header_bytes, result->header_detect_entries[i].header_size); |
AzureIoTClient | 29:4a11413cf217 | 545 | result->header_detect_entries[i].io_interface_description = header_detect_io_config->header_detect_entries[i].io_interface_description; |
AzureIoTClient | 29:4a11413cf217 | 546 | } |
AzureIoTClient | 29:4a11413cf217 | 547 | } |
AzureIoTClient | 29:4a11413cf217 | 548 | |
AzureIoTClient | 29:4a11413cf217 | 549 | if (i < header_detect_io_config->header_detect_entry_count) |
AzureIoTClient | 29:4a11413cf217 | 550 | { |
AzureIoTClient | 29:4a11413cf217 | 551 | size_t j; |
AzureIoTClient | 29:4a11413cf217 | 552 | |
AzureIoTClient | 29:4a11413cf217 | 553 | LogError("Failed copying header detect configuration"); |
AzureIoTClient | 29:4a11413cf217 | 554 | for (j = 0; j < i; j++) |
AzureIoTClient | 29:4a11413cf217 | 555 | { |
AzureIoTClient | 29:4a11413cf217 | 556 | free(result->header_detect_entries[j].header_bytes); |
AzureIoTClient | 29:4a11413cf217 | 557 | } |
AzureIoTClient | 29:4a11413cf217 | 558 | |
AzureIoTClient | 29:4a11413cf217 | 559 | free(result->header_detect_entries); |
AzureIoTClient | 29:4a11413cf217 | 560 | free(result); |
AzureIoTClient | 29:4a11413cf217 | 561 | result = NULL; |
AzureIoTClient | 29:4a11413cf217 | 562 | } |
AzureIoTClient | 29:4a11413cf217 | 563 | else |
AzureIoTClient | 29:4a11413cf217 | 564 | { |
AzureIoTClient | 30:0407b2db334c | 565 | /* Codes_SRS_HEADER_DETECT_IO_01_060: [ `header_detect_io_create` shall create a singly linked list by calling `singlylinkedlist_create` where the chained detected IOs shall be stored. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 566 | result->chained_io_list = singlylinkedlist_create(); |
AzureIoTClient | 29:4a11413cf217 | 567 | if (result->chained_io_list == NULL) |
AzureIoTClient | 29:4a11413cf217 | 568 | { |
AzureIoTClient | 29:4a11413cf217 | 569 | /* Codes_SRS_HEADER_DETECT_IO_01_065: [ If `singlylinkedlist_create` fails then `header_detect_io_create` shall fail and return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 570 | LogError("Failed copying header detect configuration"); |
AzureIoTClient | 29:4a11413cf217 | 571 | for (i = 0; i < result->header_detect_entry_count; i++) |
AzureIoTClient | 29:4a11413cf217 | 572 | { |
AzureIoTClient | 29:4a11413cf217 | 573 | free(result->header_detect_entries[i].header_bytes); |
AzureIoTClient | 29:4a11413cf217 | 574 | } |
AzureIoTClient | 29:4a11413cf217 | 575 | |
AzureIoTClient | 29:4a11413cf217 | 576 | free(result->header_detect_entries); |
AzureIoTClient | 29:4a11413cf217 | 577 | free(result); |
AzureIoTClient | 29:4a11413cf217 | 578 | result = NULL; |
AzureIoTClient | 29:4a11413cf217 | 579 | } |
AzureIoTClient | 29:4a11413cf217 | 580 | else |
AzureIoTClient | 29:4a11413cf217 | 581 | { |
AzureIoTClient | 29:4a11413cf217 | 582 | result->underlying_io = header_detect_io_config->underlying_io; |
AzureIoTClient | 29:4a11413cf217 | 583 | result->on_io_open_complete = NULL; |
AzureIoTClient | 29:4a11413cf217 | 584 | result->on_io_close_complete = NULL; |
AzureIoTClient | 29:4a11413cf217 | 585 | result->on_io_error = NULL; |
AzureIoTClient | 29:4a11413cf217 | 586 | result->on_bytes_received = NULL; |
AzureIoTClient | 29:4a11413cf217 | 587 | result->on_io_open_complete_context = NULL; |
AzureIoTClient | 29:4a11413cf217 | 588 | result->on_io_close_complete_context = NULL; |
AzureIoTClient | 29:4a11413cf217 | 589 | result->on_io_error_context = NULL; |
AzureIoTClient | 29:4a11413cf217 | 590 | result->on_bytes_received_context = NULL; |
AzureIoTClient | 29:4a11413cf217 | 591 | |
AzureIoTClient | 29:4a11413cf217 | 592 | /* Codes_SRS_HEADER_DETECT_IO_01_070: [ If no detected IO was created then `header_detect_io_close_async` shall close the `underlying_io` passed in `header_detect_io_create`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 593 | result->last_io = &result->underlying_io; |
AzureIoTClient | 29:4a11413cf217 | 594 | |
AzureIoTClient | 29:4a11413cf217 | 595 | result->io_state = IO_STATE_NOT_OPEN; |
AzureIoTClient | 29:4a11413cf217 | 596 | } |
AzureIoTClient | 29:4a11413cf217 | 597 | } |
AzureIoTClient | 29:4a11413cf217 | 598 | } |
AzureIoTClient | 29:4a11413cf217 | 599 | } |
AzureIoTClient | 29:4a11413cf217 | 600 | } |
AzureIoTClient | 28:add19eb7defa | 601 | } |
AzureIoTClient | 28:add19eb7defa | 602 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 603 | |
AzureIoTClient | 28:add19eb7defa | 604 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 605 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 606 | |
AzureIoTClient | 29:4a11413cf217 | 607 | static void header_detect_io_destroy(CONCRETE_IO_HANDLE header_detect_io) |
Azure.IoT Build | 0:6ae2f7bca550 | 608 | { |
AzureIoTClient | 29:4a11413cf217 | 609 | if (header_detect_io == NULL) |
AzureIoTClient | 29:4a11413cf217 | 610 | { |
AzureIoTClient | 29:4a11413cf217 | 611 | /* Codes_SRS_HEADER_DETECT_IO_01_012: [ If `header_detect_io` is NULL, `header_detect_io_destroy` shall do nothing. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 612 | LogError("NULL header_detect_io"); |
AzureIoTClient | 29:4a11413cf217 | 613 | } |
AzureIoTClient | 29:4a11413cf217 | 614 | else |
AzureIoTClient | 28:add19eb7defa | 615 | { |
AzureIoTClient | 29:4a11413cf217 | 616 | size_t i; |
AzureIoTClient | 28:add19eb7defa | 617 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
AzureIoTClient | 29:4a11413cf217 | 618 | |
AzureIoTClient | 29:4a11413cf217 | 619 | if (header_detect_io_instance->io_state != IO_STATE_NOT_OPEN) |
AzureIoTClient | 29:4a11413cf217 | 620 | { |
AzureIoTClient | 29:4a11413cf217 | 621 | /* Codes_SRS_HEADER_DETECT_IO_01_062: [ If the IO is still open when `header_detect_io_destroy` is called, all actions normally executed when closing the IO shall also be executed. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 622 | internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 623 | } |
AzureIoTClient | 29:4a11413cf217 | 624 | |
AzureIoTClient | 29:4a11413cf217 | 625 | /* Codes_SRS_HEADER_DETECT_IO_01_061: [ `header_detect_io_destroy` shall destroy the chained IO list by calling `singlylinkedlist_destroy`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 626 | singlylinkedlist_destroy(header_detect_io_instance->chained_io_list); |
AzureIoTClient | 29:4a11413cf217 | 627 | |
AzureIoTClient | 29:4a11413cf217 | 628 | /* Codes_SRS_HEADER_DETECT_IO_01_011: [ `header_detect_io_destroy` shall free all resources associated with the `header_detect_io` handle. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 629 | for (i = 0; i < header_detect_io_instance->header_detect_entry_count; i++) |
AzureIoTClient | 29:4a11413cf217 | 630 | { |
AzureIoTClient | 29:4a11413cf217 | 631 | /* Codes_SRS_HEADER_DETECT_IO_01_013: [ `header_detect_io_destroy` shall free the memory allocated for the `header_detect_entries`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 632 | free(header_detect_io_instance->header_detect_entries[i].header_bytes); |
AzureIoTClient | 29:4a11413cf217 | 633 | } |
AzureIoTClient | 29:4a11413cf217 | 634 | |
AzureIoTClient | 29:4a11413cf217 | 635 | free(header_detect_io_instance->header_detect_entries); |
AzureIoTClient | 29:4a11413cf217 | 636 | |
AzureIoTClient | 28:add19eb7defa | 637 | free(header_detect_io); |
AzureIoTClient | 28:add19eb7defa | 638 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 639 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 640 | |
AzureIoTClient | 29:4a11413cf217 | 641 | static int header_detect_io_open_async(CONCRETE_IO_HANDLE header_detect_io, ON_IO_OPEN_COMPLETE on_io_open_complete, void* on_io_open_complete_context, ON_BYTES_RECEIVED on_bytes_received, void* on_bytes_received_context, ON_IO_ERROR on_io_error, void* on_io_error_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 642 | { |
AzureIoTClient | 28:add19eb7defa | 643 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 644 | |
AzureIoTClient | 29:4a11413cf217 | 645 | if ((header_detect_io == NULL) || |
AzureIoTClient | 29:4a11413cf217 | 646 | (on_io_open_complete == NULL) || |
AzureIoTClient | 29:4a11413cf217 | 647 | (on_bytes_received == NULL) || |
AzureIoTClient | 29:4a11413cf217 | 648 | (on_io_error == NULL)) |
AzureIoTClient | 28:add19eb7defa | 649 | { |
AzureIoTClient | 29:4a11413cf217 | 650 | /* Codes_SRS_HEADER_DETECT_IO_01_021: [ If `header_detect_io`, `on_io_open_complete`, `on_bytes_received` or `on_io_error` is NULL, `header_detect_io_open_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 651 | LogError("Bad arguments: header_detect_io = %p, on_io_open_complete = %p, on_bytes_received = %p, on_io_error = %p", |
AzureIoTClient | 29:4a11413cf217 | 652 | header_detect_io, on_io_open_complete, on_bytes_received, on_io_error); |
AzureIoTClient | 28:add19eb7defa | 653 | result = __FAILURE__; |
AzureIoTClient | 28:add19eb7defa | 654 | } |
AzureIoTClient | 28:add19eb7defa | 655 | else |
AzureIoTClient | 28:add19eb7defa | 656 | { |
AzureIoTClient | 28:add19eb7defa | 657 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 658 | |
AzureIoTClient | 29:4a11413cf217 | 659 | if (header_detect_io_instance->io_state != IO_STATE_NOT_OPEN) |
Azure.IoT Build | 0:6ae2f7bca550 | 660 | { |
AzureIoTClient | 29:4a11413cf217 | 661 | /* Codes_SRS_HEADER_DETECT_IO_01_020: [ If the IO is already OPEN or OPENING then `header_detect_io_open_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 662 | LogError("Already OPEN"); |
AzureIoTClient | 19:000ab4e6a2c1 | 663 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 664 | } |
AzureIoTClient | 28:add19eb7defa | 665 | else |
AzureIoTClient | 28:add19eb7defa | 666 | { |
AzureIoTClient | 28:add19eb7defa | 667 | header_detect_io_instance->on_bytes_received = on_bytes_received; |
AzureIoTClient | 28:add19eb7defa | 668 | header_detect_io_instance->on_io_open_complete = on_io_open_complete; |
AzureIoTClient | 28:add19eb7defa | 669 | header_detect_io_instance->on_io_error = on_io_error; |
Azure.IoT Build | 0:6ae2f7bca550 | 670 | header_detect_io_instance->on_bytes_received_context = on_bytes_received_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 671 | header_detect_io_instance->on_io_open_complete_context = on_io_open_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 672 | header_detect_io_instance->on_io_error_context = on_io_error_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 673 | |
AzureIoTClient | 29:4a11413cf217 | 674 | header_detect_io_instance->io_state = IO_STATE_OPENING_UNDERLYING_IO; |
AzureIoTClient | 29:4a11413cf217 | 675 | header_detect_io_instance->header_pos = 0; |
AzureIoTClient | 29:4a11413cf217 | 676 | |
AzureIoTClient | 29:4a11413cf217 | 677 | /* Codes_SRS_HEADER_DETECT_IO_01_015: [ `header_detect_io_open_async` shall open the underlying IO by calling `xio_open` and passing to it: ]*/ |
AzureIoTClient | 29:4a11413cf217 | 678 | /* Codes_SRS_HEADER_DETECT_IO_01_016: [ - `xio` shall be the `underlying_io` member of the `io_create_parameters` passed to `header_detect_io_create`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 679 | /* Codes_SRS_HEADER_DETECT_IO_01_017: [ - `on_io_open_complete`, `on_io_open_complete_context`, `on_bytes_received`, `on_bytes_received_context`, `on_error` and `on_error_context` shall be set to implementation specific values of `header_detect_io`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 680 | if (xio_open(header_detect_io_instance->underlying_io, on_underlying_io_open_complete, header_detect_io_instance, on_underlying_io_bytes_received, header_detect_io_instance, on_underlying_io_error, header_detect_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 681 | { |
AzureIoTClient | 29:4a11413cf217 | 682 | /* Codes_SRS_HEADER_DETECT_IO_01_019: [ If `xio_open` fails, `header_detect_io_open_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 683 | LogError("xio_open failed"); |
AzureIoTClient | 29:4a11413cf217 | 684 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 685 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 686 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 687 | { |
AzureIoTClient | 29:4a11413cf217 | 688 | /* Codes_SRS_HEADER_DETECT_IO_01_018: [ On success `header_detect_io_open_async` shall return 0. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 689 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 690 | } |
AzureIoTClient | 28:add19eb7defa | 691 | } |
AzureIoTClient | 28:add19eb7defa | 692 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 693 | |
AzureIoTClient | 28:add19eb7defa | 694 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 695 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 696 | |
AzureIoTClient | 29:4a11413cf217 | 697 | static int header_detect_io_close_async(CONCRETE_IO_HANDLE header_detect_io, ON_IO_CLOSE_COMPLETE on_io_close_complete, void* callback_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 698 | { |
AzureIoTClient | 28:add19eb7defa | 699 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 700 | |
AzureIoTClient | 28:add19eb7defa | 701 | if (header_detect_io == NULL) |
AzureIoTClient | 28:add19eb7defa | 702 | { |
AzureIoTClient | 29:4a11413cf217 | 703 | /* Codes_SRS_HEADER_DETECT_IO_01_026: [ If `header_detect_io` is NULL, `header_detect_io_close_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 704 | LogError("NULL header_detect_io"); |
AzureIoTClient | 28:add19eb7defa | 705 | result = __FAILURE__; |
AzureIoTClient | 28:add19eb7defa | 706 | } |
AzureIoTClient | 28:add19eb7defa | 707 | else |
AzureIoTClient | 28:add19eb7defa | 708 | { |
AzureIoTClient | 28:add19eb7defa | 709 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 710 | |
AzureIoTClient | 29:4a11413cf217 | 711 | /* Codes_SRS_HEADER_DETECT_IO_01_027: [ If the IO is not OPEN (open has not been called or close has been completely carried out) `header_detect_io_close_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 712 | if ((header_detect_io_instance->io_state == IO_STATE_OPENING_UNDERLYING_IO) || |
AzureIoTClient | 29:4a11413cf217 | 713 | (header_detect_io_instance->io_state == IO_STATE_OPENING_DETECTED_IO) || |
AzureIoTClient | 29:4a11413cf217 | 714 | (header_detect_io_instance->io_state == IO_STATE_WAIT_FOR_HEADER)) |
AzureIoTClient | 29:4a11413cf217 | 715 | { |
AzureIoTClient | 29:4a11413cf217 | 716 | /* Codes_SRS_HEADER_DETECT_IO_01_028: [ If the IO is OPENING (`header_detect_io_open_async` has been called, but no header has been detected yet), `header_detect_io_close_async` shall close the underlying IO and call `on_io_open_complete` with `IO_OPEN_CANCELLED`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 717 | (void)internal_close(header_detect_io_instance); |
AzureIoTClient | 29:4a11413cf217 | 718 | header_detect_io_instance->on_io_open_complete(header_detect_io_instance->on_io_open_complete_context, IO_OPEN_CANCELLED); |
AzureIoTClient | 29:4a11413cf217 | 719 | result = 0; |
AzureIoTClient | 29:4a11413cf217 | 720 | } |
AzureIoTClient | 29:4a11413cf217 | 721 | else if ((header_detect_io_instance->io_state == IO_STATE_NOT_OPEN) || |
AzureIoTClient | 29:4a11413cf217 | 722 | /* Codes_SRS_HEADER_DETECT_IO_01_053: [ If the IO is CLOSING then `header_detect_io_close_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 28:add19eb7defa | 723 | (header_detect_io_instance->io_state == IO_STATE_CLOSING)) |
AzureIoTClient | 28:add19eb7defa | 724 | { |
AzureIoTClient | 29:4a11413cf217 | 725 | LogError("Not open"); |
AzureIoTClient | 28:add19eb7defa | 726 | result = __FAILURE__; |
AzureIoTClient | 28:add19eb7defa | 727 | } |
AzureIoTClient | 28:add19eb7defa | 728 | else |
AzureIoTClient | 28:add19eb7defa | 729 | { |
AzureIoTClient | 28:add19eb7defa | 730 | header_detect_io_instance->io_state = IO_STATE_CLOSING; |
Azure.IoT Build | 0:6ae2f7bca550 | 731 | header_detect_io_instance->on_io_close_complete = on_io_close_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 732 | header_detect_io_instance->on_io_close_complete_context = callback_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 733 | |
AzureIoTClient | 29:4a11413cf217 | 734 | /* Codes_SRS_HEADER_DETECT_IO_01_022: [ `header_detect_io_close_async` shall close the underlying IO by calling `xio_close` and passing to it: ]*/ |
AzureIoTClient | 29:4a11413cf217 | 735 | /* Codes_SRS_HEADER_DETECT_IO_01_023: [ - `xio` shall be the `underlying_io` member of the `io_create_parameters` passed to `header_detect_io_create`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 736 | /* Codes_SRS_HEADER_DETECT_IO_01_024: [ - `on_io_close_complete` shall be set to implementation specific values of `header_detect_io`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 737 | if (xio_close(*header_detect_io_instance->last_io, on_underlying_io_close_complete, header_detect_io_instance) != 0) |
AzureIoTClient | 28:add19eb7defa | 738 | { |
AzureIoTClient | 29:4a11413cf217 | 739 | /* Codes_SRS_HEADER_DETECT_IO_01_092: [ If `xio_close` fails `header_detect_io_close_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 740 | LogError("xio_close failed"); |
AzureIoTClient | 28:add19eb7defa | 741 | result = __FAILURE__; |
AzureIoTClient | 28:add19eb7defa | 742 | } |
AzureIoTClient | 28:add19eb7defa | 743 | else |
AzureIoTClient | 28:add19eb7defa | 744 | { |
AzureIoTClient | 29:4a11413cf217 | 745 | /* Codes_SRS_HEADER_DETECT_IO_01_025: [ On success `header_detect_io_close_async` shall return 0. ]*/ |
AzureIoTClient | 28:add19eb7defa | 746 | result = 0; |
AzureIoTClient | 28:add19eb7defa | 747 | } |
AzureIoTClient | 28:add19eb7defa | 748 | } |
AzureIoTClient | 28:add19eb7defa | 749 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 750 | |
AzureIoTClient | 28:add19eb7defa | 751 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 752 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 753 | |
AzureIoTClient | 29:4a11413cf217 | 754 | static int header_detect_io_send_async(CONCRETE_IO_HANDLE header_detect_io, const void* buffer, size_t size, ON_SEND_COMPLETE on_send_complete, void* callback_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 755 | { |
AzureIoTClient | 28:add19eb7defa | 756 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 757 | |
AzureIoTClient | 29:4a11413cf217 | 758 | /* Codes_SRS_HEADER_DETECT_IO_01_055: [ `on_send_complete` and `callback_context` shall be allowed to be NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 759 | if ((header_detect_io == NULL) || |
AzureIoTClient | 29:4a11413cf217 | 760 | (buffer == NULL) || |
AzureIoTClient | 29:4a11413cf217 | 761 | /* Codes_SRS_HEADER_DETECT_IO_01_034: [ If `size` is 0, `header_detect_io_send_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 762 | (size == 0)) |
AzureIoTClient | 28:add19eb7defa | 763 | { |
AzureIoTClient | 29:4a11413cf217 | 764 | /* Codes_SRS_HEADER_DETECT_IO_01_033: [ If `header_detect_io` or `buffer` is NULL, `header_detect_io_send_async` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 765 | LogError("Bad arguments: header_detect_io = %p, buffer = %p, size = %u", |
AzureIoTClient | 29:4a11413cf217 | 766 | header_detect_io, buffer, (unsigned int)size); |
AzureIoTClient | 28:add19eb7defa | 767 | result = __FAILURE__; |
AzureIoTClient | 28:add19eb7defa | 768 | } |
AzureIoTClient | 28:add19eb7defa | 769 | else |
AzureIoTClient | 28:add19eb7defa | 770 | { |
AzureIoTClient | 28:add19eb7defa | 771 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 772 | |
AzureIoTClient | 28:add19eb7defa | 773 | if (header_detect_io_instance->io_state != IO_STATE_OPEN) |
AzureIoTClient | 28:add19eb7defa | 774 | { |
AzureIoTClient | 29:4a11413cf217 | 775 | /* Codes_SRS_HEADER_DETECT_IO_01_093: [ `header_detect_io_send_async` when the IO is not open shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 776 | LogError("header_detect_io not OPEN"); |
AzureIoTClient | 28:add19eb7defa | 777 | result = __FAILURE__; |
AzureIoTClient | 28:add19eb7defa | 778 | } |
AzureIoTClient | 28:add19eb7defa | 779 | else |
AzureIoTClient | 28:add19eb7defa | 780 | { |
AzureIoTClient | 29:4a11413cf217 | 781 | /* Codes_SRS_HEADER_DETECT_IO_01_029: [ If no detected IO was created, `header_detect_io_send_async` shall send the bytes to the underlying IO passed via `header_detect_io_create`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 782 | /* Codes_SRS_HEADER_DETECT_IO_01_030: [ The `buffer`, `size`, `on_send_complete` and `callback_context` shall be passed as is to `xio_send`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 783 | /* Codes_SRS_HEADER_DETECT_IO_01_071: [ If the header IO is open `header_detect_io_send_async` shall send the bytes to the last detected IO by calling `xio_send` that was created as result of matching a header. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 784 | if (xio_send(*header_detect_io_instance->last_io, buffer, size, on_send_complete, callback_context) != 0) |
AzureIoTClient | 28:add19eb7defa | 785 | { |
AzureIoTClient | 29:4a11413cf217 | 786 | LogError("xio_send failed"); |
AzureIoTClient | 28:add19eb7defa | 787 | result = __FAILURE__; |
AzureIoTClient | 28:add19eb7defa | 788 | } |
AzureIoTClient | 28:add19eb7defa | 789 | else |
AzureIoTClient | 28:add19eb7defa | 790 | { |
AzureIoTClient | 29:4a11413cf217 | 791 | /* Codes_SRS_HEADER_DETECT_IO_01_031: [ On success `header_detect_io_send_async` shall return 0. ]*/ |
AzureIoTClient | 28:add19eb7defa | 792 | result = 0; |
AzureIoTClient | 28:add19eb7defa | 793 | } |
AzureIoTClient | 28:add19eb7defa | 794 | } |
AzureIoTClient | 28:add19eb7defa | 795 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 796 | |
AzureIoTClient | 28:add19eb7defa | 797 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 798 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 799 | |
AzureIoTClient | 29:4a11413cf217 | 800 | static void header_detect_io_dowork(CONCRETE_IO_HANDLE header_detect_io) |
Azure.IoT Build | 0:6ae2f7bca550 | 801 | { |
AzureIoTClient | 29:4a11413cf217 | 802 | if (header_detect_io == NULL) |
AzureIoTClient | 29:4a11413cf217 | 803 | { |
AzureIoTClient | 29:4a11413cf217 | 804 | /* Codes_SRS_HEADER_DETECT_IO_01_036: [ If `header_detect_io` is NULL, `header_detect_io_dowork` shall do nothing. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 805 | LogError("NULL header_detect_io"); |
AzureIoTClient | 29:4a11413cf217 | 806 | } |
AzureIoTClient | 29:4a11413cf217 | 807 | else |
AzureIoTClient | 28:add19eb7defa | 808 | { |
AzureIoTClient | 28:add19eb7defa | 809 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 810 | |
AzureIoTClient | 29:4a11413cf217 | 811 | /* Codes_SRS_HEADER_DETECT_IO_01_037: [ No work shall be scheduled if `header_detect_io` is not OPEN or in ERROR (an error has been indicated to the user). ]*/ |
AzureIoTClient | 28:add19eb7defa | 812 | if ((header_detect_io_instance->io_state != IO_STATE_NOT_OPEN) && |
AzureIoTClient | 28:add19eb7defa | 813 | (header_detect_io_instance->io_state != IO_STATE_ERROR)) |
AzureIoTClient | 28:add19eb7defa | 814 | { |
AzureIoTClient | 29:4a11413cf217 | 815 | /* Codes_SRS_HEADER_DETECT_IO_01_056: [ `header_detect_io_dowork` shall call `xio_dowork` for all detected IOs created as a result of matching headers. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 816 | LIST_ITEM_HANDLE list_item = singlylinkedlist_get_head_item(header_detect_io_instance->chained_io_list); |
AzureIoTClient | 29:4a11413cf217 | 817 | while (list_item != NULL) |
AzureIoTClient | 29:4a11413cf217 | 818 | { |
AzureIoTClient | 29:4a11413cf217 | 819 | CHAINED_IO* chained_io = (CHAINED_IO*)singlylinkedlist_item_get_value(list_item); |
AzureIoTClient | 29:4a11413cf217 | 820 | xio_dowork(chained_io->detected_io); |
AzureIoTClient | 29:4a11413cf217 | 821 | |
AzureIoTClient | 29:4a11413cf217 | 822 | list_item = singlylinkedlist_get_next_item(list_item); |
AzureIoTClient | 29:4a11413cf217 | 823 | } |
AzureIoTClient | 29:4a11413cf217 | 824 | |
AzureIoTClient | 29:4a11413cf217 | 825 | /* Codes_SRS_HEADER_DETECT_IO_01_035: [ `header_detect_io_dowork` shall schedule work for the underlying IO associated with `header_detect_io` by calling `xio_dowork` and passing as argument the `underlying_io` member of the `io_create_parameters` passed to `header_detect_io_create`. ]*/ |
AzureIoTClient | 28:add19eb7defa | 826 | xio_dowork(header_detect_io_instance->underlying_io); |
AzureIoTClient | 28:add19eb7defa | 827 | } |
AzureIoTClient | 28:add19eb7defa | 828 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 829 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 830 | |
AzureIoTClient | 29:4a11413cf217 | 831 | static int header_detect_io_set_option(CONCRETE_IO_HANDLE header_detect_io, const char* option_name, const void* value) |
Azure.IoT Build | 0:6ae2f7bca550 | 832 | { |
AzureIoTClient | 1:eab586236bfe | 833 | int result; |
AzureIoTClient | 1:eab586236bfe | 834 | |
AzureIoTClient | 29:4a11413cf217 | 835 | if ((header_detect_io == NULL) || |
AzureIoTClient | 29:4a11413cf217 | 836 | (option_name == NULL)) |
AzureIoTClient | 1:eab586236bfe | 837 | { |
AzureIoTClient | 29:4a11413cf217 | 838 | /* Codes_SRS_HEADER_DETECT_IO_01_044: [ If `header_detect_io` or `optionName` is NULL, `header_detect_io_set_option` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 839 | LogError("NULL header_detect_io"); |
AzureIoTClient | 19:000ab4e6a2c1 | 840 | result = __FAILURE__; |
AzureIoTClient | 1:eab586236bfe | 841 | } |
AzureIoTClient | 1:eab586236bfe | 842 | else |
AzureIoTClient | 1:eab586236bfe | 843 | { |
AzureIoTClient | 1:eab586236bfe | 844 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
AzureIoTClient | 1:eab586236bfe | 845 | |
AzureIoTClient | 29:4a11413cf217 | 846 | /* Codes_SRS_HEADER_DETECT_IO_01_042: [ If no detected IO was created `header_detect_io_set_option` shall pass any option to the underlying IO by calling `xio_setoption` and passing as IO handle the `underlying_io` member of the `io_create_parameters` passed to `header_detect_io_create`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 847 | /* Codes_SRS_HEADER_DETECT_IO_01_072: [ If any detected IO was created, `header_detect_io_set_option` shall pass any option to the last detected IO by calling `xio_setoption` and passing as IO handle the `underlying_io` member of the `io_create_parameters` passed to `header_detect_io_create`. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 848 | if (xio_setoption(*header_detect_io_instance->last_io, option_name, value) != 0) |
AzureIoTClient | 1:eab586236bfe | 849 | { |
AzureIoTClient | 29:4a11413cf217 | 850 | /* Codes_SRS_HEADER_DETECT_IO_01_045: [ If `xio_setoption` fails, `header_detect_io_set_option` shall fail and return a non-zero value. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 851 | LogError("Setting the option on the underlying IO failed"); |
AzureIoTClient | 19:000ab4e6a2c1 | 852 | result = __FAILURE__; |
AzureIoTClient | 1:eab586236bfe | 853 | } |
AzureIoTClient | 1:eab586236bfe | 854 | else |
AzureIoTClient | 1:eab586236bfe | 855 | { |
AzureIoTClient | 29:4a11413cf217 | 856 | /* Codes_SRS_HEADER_DETECT_IO_01_043: [ On success, `header_detect_io_set_option` shall return 0. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 857 | result = 0; |
AzureIoTClient | 1:eab586236bfe | 858 | } |
AzureIoTClient | 1:eab586236bfe | 859 | } |
AzureIoTClient | 1:eab586236bfe | 860 | |
AzureIoTClient | 1:eab586236bfe | 861 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 862 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 863 | |
AzureIoTClient | 6:641a9672db08 | 864 | /*this function will clone an option given by name and value*/ |
AzureIoTClient | 29:4a11413cf217 | 865 | static void* header_detect_io_clone_option(const char* name, const void* value) |
AzureIoTClient | 6:641a9672db08 | 866 | { |
AzureIoTClient | 17:923575db8b2d | 867 | (void)name; |
AzureIoTClient | 17:923575db8b2d | 868 | (void)value; |
AzureIoTClient | 6:641a9672db08 | 869 | return NULL; |
AzureIoTClient | 6:641a9672db08 | 870 | } |
AzureIoTClient | 6:641a9672db08 | 871 | |
AzureIoTClient | 6:641a9672db08 | 872 | /*this function destroys an option previously created*/ |
AzureIoTClient | 29:4a11413cf217 | 873 | static void header_detect_io_destroy_option(const char* name, const void* value) |
AzureIoTClient | 6:641a9672db08 | 874 | { |
AzureIoTClient | 17:923575db8b2d | 875 | (void)name; |
AzureIoTClient | 17:923575db8b2d | 876 | (void)value; |
AzureIoTClient | 6:641a9672db08 | 877 | } |
AzureIoTClient | 6:641a9672db08 | 878 | |
AzureIoTClient | 29:4a11413cf217 | 879 | static OPTIONHANDLER_HANDLE header_detect_io_retrieve_options(CONCRETE_IO_HANDLE header_detect_io) |
AzureIoTClient | 6:641a9672db08 | 880 | { |
AzureIoTClient | 6:641a9672db08 | 881 | OPTIONHANDLER_HANDLE result; |
AzureIoTClient | 29:4a11413cf217 | 882 | |
AzureIoTClient | 29:4a11413cf217 | 883 | if (header_detect_io == NULL) |
AzureIoTClient | 6:641a9672db08 | 884 | { |
AzureIoTClient | 29:4a11413cf217 | 885 | /* Codes_SRS_HEADER_DETECT_IO_01_041: [ If `header_detect_io` is NULL, `header_detect_io_retrieve_options` shall return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 886 | LogError("NULL header_detect_io"); |
AzureIoTClient | 29:4a11413cf217 | 887 | result = NULL; |
AzureIoTClient | 6:641a9672db08 | 888 | } |
AzureIoTClient | 6:641a9672db08 | 889 | else |
AzureIoTClient | 6:641a9672db08 | 890 | { |
AzureIoTClient | 29:4a11413cf217 | 891 | /* Codes_SRS_HEADER_DETECT_IO_01_038: [ `header_detect_io_retrieve_options` shall create a new `OPTIONHANDLER_HANDLE` by calling `OptionHandler_Create` and on success it shall return a non-NULL handle to the newly created option handler. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 892 | result = OptionHandler_Create(header_detect_io_clone_option, header_detect_io_destroy_option, header_detect_io_set_option); |
AzureIoTClient | 29:4a11413cf217 | 893 | if (result == NULL) |
AzureIoTClient | 29:4a11413cf217 | 894 | { |
AzureIoTClient | 29:4a11413cf217 | 895 | /* Codes_SRS_HEADER_DETECT_IO_01_040: [ If `OptionHandler_Create` fails, `header_detect_io_retrieve_options` shall return NULL. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 896 | LogError("unable to OptionHandler_Create"); |
AzureIoTClient | 29:4a11413cf217 | 897 | /*return as is*/ |
AzureIoTClient | 29:4a11413cf217 | 898 | } |
AzureIoTClient | 29:4a11413cf217 | 899 | else |
AzureIoTClient | 29:4a11413cf217 | 900 | { |
AzureIoTClient | 29:4a11413cf217 | 901 | /*insert here work to add the options to "result" handle*/ |
AzureIoTClient | 29:4a11413cf217 | 902 | /* Codes_SRS_HEADER_DETECT_IO_01_039: [ No options shall be added to the newly created option handler. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 903 | } |
AzureIoTClient | 6:641a9672db08 | 904 | } |
AzureIoTClient | 6:641a9672db08 | 905 | return result; |
AzureIoTClient | 6:641a9672db08 | 906 | } |
AzureIoTClient | 6:641a9672db08 | 907 | |
Azure.IoT Build | 0:6ae2f7bca550 | 908 | static const IO_INTERFACE_DESCRIPTION header_detect_io_interface_description = |
Azure.IoT Build | 0:6ae2f7bca550 | 909 | { |
AzureIoTClient | 29:4a11413cf217 | 910 | header_detect_io_retrieve_options, |
AzureIoTClient | 29:4a11413cf217 | 911 | header_detect_io_create, |
AzureIoTClient | 29:4a11413cf217 | 912 | header_detect_io_destroy, |
AzureIoTClient | 29:4a11413cf217 | 913 | header_detect_io_open_async, |
AzureIoTClient | 29:4a11413cf217 | 914 | header_detect_io_close_async, |
AzureIoTClient | 29:4a11413cf217 | 915 | header_detect_io_send_async, |
AzureIoTClient | 29:4a11413cf217 | 916 | header_detect_io_dowork, |
AzureIoTClient | 29:4a11413cf217 | 917 | header_detect_io_set_option |
Azure.IoT Build | 0:6ae2f7bca550 | 918 | }; |
Azure.IoT Build | 0:6ae2f7bca550 | 919 | |
AzureIoTClient | 29:4a11413cf217 | 920 | const IO_INTERFACE_DESCRIPTION* header_detect_io_get_interface_description(void) |
Azure.IoT Build | 0:6ae2f7bca550 | 921 | { |
AzureIoTClient | 28:add19eb7defa | 922 | return &header_detect_io_interface_description; |
Azure.IoT Build | 0:6ae2f7bca550 | 923 | } |
AzureIoTClient | 29:4a11413cf217 | 924 | |
AzureIoTClient | 29:4a11413cf217 | 925 | static const AMQP_HEADER amqp_header = |
AzureIoTClient | 29:4a11413cf217 | 926 | { |
AzureIoTClient | 29:4a11413cf217 | 927 | amqp_header_bytes, |
AzureIoTClient | 29:4a11413cf217 | 928 | sizeof(amqp_header_bytes) |
AzureIoTClient | 29:4a11413cf217 | 929 | }; |
AzureIoTClient | 29:4a11413cf217 | 930 | |
AzureIoTClient | 29:4a11413cf217 | 931 | static const AMQP_HEADER sasl_amqp_header = |
AzureIoTClient | 29:4a11413cf217 | 932 | { |
AzureIoTClient | 29:4a11413cf217 | 933 | sasl_amqp_header_bytes, |
AzureIoTClient | 29:4a11413cf217 | 934 | sizeof(sasl_amqp_header_bytes) |
AzureIoTClient | 29:4a11413cf217 | 935 | }; |
AzureIoTClient | 29:4a11413cf217 | 936 | |
AzureIoTClient | 29:4a11413cf217 | 937 | const AMQP_HEADER header_detect_io_get_amqp_header(void) |
AzureIoTClient | 29:4a11413cf217 | 938 | { |
AzureIoTClient | 29:4a11413cf217 | 939 | /* Codes_SRS_HEADER_DETECT_IO_01_091: [ `header_detect_io_get_amqp_header` shall return a structure that should point to a buffer that contains the bytes { 'A', 'M', 'Q', 'P', 0, 1, 0, 0 }. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 940 | return amqp_header; |
AzureIoTClient | 29:4a11413cf217 | 941 | } |
AzureIoTClient | 29:4a11413cf217 | 942 | |
AzureIoTClient | 29:4a11413cf217 | 943 | const AMQP_HEADER header_detect_io_get_sasl_amqp_header(void) |
AzureIoTClient | 29:4a11413cf217 | 944 | { |
AzureIoTClient | 29:4a11413cf217 | 945 | /* Codes_SRS_HEADER_DETECT_IO_01_091: [ `header_detect_io_get_sasl_amqp_header` shall return a structure that should point to a buffer that contains the bytes { 'A', 'M', 'Q', 'P', 3, 1, 0, 0 }. ]*/ |
AzureIoTClient | 29:4a11413cf217 | 946 | return sasl_amqp_header; |
AzureIoTClient | 29:4a11413cf217 | 947 | } |