azure_uamqp_c - A small memory footprint AMQP implimentation

Users » AzureIoTClient » Code » azure_uamqp_c

A small memory footprint AMQP implimentation

Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp

connection.c@14:0b0e28c75ded, 2016-12-14 (annotated)

Committer:: Azure.IoT.Build
Date:: Wed Dec 14 16:00:07 2016 -0800
Revision:: 14:0b0e28c75ded
Parent:: 11:b9de84324501
Child:: 15:5db103709f20

1.1.2

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	#include <string.h>
Azure.IoT Build	0:6ae2f7bca550	9
Azure.IoT Build	0:6ae2f7bca550	10	#include "azure_c_shared_utility/xio.h"
Azure.IoT Build	0:6ae2f7bca550	11	#include "azure_c_shared_utility/xlogging.h"
Azure.IoT Build	0:6ae2f7bca550	12	#include "azure_c_shared_utility/tickcounter.h"
Azure.IoT Build	0:6ae2f7bca550	13
Azure.IoT Build	0:6ae2f7bca550	14	#include "azure_uamqp_c/connection.h"
Azure.IoT Build	0:6ae2f7bca550	15	#include "azure_uamqp_c/frame_codec.h"
Azure.IoT Build	0:6ae2f7bca550	16	#include "azure_uamqp_c/amqp_frame_codec.h"
Azure.IoT Build	0:6ae2f7bca550	17	#include "azure_uamqp_c/amqp_definitions.h"
Azure.IoT Build	0:6ae2f7bca550	18	#include "azure_uamqp_c/amqpalloc.h"
Azure.IoT Build	0:6ae2f7bca550	19	#include "azure_uamqp_c/amqpvalue_to_string.h"
Azure.IoT Build	0:6ae2f7bca550	20
Azure.IoT Build	0:6ae2f7bca550	21	/* Requirements satisfied by the virtue of implementing the ISO:*/
Azure.IoT Build	0:6ae2f7bca550	22	/* Codes_SRS_CONNECTION_01_088: [Any data appearing beyond the protocol header MUST match the version indicated by the protocol header.] */
Azure.IoT Build	0:6ae2f7bca550	23	/* Codes_SRS_CONNECTION_01_015: [Implementations SHOULD NOT expect to be able to reuse open TCP sockets after close performatives have been exchanged.] */
Azure.IoT Build	0:6ae2f7bca550	24
Azure.IoT Build	0:6ae2f7bca550	25	/* Codes_SRS_CONNECTION_01_087: [The protocol header consists of the upper case ASCII letters AMQP followed by a protocol id of zero, followed by three unsigned bytes representing the major, minor, and revision of the protocol version (currently 1 (MAJOR), 0 (MINOR), 0 (REVISION)). In total this is an 8-octet sequence] */
Azure.IoT Build	0:6ae2f7bca550	26	static const unsigned char amqp_header[] = { 'A', 'M', 'Q', 'P', 0, 1, 0, 0 };
Azure.IoT Build	0:6ae2f7bca550	27
Azure.IoT Build	0:6ae2f7bca550	28	typedef enum RECEIVE_FRAME_STATE_TAG
Azure.IoT Build	0:6ae2f7bca550	29	{
AzureIoTClient	4:98007eb79fa8	30	RECEIVE_FRAME_STATE_FRAME_SIZE,
AzureIoTClient	4:98007eb79fa8	31	RECEIVE_FRAME_STATE_FRAME_DATA
Azure.IoT Build	0:6ae2f7bca550	32	} RECEIVE_FRAME_STATE;
Azure.IoT Build	0:6ae2f7bca550	33
Azure.IoT Build	0:6ae2f7bca550	34	typedef struct ENDPOINT_INSTANCE_TAG
Azure.IoT Build	0:6ae2f7bca550	35	{
AzureIoTClient	4:98007eb79fa8	36	uint16_t incoming_channel;
AzureIoTClient	4:98007eb79fa8	37	uint16_t outgoing_channel;
AzureIoTClient	4:98007eb79fa8	38	ON_ENDPOINT_FRAME_RECEIVED on_endpoint_frame_received;
AzureIoTClient	4:98007eb79fa8	39	ON_CONNECTION_STATE_CHANGED on_connection_state_changed;
AzureIoTClient	4:98007eb79fa8	40	void* callback_context;
AzureIoTClient	4:98007eb79fa8	41	CONNECTION_HANDLE connection;
Azure.IoT Build	0:6ae2f7bca550	42	} ENDPOINT_INSTANCE;
Azure.IoT Build	0:6ae2f7bca550	43
Azure.IoT Build	0:6ae2f7bca550	44	typedef struct CONNECTION_INSTANCE_TAG
Azure.IoT Build	0:6ae2f7bca550	45	{
AzureIoTClient	4:98007eb79fa8	46	XIO_HANDLE io;
AzureIoTClient	4:98007eb79fa8	47	size_t header_bytes_received;
AzureIoTClient	4:98007eb79fa8	48	CONNECTION_STATE connection_state;
AzureIoTClient	4:98007eb79fa8	49	FRAME_CODEC_HANDLE frame_codec;
AzureIoTClient	4:98007eb79fa8	50	AMQP_FRAME_CODEC_HANDLE amqp_frame_codec;
AzureIoTClient	4:98007eb79fa8	51	ENDPOINT_INSTANCE** endpoints;
AzureIoTClient	4:98007eb79fa8	52	uint32_t endpoint_count;
AzureIoTClient	4:98007eb79fa8	53	char* host_name;
AzureIoTClient	4:98007eb79fa8	54	char* container_id;
AzureIoTClient	4:98007eb79fa8	55	TICK_COUNTER_HANDLE tick_counter;
AzureIoTClient	4:98007eb79fa8	56	uint32_t remote_max_frame_size;
Azure.IoT Build	0:6ae2f7bca550	57
AzureIoTClient	4:98007eb79fa8	58	ON_SEND_COMPLETE on_send_complete;
AzureIoTClient	4:98007eb79fa8	59	void* on_send_complete_callback_context;
Azure.IoT Build	0:6ae2f7bca550	60
AzureIoTClient	4:98007eb79fa8	61	ON_NEW_ENDPOINT on_new_endpoint;
AzureIoTClient	4:98007eb79fa8	62	void* on_new_endpoint_callback_context;
Azure.IoT Build	0:6ae2f7bca550	63
Azure.IoT Build	0:6ae2f7bca550	64	ON_CONNECTION_STATE_CHANGED on_connection_state_changed;
Azure.IoT Build	0:6ae2f7bca550	65	void* on_connection_state_changed_callback_context;
Azure.IoT Build	0:6ae2f7bca550	66	ON_IO_ERROR on_io_error;
Azure.IoT Build	0:6ae2f7bca550	67	void* on_io_error_callback_context;
Azure.IoT Build	0:6ae2f7bca550	68
AzureIoTClient	4:98007eb79fa8	69	/* options */
AzureIoTClient	4:98007eb79fa8	70	uint32_t max_frame_size;
AzureIoTClient	4:98007eb79fa8	71	uint16_t channel_max;
AzureIoTClient	4:98007eb79fa8	72	milliseconds idle_timeout;
AzureIoTClient	4:98007eb79fa8	73	milliseconds remote_idle_timeout;
Azure.IoT.Build	14:0b0e28c75ded	74	tickcounter_ms_t last_frame_received_time;
Azure.IoT.Build	14:0b0e28c75ded	75	tickcounter_ms_t last_frame_sent_time;
Azure.IoT Build	0:6ae2f7bca550	76
AzureIoTClient	4:98007eb79fa8	77	unsigned int is_underlying_io_open : 1;
AzureIoTClient	4:98007eb79fa8	78	unsigned int idle_timeout_specified : 1;
AzureIoTClient	4:98007eb79fa8	79	unsigned int is_remote_frame_received : 1;
AzureIoTClient	4:98007eb79fa8	80	unsigned int is_trace_on : 1;
Azure.IoT Build	0:6ae2f7bca550	81	} CONNECTION_INSTANCE;
Azure.IoT Build	0:6ae2f7bca550	82
Azure.IoT Build	0:6ae2f7bca550	83	/* Codes_SRS_CONNECTION_01_258: [on_connection_state_changed shall be invoked whenever the connection state changes.]*/
Azure.IoT Build	0:6ae2f7bca550	84	static void connection_set_state(CONNECTION_INSTANCE* connection_instance, CONNECTION_STATE connection_state)
Azure.IoT Build	0:6ae2f7bca550	85	{
AzureIoTClient	4:98007eb79fa8	86	uint64_t i;
Azure.IoT Build	0:6ae2f7bca550	87
AzureIoTClient	4:98007eb79fa8	88	CONNECTION_STATE previous_state = connection_instance->connection_state;
AzureIoTClient	4:98007eb79fa8	89	connection_instance->connection_state = connection_state;
Azure.IoT Build	0:6ae2f7bca550	90
Azure.IoT Build	0:6ae2f7bca550	91	/* Codes_SRS_CONNECTION_22_001: [If a connection state changed occurs and a callback is registered the callback shall be called.] */
Azure.IoT Build	0:6ae2f7bca550	92	if (connection_instance->on_connection_state_changed)
Azure.IoT Build	0:6ae2f7bca550	93	{
Azure.IoT Build	0:6ae2f7bca550	94	connection_instance->on_connection_state_changed(connection_instance->on_connection_state_changed_callback_context, connection_state, previous_state);
Azure.IoT Build	0:6ae2f7bca550	95	}
Azure.IoT Build	0:6ae2f7bca550	96
AzureIoTClient	4:98007eb79fa8	97	/* Codes_SRS_CONNECTION_01_260: [Each endpoints on_connection_state_changed shall be called.] */
AzureIoTClient	4:98007eb79fa8	98	for (i = 0; i < connection_instance->endpoint_count; i++)
AzureIoTClient	4:98007eb79fa8	99	{
AzureIoTClient	4:98007eb79fa8	100	/* Codes_SRS_CONNECTION_01_259: [The callback_context passed in connection_create_endpoint.] */
AzureIoTClient	4:98007eb79fa8	101	connection_instance->endpoints[i]->on_connection_state_changed(connection_instance->endpoints[i]->callback_context, connection_state, previous_state);
AzureIoTClient	4:98007eb79fa8	102	}
Azure.IoT Build	0:6ae2f7bca550	103	}
Azure.IoT Build	0:6ae2f7bca550	104
Azure.IoT Build	0:6ae2f7bca550	105	static int send_header(CONNECTION_INSTANCE* connection_instance)
Azure.IoT Build	0:6ae2f7bca550	106	{
AzureIoTClient	4:98007eb79fa8	107	int result;
Azure.IoT Build	0:6ae2f7bca550	108
AzureIoTClient	4:98007eb79fa8	109	/* Codes_SRS_CONNECTION_01_093: [_ When the client opens a new socket connection to a server, it MUST send a protocol header with the clients preferred protocol version.] */
AzureIoTClient	4:98007eb79fa8	110	/* Codes_SRS_CONNECTION_01_104: [Sending the protocol header shall be done by using xio_send.] */
AzureIoTClient	4:98007eb79fa8	111	if (xio_send(connection_instance->io, amqp_header, sizeof(amqp_header), NULL, NULL) != 0)
AzureIoTClient	4:98007eb79fa8	112	{
AzureIoTClient	4:98007eb79fa8	113	/* Codes_SRS_CONNECTION_01_106: [When sending the protocol header fails, the connection shall be immediately closed.] */
AzureIoTClient	4:98007eb79fa8	114	xio_close(connection_instance->io, NULL, NULL);
Azure.IoT Build	0:6ae2f7bca550	115
AzureIoTClient	4:98007eb79fa8	116	/* Codes_SRS_CONNECTION_01_057: [END In this state it is illegal for either endpoint to write anything more onto the connection. The connection can be safely closed and discarded.] */
AzureIoTClient	4:98007eb79fa8	117	connection_set_state(connection_instance, CONNECTION_STATE_END);
Azure.IoT Build	0:6ae2f7bca550	118
AzureIoTClient	4:98007eb79fa8	119	/* Codes_SRS_CONNECTION_01_105: [When xio_send fails, connection_dowork shall return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	120	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	121	}
AzureIoTClient	4:98007eb79fa8	122	else
AzureIoTClient	4:98007eb79fa8	123	{
AzureIoTClient	4:98007eb79fa8	124	if (connection_instance->is_trace_on == 1)
AzureIoTClient	4:98007eb79fa8	125	{
Azure.IoT Build	5:ae49385aff34	126	LOG(LOG_TRACE, LOG_LINE, "-> Header (AMQP 0.1.0.0)");
AzureIoTClient	4:98007eb79fa8	127	}
Azure.IoT Build	0:6ae2f7bca550	128
AzureIoTClient	4:98007eb79fa8	129	/* Codes_SRS_CONNECTION_01_041: [HDR SENT In this state the connection header has been sent to the peer but no connection header has been received.] */
AzureIoTClient	4:98007eb79fa8	130	connection_set_state(connection_instance, CONNECTION_STATE_HDR_SENT);
AzureIoTClient	4:98007eb79fa8	131	result = 0;
AzureIoTClient	4:98007eb79fa8	132	}
Azure.IoT Build	0:6ae2f7bca550	133
AzureIoTClient	4:98007eb79fa8	134	return result;
Azure.IoT Build	0:6ae2f7bca550	135	}
Azure.IoT Build	0:6ae2f7bca550	136
Azure.IoT Build	0:6ae2f7bca550	137	static const char* get_frame_type_as_string(AMQP_VALUE descriptor)
Azure.IoT Build	0:6ae2f7bca550	138	{
AzureIoTClient	4:98007eb79fa8	139	const char* result;
Azure.IoT Build	0:6ae2f7bca550	140
AzureIoTClient	4:98007eb79fa8	141	if (is_open_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	142	{
AzureIoTClient	4:98007eb79fa8	143	result = "[OPEN]";
AzureIoTClient	4:98007eb79fa8	144	}
AzureIoTClient	4:98007eb79fa8	145	else if (is_begin_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	146	{
AzureIoTClient	4:98007eb79fa8	147	result = "[BEGIN]";
AzureIoTClient	4:98007eb79fa8	148	}
AzureIoTClient	4:98007eb79fa8	149	else if (is_attach_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	150	{
AzureIoTClient	4:98007eb79fa8	151	result = "[ATTACH]";
AzureIoTClient	4:98007eb79fa8	152	}
AzureIoTClient	4:98007eb79fa8	153	else if (is_flow_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	154	{
AzureIoTClient	4:98007eb79fa8	155	result = "[FLOW]";
AzureIoTClient	4:98007eb79fa8	156	}
AzureIoTClient	4:98007eb79fa8	157	else if (is_disposition_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	158	{
AzureIoTClient	4:98007eb79fa8	159	result = "[DISPOSITION]";
AzureIoTClient	4:98007eb79fa8	160	}
AzureIoTClient	4:98007eb79fa8	161	else if (is_transfer_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	162	{
AzureIoTClient	4:98007eb79fa8	163	result = "[TRANSFER]";
AzureIoTClient	4:98007eb79fa8	164	}
AzureIoTClient	4:98007eb79fa8	165	else if (is_detach_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	166	{
AzureIoTClient	4:98007eb79fa8	167	result = "[DETACH]";
AzureIoTClient	4:98007eb79fa8	168	}
AzureIoTClient	4:98007eb79fa8	169	else if (is_end_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	170	{
AzureIoTClient	4:98007eb79fa8	171	result = "[END]";
AzureIoTClient	4:98007eb79fa8	172	}
AzureIoTClient	4:98007eb79fa8	173	else if (is_close_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	174	{
AzureIoTClient	4:98007eb79fa8	175	result = "[CLOSE]";
AzureIoTClient	4:98007eb79fa8	176	}
AzureIoTClient	4:98007eb79fa8	177	else
AzureIoTClient	4:98007eb79fa8	178	{
AzureIoTClient	4:98007eb79fa8	179	result = "[Unknown]";
AzureIoTClient	4:98007eb79fa8	180	}
Azure.IoT Build	0:6ae2f7bca550	181
AzureIoTClient	4:98007eb79fa8	182	return result;
Azure.IoT Build	0:6ae2f7bca550	183	}
Azure.IoT Build	0:6ae2f7bca550	184
Azure.IoT Build	5:ae49385aff34	185	static void log_incoming_frame(AMQP_VALUE performative)
Azure.IoT Build	0:6ae2f7bca550	186	{
AzureIoTClient	9:c22db038556c	187	#ifdef NO_LOGGING
AzureIoTClient	9:c22db038556c	188	UNUSED(performative);
AzureIoTClient	9:c22db038556c	189	#else
AzureIoTClient	4:98007eb79fa8	190	AMQP_VALUE descriptor = amqpvalue_get_inplace_descriptor(performative);
AzureIoTClient	4:98007eb79fa8	191	if (descriptor != NULL)
AzureIoTClient	4:98007eb79fa8	192	{
Azure.IoT Build	5:ae49385aff34	193	LOG(LOG_TRACE, 0, "<- ");
Azure.IoT Build	5:ae49385aff34	194	LOG(LOG_TRACE, 0, (char*)get_frame_type_as_string(descriptor));
AzureIoTClient	4:98007eb79fa8	195	char* performative_as_string = NULL;
Azure.IoT Build	5:ae49385aff34	196	LOG(LOG_TRACE, LOG_LINE, (performative_as_string = amqpvalue_to_string(performative)));
AzureIoTClient	4:98007eb79fa8	197	if (performative_as_string != NULL)
AzureIoTClient	4:98007eb79fa8	198	{
AzureIoTClient	4:98007eb79fa8	199	amqpalloc_free(performative_as_string);
AzureIoTClient	4:98007eb79fa8	200	}
AzureIoTClient	4:98007eb79fa8	201	}
AzureIoTClient	9:c22db038556c	202	#endif
Azure.IoT Build	0:6ae2f7bca550	203	}
Azure.IoT Build	0:6ae2f7bca550	204
Azure.IoT Build	5:ae49385aff34	205	static void log_outgoing_frame(AMQP_VALUE performative)
Azure.IoT Build	0:6ae2f7bca550	206	{
AzureIoTClient	9:c22db038556c	207	#ifdef NO_LOGGING
AzureIoTClient	9:c22db038556c	208	UNUSED(performative);
AzureIoTClient	9:c22db038556c	209	#else
AzureIoTClient	4:98007eb79fa8	210	AMQP_VALUE descriptor = amqpvalue_get_inplace_descriptor(performative);
AzureIoTClient	4:98007eb79fa8	211	if (descriptor != NULL)
AzureIoTClient	4:98007eb79fa8	212	{
Azure.IoT Build	5:ae49385aff34	213	LOG(LOG_TRACE, 0, "-> ");
Azure.IoT Build	5:ae49385aff34	214	LOG(LOG_TRACE, 0, (char*)get_frame_type_as_string(descriptor));
AzureIoTClient	4:98007eb79fa8	215	char* performative_as_string = NULL;
Azure.IoT Build	5:ae49385aff34	216	LOG(LOG_TRACE, LOG_LINE, (performative_as_string = amqpvalue_to_string(performative)));
AzureIoTClient	4:98007eb79fa8	217	if (performative_as_string != NULL)
AzureIoTClient	4:98007eb79fa8	218	{
AzureIoTClient	4:98007eb79fa8	219	amqpalloc_free(performative_as_string);
AzureIoTClient	4:98007eb79fa8	220	}
AzureIoTClient	4:98007eb79fa8	221	}
AzureIoTClient	9:c22db038556c	222	#endif
Azure.IoT Build	0:6ae2f7bca550	223	}
Azure.IoT Build	0:6ae2f7bca550	224
Azure.IoT Build	0:6ae2f7bca550	225	static void on_bytes_encoded(void* context, const unsigned char* bytes, size_t length, bool encode_complete)
Azure.IoT Build	0:6ae2f7bca550	226	{
AzureIoTClient	4:98007eb79fa8	227	CONNECTION_INSTANCE* connection_instance = (CONNECTION_INSTANCE*)context;
AzureIoTClient	4:98007eb79fa8	228	if (xio_send(connection_instance->io, bytes, length, encode_complete ? connection_instance->on_send_complete : NULL, connection_instance->on_send_complete_callback_context) != 0)
AzureIoTClient	4:98007eb79fa8	229	{
AzureIoTClient	4:98007eb79fa8	230	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	231	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	232	}
Azure.IoT Build	0:6ae2f7bca550	233	}
Azure.IoT Build	0:6ae2f7bca550	234
Azure.IoT Build	0:6ae2f7bca550	235	static int send_open_frame(CONNECTION_INSTANCE* connection_instance)
Azure.IoT Build	0:6ae2f7bca550	236	{
AzureIoTClient	4:98007eb79fa8	237	int result;
Azure.IoT Build	0:6ae2f7bca550	238
AzureIoTClient	4:98007eb79fa8	239	/* Codes_SRS_CONNECTION_01_151: [The connection max_frame_size setting shall be passed down to the frame_codec when the Open frame is sent.] */
AzureIoTClient	4:98007eb79fa8	240	if (frame_codec_set_max_frame_size(connection_instance->frame_codec, connection_instance->max_frame_size) != 0)
AzureIoTClient	4:98007eb79fa8	241	{
AzureIoTClient	4:98007eb79fa8	242	/* Codes_SRS_CONNECTION_01_207: [If frame_codec_set_max_frame_size fails the connection shall be closed and the state set to END.] */
AzureIoTClient	4:98007eb79fa8	243	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	244	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	245	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	246	}
AzureIoTClient	4:98007eb79fa8	247	else
AzureIoTClient	4:98007eb79fa8	248	{
AzureIoTClient	4:98007eb79fa8	249	/* Codes_SRS_CONNECTION_01_134: [The container id field shall be filled with the container id specified in connection_create.] */
AzureIoTClient	4:98007eb79fa8	250	OPEN_HANDLE open_performative = open_create(connection_instance->container_id);
AzureIoTClient	4:98007eb79fa8	251	if (open_performative == NULL)
AzureIoTClient	4:98007eb79fa8	252	{
AzureIoTClient	4:98007eb79fa8	253	/* Codes_SRS_CONNECTION_01_208: [If the open frame cannot be constructed, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	254	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	255	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	256	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	257	}
AzureIoTClient	4:98007eb79fa8	258	else
AzureIoTClient	4:98007eb79fa8	259	{
AzureIoTClient	4:98007eb79fa8	260	/* Codes_SRS_CONNECTION_01_137: [The max_frame_size connection setting shall be set in the open frame by using open_set_max_frame_size.] */
AzureIoTClient	4:98007eb79fa8	261	if (open_set_max_frame_size(open_performative, connection_instance->max_frame_size) != 0)
AzureIoTClient	4:98007eb79fa8	262	{
AzureIoTClient	4:98007eb79fa8	263	/* Codes_SRS_CONNECTION_01_208: [If the open frame cannot be constructed, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	264	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	265	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	266	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	267	}
AzureIoTClient	4:98007eb79fa8	268	/* Codes_SRS_CONNECTION_01_139: [The channel_max connection setting shall be set in the open frame by using open_set_channel_max.] */
AzureIoTClient	4:98007eb79fa8	269	else if (open_set_channel_max(open_performative, connection_instance->channel_max) != 0)
AzureIoTClient	4:98007eb79fa8	270	{
AzureIoTClient	4:98007eb79fa8	271	/* Codes_SRS_CONNECTION_01_208: [If the open frame cannot be constructed, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	272	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	273	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	274	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	275	}
AzureIoTClient	4:98007eb79fa8	276	/* Codes_SRS_CONNECTION_01_142: [If no idle_timeout value has been specified, no value shall be stamped in the open frame (no call to open_set_idle_time_out shall be made).] */
AzureIoTClient	4:98007eb79fa8	277	else if ((connection_instance->idle_timeout_specified) &&
AzureIoTClient	4:98007eb79fa8	278	/* Codes_SRS_CONNECTION_01_141: [If idle_timeout has been specified by a call to connection_set_idle_timeout, then that value shall be stamped in the open frame.] */
AzureIoTClient	4:98007eb79fa8	279	(open_set_idle_time_out(open_performative, connection_instance->idle_timeout) != 0))
AzureIoTClient	4:98007eb79fa8	280	{
AzureIoTClient	4:98007eb79fa8	281	/* Codes_SRS_CONNECTION_01_208: [If the open frame cannot be constructed, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	282	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	283	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	284	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	285	}
AzureIoTClient	4:98007eb79fa8	286	/* Codes_SRS_CONNECTION_01_136: [If no hostname value has been specified, no value shall be stamped in the open frame (no call to open_set_hostname shall be made).] */
AzureIoTClient	4:98007eb79fa8	287	else if ((connection_instance->host_name != NULL) &&
AzureIoTClient	4:98007eb79fa8	288	/* Codes_SRS_CONNECTION_01_135: [If hostname has been specified by a call to connection_set_hostname, then that value shall be stamped in the open frame.] */
AzureIoTClient	4:98007eb79fa8	289	(open_set_hostname(open_performative, connection_instance->host_name) != 0))
AzureIoTClient	4:98007eb79fa8	290	{
AzureIoTClient	4:98007eb79fa8	291	/* Codes_SRS_CONNECTION_01_208: [If the open frame cannot be constructed, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	292	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	293	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	294	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	295	}
AzureIoTClient	4:98007eb79fa8	296	else
AzureIoTClient	4:98007eb79fa8	297	{
AzureIoTClient	4:98007eb79fa8	298	AMQP_VALUE open_performative_value = amqpvalue_create_open(open_performative);
AzureIoTClient	4:98007eb79fa8	299	if (open_performative_value == NULL)
AzureIoTClient	4:98007eb79fa8	300	{
AzureIoTClient	4:98007eb79fa8	301	/* Codes_SRS_CONNECTION_01_208: [If the open frame cannot be constructed, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	302	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	303	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	304	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	305	}
AzureIoTClient	4:98007eb79fa8	306	else
AzureIoTClient	4:98007eb79fa8	307	{
AzureIoTClient	4:98007eb79fa8	308	/* Codes_SRS_CONNECTION_01_002: [Each AMQP connection begins with an exchange of capabilities and limitations, including the maximum frame size.] */
AzureIoTClient	4:98007eb79fa8	309	/* Codes_SRS_CONNECTION_01_004: [After establishing or accepting a TCP connection and sending the protocol header, each peer MUST send an open frame before sending any other frames.] */
AzureIoTClient	4:98007eb79fa8	310	/* Codes_SRS_CONNECTION_01_005: [The open frame describes the capabilities and limits of that peer.] */
AzureIoTClient	4:98007eb79fa8	311	/* Codes_SRS_CONNECTION_01_205: [Sending the AMQP OPEN frame shall be done by calling amqp_frame_codec_begin_encode_frame with channel number 0, the actual performative payload and 0 as payload_size.] */
AzureIoTClient	4:98007eb79fa8	312	/* Codes_SRS_CONNECTION_01_006: [The open frame can only be sent on channel 0.] */
AzureIoTClient	4:98007eb79fa8	313	connection_instance->on_send_complete = NULL;
AzureIoTClient	4:98007eb79fa8	314	connection_instance->on_send_complete_callback_context = NULL;
AzureIoTClient	4:98007eb79fa8	315	if (amqp_frame_codec_encode_frame(connection_instance->amqp_frame_codec, 0, open_performative_value, NULL, 0, on_bytes_encoded, connection_instance) != 0)
AzureIoTClient	4:98007eb79fa8	316	{
AzureIoTClient	4:98007eb79fa8	317	/* Codes_SRS_CONNECTION_01_206: [If sending the frame fails, the connection shall be closed and state set to END.] */
AzureIoTClient	4:98007eb79fa8	318	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	319	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	320	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	321	}
AzureIoTClient	4:98007eb79fa8	322	else
AzureIoTClient	4:98007eb79fa8	323	{
AzureIoTClient	4:98007eb79fa8	324	if (connection_instance->is_trace_on == 1)
AzureIoTClient	4:98007eb79fa8	325	{
Azure.IoT Build	5:ae49385aff34	326	log_outgoing_frame(open_performative_value);
AzureIoTClient	4:98007eb79fa8	327	}
Azure.IoT Build	0:6ae2f7bca550	328
AzureIoTClient	4:98007eb79fa8	329	/* Codes_SRS_CONNECTION_01_046: [OPEN SENT In this state the connection headers have been exchanged. An open frame has been sent to the peer but no open frame has yet been received.] */
AzureIoTClient	4:98007eb79fa8	330	connection_set_state(connection_instance, CONNECTION_STATE_OPEN_SENT);
AzureIoTClient	4:98007eb79fa8	331	result = 0;
AzureIoTClient	4:98007eb79fa8	332	}
Azure.IoT Build	0:6ae2f7bca550	333
AzureIoTClient	4:98007eb79fa8	334	amqpvalue_destroy(open_performative_value);
AzureIoTClient	4:98007eb79fa8	335	}
AzureIoTClient	4:98007eb79fa8	336	}
Azure.IoT Build	0:6ae2f7bca550	337
AzureIoTClient	4:98007eb79fa8	338	open_destroy(open_performative);
AzureIoTClient	4:98007eb79fa8	339	}
AzureIoTClient	4:98007eb79fa8	340	}
Azure.IoT Build	0:6ae2f7bca550	341
AzureIoTClient	4:98007eb79fa8	342	return result;
Azure.IoT Build	0:6ae2f7bca550	343	}
Azure.IoT Build	0:6ae2f7bca550	344
Azure.IoT Build	0:6ae2f7bca550	345	static int send_close_frame(CONNECTION_INSTANCE* connection_instance, ERROR_HANDLE error_handle)
Azure.IoT Build	0:6ae2f7bca550	346	{
AzureIoTClient	4:98007eb79fa8	347	int result;
AzureIoTClient	4:98007eb79fa8	348	CLOSE_HANDLE close_performative;
Azure.IoT Build	0:6ae2f7bca550	349
AzureIoTClient	4:98007eb79fa8	350	/* Codes_SRS_CONNECTION_01_217: [The CLOSE frame shall be constructed by using close_create.] */
AzureIoTClient	4:98007eb79fa8	351	close_performative = close_create();
AzureIoTClient	4:98007eb79fa8	352	if (close_performative == NULL)
AzureIoTClient	4:98007eb79fa8	353	{
AzureIoTClient	4:98007eb79fa8	354	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	355	}
AzureIoTClient	4:98007eb79fa8	356	else
AzureIoTClient	4:98007eb79fa8	357	{
AzureIoTClient	4:98007eb79fa8	358	if ((error_handle != NULL) &&
AzureIoTClient	4:98007eb79fa8	359	/* Codes_SRS_CONNECTION_01_238: [If set, this field indicates that the connection is being closed due to an error condition.] */
AzureIoTClient	4:98007eb79fa8	360	(close_set_error(close_performative, error_handle) != 0))
AzureIoTClient	4:98007eb79fa8	361	{
AzureIoTClient	4:98007eb79fa8	362	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	363	}
AzureIoTClient	4:98007eb79fa8	364	else
AzureIoTClient	4:98007eb79fa8	365	{
AzureIoTClient	4:98007eb79fa8	366	AMQP_VALUE close_performative_value = amqpvalue_create_close(close_performative);
AzureIoTClient	4:98007eb79fa8	367	if (close_performative_value == NULL)
AzureIoTClient	4:98007eb79fa8	368	{
AzureIoTClient	4:98007eb79fa8	369	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	370	}
AzureIoTClient	4:98007eb79fa8	371	else
AzureIoTClient	4:98007eb79fa8	372	{
AzureIoTClient	4:98007eb79fa8	373	/* Codes_SRS_CONNECTION_01_215: [Sending the AMQP CLOSE frame shall be done by calling amqp_frame_codec_begin_encode_frame with channel number 0, the actual performative payload and 0 as payload_size.] */
AzureIoTClient	4:98007eb79fa8	374	/* Codes_SRS_CONNECTION_01_013: [However, implementations SHOULD send it on channel 0] */
AzureIoTClient	4:98007eb79fa8	375	connection_instance->on_send_complete = NULL;
AzureIoTClient	4:98007eb79fa8	376	connection_instance->on_send_complete_callback_context = NULL;
AzureIoTClient	4:98007eb79fa8	377	if (amqp_frame_codec_encode_frame(connection_instance->amqp_frame_codec, 0, close_performative_value, NULL, 0, on_bytes_encoded, connection_instance) != 0)
AzureIoTClient	4:98007eb79fa8	378	{
AzureIoTClient	4:98007eb79fa8	379	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	380	}
AzureIoTClient	4:98007eb79fa8	381	else
AzureIoTClient	4:98007eb79fa8	382	{
AzureIoTClient	4:98007eb79fa8	383	if (connection_instance->is_trace_on == 1)
AzureIoTClient	4:98007eb79fa8	384	{
Azure.IoT Build	5:ae49385aff34	385	log_outgoing_frame(close_performative_value);
AzureIoTClient	4:98007eb79fa8	386	}
Azure.IoT Build	5:ae49385aff34	387
AzureIoTClient	4:98007eb79fa8	388	result = 0;
AzureIoTClient	4:98007eb79fa8	389	}
Azure.IoT Build	0:6ae2f7bca550	390
AzureIoTClient	4:98007eb79fa8	391	amqpvalue_destroy(close_performative_value);
AzureIoTClient	4:98007eb79fa8	392	}
AzureIoTClient	4:98007eb79fa8	393	}
Azure.IoT Build	0:6ae2f7bca550	394
AzureIoTClient	4:98007eb79fa8	395	close_destroy(close_performative);
AzureIoTClient	4:98007eb79fa8	396	}
Azure.IoT Build	0:6ae2f7bca550	397
AzureIoTClient	4:98007eb79fa8	398	return result;
Azure.IoT Build	0:6ae2f7bca550	399	}
Azure.IoT Build	0:6ae2f7bca550	400
Azure.IoT Build	0:6ae2f7bca550	401	static void close_connection_with_error(CONNECTION_INSTANCE* connection_instance, const char* condition_value, const char* description)
Azure.IoT Build	0:6ae2f7bca550	402	{
AzureIoTClient	4:98007eb79fa8	403	ERROR_HANDLE error_handle = error_create(condition_value);
AzureIoTClient	4:98007eb79fa8	404	if (error_handle == NULL)
AzureIoTClient	4:98007eb79fa8	405	{
AzureIoTClient	4:98007eb79fa8	406	/* Codes_SRS_CONNECTION_01_214: [If the close frame cannot be constructed or sent, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	407	(void)xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	408	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	409	}
AzureIoTClient	4:98007eb79fa8	410	else
AzureIoTClient	4:98007eb79fa8	411	{
AzureIoTClient	4:98007eb79fa8	412	/* Codes_SRS_CONNECTION_01_219: [The error description shall be set to an implementation defined string.] */
AzureIoTClient	4:98007eb79fa8	413	if ((error_set_description(error_handle, description) != 0) \|\|
AzureIoTClient	4:98007eb79fa8	414	(send_close_frame(connection_instance, error_handle) != 0))
AzureIoTClient	4:98007eb79fa8	415	{
AzureIoTClient	4:98007eb79fa8	416	/* Codes_SRS_CONNECTION_01_214: [If the close frame cannot be constructed or sent, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	417	(void)xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	418	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	419	}
AzureIoTClient	4:98007eb79fa8	420	else
AzureIoTClient	4:98007eb79fa8	421	{
AzureIoTClient	4:98007eb79fa8	422	/* Codes_SRS_CONNECTION_01_213: [When passing the bytes to frame_codec fails, a CLOSE frame shall be sent and the state shall be set to DISCARDING.] */
AzureIoTClient	4:98007eb79fa8	423	/* Codes_SRS_CONNECTION_01_055: [DISCARDING The DISCARDING state is a variant of the CLOSE SENT state where the close is triggered by an error.] */
AzureIoTClient	4:98007eb79fa8	424	/* Codes_SRS_CONNECTION_01_010: [After writing this frame the peer SHOULD continue to read from the connection until it receives the partners close frame ] */
AzureIoTClient	4:98007eb79fa8	425	connection_set_state(connection_instance, CONNECTION_STATE_DISCARDING);
AzureIoTClient	4:98007eb79fa8	426	}
Azure.IoT Build	0:6ae2f7bca550	427
AzureIoTClient	4:98007eb79fa8	428	error_destroy(error_handle);
AzureIoTClient	4:98007eb79fa8	429	}
Azure.IoT Build	0:6ae2f7bca550	430	}
Azure.IoT Build	0:6ae2f7bca550	431
Azure.IoT Build	0:6ae2f7bca550	432	static ENDPOINT_INSTANCE* find_session_endpoint_by_outgoing_channel(CONNECTION_INSTANCE* connection, uint16_t outgoing_channel)
Azure.IoT Build	0:6ae2f7bca550	433	{
AzureIoTClient	4:98007eb79fa8	434	uint32_t i;
AzureIoTClient	4:98007eb79fa8	435	ENDPOINT_INSTANCE* result;
Azure.IoT Build	0:6ae2f7bca550	436
AzureIoTClient	4:98007eb79fa8	437	for (i = 0; i < connection->endpoint_count; i++)
AzureIoTClient	4:98007eb79fa8	438	{
AzureIoTClient	4:98007eb79fa8	439	if (connection->endpoints[i]->outgoing_channel == outgoing_channel)
AzureIoTClient	4:98007eb79fa8	440	{
AzureIoTClient	4:98007eb79fa8	441	break;
AzureIoTClient	4:98007eb79fa8	442	}
AzureIoTClient	4:98007eb79fa8	443	}
Azure.IoT Build	0:6ae2f7bca550	444
AzureIoTClient	4:98007eb79fa8	445	if (i == connection->endpoint_count)
AzureIoTClient	4:98007eb79fa8	446	{
AzureIoTClient	4:98007eb79fa8	447	result = NULL;
AzureIoTClient	4:98007eb79fa8	448	}
AzureIoTClient	4:98007eb79fa8	449	else
AzureIoTClient	4:98007eb79fa8	450	{
AzureIoTClient	4:98007eb79fa8	451	result = connection->endpoints[i];
AzureIoTClient	4:98007eb79fa8	452	}
Azure.IoT Build	0:6ae2f7bca550	453
AzureIoTClient	4:98007eb79fa8	454	return result;
Azure.IoT Build	0:6ae2f7bca550	455	}
Azure.IoT Build	0:6ae2f7bca550	456
Azure.IoT Build	0:6ae2f7bca550	457	static ENDPOINT_INSTANCE* find_session_endpoint_by_incoming_channel(CONNECTION_INSTANCE* connection, uint16_t incoming_channel)
Azure.IoT Build	0:6ae2f7bca550	458	{
AzureIoTClient	4:98007eb79fa8	459	uint32_t i;
AzureIoTClient	4:98007eb79fa8	460	ENDPOINT_INSTANCE* result;
Azure.IoT Build	0:6ae2f7bca550	461
AzureIoTClient	4:98007eb79fa8	462	for (i = 0; i < connection->endpoint_count; i++)
AzureIoTClient	4:98007eb79fa8	463	{
AzureIoTClient	4:98007eb79fa8	464	if (connection->endpoints[i]->incoming_channel == incoming_channel)
AzureIoTClient	4:98007eb79fa8	465	{
AzureIoTClient	4:98007eb79fa8	466	break;
AzureIoTClient	4:98007eb79fa8	467	}
AzureIoTClient	4:98007eb79fa8	468	}
Azure.IoT Build	0:6ae2f7bca550	469
AzureIoTClient	4:98007eb79fa8	470	if (i == connection->endpoint_count)
AzureIoTClient	4:98007eb79fa8	471	{
AzureIoTClient	4:98007eb79fa8	472	result = NULL;
AzureIoTClient	4:98007eb79fa8	473	}
AzureIoTClient	4:98007eb79fa8	474	else
AzureIoTClient	4:98007eb79fa8	475	{
AzureIoTClient	4:98007eb79fa8	476	result = connection->endpoints[i];
AzureIoTClient	4:98007eb79fa8	477	}
Azure.IoT Build	0:6ae2f7bca550	478
AzureIoTClient	4:98007eb79fa8	479	return result;
Azure.IoT Build	0:6ae2f7bca550	480	}
Azure.IoT Build	0:6ae2f7bca550	481
Azure.IoT Build	0:6ae2f7bca550	482	static int connection_byte_received(CONNECTION_INSTANCE* connection_instance, unsigned char b)
Azure.IoT Build	0:6ae2f7bca550	483	{
AzureIoTClient	4:98007eb79fa8	484	int result;
Azure.IoT Build	0:6ae2f7bca550	485
AzureIoTClient	4:98007eb79fa8	486	switch (connection_instance->connection_state)
AzureIoTClient	4:98007eb79fa8	487	{
AzureIoTClient	4:98007eb79fa8	488	default:
AzureIoTClient	4:98007eb79fa8	489	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	490	break;
Azure.IoT Build	0:6ae2f7bca550	491
AzureIoTClient	4:98007eb79fa8	492	/* Codes_SRS_CONNECTION_01_039: [START In this state a connection exists, but nothing has been sent or received. This is the state an implementation would be in immediately after performing a socket connect or socket accept.] */
AzureIoTClient	4:98007eb79fa8	493	case CONNECTION_STATE_START:
Azure.IoT Build	0:6ae2f7bca550	494
AzureIoTClient	4:98007eb79fa8	495	/* Codes_SRS_CONNECTION_01_041: [HDR SENT In this state the connection header has been sent to the peer but no connection header has been received.] */
AzureIoTClient	4:98007eb79fa8	496	case CONNECTION_STATE_HDR_SENT:
AzureIoTClient	4:98007eb79fa8	497	if (b != amqp_header[connection_instance->header_bytes_received])
AzureIoTClient	4:98007eb79fa8	498	{
AzureIoTClient	4:98007eb79fa8	499	/* Codes_SRS_CONNECTION_01_089: [If the incoming and outgoing protocol headers do not match, both peers MUST close their outgoing stream] */
AzureIoTClient	4:98007eb79fa8	500	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	501	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	502	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	503	}
AzureIoTClient	4:98007eb79fa8	504	else
AzureIoTClient	4:98007eb79fa8	505	{
AzureIoTClient	4:98007eb79fa8	506	connection_instance->header_bytes_received++;
AzureIoTClient	4:98007eb79fa8	507	if (connection_instance->header_bytes_received == sizeof(amqp_header))
AzureIoTClient	4:98007eb79fa8	508	{
AzureIoTClient	4:98007eb79fa8	509	if (connection_instance->is_trace_on == 1)
AzureIoTClient	4:98007eb79fa8	510	{
Azure.IoT Build	5:ae49385aff34	511	LOG(LOG_TRACE, LOG_LINE, "<- Header (AMQP 0.1.0.0)");
AzureIoTClient	4:98007eb79fa8	512	}
Azure.IoT Build	0:6ae2f7bca550	513
AzureIoTClient	4:98007eb79fa8	514	connection_set_state(connection_instance, CONNECTION_STATE_HDR_EXCH);
Azure.IoT Build	0:6ae2f7bca550	515
AzureIoTClient	4:98007eb79fa8	516	if (send_open_frame(connection_instance) != 0)
AzureIoTClient	4:98007eb79fa8	517	{
AzureIoTClient	4:98007eb79fa8	518	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	519	}
AzureIoTClient	4:98007eb79fa8	520	}
Azure.IoT Build	0:6ae2f7bca550	521
AzureIoTClient	4:98007eb79fa8	522	result = 0;
AzureIoTClient	4:98007eb79fa8	523	}
AzureIoTClient	4:98007eb79fa8	524	break;
Azure.IoT Build	0:6ae2f7bca550	525
AzureIoTClient	4:98007eb79fa8	526	/* Codes_SRS_CONNECTION_01_040: [HDR RCVD In this state the connection header has been received from the peer but a connection header has not been sent.] */
AzureIoTClient	4:98007eb79fa8	527	case CONNECTION_STATE_HDR_RCVD:
Azure.IoT Build	0:6ae2f7bca550	528
AzureIoTClient	4:98007eb79fa8	529	/* Codes_SRS_CONNECTION_01_042: [HDR EXCH In this state the connection header has been sent to the peer and a connection header has been received from the peer.] */
AzureIoTClient	4:98007eb79fa8	530	/* we should not really get into this state, but just in case, we would treat that in the same way as HDR_RCVD */
AzureIoTClient	4:98007eb79fa8	531	case CONNECTION_STATE_HDR_EXCH:
Azure.IoT Build	0:6ae2f7bca550	532
AzureIoTClient	4:98007eb79fa8	533	/* Codes_SRS_CONNECTION_01_045: [OPEN RCVD In this state the connection headers have been exchanged. An open frame has been received from the peer but an open frame has not been sent.] */
AzureIoTClient	4:98007eb79fa8	534	case CONNECTION_STATE_OPEN_RCVD:
Azure.IoT Build	0:6ae2f7bca550	535
AzureIoTClient	4:98007eb79fa8	536	/* Codes_SRS_CONNECTION_01_046: [OPEN SENT In this state the connection headers have been exchanged. An open frame has been sent to the peer but no open frame has yet been received.] */
AzureIoTClient	4:98007eb79fa8	537	case CONNECTION_STATE_OPEN_SENT:
Azure.IoT Build	0:6ae2f7bca550	538
AzureIoTClient	4:98007eb79fa8	539	/* Codes_SRS_CONNECTION_01_048: [OPENED In this state the connection header and the open frame have been both sent and received.] */
AzureIoTClient	4:98007eb79fa8	540	case CONNECTION_STATE_OPENED:
AzureIoTClient	4:98007eb79fa8	541	/* Codes_SRS_CONNECTION_01_212: [After the initial handshake has been done all bytes received from the io instance shall be passed to the frame_codec for decoding by calling frame_codec_receive_bytes.] */
AzureIoTClient	4:98007eb79fa8	542	if (frame_codec_receive_bytes(connection_instance->frame_codec, &b, 1) != 0)
AzureIoTClient	4:98007eb79fa8	543	{
AzureIoTClient	4:98007eb79fa8	544	/* Codes_SRS_CONNECTION_01_218: [The error amqp:internal-error shall be set in the error.condition field of the CLOSE frame.] */
AzureIoTClient	4:98007eb79fa8	545	/* Codes_SRS_CONNECTION_01_219: [The error description shall be set to an implementation defined string.] */
AzureIoTClient	4:98007eb79fa8	546	close_connection_with_error(connection_instance, "amqp:internal-error", "connection_byte_received::frame_codec_receive_bytes failed");
AzureIoTClient	4:98007eb79fa8	547	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	548	}
AzureIoTClient	4:98007eb79fa8	549	else
AzureIoTClient	4:98007eb79fa8	550	{
AzureIoTClient	4:98007eb79fa8	551	result = 0;
AzureIoTClient	4:98007eb79fa8	552	}
Azure.IoT Build	0:6ae2f7bca550	553
AzureIoTClient	4:98007eb79fa8	554	break;
AzureIoTClient	4:98007eb79fa8	555	}
AzureIoTClient	4:98007eb79fa8	556
AzureIoTClient	4:98007eb79fa8	557	return result;
Azure.IoT Build	0:6ae2f7bca550	558	}
Azure.IoT Build	0:6ae2f7bca550	559
Azure.IoT Build	0:6ae2f7bca550	560	static void connection_on_bytes_received(void* context, const unsigned char* buffer, size_t size)
Azure.IoT Build	0:6ae2f7bca550	561	{
AzureIoTClient	4:98007eb79fa8	562	size_t i;
Azure.IoT Build	0:6ae2f7bca550	563
AzureIoTClient	4:98007eb79fa8	564	for (i = 0; i < size; i++)
AzureIoTClient	4:98007eb79fa8	565	{
AzureIoTClient	4:98007eb79fa8	566	if (connection_byte_received((CONNECTION_INSTANCE*)context, buffer[i]) != 0)
AzureIoTClient	4:98007eb79fa8	567	{
AzureIoTClient	4:98007eb79fa8	568	break;
AzureIoTClient	4:98007eb79fa8	569	}
AzureIoTClient	4:98007eb79fa8	570	}
Azure.IoT Build	0:6ae2f7bca550	571	}
Azure.IoT Build	0:6ae2f7bca550	572
Azure.IoT Build	0:6ae2f7bca550	573	static void connection_on_io_open_complete(void* context, IO_OPEN_RESULT io_open_result)
Azure.IoT Build	0:6ae2f7bca550	574	{
AzureIoTClient	4:98007eb79fa8	575	CONNECTION_INSTANCE* connection_instance = (CONNECTION_INSTANCE*)context;
Azure.IoT Build	0:6ae2f7bca550	576
AzureIoTClient	4:98007eb79fa8	577	if (io_open_result == IO_OPEN_OK)
AzureIoTClient	4:98007eb79fa8	578	{
AzureIoTClient	4:98007eb79fa8	579	/* Codes_SRS_CONNECTION_01_084: [The connection_instance state machine implementing the protocol requirements shall be run as part of connection_dowork.] */
AzureIoTClient	4:98007eb79fa8	580	switch (connection_instance->connection_state)
AzureIoTClient	4:98007eb79fa8	581	{
AzureIoTClient	4:98007eb79fa8	582	default:
AzureIoTClient	4:98007eb79fa8	583	break;
Azure.IoT Build	0:6ae2f7bca550	584
AzureIoTClient	4:98007eb79fa8	585	case CONNECTION_STATE_START:
AzureIoTClient	4:98007eb79fa8	586	/* Codes_SRS_CONNECTION_01_086: [Prior to sending any frames on a connection_instance, each peer MUST start by sending a protocol header that indicates the protocol version used on the connection_instance.] */
AzureIoTClient	4:98007eb79fa8	587	/* Codes_SRS_CONNECTION_01_091: [The AMQP peer which acted in the role of the TCP client (i.e. the peer that actively opened the connection_instance) MUST immediately send its outgoing protocol header on establishment of the TCP connection_instance.] */
AzureIoTClient	4:98007eb79fa8	588	(void)send_header(connection_instance);
AzureIoTClient	4:98007eb79fa8	589	break;
Azure.IoT Build	0:6ae2f7bca550	590
AzureIoTClient	4:98007eb79fa8	591	case CONNECTION_STATE_HDR_SENT:
AzureIoTClient	4:98007eb79fa8	592	case CONNECTION_STATE_OPEN_SENT:
AzureIoTClient	4:98007eb79fa8	593	case CONNECTION_STATE_OPENED:
AzureIoTClient	4:98007eb79fa8	594	break;
Azure.IoT Build	0:6ae2f7bca550	595
AzureIoTClient	4:98007eb79fa8	596	case CONNECTION_STATE_HDR_EXCH:
AzureIoTClient	4:98007eb79fa8	597	/* Codes_SRS_CONNECTION_01_002: [Each AMQP connection_instance begins with an exchange of capabilities and limitations, including the maximum frame size.] */
AzureIoTClient	4:98007eb79fa8	598	/* Codes_SRS_CONNECTION_01_004: [After establishing or accepting a TCP connection_instance and sending the protocol header, each peer MUST send an open frame before sending any other frames.] */
AzureIoTClient	4:98007eb79fa8	599	/* Codes_SRS_CONNECTION_01_005: [The open frame describes the capabilities and limits of that peer.] */
AzureIoTClient	4:98007eb79fa8	600	if (send_open_frame(connection_instance) != 0)
AzureIoTClient	4:98007eb79fa8	601	{
AzureIoTClient	4:98007eb79fa8	602	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	603	}
AzureIoTClient	4:98007eb79fa8	604	break;
Azure.IoT Build	0:6ae2f7bca550	605
AzureIoTClient	4:98007eb79fa8	606	case CONNECTION_STATE_OPEN_RCVD:
AzureIoTClient	4:98007eb79fa8	607	break;
AzureIoTClient	4:98007eb79fa8	608	}
AzureIoTClient	4:98007eb79fa8	609	}
AzureIoTClient	4:98007eb79fa8	610	else
AzureIoTClient	4:98007eb79fa8	611	{
AzureIoTClient	4:98007eb79fa8	612	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	613	}
Azure.IoT Build	0:6ae2f7bca550	614	}
Azure.IoT Build	0:6ae2f7bca550	615
Azure.IoT Build	0:6ae2f7bca550	616	static void connection_on_io_error(void* context)
Azure.IoT Build	0:6ae2f7bca550	617	{
AzureIoTClient	4:98007eb79fa8	618	CONNECTION_INSTANCE* connection_instance = (CONNECTION_INSTANCE*)context;
Azure.IoT Build	0:6ae2f7bca550	619
Azure.IoT Build	0:6ae2f7bca550	620	/* Codes_SRS_CONNECTION_22_005: [If the io notifies the connection instance of an IO_STATE_ERROR state and an io error callback is registered, the connection shall call the registered callback.] */
Azure.IoT Build	0:6ae2f7bca550	621	if (connection_instance->on_io_error)
Azure.IoT Build	0:6ae2f7bca550	622	{
Azure.IoT Build	0:6ae2f7bca550	623	connection_instance->on_io_error(connection_instance->on_io_error_callback_context);
Azure.IoT Build	0:6ae2f7bca550	624	}
Azure.IoT Build	0:6ae2f7bca550	625
AzureIoTClient	4:98007eb79fa8	626	if (connection_instance->connection_state != CONNECTION_STATE_END)
AzureIoTClient	4:98007eb79fa8	627	{
AzureIoTClient	4:98007eb79fa8	628	/* Codes_SRS_CONNECTION_01_202: [If the io notifies the connection instance of an IO_STATE_ERROR state the connection shall be closed and the state set to END.] */
AzureIoTClient	4:98007eb79fa8	629	connection_set_state(connection_instance, CONNECTION_STATE_ERROR);
AzureIoTClient	4:98007eb79fa8	630	(void)xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	631	}
Azure.IoT Build	0:6ae2f7bca550	632	}
Azure.IoT Build	0:6ae2f7bca550	633
Azure.IoT Build	0:6ae2f7bca550	634	static void on_empty_amqp_frame_received(void* context, uint16_t channel)
Azure.IoT Build	0:6ae2f7bca550	635	{
AzureIoTClient	6:641a9672db08	636	(void)channel;
AzureIoTClient	6:641a9672db08	637	/* It does not matter on which channel we received the frame */
AzureIoTClient	4:98007eb79fa8	638	CONNECTION_INSTANCE* connection_instance = (CONNECTION_INSTANCE*)context;
AzureIoTClient	6:641a9672db08	639	if (connection_instance->is_trace_on == 1)
AzureIoTClient	6:641a9672db08	640	{
AzureIoTClient	6:641a9672db08	641	LOG(LOG_TRACE, LOG_LINE, "<- Empty frame");
AzureIoTClient	6:641a9672db08	642	}
AzureIoTClient	4:98007eb79fa8	643	if (tickcounter_get_current_ms(connection_instance->tick_counter, &connection_instance->last_frame_received_time) != 0)
AzureIoTClient	4:98007eb79fa8	644	{
AzureIoTClient	4:98007eb79fa8	645	/* error */
AzureIoTClient	4:98007eb79fa8	646	}
Azure.IoT Build	0:6ae2f7bca550	647	}
Azure.IoT Build	0:6ae2f7bca550	648
Azure.IoT Build	0:6ae2f7bca550	649	static void on_amqp_frame_received(void* context, uint16_t channel, AMQP_VALUE performative, const unsigned char* payload_bytes, uint32_t payload_size)
Azure.IoT Build	0:6ae2f7bca550	650	{
AzureIoTClient	6:641a9672db08	651	(void)channel;
AzureIoTClient	4:98007eb79fa8	652	CONNECTION_INSTANCE* connection_instance = (CONNECTION_INSTANCE*)context;
Azure.IoT Build	0:6ae2f7bca550	653
AzureIoTClient	4:98007eb79fa8	654	if (tickcounter_get_current_ms(connection_instance->tick_counter, &connection_instance->last_frame_received_time) != 0)
AzureIoTClient	4:98007eb79fa8	655	{
AzureIoTClient	4:98007eb79fa8	656	close_connection_with_error(connection_instance, "amqp:internal-error", "cannot get current tick count");
AzureIoTClient	4:98007eb79fa8	657	}
AzureIoTClient	4:98007eb79fa8	658	else
AzureIoTClient	4:98007eb79fa8	659	{
AzureIoTClient	4:98007eb79fa8	660	if (connection_instance->is_underlying_io_open)
AzureIoTClient	4:98007eb79fa8	661	{
AzureIoTClient	4:98007eb79fa8	662	switch (connection_instance->connection_state)
AzureIoTClient	4:98007eb79fa8	663	{
AzureIoTClient	4:98007eb79fa8	664	default:
AzureIoTClient	4:98007eb79fa8	665	if (performative == NULL)
AzureIoTClient	4:98007eb79fa8	666	{
AzureIoTClient	4:98007eb79fa8	667	/* Codes_SRS_CONNECTION_01_223: [If the on_endpoint_frame_received is called with a NULL performative then the connection shall be closed with the error condition amqp:internal-error and an implementation defined error description.] */
AzureIoTClient	4:98007eb79fa8	668	close_connection_with_error(connection_instance, "amqp:internal-error", "connection_endpoint_frame_received::NULL performative");
AzureIoTClient	4:98007eb79fa8	669	}
AzureIoTClient	4:98007eb79fa8	670	else
AzureIoTClient	4:98007eb79fa8	671	{
AzureIoTClient	4:98007eb79fa8	672	AMQP_VALUE descriptor = amqpvalue_get_inplace_descriptor(performative);
AzureIoTClient	4:98007eb79fa8	673	uint64_t performative_ulong;
Azure.IoT Build	0:6ae2f7bca550	674
AzureIoTClient	4:98007eb79fa8	675	if (connection_instance->is_trace_on == 1)
AzureIoTClient	4:98007eb79fa8	676	{
Azure.IoT Build	5:ae49385aff34	677	log_incoming_frame(performative);
AzureIoTClient	4:98007eb79fa8	678	}
Azure.IoT Build	0:6ae2f7bca550	679
AzureIoTClient	4:98007eb79fa8	680	if (is_open_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	681	{
AzureIoTClient	4:98007eb79fa8	682	if (channel != 0)
AzureIoTClient	4:98007eb79fa8	683	{
AzureIoTClient	4:98007eb79fa8	684	/* Codes_SRS_CONNECTION_01_006: [The open frame can only be sent on channel 0.] */
AzureIoTClient	4:98007eb79fa8	685	/* Codes_SRS_CONNECTION_01_222: [If an Open frame is received in a manner violating the ISO specification, the connection shall be closed with condition amqp:not-allowed and description being an implementation defined string.] */
AzureIoTClient	4:98007eb79fa8	686	close_connection_with_error(connection_instance, "amqp:not-allowed", "OPEN frame received on a channel that is not 0");
AzureIoTClient	4:98007eb79fa8	687	}
Azure.IoT Build	0:6ae2f7bca550	688
AzureIoTClient	4:98007eb79fa8	689	if (connection_instance->connection_state == CONNECTION_STATE_OPENED)
AzureIoTClient	4:98007eb79fa8	690	{
AzureIoTClient	4:98007eb79fa8	691	/* Codes_SRS_CONNECTION_01_239: [If an Open frame is received in the Opened state the connection shall be closed with condition amqp:illegal-state and description being an implementation defined string.] */
AzureIoTClient	4:98007eb79fa8	692	close_connection_with_error(connection_instance, "amqp:illegal-state", "OPEN frame received in the OPENED state");
AzureIoTClient	4:98007eb79fa8	693	}
AzureIoTClient	4:98007eb79fa8	694	else if ((connection_instance->connection_state == CONNECTION_STATE_OPEN_SENT) \|\|
AzureIoTClient	4:98007eb79fa8	695	(connection_instance->connection_state == CONNECTION_STATE_HDR_EXCH))
AzureIoTClient	4:98007eb79fa8	696	{
AzureIoTClient	4:98007eb79fa8	697	OPEN_HANDLE open_handle;
AzureIoTClient	4:98007eb79fa8	698	if (amqpvalue_get_open(performative, &open_handle) != 0)
AzureIoTClient	4:98007eb79fa8	699	{
AzureIoTClient	4:98007eb79fa8	700	/* Codes_SRS_CONNECTION_01_143: [If any of the values in the received open frame are invalid then the connection shall be closed.] */
AzureIoTClient	4:98007eb79fa8	701	/* Codes_SRS_CONNECTION_01_220: [The error amqp:invalid-field shall be set in the error.condition field of the CLOSE frame.] */
AzureIoTClient	4:98007eb79fa8	702	close_connection_with_error(connection_instance, "amqp:invalid-field", "connection_endpoint_frame_received::failed parsing OPEN frame");
AzureIoTClient	4:98007eb79fa8	703	}
AzureIoTClient	4:98007eb79fa8	704	else
AzureIoTClient	4:98007eb79fa8	705	{
AzureIoTClient	4:98007eb79fa8	706	(void)open_get_idle_time_out(open_handle, &connection_instance->remote_idle_timeout);
AzureIoTClient	4:98007eb79fa8	707	if ((open_get_max_frame_size(open_handle, &connection_instance->remote_max_frame_size) != 0) \|\|
AzureIoTClient	4:98007eb79fa8	708	/* Codes_SRS_CONNECTION_01_167: [Both peers MUST accept frames of up to 512 (MIN-MAX-FRAME-SIZE) octets.] */
AzureIoTClient	4:98007eb79fa8	709	(connection_instance->remote_max_frame_size < 512))
AzureIoTClient	4:98007eb79fa8	710	{
AzureIoTClient	4:98007eb79fa8	711	/* Codes_SRS_CONNECTION_01_143: [If any of the values in the received open frame are invalid then the connection shall be closed.] */
AzureIoTClient	4:98007eb79fa8	712	/* Codes_SRS_CONNECTION_01_220: [The error amqp:invalid-field shall be set in the error.condition field of the CLOSE frame.] */
AzureIoTClient	4:98007eb79fa8	713	close_connection_with_error(connection_instance, "amqp:invalid-field", "connection_endpoint_frame_received::failed parsing OPEN frame");
AzureIoTClient	4:98007eb79fa8	714	}
AzureIoTClient	4:98007eb79fa8	715	else
AzureIoTClient	4:98007eb79fa8	716	{
AzureIoTClient	4:98007eb79fa8	717	if (connection_instance->connection_state == CONNECTION_STATE_OPEN_SENT)
AzureIoTClient	4:98007eb79fa8	718	{
AzureIoTClient	4:98007eb79fa8	719	connection_set_state(connection_instance, CONNECTION_STATE_OPENED);
AzureIoTClient	4:98007eb79fa8	720	}
AzureIoTClient	4:98007eb79fa8	721	else
AzureIoTClient	4:98007eb79fa8	722	{
AzureIoTClient	4:98007eb79fa8	723	if (send_open_frame(connection_instance) != 0)
AzureIoTClient	4:98007eb79fa8	724	{
AzureIoTClient	4:98007eb79fa8	725	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	726	}
AzureIoTClient	4:98007eb79fa8	727	else
AzureIoTClient	4:98007eb79fa8	728	{
AzureIoTClient	4:98007eb79fa8	729	connection_set_state(connection_instance, CONNECTION_STATE_OPENED);
AzureIoTClient	4:98007eb79fa8	730	}
AzureIoTClient	4:98007eb79fa8	731	}
AzureIoTClient	4:98007eb79fa8	732	}
Azure.IoT Build	0:6ae2f7bca550	733
AzureIoTClient	4:98007eb79fa8	734	open_destroy(open_handle);
AzureIoTClient	4:98007eb79fa8	735	}
AzureIoTClient	4:98007eb79fa8	736	}
AzureIoTClient	4:98007eb79fa8	737	else
AzureIoTClient	4:98007eb79fa8	738	{
AzureIoTClient	4:98007eb79fa8	739	/* do nothing for now ... */
AzureIoTClient	4:98007eb79fa8	740	}
AzureIoTClient	4:98007eb79fa8	741	}
AzureIoTClient	4:98007eb79fa8	742	else if (is_close_type_by_descriptor(descriptor))
AzureIoTClient	4:98007eb79fa8	743	{
AzureIoTClient	4:98007eb79fa8	744	/* Codes_SRS_CONNECTION_01_012: [A close frame MAY be received on any channel up to the maximum channel number negotiated in open.] */
AzureIoTClient	4:98007eb79fa8	745	/* Codes_SRS_CONNECTION_01_242: [The connection module shall accept CLOSE frames even if they have extra payload bytes besides the Close performative.] */
Azure.IoT Build	0:6ae2f7bca550	746
AzureIoTClient	4:98007eb79fa8	747	/* Codes_SRS_CONNECTION_01_225: [HDR_RCVD HDR OPEN] */
AzureIoTClient	4:98007eb79fa8	748	if ((connection_instance->connection_state == CONNECTION_STATE_HDR_RCVD) \|\|
AzureIoTClient	4:98007eb79fa8	749	/* Codes_SRS_CONNECTION_01_227: [HDR_EXCH OPEN OPEN] */
AzureIoTClient	4:98007eb79fa8	750	(connection_instance->connection_state == CONNECTION_STATE_HDR_EXCH) \|\|
AzureIoTClient	4:98007eb79fa8	751	/* Codes_SRS_CONNECTION_01_228: [OPEN_RCVD OPEN ] /
AzureIoTClient	4:98007eb79fa8	752	(connection_instance->connection_state == CONNECTION_STATE_OPEN_RCVD) \|\|
AzureIoTClient	4:98007eb79fa8	753	/* Codes_SRS_CONNECTION_01_235: [CLOSE_SENT - * TCP Close for Write] */
AzureIoTClient	4:98007eb79fa8	754	(connection_instance->connection_state == CONNECTION_STATE_CLOSE_SENT) \|\|
AzureIoTClient	4:98007eb79fa8	755	/* Codes_SRS_CONNECTION_01_236: [DISCARDING - * TCP Close for Write] */
AzureIoTClient	4:98007eb79fa8	756	(connection_instance->connection_state == CONNECTION_STATE_DISCARDING))
AzureIoTClient	4:98007eb79fa8	757	{
AzureIoTClient	4:98007eb79fa8	758	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	759	}
AzureIoTClient	4:98007eb79fa8	760	else
AzureIoTClient	4:98007eb79fa8	761	{
AzureIoTClient	4:98007eb79fa8	762	CLOSE_HANDLE close_handle;
Azure.IoT Build	0:6ae2f7bca550	763
AzureIoTClient	4:98007eb79fa8	764	/* Codes_SRS_CONNECTION_01_012: [A close frame MAY be received on any channel up to the maximum channel number negotiated in open.] */
AzureIoTClient	4:98007eb79fa8	765	if (channel > connection_instance->channel_max)
AzureIoTClient	4:98007eb79fa8	766	{
AzureIoTClient	4:98007eb79fa8	767	close_connection_with_error(connection_instance, "amqp:invalid-field", "connection_endpoint_frame_received::failed parsing CLOSE frame");
AzureIoTClient	4:98007eb79fa8	768	}
AzureIoTClient	4:98007eb79fa8	769	else
AzureIoTClient	4:98007eb79fa8	770	{
AzureIoTClient	4:98007eb79fa8	771	if (amqpvalue_get_close(performative, &close_handle) != 0)
AzureIoTClient	4:98007eb79fa8	772	{
AzureIoTClient	4:98007eb79fa8	773	close_connection_with_error(connection_instance, "amqp:invalid-field", "connection_endpoint_frame_received::failed parsing CLOSE frame");
AzureIoTClient	4:98007eb79fa8	774	}
AzureIoTClient	4:98007eb79fa8	775	else
AzureIoTClient	4:98007eb79fa8	776	{
AzureIoTClient	4:98007eb79fa8	777	close_destroy(close_handle);
Azure.IoT Build	0:6ae2f7bca550	778
AzureIoTClient	4:98007eb79fa8	779	connection_set_state(connection_instance, CONNECTION_STATE_CLOSE_RCVD);
Azure.IoT Build	0:6ae2f7bca550	780
AzureIoTClient	4:98007eb79fa8	781	(void)send_close_frame(connection_instance, NULL);
AzureIoTClient	4:98007eb79fa8	782	/* Codes_SRS_CONNECTION_01_214: [If the close frame cannot be constructed or sent, the connection shall be closed and set to the END state.] */
AzureIoTClient	4:98007eb79fa8	783	(void)xio_close(connection_instance->io, NULL, NULL);
Azure.IoT Build	0:6ae2f7bca550	784
AzureIoTClient	4:98007eb79fa8	785	connection_set_state(connection_instance, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	786	}
AzureIoTClient	4:98007eb79fa8	787	}
AzureIoTClient	4:98007eb79fa8	788	}
AzureIoTClient	4:98007eb79fa8	789	}
AzureIoTClient	4:98007eb79fa8	790	else
AzureIoTClient	4:98007eb79fa8	791	{
AzureIoTClient	4:98007eb79fa8	792	amqpvalue_get_ulong(descriptor, &performative_ulong);
Azure.IoT Build	0:6ae2f7bca550	793
AzureIoTClient	4:98007eb79fa8	794	switch (performative_ulong)
AzureIoTClient	4:98007eb79fa8	795	{
AzureIoTClient	4:98007eb79fa8	796	default:
AzureIoTClient	6:641a9672db08	797	LOG(LOG_ERROR, LOG_LINE, "Bad performative: %02x", performative);
AzureIoTClient	4:98007eb79fa8	798	break;
Azure.IoT Build	0:6ae2f7bca550	799
AzureIoTClient	4:98007eb79fa8	800	case AMQP_BEGIN:
AzureIoTClient	4:98007eb79fa8	801	{
AzureIoTClient	4:98007eb79fa8	802	BEGIN_HANDLE begin;
AzureIoTClient	4:98007eb79fa8	803	amqpvalue_get_begin(performative, &begin);
Azure.IoT Build	0:6ae2f7bca550	804
AzureIoTClient	4:98007eb79fa8	805	if (begin == NULL)
AzureIoTClient	4:98007eb79fa8	806	{
AzureIoTClient	4:98007eb79fa8	807	/* error */
AzureIoTClient	4:98007eb79fa8	808	}
AzureIoTClient	4:98007eb79fa8	809	else
AzureIoTClient	4:98007eb79fa8	810	{
AzureIoTClient	4:98007eb79fa8	811	uint16_t remote_channel;
AzureIoTClient	4:98007eb79fa8	812	ENDPOINT_HANDLE new_endpoint = NULL;
AzureIoTClient	4:98007eb79fa8	813	bool remote_begin = false;
Azure.IoT Build	0:6ae2f7bca550	814
AzureIoTClient	4:98007eb79fa8	815	if (begin_get_remote_channel(begin, &remote_channel) != 0)
AzureIoTClient	4:98007eb79fa8	816	{
AzureIoTClient	4:98007eb79fa8	817	remote_begin = true;
AzureIoTClient	4:98007eb79fa8	818	if (connection_instance->on_new_endpoint != NULL)
AzureIoTClient	4:98007eb79fa8	819	{
AzureIoTClient	4:98007eb79fa8	820	new_endpoint = connection_create_endpoint(connection_instance);
AzureIoTClient	4:98007eb79fa8	821	if (!connection_instance->on_new_endpoint(connection_instance->on_new_endpoint_callback_context, new_endpoint))
AzureIoTClient	4:98007eb79fa8	822	{
AzureIoTClient	4:98007eb79fa8	823	connection_destroy_endpoint(new_endpoint);
AzureIoTClient	4:98007eb79fa8	824	new_endpoint = NULL;
AzureIoTClient	4:98007eb79fa8	825	}
AzureIoTClient	4:98007eb79fa8	826	}
AzureIoTClient	4:98007eb79fa8	827	}
Azure.IoT Build	0:6ae2f7bca550	828
AzureIoTClient	4:98007eb79fa8	829	if (!remote_begin)
AzureIoTClient	4:98007eb79fa8	830	{
AzureIoTClient	4:98007eb79fa8	831	ENDPOINT_INSTANCE* session_endpoint = find_session_endpoint_by_outgoing_channel(connection_instance, remote_channel);
AzureIoTClient	4:98007eb79fa8	832	if (session_endpoint == NULL)
AzureIoTClient	4:98007eb79fa8	833	{
AzureIoTClient	4:98007eb79fa8	834	/* error */
AzureIoTClient	4:98007eb79fa8	835	}
AzureIoTClient	4:98007eb79fa8	836	else
AzureIoTClient	4:98007eb79fa8	837	{
AzureIoTClient	4:98007eb79fa8	838	session_endpoint->incoming_channel = channel;
AzureIoTClient	4:98007eb79fa8	839	session_endpoint->on_endpoint_frame_received(session_endpoint->callback_context, performative, payload_size, payload_bytes);
AzureIoTClient	4:98007eb79fa8	840	}
AzureIoTClient	4:98007eb79fa8	841	}
AzureIoTClient	4:98007eb79fa8	842	else
AzureIoTClient	4:98007eb79fa8	843	{
Azure.IoT Build	0:6ae2f7bca550	844	if (new_endpoint != NULL)
Azure.IoT Build	0:6ae2f7bca550	845	{
Azure.IoT Build	0:6ae2f7bca550	846	new_endpoint->incoming_channel = channel;
Azure.IoT Build	0:6ae2f7bca550	847	new_endpoint->on_endpoint_frame_received(new_endpoint->callback_context, performative, payload_size, payload_bytes);
Azure.IoT Build	0:6ae2f7bca550	848	}
AzureIoTClient	4:98007eb79fa8	849	}
Azure.IoT Build	0:6ae2f7bca550	850
AzureIoTClient	4:98007eb79fa8	851	begin_destroy(begin);
AzureIoTClient	4:98007eb79fa8	852	}
Azure.IoT Build	0:6ae2f7bca550	853
AzureIoTClient	4:98007eb79fa8	854	break;
AzureIoTClient	4:98007eb79fa8	855	}
Azure.IoT Build	0:6ae2f7bca550	856
AzureIoTClient	4:98007eb79fa8	857	case AMQP_FLOW:
AzureIoTClient	4:98007eb79fa8	858	case AMQP_TRANSFER:
AzureIoTClient	4:98007eb79fa8	859	case AMQP_DISPOSITION:
AzureIoTClient	4:98007eb79fa8	860	case AMQP_END:
AzureIoTClient	4:98007eb79fa8	861	case AMQP_ATTACH:
AzureIoTClient	4:98007eb79fa8	862	case AMQP_DETACH:
AzureIoTClient	4:98007eb79fa8	863	{
AzureIoTClient	4:98007eb79fa8	864	ENDPOINT_INSTANCE* session_endpoint = find_session_endpoint_by_incoming_channel(connection_instance, channel);
AzureIoTClient	4:98007eb79fa8	865	if (session_endpoint == NULL)
AzureIoTClient	4:98007eb79fa8	866	{
AzureIoTClient	4:98007eb79fa8	867	/* error */
AzureIoTClient	4:98007eb79fa8	868	}
AzureIoTClient	4:98007eb79fa8	869	else
AzureIoTClient	4:98007eb79fa8	870	{
AzureIoTClient	4:98007eb79fa8	871	session_endpoint->on_endpoint_frame_received(session_endpoint->callback_context, performative, payload_size, payload_bytes);
AzureIoTClient	4:98007eb79fa8	872	}
Azure.IoT Build	0:6ae2f7bca550	873
AzureIoTClient	4:98007eb79fa8	874	break;
AzureIoTClient	4:98007eb79fa8	875	}
AzureIoTClient	4:98007eb79fa8	876	}
AzureIoTClient	4:98007eb79fa8	877	}
AzureIoTClient	4:98007eb79fa8	878	}
AzureIoTClient	4:98007eb79fa8	879	break;
Azure.IoT Build	0:6ae2f7bca550	880
AzureIoTClient	4:98007eb79fa8	881	case CONNECTION_STATE_START:
AzureIoTClient	4:98007eb79fa8	882	/* Codes_SRS_CONNECTION_01_224: [START HDR HDR] */
AzureIoTClient	4:98007eb79fa8	883	case CONNECTION_STATE_HDR_SENT:
AzureIoTClient	4:98007eb79fa8	884	/* Codes_SRS_CONNECTION_01_226: [HDR_SENT OPEN HDR] */
AzureIoTClient	4:98007eb79fa8	885	case CONNECTION_STATE_OPEN_PIPE:
AzureIoTClient	4:98007eb79fa8	886	/* Codes_SRS_CONNECTION_01_230: [OPEN_PIPE ** HDR] */
AzureIoTClient	4:98007eb79fa8	887	case CONNECTION_STATE_OC_PIPE:
AzureIoTClient	4:98007eb79fa8	888	/* Codes_SRS_CONNECTION_01_232: [OC_PIPE - HDR TCP Close for Write] */
AzureIoTClient	4:98007eb79fa8	889	case CONNECTION_STATE_CLOSE_RCVD:
AzureIoTClient	4:98007eb79fa8	890	/* Codes_SRS_CONNECTION_01_234: [CLOSE_RCVD * - TCP Close for Read] */
AzureIoTClient	4:98007eb79fa8	891	case CONNECTION_STATE_END:
AzureIoTClient	4:98007eb79fa8	892	/* Codes_SRS_CONNECTION_01_237: [END - - TCP Close] */
AzureIoTClient	4:98007eb79fa8	893	xio_close(connection_instance->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	894	break;
AzureIoTClient	4:98007eb79fa8	895	}
AzureIoTClient	4:98007eb79fa8	896	}
AzureIoTClient	4:98007eb79fa8	897	}
Azure.IoT Build	0:6ae2f7bca550	898	}
Azure.IoT Build	0:6ae2f7bca550	899
Azure.IoT Build	0:6ae2f7bca550	900	static void frame_codec_error(void* context)
Azure.IoT Build	0:6ae2f7bca550	901	{
AzureIoTClient	6:641a9672db08	902	/* Bug: some error handling should happen here
AzureIoTClient	6:641a9672db08	903	Filed: uAMQP: frame_codec error and amqp_frame_codec_error should handle the errors */
AzureIoTClient	6:641a9672db08	904	(void)context;
Azure.IoT Build	0:6ae2f7bca550	905	}
Azure.IoT Build	0:6ae2f7bca550	906
Azure.IoT Build	0:6ae2f7bca550	907	static void amqp_frame_codec_error(void* context)
Azure.IoT Build	0:6ae2f7bca550	908	{
AzureIoTClient	6:641a9672db08	909	/* Bug: some error handling should happen here
AzureIoTClient	6:641a9672db08	910	Filed: uAMQP: frame_codec error and amqp_frame_codec_error should handle the errors */
AzureIoTClient	6:641a9672db08	911	(void)context;
Azure.IoT Build	0:6ae2f7bca550	912	}
Azure.IoT Build	0:6ae2f7bca550	913
Azure.IoT Build	0:6ae2f7bca550	914	/* Codes_SRS_CONNECTION_01_001: [connection_create shall open a new connection to a specified host/port.] */
Azure.IoT Build	0:6ae2f7bca550	915	CONNECTION_HANDLE connection_create(XIO_HANDLE xio, const char* hostname, const char* container_id, ON_NEW_ENDPOINT on_new_endpoint, void* callback_context)
Azure.IoT Build	0:6ae2f7bca550	916	{
Azure.IoT Build	5:ae49385aff34	917	return connection_create2(xio, hostname, container_id, on_new_endpoint, callback_context, NULL, NULL, NULL, NULL);
Azure.IoT Build	0:6ae2f7bca550	918	}
Azure.IoT Build	0:6ae2f7bca550	919
Azure.IoT Build	0:6ae2f7bca550	920	/* Codes_SRS_CONNECTION_01_001: [connection_create shall open a new connection to a specified host/port.] */
Azure.IoT Build	0:6ae2f7bca550	921	/* Codes_SRS_CONNECTION_22_002: [connection_create shall allow registering connections state and io error callbacks.] */
Azure.IoT Build	5:ae49385aff34	922	CONNECTION_HANDLE connection_create2(XIO_HANDLE xio, const char* hostname, const char* container_id, ON_NEW_ENDPOINT on_new_endpoint, void* callback_context, ON_CONNECTION_STATE_CHANGED on_connection_state_changed, void* on_connection_state_changed_context, ON_IO_ERROR on_io_error, void* on_io_error_context)
Azure.IoT Build	0:6ae2f7bca550	923	{
AzureIoTClient	4:98007eb79fa8	924	CONNECTION_INSTANCE* result;
Azure.IoT Build	0:6ae2f7bca550	925
AzureIoTClient	4:98007eb79fa8	926	if ((xio == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	927	(container_id == NULL))
AzureIoTClient	4:98007eb79fa8	928	{
AzureIoTClient	4:98007eb79fa8	929	/* Codes_SRS_CONNECTION_01_071: [If xio or container_id is NULL, connection_create shall return NULL.] */
AzureIoTClient	4:98007eb79fa8	930	result = NULL;
AzureIoTClient	4:98007eb79fa8	931	}
AzureIoTClient	4:98007eb79fa8	932	else
AzureIoTClient	4:98007eb79fa8	933	{
AzureIoTClient	4:98007eb79fa8	934	result = (CONNECTION_INSTANCE*)amqpalloc_malloc(sizeof(CONNECTION_INSTANCE));
AzureIoTClient	4:98007eb79fa8	935	/* Codes_SRS_CONNECTION_01_081: [If allocating the memory for the connection fails then connection_create shall return NULL.] */
AzureIoTClient	4:98007eb79fa8	936	if (result != NULL)
AzureIoTClient	4:98007eb79fa8	937	{
AzureIoTClient	4:98007eb79fa8	938	result->io = xio;
Azure.IoT Build	0:6ae2f7bca550	939
AzureIoTClient	4:98007eb79fa8	940	/* Codes_SRS_CONNECTION_01_082: [connection_create shall allocate a new frame_codec instance to be used for frame encoding/decoding.] */
Azure.IoT Build	5:ae49385aff34	941	result->frame_codec = frame_codec_create(frame_codec_error, result);
AzureIoTClient	4:98007eb79fa8	942	if (result->frame_codec == NULL)
AzureIoTClient	4:98007eb79fa8	943	{
AzureIoTClient	4:98007eb79fa8	944	/* Codes_SRS_CONNECTION_01_083: [If frame_codec_create fails then connection_create shall return NULL.] */
AzureIoTClient	4:98007eb79fa8	945	amqpalloc_free(result);
AzureIoTClient	4:98007eb79fa8	946	result = NULL;
AzureIoTClient	4:98007eb79fa8	947	}
AzureIoTClient	4:98007eb79fa8	948	else
AzureIoTClient	4:98007eb79fa8	949	{
AzureIoTClient	4:98007eb79fa8	950	result->amqp_frame_codec = amqp_frame_codec_create(result->frame_codec, on_amqp_frame_received, on_empty_amqp_frame_received, amqp_frame_codec_error, result);
AzureIoTClient	4:98007eb79fa8	951	if (result->amqp_frame_codec == NULL)
AzureIoTClient	4:98007eb79fa8	952	{
AzureIoTClient	4:98007eb79fa8	953	/* Codes_SRS_CONNECTION_01_108: [If amqp_frame_codec_create fails, connection_create shall return NULL.] */
AzureIoTClient	4:98007eb79fa8	954	frame_codec_destroy(result->frame_codec);
AzureIoTClient	4:98007eb79fa8	955	amqpalloc_free(result);
AzureIoTClient	4:98007eb79fa8	956	result = NULL;
AzureIoTClient	4:98007eb79fa8	957	}
AzureIoTClient	4:98007eb79fa8	958	else
AzureIoTClient	4:98007eb79fa8	959	{
AzureIoTClient	4:98007eb79fa8	960	if (hostname != NULL)
AzureIoTClient	4:98007eb79fa8	961	{
AzureIoTClient	4:98007eb79fa8	962	result->host_name = (char*)amqpalloc_malloc(strlen(hostname) + 1);
AzureIoTClient	4:98007eb79fa8	963	if (result->host_name == NULL)
AzureIoTClient	4:98007eb79fa8	964	{
AzureIoTClient	4:98007eb79fa8	965	/* Codes_SRS_CONNECTION_01_081: [If allocating the memory for the connection fails then connection_create shall return NULL.] */
AzureIoTClient	4:98007eb79fa8	966	amqp_frame_codec_destroy(result->amqp_frame_codec);
AzureIoTClient	4:98007eb79fa8	967	frame_codec_destroy(result->frame_codec);
AzureIoTClient	4:98007eb79fa8	968	amqpalloc_free(result);
AzureIoTClient	4:98007eb79fa8	969	result = NULL;
AzureIoTClient	4:98007eb79fa8	970	}
AzureIoTClient	4:98007eb79fa8	971	else
AzureIoTClient	4:98007eb79fa8	972	{
AzureIoTClient	4:98007eb79fa8	973	strcpy(result->host_name, hostname);
AzureIoTClient	4:98007eb79fa8	974	}
AzureIoTClient	4:98007eb79fa8	975	}
AzureIoTClient	4:98007eb79fa8	976	else
AzureIoTClient	4:98007eb79fa8	977	{
AzureIoTClient	4:98007eb79fa8	978	result->host_name = NULL;
AzureIoTClient	4:98007eb79fa8	979	}
Azure.IoT Build	0:6ae2f7bca550	980
AzureIoTClient	4:98007eb79fa8	981	if (result != NULL)
AzureIoTClient	4:98007eb79fa8	982	{
AzureIoTClient	4:98007eb79fa8	983	result->container_id = (char*)amqpalloc_malloc(strlen(container_id) + 1);
AzureIoTClient	4:98007eb79fa8	984	if (result->container_id == NULL)
AzureIoTClient	4:98007eb79fa8	985	{
AzureIoTClient	4:98007eb79fa8	986	/* Codes_SRS_CONNECTION_01_081: [If allocating the memory for the connection fails then connection_create shall return NULL.] */
AzureIoTClient	4:98007eb79fa8	987	amqpalloc_free(result->host_name);
AzureIoTClient	4:98007eb79fa8	988	amqp_frame_codec_destroy(result->amqp_frame_codec);
AzureIoTClient	4:98007eb79fa8	989	frame_codec_destroy(result->frame_codec);
AzureIoTClient	4:98007eb79fa8	990	amqpalloc_free(result);
AzureIoTClient	4:98007eb79fa8	991	result = NULL;
AzureIoTClient	4:98007eb79fa8	992	}
AzureIoTClient	4:98007eb79fa8	993	else
AzureIoTClient	4:98007eb79fa8	994	{
AzureIoTClient	4:98007eb79fa8	995	result->tick_counter = tickcounter_create();
AzureIoTClient	4:98007eb79fa8	996	if (result->tick_counter == NULL)
AzureIoTClient	4:98007eb79fa8	997	{
AzureIoTClient	4:98007eb79fa8	998	amqpalloc_free(result->container_id);
AzureIoTClient	4:98007eb79fa8	999	amqpalloc_free(result->host_name);
AzureIoTClient	4:98007eb79fa8	1000	amqp_frame_codec_destroy(result->amqp_frame_codec);
AzureIoTClient	4:98007eb79fa8	1001	frame_codec_destroy(result->frame_codec);
AzureIoTClient	4:98007eb79fa8	1002	amqpalloc_free(result);
AzureIoTClient	4:98007eb79fa8	1003	result = NULL;
AzureIoTClient	4:98007eb79fa8	1004	}
AzureIoTClient	4:98007eb79fa8	1005	else
AzureIoTClient	4:98007eb79fa8	1006	{
AzureIoTClient	4:98007eb79fa8	1007	strcpy(result->container_id, container_id);
Azure.IoT Build	0:6ae2f7bca550	1008
AzureIoTClient	4:98007eb79fa8	1009	/* Codes_SRS_CONNECTION_01_173: [<field name="max-frame-size" type="uint" default="4294967295"/>] */
AzureIoTClient	4:98007eb79fa8	1010	result->max_frame_size = 4294967295u;
AzureIoTClient	4:98007eb79fa8	1011	/* Codes: [<field name="channel-max" type="ushort" default="65535"/>] */
AzureIoTClient	4:98007eb79fa8	1012	result->channel_max = 65535;
Azure.IoT Build	0:6ae2f7bca550	1013
AzureIoTClient	4:98007eb79fa8	1014	/* Codes_SRS_CONNECTION_01_175: [<field name="idle-time-out" type="milliseconds"/>] */
AzureIoTClient	4:98007eb79fa8	1015	/* Codes_SRS_CONNECTION_01_192: [A value of zero is the same as if it was not set (null).] */
AzureIoTClient	4:98007eb79fa8	1016	result->idle_timeout = 0;
AzureIoTClient	4:98007eb79fa8	1017	result->remote_idle_timeout = 0;
Azure.IoT Build	0:6ae2f7bca550	1018
AzureIoTClient	4:98007eb79fa8	1019	result->endpoint_count = 0;
AzureIoTClient	4:98007eb79fa8	1020	result->endpoints = NULL;
AzureIoTClient	4:98007eb79fa8	1021	result->header_bytes_received = 0;
AzureIoTClient	4:98007eb79fa8	1022	result->is_remote_frame_received = 0;
Azure.IoT Build	0:6ae2f7bca550	1023
AzureIoTClient	4:98007eb79fa8	1024	result->is_underlying_io_open = 0;
AzureIoTClient	4:98007eb79fa8	1025	result->remote_max_frame_size = 512;
AzureIoTClient	4:98007eb79fa8	1026	result->is_trace_on = 0;
Azure.IoT Build	0:6ae2f7bca550	1027
AzureIoTClient	4:98007eb79fa8	1028	/* Mark that settings have not yet been set by the user */
AzureIoTClient	4:98007eb79fa8	1029	result->idle_timeout_specified = 0;
Azure.IoT Build	0:6ae2f7bca550	1030
AzureIoTClient	4:98007eb79fa8	1031	result->on_new_endpoint = on_new_endpoint;
AzureIoTClient	4:98007eb79fa8	1032	result->on_new_endpoint_callback_context = callback_context;
Azure.IoT Build	0:6ae2f7bca550	1033
Azure.IoT Build	0:6ae2f7bca550	1034	result->on_io_error = on_io_error;
Azure.IoT Build	0:6ae2f7bca550	1035	result->on_io_error_callback_context = on_io_error_context;
Azure.IoT Build	0:6ae2f7bca550	1036	result->on_connection_state_changed = on_connection_state_changed;
Azure.IoT Build	0:6ae2f7bca550	1037	result->on_connection_state_changed_callback_context = on_connection_state_changed_context;
Azure.IoT Build	0:6ae2f7bca550	1038
AzureIoTClient	4:98007eb79fa8	1039	/* Codes_SRS_CONNECTION_01_072: [When connection_create succeeds, the state of the connection shall be CONNECTION_STATE_START.] */
AzureIoTClient	4:98007eb79fa8	1040	connection_set_state(result, CONNECTION_STATE_START);
AzureIoTClient	4:98007eb79fa8	1041	}
AzureIoTClient	4:98007eb79fa8	1042	}
AzureIoTClient	4:98007eb79fa8	1043	}
AzureIoTClient	4:98007eb79fa8	1044	}
AzureIoTClient	4:98007eb79fa8	1045	}
AzureIoTClient	4:98007eb79fa8	1046	}
AzureIoTClient	4:98007eb79fa8	1047	}
Azure.IoT Build	0:6ae2f7bca550	1048
AzureIoTClient	4:98007eb79fa8	1049	return result;
Azure.IoT Build	0:6ae2f7bca550	1050	}
Azure.IoT Build	0:6ae2f7bca550	1051
Azure.IoT Build	0:6ae2f7bca550	1052	void connection_destroy(CONNECTION_HANDLE connection)
Azure.IoT Build	0:6ae2f7bca550	1053	{
AzureIoTClient	4:98007eb79fa8	1054	/* Codes_SRS_CONNECTION_01_079: [If handle is NULL, connection_destroy shall do nothing.] */
AzureIoTClient	4:98007eb79fa8	1055	if (connection != NULL)
AzureIoTClient	4:98007eb79fa8	1056	{
AzureIoTClient	4:98007eb79fa8	1057	/* Codes_SRS_CONNECTION_01_073: [connection_destroy shall free all resources associated with a connection.] */
AzureIoTClient	4:98007eb79fa8	1058	if (connection->is_underlying_io_open)
AzureIoTClient	4:98007eb79fa8	1059	{
AzureIoTClient	4:98007eb79fa8	1060	connection_close(connection, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	1061	}
Azure.IoT Build	0:6ae2f7bca550	1062
AzureIoTClient	4:98007eb79fa8	1063	amqp_frame_codec_destroy(connection->amqp_frame_codec);
AzureIoTClient	4:98007eb79fa8	1064	frame_codec_destroy(connection->frame_codec);
AzureIoTClient	4:98007eb79fa8	1065	tickcounter_destroy(connection->tick_counter);
Azure.IoT Build	0:6ae2f7bca550	1066
AzureIoTClient	4:98007eb79fa8	1067	amqpalloc_free(connection->host_name);
AzureIoTClient	4:98007eb79fa8	1068	amqpalloc_free(connection->container_id);
Azure.IoT Build	0:6ae2f7bca550	1069
AzureIoTClient	4:98007eb79fa8	1070	/* Codes_SRS_CONNECTION_01_074: [connection_destroy shall close the socket connection.] */
AzureIoTClient	4:98007eb79fa8	1071	amqpalloc_free(connection);
AzureIoTClient	4:98007eb79fa8	1072	}
Azure.IoT Build	0:6ae2f7bca550	1073	}
Azure.IoT Build	0:6ae2f7bca550	1074
Azure.IoT Build	0:6ae2f7bca550	1075	int connection_open(CONNECTION_HANDLE connection)
Azure.IoT Build	0:6ae2f7bca550	1076	{
AzureIoTClient	4:98007eb79fa8	1077	int result;
Azure.IoT Build	0:6ae2f7bca550	1078
AzureIoTClient	4:98007eb79fa8	1079	if (connection == NULL)
AzureIoTClient	4:98007eb79fa8	1080	{
AzureIoTClient	4:98007eb79fa8	1081	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1082	}
AzureIoTClient	4:98007eb79fa8	1083	else
AzureIoTClient	4:98007eb79fa8	1084	{
AzureIoTClient	4:98007eb79fa8	1085	if (!connection->is_underlying_io_open)
AzureIoTClient	4:98007eb79fa8	1086	{
AzureIoTClient	4:98007eb79fa8	1087	if (xio_open(connection->io, connection_on_io_open_complete, connection, connection_on_bytes_received, connection, connection_on_io_error, connection) != 0)
AzureIoTClient	4:98007eb79fa8	1088	{
AzureIoTClient	4:98007eb79fa8	1089	connection_set_state(connection, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	1090	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1091	}
AzureIoTClient	4:98007eb79fa8	1092	else
AzureIoTClient	4:98007eb79fa8	1093	{
AzureIoTClient	4:98007eb79fa8	1094	connection->is_underlying_io_open = 1;
Azure.IoT Build	0:6ae2f7bca550	1095
AzureIoTClient	4:98007eb79fa8	1096	connection_set_state(connection, CONNECTION_STATE_START);
Azure.IoT Build	0:6ae2f7bca550	1097
AzureIoTClient	4:98007eb79fa8	1098	result = 0;
AzureIoTClient	4:98007eb79fa8	1099	}
AzureIoTClient	4:98007eb79fa8	1100	}
AzureIoTClient	4:98007eb79fa8	1101	else
AzureIoTClient	4:98007eb79fa8	1102	{
AzureIoTClient	4:98007eb79fa8	1103	result = 0;
AzureIoTClient	4:98007eb79fa8	1104	}
AzureIoTClient	4:98007eb79fa8	1105	}
Azure.IoT Build	0:6ae2f7bca550	1106
AzureIoTClient	4:98007eb79fa8	1107	return result;
Azure.IoT Build	0:6ae2f7bca550	1108	}
Azure.IoT Build	0:6ae2f7bca550	1109
Azure.IoT Build	0:6ae2f7bca550	1110	int connection_listen(CONNECTION_HANDLE connection)
Azure.IoT Build	0:6ae2f7bca550	1111	{
AzureIoTClient	4:98007eb79fa8	1112	int result;
Azure.IoT Build	0:6ae2f7bca550	1113
AzureIoTClient	4:98007eb79fa8	1114	if (connection == NULL)
AzureIoTClient	4:98007eb79fa8	1115	{
AzureIoTClient	4:98007eb79fa8	1116	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1117	}
AzureIoTClient	4:98007eb79fa8	1118	else
AzureIoTClient	4:98007eb79fa8	1119	{
AzureIoTClient	4:98007eb79fa8	1120	if (!connection->is_underlying_io_open)
AzureIoTClient	4:98007eb79fa8	1121	{
AzureIoTClient	4:98007eb79fa8	1122	if (xio_open(connection->io, connection_on_io_open_complete, connection, connection_on_bytes_received, connection, connection_on_io_error, connection) != 0)
AzureIoTClient	4:98007eb79fa8	1123	{
AzureIoTClient	4:98007eb79fa8	1124	connection_set_state(connection, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	1125	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1126	}
AzureIoTClient	4:98007eb79fa8	1127	else
AzureIoTClient	4:98007eb79fa8	1128	{
AzureIoTClient	4:98007eb79fa8	1129	connection->is_underlying_io_open = 1;
Azure.IoT Build	0:6ae2f7bca550	1130
AzureIoTClient	4:98007eb79fa8	1131	connection_set_state(connection, CONNECTION_STATE_HDR_EXCH);
Azure.IoT Build	0:6ae2f7bca550	1132
AzureIoTClient	4:98007eb79fa8	1133	result = 0;
AzureIoTClient	4:98007eb79fa8	1134	}
AzureIoTClient	4:98007eb79fa8	1135	}
AzureIoTClient	4:98007eb79fa8	1136	else
AzureIoTClient	4:98007eb79fa8	1137	{
AzureIoTClient	4:98007eb79fa8	1138	result = 0;
AzureIoTClient	4:98007eb79fa8	1139	}
AzureIoTClient	4:98007eb79fa8	1140	}
Azure.IoT Build	0:6ae2f7bca550	1141
AzureIoTClient	4:98007eb79fa8	1142	return result;
Azure.IoT Build	0:6ae2f7bca550	1143	}
Azure.IoT Build	0:6ae2f7bca550	1144
Azure.IoT Build	0:6ae2f7bca550	1145	int connection_close(CONNECTION_HANDLE connection, const char* condition_value, const char* description)
Azure.IoT Build	0:6ae2f7bca550	1146	{
AzureIoTClient	4:98007eb79fa8	1147	int result;
Azure.IoT Build	0:6ae2f7bca550	1148
AzureIoTClient	4:98007eb79fa8	1149	if (connection == NULL)
AzureIoTClient	4:98007eb79fa8	1150	{
AzureIoTClient	4:98007eb79fa8	1151	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1152	}
AzureIoTClient	4:98007eb79fa8	1153	else
AzureIoTClient	4:98007eb79fa8	1154	{
AzureIoTClient	4:98007eb79fa8	1155	if (condition_value != NULL)
AzureIoTClient	4:98007eb79fa8	1156	{
AzureIoTClient	4:98007eb79fa8	1157	close_connection_with_error(connection, condition_value, description);
AzureIoTClient	4:98007eb79fa8	1158	}
AzureIoTClient	4:98007eb79fa8	1159	else
AzureIoTClient	4:98007eb79fa8	1160	{
AzureIoTClient	4:98007eb79fa8	1161	(void)send_close_frame(connection, NULL);
AzureIoTClient	4:98007eb79fa8	1162	connection_set_state(connection, CONNECTION_STATE_END);
AzureIoTClient	4:98007eb79fa8	1163	}
Azure.IoT Build	0:6ae2f7bca550	1164
AzureIoTClient	4:98007eb79fa8	1165	(void)xio_close(connection->io, NULL, NULL);
AzureIoTClient	4:98007eb79fa8	1166	connection->is_underlying_io_open = 1;
Azure.IoT Build	0:6ae2f7bca550	1167
Azure.IoT Build	0:6ae2f7bca550	1168	result = 0;
AzureIoTClient	4:98007eb79fa8	1169	}
Azure.IoT Build	0:6ae2f7bca550	1170
AzureIoTClient	4:98007eb79fa8	1171	return result;
Azure.IoT Build	0:6ae2f7bca550	1172	}
Azure.IoT Build	0:6ae2f7bca550	1173
Azure.IoT Build	0:6ae2f7bca550	1174	int connection_set_max_frame_size(CONNECTION_HANDLE connection, uint32_t max_frame_size)
Azure.IoT Build	0:6ae2f7bca550	1175	{
AzureIoTClient	4:98007eb79fa8	1176	int result;
Azure.IoT Build	0:6ae2f7bca550	1177
AzureIoTClient	4:98007eb79fa8	1178	/* Codes_SRS_CONNECTION_01_163: [If connection is NULL, connection_set_max_frame_size shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1179	if ((connection == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1180	/* Codes_SRS_CONNECTION_01_150: [If the max_frame_size is invalid then connection_set_max_frame_size shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1181	/* Codes_SRS_CONNECTION_01_167: [Both peers MUST accept frames of up to 512 (MIN-MAX-FRAME-SIZE) octets.] */
AzureIoTClient	4:98007eb79fa8	1182	(max_frame_size < 512))
AzureIoTClient	4:98007eb79fa8	1183	{
AzureIoTClient	4:98007eb79fa8	1184	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1185	}
AzureIoTClient	4:98007eb79fa8	1186	else
AzureIoTClient	4:98007eb79fa8	1187	{
AzureIoTClient	4:98007eb79fa8	1188	/* Codes_SRS_CONNECTION_01_157: [If connection_set_max_frame_size is called after the initial Open frame has been sent, it shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1189	if (connection->connection_state != CONNECTION_STATE_START)
AzureIoTClient	4:98007eb79fa8	1190	{
AzureIoTClient	4:98007eb79fa8	1191	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1192	}
AzureIoTClient	4:98007eb79fa8	1193	else
AzureIoTClient	4:98007eb79fa8	1194	{
AzureIoTClient	4:98007eb79fa8	1195	/* Codes_SRS_CONNECTION_01_148: [connection_set_max_frame_size shall set the max_frame_size associated with a connection.] */
AzureIoTClient	4:98007eb79fa8	1196	/* Codes_SRS_CONNECTION_01_164: [If connection_set_max_frame_size fails, the previous max_frame_size setting shall be retained.] */
AzureIoTClient	4:98007eb79fa8	1197	connection->max_frame_size = max_frame_size;
Azure.IoT Build	0:6ae2f7bca550	1198
AzureIoTClient	4:98007eb79fa8	1199	/* Codes_SRS_CONNECTION_01_149: [On success connection_set_max_frame_size shall return 0.] */
AzureIoTClient	4:98007eb79fa8	1200	result = 0;
AzureIoTClient	4:98007eb79fa8	1201	}
AzureIoTClient	4:98007eb79fa8	1202	}
Azure.IoT Build	0:6ae2f7bca550	1203
AzureIoTClient	4:98007eb79fa8	1204	return result;
Azure.IoT Build	0:6ae2f7bca550	1205	}
Azure.IoT Build	0:6ae2f7bca550	1206
Azure.IoT Build	0:6ae2f7bca550	1207	int connection_get_max_frame_size(CONNECTION_HANDLE connection, uint32_t* max_frame_size)
Azure.IoT Build	0:6ae2f7bca550	1208	{
AzureIoTClient	4:98007eb79fa8	1209	int result;
Azure.IoT Build	0:6ae2f7bca550	1210
AzureIoTClient	4:98007eb79fa8	1211	/* Codes_SRS_CONNECTION_01_170: [If connection or max_frame_size is NULL, connection_get_max_frame_size shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1212	if ((connection == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1213	(max_frame_size == NULL))
AzureIoTClient	4:98007eb79fa8	1214	{
AzureIoTClient	4:98007eb79fa8	1215	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1216	}
AzureIoTClient	4:98007eb79fa8	1217	else
AzureIoTClient	4:98007eb79fa8	1218	{
AzureIoTClient	4:98007eb79fa8	1219	/* Codes_SRS_CONNECTION_01_168: [connection_get_max_frame_size shall return in the max_frame_size argument the current max frame size setting.] */
AzureIoTClient	4:98007eb79fa8	1220	*max_frame_size = connection->max_frame_size;
Azure.IoT Build	0:6ae2f7bca550	1221
AzureIoTClient	4:98007eb79fa8	1222	/* Codes_SRS_CONNECTION_01_169: [On success, connection_get_max_frame_size shall return 0.] */
AzureIoTClient	4:98007eb79fa8	1223	result = 0;
AzureIoTClient	4:98007eb79fa8	1224	}
Azure.IoT Build	0:6ae2f7bca550	1225
AzureIoTClient	4:98007eb79fa8	1226	return result;
Azure.IoT Build	0:6ae2f7bca550	1227	}
Azure.IoT Build	0:6ae2f7bca550	1228
Azure.IoT Build	0:6ae2f7bca550	1229	int connection_set_channel_max(CONNECTION_HANDLE connection, uint16_t channel_max)
Azure.IoT Build	0:6ae2f7bca550	1230	{
AzureIoTClient	4:98007eb79fa8	1231	int result;
Azure.IoT Build	0:6ae2f7bca550	1232
AzureIoTClient	4:98007eb79fa8	1233	/* Codes_SRS_CONNECTION_01_181: [If connection is NULL then connection_set_channel_max shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1234	if (connection == NULL)
AzureIoTClient	4:98007eb79fa8	1235	{
AzureIoTClient	4:98007eb79fa8	1236	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1237	}
AzureIoTClient	4:98007eb79fa8	1238	else
AzureIoTClient	4:98007eb79fa8	1239	{
AzureIoTClient	4:98007eb79fa8	1240	/* Codes_SRS_CONNECTION_01_156: [If connection_set_channel_max is called after the initial Open frame has been sent, it shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1241	if (connection->connection_state != CONNECTION_STATE_START)
AzureIoTClient	4:98007eb79fa8	1242	{
AzureIoTClient	4:98007eb79fa8	1243	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1244	}
AzureIoTClient	4:98007eb79fa8	1245	else
AzureIoTClient	4:98007eb79fa8	1246	{
AzureIoTClient	4:98007eb79fa8	1247	/* Codes_SRS_CONNECTION_01_153: [connection_set_channel_max shall set the channel_max associated with a connection.] */
AzureIoTClient	4:98007eb79fa8	1248	/* Codes_SRS_CONNECTION_01_165: [If connection_set_channel_max fails, the previous channel_max setting shall be retained.] */
AzureIoTClient	4:98007eb79fa8	1249	connection->channel_max = channel_max;
Azure.IoT Build	0:6ae2f7bca550	1250
AzureIoTClient	4:98007eb79fa8	1251	/* Codes_SRS_CONNECTION_01_154: [On success connection_set_channel_max shall return 0.] */
AzureIoTClient	4:98007eb79fa8	1252	result = 0;
AzureIoTClient	4:98007eb79fa8	1253	}
AzureIoTClient	4:98007eb79fa8	1254	}
Azure.IoT Build	0:6ae2f7bca550	1255
AzureIoTClient	4:98007eb79fa8	1256	return result;
Azure.IoT Build	0:6ae2f7bca550	1257	}
Azure.IoT Build	0:6ae2f7bca550	1258
Azure.IoT Build	0:6ae2f7bca550	1259	int connection_get_channel_max(CONNECTION_HANDLE connection, uint16_t* channel_max)
Azure.IoT Build	0:6ae2f7bca550	1260	{
AzureIoTClient	4:98007eb79fa8	1261	int result;
Azure.IoT Build	0:6ae2f7bca550	1262
AzureIoTClient	4:98007eb79fa8	1263	/* Codes_SRS_CONNECTION_01_184: [If connection or channel_max is NULL, connection_get_channel_max shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1264	if ((connection == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1265	(channel_max == NULL))
AzureIoTClient	4:98007eb79fa8	1266	{
AzureIoTClient	4:98007eb79fa8	1267	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1268	}
AzureIoTClient	4:98007eb79fa8	1269	else
AzureIoTClient	4:98007eb79fa8	1270	{
AzureIoTClient	4:98007eb79fa8	1271	/* Codes_SRS_CONNECTION_01_182: [connection_get_channel_max shall return in the channel_max argument the current channel_max setting.] */
AzureIoTClient	4:98007eb79fa8	1272	*channel_max = connection->channel_max;
Azure.IoT Build	0:6ae2f7bca550	1273
AzureIoTClient	4:98007eb79fa8	1274	/* Codes_SRS_CONNECTION_01_183: [On success, connection_get_channel_max shall return 0.] */
AzureIoTClient	4:98007eb79fa8	1275	result = 0;
AzureIoTClient	4:98007eb79fa8	1276	}
Azure.IoT Build	0:6ae2f7bca550	1277
AzureIoTClient	4:98007eb79fa8	1278	return result;
Azure.IoT Build	0:6ae2f7bca550	1279	}
Azure.IoT Build	0:6ae2f7bca550	1280
Azure.IoT Build	0:6ae2f7bca550	1281	int connection_set_idle_timeout(CONNECTION_HANDLE connection, milliseconds idle_timeout)
Azure.IoT Build	0:6ae2f7bca550	1282	{
AzureIoTClient	4:98007eb79fa8	1283	int result;
Azure.IoT Build	0:6ae2f7bca550	1284
AzureIoTClient	4:98007eb79fa8	1285	/* Codes_SRS_CONNECTION_01_191: [If connection is NULL, connection_set_idle_timeout shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1286	if (connection == NULL)
AzureIoTClient	4:98007eb79fa8	1287	{
AzureIoTClient	4:98007eb79fa8	1288	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1289	}
AzureIoTClient	4:98007eb79fa8	1290	else
AzureIoTClient	4:98007eb79fa8	1291	{
AzureIoTClient	4:98007eb79fa8	1292	/* Codes_SRS_CONNECTION_01_158: [If connection_set_idle_timeout is called after the initial Open frame has been sent, it shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1293	if (connection->connection_state != CONNECTION_STATE_START)
AzureIoTClient	4:98007eb79fa8	1294	{
AzureIoTClient	4:98007eb79fa8	1295	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1296	}
AzureIoTClient	4:98007eb79fa8	1297	else
AzureIoTClient	4:98007eb79fa8	1298	{
AzureIoTClient	4:98007eb79fa8	1299	/* Codes_SRS_CONNECTION_01_159: [connection_set_idle_timeout shall set the idle_timeout associated with a connection.] */
AzureIoTClient	4:98007eb79fa8	1300	/* Codes_SRS_CONNECTION_01_166: [If connection_set_idle_timeout fails, the previous idle_timeout setting shall be retained.] */
AzureIoTClient	4:98007eb79fa8	1301	connection->idle_timeout = idle_timeout;
AzureIoTClient	4:98007eb79fa8	1302	connection->idle_timeout_specified = true;
Azure.IoT Build	0:6ae2f7bca550	1303
AzureIoTClient	4:98007eb79fa8	1304	/* Codes_SRS_CONNECTION_01_160: [On success connection_set_idle_timeout shall return 0.] */
AzureIoTClient	4:98007eb79fa8	1305	result = 0;
AzureIoTClient	4:98007eb79fa8	1306	}
AzureIoTClient	4:98007eb79fa8	1307	}
Azure.IoT Build	0:6ae2f7bca550	1308
AzureIoTClient	4:98007eb79fa8	1309	return result;
Azure.IoT Build	0:6ae2f7bca550	1310	}
Azure.IoT Build	0:6ae2f7bca550	1311
Azure.IoT Build	0:6ae2f7bca550	1312	int connection_get_idle_timeout(CONNECTION_HANDLE connection, milliseconds* idle_timeout)
Azure.IoT Build	0:6ae2f7bca550	1313	{
AzureIoTClient	4:98007eb79fa8	1314	int result;
Azure.IoT Build	0:6ae2f7bca550	1315
AzureIoTClient	4:98007eb79fa8	1316	/* Codes_SRS_CONNECTION_01_190: [If connection or idle_timeout is NULL, connection_get_idle_timeout shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1317	if ((connection == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1318	(idle_timeout == NULL))
AzureIoTClient	4:98007eb79fa8	1319	{
AzureIoTClient	4:98007eb79fa8	1320	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1321	}
AzureIoTClient	4:98007eb79fa8	1322	else
AzureIoTClient	4:98007eb79fa8	1323	{
AzureIoTClient	4:98007eb79fa8	1324	/* Codes_SRS_CONNECTION_01_188: [connection_get_idle_timeout shall return in the idle_timeout argument the current idle_timeout setting.] */
AzureIoTClient	4:98007eb79fa8	1325	*idle_timeout = connection->idle_timeout;
Azure.IoT Build	0:6ae2f7bca550	1326
AzureIoTClient	4:98007eb79fa8	1327	/* Codes_SRS_CONNECTION_01_189: [On success, connection_get_idle_timeout shall return 0.] */
AzureIoTClient	4:98007eb79fa8	1328	result = 0;
AzureIoTClient	4:98007eb79fa8	1329	}
Azure.IoT Build	0:6ae2f7bca550	1330
AzureIoTClient	4:98007eb79fa8	1331	return result;
Azure.IoT Build	0:6ae2f7bca550	1332	}
Azure.IoT Build	0:6ae2f7bca550	1333
Azure.IoT Build	0:6ae2f7bca550	1334	int connection_get_remote_max_frame_size(CONNECTION_HANDLE connection, uint32_t* remote_max_frame_size)
Azure.IoT Build	0:6ae2f7bca550	1335	{
AzureIoTClient	4:98007eb79fa8	1336	int result;
Azure.IoT Build	0:6ae2f7bca550	1337
AzureIoTClient	4:98007eb79fa8	1338	if ((connection == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1339	(remote_max_frame_size == NULL))
AzureIoTClient	4:98007eb79fa8	1340	{
AzureIoTClient	4:98007eb79fa8	1341	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1342	}
AzureIoTClient	4:98007eb79fa8	1343	else
AzureIoTClient	4:98007eb79fa8	1344	{
AzureIoTClient	4:98007eb79fa8	1345	*remote_max_frame_size = connection->remote_max_frame_size;
Azure.IoT Build	0:6ae2f7bca550	1346
AzureIoTClient	4:98007eb79fa8	1347	result = 0;
AzureIoTClient	4:98007eb79fa8	1348	}
Azure.IoT Build	0:6ae2f7bca550	1349
AzureIoTClient	4:98007eb79fa8	1350	return result;
Azure.IoT Build	0:6ae2f7bca550	1351	}
Azure.IoT Build	0:6ae2f7bca550	1352
AzureIoTClient	1:eab586236bfe	1353	uint64_t connection_handle_deadlines(CONNECTION_HANDLE connection)
AzureIoTClient	1:eab586236bfe	1354	{
AzureIoTClient	1:eab586236bfe	1355	uint64_t local_deadline = (uint64_t )-1;
AzureIoTClient	1:eab586236bfe	1356	uint64_t remote_deadline = (uint64_t)-1;
AzureIoTClient	1:eab586236bfe	1357
AzureIoTClient	1:eab586236bfe	1358	if (connection != NULL)
AzureIoTClient	1:eab586236bfe	1359	{
Azure.IoT.Build	14:0b0e28c75ded	1360	tickcounter_ms_t current_ms;
AzureIoTClient	1:eab586236bfe	1361
AzureIoTClient	1:eab586236bfe	1362	if (tickcounter_get_current_ms(connection->tick_counter, &current_ms) != 0)
AzureIoTClient	1:eab586236bfe	1363	{
AzureIoTClient	1:eab586236bfe	1364	close_connection_with_error(connection, "amqp:internal-error", "Could not get tick count");
AzureIoTClient	1:eab586236bfe	1365	}
AzureIoTClient	1:eab586236bfe	1366	else
AzureIoTClient	1:eab586236bfe	1367	{
AzureIoTClient	1:eab586236bfe	1368	if (connection->idle_timeout_specified && (connection->idle_timeout != 0))
AzureIoTClient	1:eab586236bfe	1369	{
AzureIoTClient	1:eab586236bfe	1370	/* Calculate time until configured idle timeout expires */
AzureIoTClient	1:eab586236bfe	1371
AzureIoTClient	1:eab586236bfe	1372	uint64_t time_since_last_received = current_ms - connection->last_frame_received_time;
AzureIoTClient	1:eab586236bfe	1373	if (time_since_last_received < connection->idle_timeout)
AzureIoTClient	1:eab586236bfe	1374	{
AzureIoTClient	1:eab586236bfe	1375	local_deadline = connection->idle_timeout - time_since_last_received;
AzureIoTClient	1:eab586236bfe	1376	}
AzureIoTClient	1:eab586236bfe	1377	else
AzureIoTClient	1:eab586236bfe	1378	{
AzureIoTClient	1:eab586236bfe	1379	local_deadline = 0;
AzureIoTClient	1:eab586236bfe	1380
AzureIoTClient	1:eab586236bfe	1381	/* close connection */
AzureIoTClient	1:eab586236bfe	1382	close_connection_with_error(connection, "amqp:internal-error", "No frame received for the idle timeout");
AzureIoTClient	1:eab586236bfe	1383	}
AzureIoTClient	1:eab586236bfe	1384	}
AzureIoTClient	1:eab586236bfe	1385
AzureIoTClient	1:eab586236bfe	1386	if (local_deadline != 0 && connection->remote_idle_timeout != 0)
AzureIoTClient	1:eab586236bfe	1387	{
AzureIoTClient	1:eab586236bfe	1388	/* Calculate time until remote idle timeout expires */
AzureIoTClient	1:eab586236bfe	1389
AzureIoTClient	1:eab586236bfe	1390	uint64_t remote_idle_timeout = (connection->remote_idle_timeout / 2);
AzureIoTClient	1:eab586236bfe	1391	uint64_t time_since_last_sent = current_ms - connection->last_frame_sent_time;
AzureIoTClient	1:eab586236bfe	1392
AzureIoTClient	1:eab586236bfe	1393	if (time_since_last_sent < remote_idle_timeout)
AzureIoTClient	1:eab586236bfe	1394	{
AzureIoTClient	1:eab586236bfe	1395	remote_deadline = remote_idle_timeout - time_since_last_sent;
AzureIoTClient	1:eab586236bfe	1396	}
AzureIoTClient	1:eab586236bfe	1397	else
AzureIoTClient	1:eab586236bfe	1398	{
AzureIoTClient	1:eab586236bfe	1399	connection->on_send_complete = NULL;
AzureIoTClient	1:eab586236bfe	1400	if (amqp_frame_codec_encode_empty_frame(connection->amqp_frame_codec, 0, on_bytes_encoded, connection) != 0)
AzureIoTClient	1:eab586236bfe	1401	{
AzureIoTClient	1:eab586236bfe	1402	/* close connection */
AzureIoTClient	1:eab586236bfe	1403	close_connection_with_error(connection, "amqp:internal-error", "Cannot send empty frame");
AzureIoTClient	1:eab586236bfe	1404	}
AzureIoTClient	1:eab586236bfe	1405	else
AzureIoTClient	1:eab586236bfe	1406	{
AzureIoTClient	6:641a9672db08	1407	if (connection->is_trace_on == 1)
AzureIoTClient	6:641a9672db08	1408	{
AzureIoTClient	6:641a9672db08	1409	LOG(LOG_TRACE, LOG_LINE, "-> Empty frame");
AzureIoTClient	6:641a9672db08	1410	}
AzureIoTClient	1:eab586236bfe	1411
AzureIoTClient	1:eab586236bfe	1412	connection->last_frame_sent_time = current_ms;
AzureIoTClient	1:eab586236bfe	1413
AzureIoTClient	1:eab586236bfe	1414	remote_deadline = remote_idle_timeout;
AzureIoTClient	1:eab586236bfe	1415	}
AzureIoTClient	1:eab586236bfe	1416	}
AzureIoTClient	1:eab586236bfe	1417	}
AzureIoTClient	1:eab586236bfe	1418	}
AzureIoTClient	1:eab586236bfe	1419	}
AzureIoTClient	1:eab586236bfe	1420
AzureIoTClient	1:eab586236bfe	1421	/* Return the shorter of each deadline, or 0 to indicate connection closed */
AzureIoTClient	1:eab586236bfe	1422	return local_deadline > remote_deadline ? remote_deadline : local_deadline;
AzureIoTClient	1:eab586236bfe	1423	}
AzureIoTClient	1:eab586236bfe	1424
Azure.IoT Build	0:6ae2f7bca550	1425	void connection_dowork(CONNECTION_HANDLE connection)
Azure.IoT Build	0:6ae2f7bca550	1426	{
AzureIoTClient	4:98007eb79fa8	1427	/* Codes_SRS_CONNECTION_01_078: [If handle is NULL, connection_dowork shall do nothing.] */
AzureIoTClient	1:eab586236bfe	1428	if (connection != NULL)
AzureIoTClient	1:eab586236bfe	1429	{
AzureIoTClient	1:eab586236bfe	1430	if (connection_handle_deadlines(connection) > 0)
AzureIoTClient	1:eab586236bfe	1431	{
AzureIoTClient	1:eab586236bfe	1432	/* Codes_SRS_CONNECTION_01_076: [connection_dowork shall schedule the underlying IO interface to do its work by calling xio_dowork.] */
AzureIoTClient	1:eab586236bfe	1433	xio_dowork(connection->io);
AzureIoTClient	1:eab586236bfe	1434	}
AzureIoTClient	1:eab586236bfe	1435	}
Azure.IoT Build	0:6ae2f7bca550	1436	}
Azure.IoT Build	0:6ae2f7bca550	1437
Azure.IoT Build	0:6ae2f7bca550	1438	ENDPOINT_HANDLE connection_create_endpoint(CONNECTION_HANDLE connection)
Azure.IoT Build	0:6ae2f7bca550	1439	{
AzureIoTClient	4:98007eb79fa8	1440	ENDPOINT_INSTANCE* result;
Azure.IoT Build	0:6ae2f7bca550	1441
AzureIoTClient	4:98007eb79fa8	1442	/* Codes_SRS_CONNECTION_01_113: [If connection, on_endpoint_frame_received or on_connection_state_changed is NULL, connection_create_endpoint shall fail and return NULL.] */
AzureIoTClient	4:98007eb79fa8	1443	/* Codes_SRS_CONNECTION_01_193: [The context argument shall be allowed to be NULL.] */
AzureIoTClient	4:98007eb79fa8	1444	if (connection == NULL)
AzureIoTClient	4:98007eb79fa8	1445	{
AzureIoTClient	4:98007eb79fa8	1446	result = NULL;
AzureIoTClient	4:98007eb79fa8	1447	}
AzureIoTClient	4:98007eb79fa8	1448	else
AzureIoTClient	4:98007eb79fa8	1449	{
AzureIoTClient	4:98007eb79fa8	1450	/* Codes_SRS_CONNECTION_01_115: [If no more endpoints can be created due to all channels being used, connection_create_endpoint shall fail and return NULL.] */
AzureIoTClient	4:98007eb79fa8	1451	if (connection->endpoint_count >= connection->channel_max)
AzureIoTClient	4:98007eb79fa8	1452	{
AzureIoTClient	4:98007eb79fa8	1453	result = NULL;
AzureIoTClient	4:98007eb79fa8	1454	}
AzureIoTClient	4:98007eb79fa8	1455	else
AzureIoTClient	4:98007eb79fa8	1456	{
AzureIoTClient	4:98007eb79fa8	1457	uint32_t i = 0;
Azure.IoT Build	0:6ae2f7bca550	1458
AzureIoTClient	4:98007eb79fa8	1459	/* Codes_SRS_CONNECTION_01_128: [The lowest number outgoing channel shall be associated with the newly created endpoint.] */
AzureIoTClient	4:98007eb79fa8	1460	for (i = 0; i < connection->endpoint_count; i++)
AzureIoTClient	4:98007eb79fa8	1461	{
AzureIoTClient	4:98007eb79fa8	1462	if (connection->endpoints[i]->outgoing_channel > i)
AzureIoTClient	4:98007eb79fa8	1463	{
AzureIoTClient	4:98007eb79fa8	1464	/* found a gap in the sorted endpoint array */
AzureIoTClient	4:98007eb79fa8	1465	break;
AzureIoTClient	4:98007eb79fa8	1466	}
AzureIoTClient	4:98007eb79fa8	1467	}
Azure.IoT Build	0:6ae2f7bca550	1468
AzureIoTClient	4:98007eb79fa8	1469	/* Codes_SRS_CONNECTION_01_127: [On success, connection_create_endpoint shall return a non-NULL handle to the newly created endpoint.] */
AzureIoTClient	4:98007eb79fa8	1470	result = amqpalloc_malloc(sizeof(ENDPOINT_INSTANCE));
AzureIoTClient	4:98007eb79fa8	1471	/* Codes_SRS_CONNECTION_01_196: [If memory cannot be allocated for the new endpoint, connection_create_endpoint shall fail and return NULL.] */
AzureIoTClient	4:98007eb79fa8	1472	if (result != NULL)
AzureIoTClient	4:98007eb79fa8	1473	{
AzureIoTClient	4:98007eb79fa8	1474	ENDPOINT_INSTANCE** new_endpoints;
Azure.IoT Build	0:6ae2f7bca550	1475
AzureIoTClient	4:98007eb79fa8	1476	result->on_endpoint_frame_received = NULL;
AzureIoTClient	4:98007eb79fa8	1477	result->on_connection_state_changed = NULL;
AzureIoTClient	4:98007eb79fa8	1478	result->callback_context = NULL;
AzureIoTClient	6:641a9672db08	1479	result->outgoing_channel = (uint16_t)i;
AzureIoTClient	4:98007eb79fa8	1480	result->connection = connection;
Azure.IoT Build	0:6ae2f7bca550	1481
AzureIoTClient	4:98007eb79fa8	1482	/* Codes_SRS_CONNECTION_01_197: [The newly created endpoint shall be added to the endpoints list, so that it can be tracked.] */
AzureIoTClient	4:98007eb79fa8	1483	new_endpoints = (ENDPOINT_INSTANCE*)amqpalloc_realloc(connection->endpoints, sizeof(ENDPOINT_INSTANCE) * (connection->endpoint_count + 1));
AzureIoTClient	4:98007eb79fa8	1484	if (new_endpoints == NULL)
AzureIoTClient	4:98007eb79fa8	1485	{
AzureIoTClient	4:98007eb79fa8	1486	/* Tests_SRS_CONNECTION_01_198: [If adding the endpoint to the endpoints list tracked by the connection fails, connection_create_endpoint shall fail and return NULL.] */
AzureIoTClient	4:98007eb79fa8	1487	amqpalloc_free(result);
AzureIoTClient	4:98007eb79fa8	1488	result = NULL;
AzureIoTClient	4:98007eb79fa8	1489	}
AzureIoTClient	4:98007eb79fa8	1490	else
AzureIoTClient	4:98007eb79fa8	1491	{
AzureIoTClient	4:98007eb79fa8	1492	connection->endpoints = new_endpoints;
Azure.IoT Build	0:6ae2f7bca550	1493
AzureIoTClient	4:98007eb79fa8	1494	if (i < connection->endpoint_count)
AzureIoTClient	4:98007eb79fa8	1495	{
AzureIoTClient	4:98007eb79fa8	1496	(void)memmove(&connection->endpoints[i + 1], &connection->endpoints[i], sizeof(ENDPOINT_INSTANCE) (connection->endpoint_count - i));
AzureIoTClient	4:98007eb79fa8	1497	}
Azure.IoT Build	0:6ae2f7bca550	1498
AzureIoTClient	4:98007eb79fa8	1499	connection->endpoints[i] = result;
AzureIoTClient	4:98007eb79fa8	1500	connection->endpoint_count++;
Azure.IoT Build	0:6ae2f7bca550	1501
AzureIoTClient	4:98007eb79fa8	1502	/* Codes_SRS_CONNECTION_01_112: [connection_create_endpoint shall create a new endpoint that can be used by a session.] */
AzureIoTClient	4:98007eb79fa8	1503	}
AzureIoTClient	4:98007eb79fa8	1504	}
AzureIoTClient	4:98007eb79fa8	1505	}
AzureIoTClient	4:98007eb79fa8	1506	}
Azure.IoT Build	0:6ae2f7bca550	1507
AzureIoTClient	4:98007eb79fa8	1508	return result;
Azure.IoT Build	0:6ae2f7bca550	1509	}
Azure.IoT Build	0:6ae2f7bca550	1510
Azure.IoT Build	0:6ae2f7bca550	1511	int connection_start_endpoint(ENDPOINT_HANDLE endpoint, ON_ENDPOINT_FRAME_RECEIVED on_endpoint_frame_received, ON_CONNECTION_STATE_CHANGED on_connection_state_changed, void* context)
Azure.IoT Build	0:6ae2f7bca550	1512	{
AzureIoTClient	4:98007eb79fa8	1513	int result;
Azure.IoT Build	0:6ae2f7bca550	1514
AzureIoTClient	4:98007eb79fa8	1515	if ((endpoint == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1516	(on_endpoint_frame_received == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1517	(on_connection_state_changed == NULL))
AzureIoTClient	4:98007eb79fa8	1518	{
AzureIoTClient	4:98007eb79fa8	1519	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1520	}
AzureIoTClient	4:98007eb79fa8	1521	else
AzureIoTClient	4:98007eb79fa8	1522	{
AzureIoTClient	4:98007eb79fa8	1523	endpoint->on_endpoint_frame_received = on_endpoint_frame_received;
AzureIoTClient	4:98007eb79fa8	1524	endpoint->on_connection_state_changed = on_connection_state_changed;
AzureIoTClient	4:98007eb79fa8	1525	endpoint->callback_context = context;
Azure.IoT Build	0:6ae2f7bca550	1526
AzureIoTClient	4:98007eb79fa8	1527	result = 0;
AzureIoTClient	4:98007eb79fa8	1528	}
Azure.IoT Build	0:6ae2f7bca550	1529
AzureIoTClient	4:98007eb79fa8	1530	return result;
Azure.IoT Build	0:6ae2f7bca550	1531	}
Azure.IoT Build	0:6ae2f7bca550	1532
Azure.IoT Build	0:6ae2f7bca550	1533	int connection_endpoint_get_incoming_channel(ENDPOINT_HANDLE endpoint, uint16_t* incoming_channel)
Azure.IoT Build	0:6ae2f7bca550	1534	{
AzureIoTClient	4:98007eb79fa8	1535	int result;
Azure.IoT Build	0:6ae2f7bca550	1536
AzureIoTClient	4:98007eb79fa8	1537	if ((endpoint == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1538	(incoming_channel == NULL))
AzureIoTClient	4:98007eb79fa8	1539	{
AzureIoTClient	4:98007eb79fa8	1540	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1541	}
AzureIoTClient	4:98007eb79fa8	1542	else
AzureIoTClient	4:98007eb79fa8	1543	{
AzureIoTClient	4:98007eb79fa8	1544	*incoming_channel = endpoint->incoming_channel;
AzureIoTClient	4:98007eb79fa8	1545	result = 0;
AzureIoTClient	4:98007eb79fa8	1546	}
Azure.IoT Build	0:6ae2f7bca550	1547
AzureIoTClient	4:98007eb79fa8	1548	return result;
Azure.IoT Build	0:6ae2f7bca550	1549	}
Azure.IoT Build	0:6ae2f7bca550	1550
Azure.IoT Build	0:6ae2f7bca550	1551	/* Codes_SRS_CONNECTION_01_129: [connection_destroy_endpoint shall free all resources associated with an endpoint created by connection_create_endpoint.] */
Azure.IoT Build	0:6ae2f7bca550	1552	void connection_destroy_endpoint(ENDPOINT_HANDLE endpoint)
Azure.IoT Build	0:6ae2f7bca550	1553	{
AzureIoTClient	4:98007eb79fa8	1554	if (endpoint != NULL)
AzureIoTClient	4:98007eb79fa8	1555	{
AzureIoTClient	4:98007eb79fa8	1556	CONNECTION_INSTANCE* connection = (CONNECTION_INSTANCE*)endpoint->connection;
AzureIoTClient	4:98007eb79fa8	1557	size_t i;
Azure.IoT Build	0:6ae2f7bca550	1558
AzureIoTClient	4:98007eb79fa8	1559	for (i = 0; i < connection->endpoint_count; i++)
AzureIoTClient	4:98007eb79fa8	1560	{
AzureIoTClient	4:98007eb79fa8	1561	if (connection->endpoints[i] == endpoint)
AzureIoTClient	4:98007eb79fa8	1562	{
AzureIoTClient	4:98007eb79fa8	1563	break;
AzureIoTClient	4:98007eb79fa8	1564	}
AzureIoTClient	4:98007eb79fa8	1565	}
Azure.IoT Build	0:6ae2f7bca550	1566
AzureIoTClient	4:98007eb79fa8	1567	/* Codes_SRS_CONNECTION_01_130: [The outgoing channel associated with the endpoint shall be released by removing the endpoint from the endpoint list.] */
AzureIoTClient	4:98007eb79fa8	1568	/* Codes_SRS_CONNECTION_01_131: [Any incoming channel number associated with the endpoint shall be released.] */
AzureIoTClient	11:b9de84324501	1569	if (i < connection->endpoint_count && i > 0)
AzureIoTClient	11:b9de84324501	1570	{
AzureIoTClient	11:b9de84324501	1571	(void)memmove(connection->endpoints + i, connection->endpoints + i + 1, sizeof(ENDPOINT_INSTANCE) (connection->endpoint_count - i - 1));
Azure.IoT Build	0:6ae2f7bca550	1572
AzureIoTClient	11:b9de84324501	1573	ENDPOINT_INSTANCE new_endpoints = (ENDPOINT_INSTANCE)amqpalloc_realloc(connection->endpoints, (connection->endpoint_count - 1) * sizeof(ENDPOINT_INSTANCE*));
AzureIoTClient	11:b9de84324501	1574	if (new_endpoints != NULL)
AzureIoTClient	11:b9de84324501	1575	{
AzureIoTClient	11:b9de84324501	1576	connection->endpoints = new_endpoints;
AzureIoTClient	11:b9de84324501	1577	}
Azure.IoT Build	0:6ae2f7bca550	1578
AzureIoTClient	11:b9de84324501	1579	connection->endpoint_count--;
AzureIoTClient	11:b9de84324501	1580	}
AzureIoTClient	11:b9de84324501	1581	else if (connection->endpoint_count == 1)
AzureIoTClient	11:b9de84324501	1582	{
AzureIoTClient	11:b9de84324501	1583	amqpalloc_free(connection->endpoints);
AzureIoTClient	11:b9de84324501	1584	connection->endpoints = NULL;
AzureIoTClient	11:b9de84324501	1585	connection->endpoint_count = 0;
AzureIoTClient	11:b9de84324501	1586	}
Azure.IoT Build	0:6ae2f7bca550	1587
AzureIoTClient	4:98007eb79fa8	1588	amqpalloc_free(endpoint);
AzureIoTClient	4:98007eb79fa8	1589	}
Azure.IoT Build	0:6ae2f7bca550	1590	}
Azure.IoT Build	0:6ae2f7bca550	1591
Azure.IoT Build	0:6ae2f7bca550	1592	/* Codes_SRS_CONNECTION_01_247: [connection_encode_frame shall send a frame for a certain endpoint.] */
Azure.IoT Build	0:6ae2f7bca550	1593	int connection_encode_frame(ENDPOINT_HANDLE endpoint, const AMQP_VALUE performative, PAYLOAD* payloads, size_t payload_count, ON_SEND_COMPLETE on_send_complete, void* callback_context)
Azure.IoT Build	0:6ae2f7bca550	1594	{
AzureIoTClient	4:98007eb79fa8	1595	int result;
Azure.IoT Build	0:6ae2f7bca550	1596
AzureIoTClient	4:98007eb79fa8	1597	/* Codes_SRS_CONNECTION_01_249: [If endpoint or performative are NULL, connection_encode_frame shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1598	if ((endpoint == NULL) \|\|
AzureIoTClient	4:98007eb79fa8	1599	(performative == NULL))
AzureIoTClient	4:98007eb79fa8	1600	{
AzureIoTClient	4:98007eb79fa8	1601	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1602	}
AzureIoTClient	4:98007eb79fa8	1603	else
AzureIoTClient	4:98007eb79fa8	1604	{
AzureIoTClient	4:98007eb79fa8	1605	CONNECTION_INSTANCE* connection = (CONNECTION_INSTANCE*)endpoint->connection;
AzureIoTClient	4:98007eb79fa8	1606	AMQP_FRAME_CODEC_HANDLE amqp_frame_codec = connection->amqp_frame_codec;
Azure.IoT Build	0:6ae2f7bca550	1607
AzureIoTClient	4:98007eb79fa8	1608	/* Codes_SRS_CONNECTION_01_254: [If connection_encode_frame is called before the connection is in the OPENED state, connection_encode_frame shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1609	if (connection->connection_state != CONNECTION_STATE_OPENED)
AzureIoTClient	4:98007eb79fa8	1610	{
AzureIoTClient	4:98007eb79fa8	1611	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1612	}
AzureIoTClient	4:98007eb79fa8	1613	else
AzureIoTClient	4:98007eb79fa8	1614	{
AzureIoTClient	4:98007eb79fa8	1615	/* Codes_SRS_CONNECTION_01_255: [The payload size shall be computed based on all the payload chunks passed as argument in payloads.] */
AzureIoTClient	4:98007eb79fa8	1616	/* Codes_SRS_CONNECTION_01_250: [connection_encode_frame shall initiate the frame send by calling amqp_frame_codec_begin_encode_frame.] */
AzureIoTClient	4:98007eb79fa8	1617	/* Codes_SRS_CONNECTION_01_251: [The channel number passed to amqp_frame_codec_begin_encode_frame shall be the outgoing channel number associated with the endpoint by connection_create_endpoint.] */
AzureIoTClient	4:98007eb79fa8	1618	/* Codes_SRS_CONNECTION_01_252: [The performative passed to amqp_frame_codec_begin_encode_frame shall be the performative argument of connection_encode_frame.] */
AzureIoTClient	4:98007eb79fa8	1619	connection->on_send_complete = on_send_complete;
AzureIoTClient	4:98007eb79fa8	1620	connection->on_send_complete_callback_context = callback_context;
AzureIoTClient	4:98007eb79fa8	1621	if (amqp_frame_codec_encode_frame(amqp_frame_codec, endpoint->outgoing_channel, performative, payloads, payload_count, on_bytes_encoded, connection) != 0)
AzureIoTClient	4:98007eb79fa8	1622	{
AzureIoTClient	4:98007eb79fa8	1623	/* Codes_SRS_CONNECTION_01_253: [If amqp_frame_codec_begin_encode_frame or amqp_frame_codec_encode_payload_bytes fails, then connection_encode_frame shall fail and return a non-zero value.] */
AzureIoTClient	4:98007eb79fa8	1624	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1625	}
AzureIoTClient	4:98007eb79fa8	1626	else
AzureIoTClient	4:98007eb79fa8	1627	{
AzureIoTClient	4:98007eb79fa8	1628	if (connection->is_trace_on == 1)
AzureIoTClient	4:98007eb79fa8	1629	{
Azure.IoT Build	5:ae49385aff34	1630	log_outgoing_frame(performative);
AzureIoTClient	4:98007eb79fa8	1631	}
Azure.IoT Build	5:ae49385aff34	1632
AzureIoTClient	4:98007eb79fa8	1633	if (tickcounter_get_current_ms(connection->tick_counter, &connection->last_frame_sent_time) != 0)
AzureIoTClient	4:98007eb79fa8	1634	{
AzureIoTClient	4:98007eb79fa8	1635	result = __LINE__;
AzureIoTClient	4:98007eb79fa8	1636	}
AzureIoTClient	4:98007eb79fa8	1637	else
AzureIoTClient	4:98007eb79fa8	1638	{
AzureIoTClient	4:98007eb79fa8	1639	/* Codes_SRS_CONNECTION_01_248: [On success it shall return 0.] */
AzureIoTClient	4:98007eb79fa8	1640	result = 0;
AzureIoTClient	4:98007eb79fa8	1641	}
AzureIoTClient	4:98007eb79fa8	1642	}
AzureIoTClient	4:98007eb79fa8	1643	}
AzureIoTClient	4:98007eb79fa8	1644	}
Azure.IoT Build	0:6ae2f7bca550	1645
AzureIoTClient	4:98007eb79fa8	1646	return result;
Azure.IoT Build	0:6ae2f7bca550	1647	}
AzureIoTClient	4:98007eb79fa8	1648
AzureIoTClient	4:98007eb79fa8	1649	void connection_set_trace(CONNECTION_HANDLE connection, bool traceOn)
AzureIoTClient	4:98007eb79fa8	1650	{
AzureIoTClient	4:98007eb79fa8	1651	/* Codes_SRS_CONNECTION_07_002: [If connection is NULL then connection_set_trace shall do nothing.] */
AzureIoTClient	4:98007eb79fa8	1652	if (connection != NULL)
AzureIoTClient	4:98007eb79fa8	1653	{
AzureIoTClient	4:98007eb79fa8	1654	/* Codes_SRS_CONNECTION_07_001: [connection_set_trace shall set the ability to turn on and off trace logging.] */
AzureIoTClient	4:98007eb79fa8	1655	connection->is_trace_on = traceOn ? 1 : 0;
AzureIoTClient	4:98007eb79fa8	1656	}
AzureIoTClient	4:98007eb79fa8	1657	}

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	08 Apr 2016
Imports:	44
Forks:	0
Commits:	48
Dependents:	3
Dependencies:	0
Followers:	7

Developers

Azure IoT

Dan Cristoloveanu

The code in this repository is MIT licensed.

connection.c@14:0b0e28c75ded, 2016-12-14 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Developers

Important Information for this Arm website

Access Warning