azure_umqtt_c - A small footprint MQTT library

Users » AzureIoTClient » Code » azure_umqtt_c

A small footprint MQTT library

Dependents: STM32F746_iothub_client_sample_mqtt FXOS8700CQ_To_Azure_IoT f767zi_mqtt FXOS8700CQ_To_Azure_IoT ... more

mqtt_client.c@27:a2eb9cb1e731, 2018-05-04 (annotated)

Committer:: AzureIoTClient
Date:: Fri May 04 13:25:24 2018 -0700
Revision:: 27:a2eb9cb1e731
Parent:: 24:75f5b91d1c6e
Child:: 28:35eea447689a

1.2.4

Who changed what in which revision?

User	Revision	Line number	New contents of line
Azure.IoT Build	0:ef4901974abc	1	// Copyright (c) Microsoft. All rights reserved.
Azure.IoT Build	0:ef4901974abc	2	// Licensed under the MIT license. See LICENSE file in the project root for full license information.
Azure.IoT Build	0:ef4901974abc	3
Azure.IoT Build	0:ef4901974abc	4	#include <stdlib.h>
AzureIoTClient	15:ec5a36121959	5	#include "azure_c_shared_utility/optimize_size.h"
Azure.IoT Build	0:ef4901974abc	6	#include "azure_c_shared_utility/gballoc.h"
Azure.IoT Build	0:ef4901974abc	7	#include "azure_c_shared_utility/platform.h"
Azure.IoT Build	0:ef4901974abc	8	#include "azure_c_shared_utility/tickcounter.h"
Azure.IoT Build	0:ef4901974abc	9	#include "azure_c_shared_utility/crt_abstractions.h"
Azure.IoT Build	4:e7167dabd6e4	10	#include "azure_c_shared_utility/xlogging.h"
AzureIoTClient	8:83bb166aba73	11	#include "azure_c_shared_utility/strings.h"
AzureIoTClient	8:83bb166aba73	12	#include "azure_c_shared_utility/agenttime.h"
AzureIoTClient	9:37d14c31ff6e	13	#include "azure_c_shared_utility/threadapi.h"
Azure.IoT Build	0:ef4901974abc	14
Azure.IoT Build	0:ef4901974abc	15	#include "azure_umqtt_c/mqtt_client.h"
Azure.IoT Build	0:ef4901974abc	16	#include "azure_umqtt_c/mqtt_codec.h"
AzureIoTClient	8:83bb166aba73	17	#include <inttypes.h>
Azure.IoT Build	0:ef4901974abc	18
Azure.IoT Build	0:ef4901974abc	19	#define VARIABLE_HEADER_OFFSET 2
Azure.IoT Build	0:ef4901974abc	20	#define RETAIN_FLAG_MASK 0x1
Azure.IoT Build	0:ef4901974abc	21	#define QOS_LEAST_ONCE_FLAG_MASK 0x2
Azure.IoT Build	0:ef4901974abc	22	#define QOS_EXACTLY_ONCE_FLAG_MASK 0x4
Azure.IoT Build	0:ef4901974abc	23	#define DUPLICATE_FLAG_MASK 0x8
Azure.IoT Build	0:ef4901974abc	24	#define CONNECT_PACKET_MASK 0xf0
AzureIoTClient	1:8dba42ff9701	25	#define TIME_MAX_BUFFER 16
AzureIoTClient	8:83bb166aba73	26	#define DEFAULT_MAX_PING_RESPONSE_TIME 80 // % of time to send pings
AzureIoTClient	23:80794cfb3565	27	#define MAX_CLOSE_RETRIES 2
Azure.IoT Build	0:ef4901974abc	28
AzureIoTClient	24:75f5b91d1c6e	29	static const char* const TRUE_CONST = "true";
AzureIoTClient	24:75f5b91d1c6e	30	static const char* const FALSE_CONST = "false";
AzureIoTClient	8:83bb166aba73	31
AzureIoTClient	8:83bb166aba73	32	DEFINE_ENUM_STRINGS(QOS_VALUE, QOS_VALUE_VALUES);
Azure.IoT Build	0:ef4901974abc	33
Azure.IoT Build	0:ef4901974abc	34	typedef struct MQTT_CLIENT_TAG
Azure.IoT Build	0:ef4901974abc	35	{
Azure.IoT Build	0:ef4901974abc	36	XIO_HANDLE xioHandle;
Azure.IoT Build	0:ef4901974abc	37	MQTTCODEC_HANDLE codec_handle;
Azure.IoT Build	0:ef4901974abc	38	CONTROL_PACKET_TYPE packetState;
Azure.IoT Build	0:ef4901974abc	39	TICK_COUNTER_HANDLE packetTickCntr;
Azure.IoT.Build	10:2ab268507775	40	tickcounter_ms_t packetSendTimeMs;
Azure.IoT Build	0:ef4901974abc	41	ON_MQTT_OPERATION_CALLBACK fnOperationCallback;
Azure.IoT Build	0:ef4901974abc	42	ON_MQTT_MESSAGE_RECV_CALLBACK fnMessageRecv;
Azure.IoT Build	0:ef4901974abc	43	void* ctx;
AzureIoTClient	9:37d14c31ff6e	44	ON_MQTT_ERROR_CALLBACK fnOnErrorCallBack;
AzureIoTClient	9:37d14c31ff6e	45	void* errorCBCtx;
AzureIoTClient	19:e283dcf26037	46	ON_MQTT_DISCONNECTED_CALLBACK disconnect_cb;
AzureIoTClient	19:e283dcf26037	47	void* disconnect_ctx;
Azure.IoT Build	0:ef4901974abc	48	QOS_VALUE qosValue;
Azure.IoT Build	0:ef4901974abc	49	uint16_t keepAliveInterval;
Azure.IoT Build	0:ef4901974abc	50	MQTT_CLIENT_OPTIONS mqttOptions;
Azure.IoT Build	0:ef4901974abc	51	bool clientConnected;
Azure.IoT Build	0:ef4901974abc	52	bool socketConnected;
Azure.IoT Build	0:ef4901974abc	53	bool logTrace;
Azure.IoT Build	0:ef4901974abc	54	bool rawBytesTrace;
Azure.IoT.Build	10:2ab268507775	55	tickcounter_ms_t timeSincePing;
AzureIoTClient	3:9b4e7158ca0d	56	uint16_t maxPingRespTime;
Azure.IoT Build	0:ef4901974abc	57	} MQTT_CLIENT;
Azure.IoT Build	0:ef4901974abc	58
AzureIoTClient	9:37d14c31ff6e	59	static void on_connection_closed(void* context)
AzureIoTClient	9:37d14c31ff6e	60	{
AzureIoTClient	19:e283dcf26037	61	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)context;
AzureIoTClient	19:e283dcf26037	62	if (mqtt_client != NULL)
AzureIoTClient	19:e283dcf26037	63	{
AzureIoTClient	19:e283dcf26037	64	mqtt_client->socketConnected = false;
AzureIoTClient	19:e283dcf26037	65	mqtt_client->clientConnected = false;
AzureIoTClient	19:e283dcf26037	66	if (mqtt_client->disconnect_cb)
AzureIoTClient	19:e283dcf26037	67	{
AzureIoTClient	19:e283dcf26037	68	mqtt_client->disconnect_cb(mqtt_client->disconnect_ctx);
AzureIoTClient	19:e283dcf26037	69	}
AzureIoTClient	19:e283dcf26037	70	}
AzureIoTClient	9:37d14c31ff6e	71	}
AzureIoTClient	9:37d14c31ff6e	72
AzureIoTClient	9:37d14c31ff6e	73	static void close_connection(MQTT_CLIENT* mqtt_client)
AzureIoTClient	9:37d14c31ff6e	74	{
AzureIoTClient	23:80794cfb3565	75	if (mqtt_client->socketConnected)
AzureIoTClient	9:37d14c31ff6e	76	{
AzureIoTClient	23:80794cfb3565	77	(void)xio_close(mqtt_client->xioHandle, on_connection_closed, mqtt_client);
AzureIoTClient	23:80794cfb3565	78	if (mqtt_client->disconnect_cb == NULL)
AzureIoTClient	19:e283dcf26037	79	{
AzureIoTClient	23:80794cfb3565	80	size_t counter = 0;
AzureIoTClient	23:80794cfb3565	81	do
AzureIoTClient	23:80794cfb3565	82	{
AzureIoTClient	23:80794cfb3565	83	xio_dowork(mqtt_client->xioHandle);
AzureIoTClient	23:80794cfb3565	84	counter++;
AzureIoTClient	23:80794cfb3565	85	ThreadAPI_Sleep(2);
AzureIoTClient	23:80794cfb3565	86	} while (mqtt_client->clientConnected && counter < MAX_CLOSE_RETRIES);
AzureIoTClient	23:80794cfb3565	87	}
AzureIoTClient	23:80794cfb3565	88	}
AzureIoTClient	23:80794cfb3565	89	else
AzureIoTClient	23:80794cfb3565	90	{
AzureIoTClient	23:80794cfb3565	91	if (mqtt_client->disconnect_cb)
AzureIoTClient	23:80794cfb3565	92	{
AzureIoTClient	23:80794cfb3565	93	mqtt_client->disconnect_cb(mqtt_client->disconnect_ctx);
AzureIoTClient	23:80794cfb3565	94	}
AzureIoTClient	19:e283dcf26037	95	}
AzureIoTClient	27:a2eb9cb1e731	96	mqtt_client->xioHandle = NULL;
AzureIoTClient	9:37d14c31ff6e	97	}
AzureIoTClient	9:37d14c31ff6e	98
AzureIoTClient	9:37d14c31ff6e	99	static void set_error_callback(MQTT_CLIENT* mqtt_client, MQTT_CLIENT_EVENT_ERROR error_type)
AzureIoTClient	9:37d14c31ff6e	100	{
AzureIoTClient	9:37d14c31ff6e	101	if (mqtt_client->fnOnErrorCallBack)
AzureIoTClient	9:37d14c31ff6e	102	{
AzureIoTClient	9:37d14c31ff6e	103	mqtt_client->fnOnErrorCallBack(mqtt_client, error_type, mqtt_client->errorCBCtx);
AzureIoTClient	9:37d14c31ff6e	104	}
AzureIoTClient	9:37d14c31ff6e	105	close_connection(mqtt_client);
AzureIoTClient	9:37d14c31ff6e	106	}
AzureIoTClient	9:37d14c31ff6e	107
AzureIoTClient	8:83bb166aba73	108	static STRING_HANDLE construct_trace_log_handle(MQTT_CLIENT* mqtt_client)
AzureIoTClient	8:83bb166aba73	109	{
AzureIoTClient	8:83bb166aba73	110	STRING_HANDLE trace_log;
AzureIoTClient	8:83bb166aba73	111	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	112	{
AzureIoTClient	8:83bb166aba73	113	trace_log = STRING_new();
AzureIoTClient	8:83bb166aba73	114	}
AzureIoTClient	8:83bb166aba73	115	else
AzureIoTClient	8:83bb166aba73	116	{
AzureIoTClient	8:83bb166aba73	117	trace_log = NULL;
AzureIoTClient	8:83bb166aba73	118	}
AzureIoTClient	8:83bb166aba73	119	return trace_log;
AzureIoTClient	8:83bb166aba73	120	}
AzureIoTClient	8:83bb166aba73	121
AzureIoTClient	8:83bb166aba73	122	static uint16_t byteutil_read_uint16(uint8_t** buffer, size_t len)
Azure.IoT Build	0:ef4901974abc	123	{
Azure.IoT Build	0:ef4901974abc	124	uint16_t result = 0;
AzureIoTClient	8:83bb166aba73	125	if (buffer != NULL && *buffer != NULL && len >= 2)
Azure.IoT Build	0:ef4901974abc	126	{
AzureIoTClient	8:83bb166aba73	127	result = 256 * (*buffer) + ((*buffer + 1));
Azure.IoT Build	0:ef4901974abc	128	*buffer += 2; // Move the ptr
Azure.IoT Build	0:ef4901974abc	129	}
AzureIoTClient	8:83bb166aba73	130	else
AzureIoTClient	8:83bb166aba73	131	{
AzureIoTClient	11:a0a6a4cf7812	132	LOG(AZ_LOG_ERROR, LOG_LINE, "byteutil_read_uint16 == NULL or less than 2");
AzureIoTClient	8:83bb166aba73	133	}
Azure.IoT Build	0:ef4901974abc	134	return result;
Azure.IoT Build	0:ef4901974abc	135	}
Azure.IoT Build	0:ef4901974abc	136
Azure.IoT Build	0:ef4901974abc	137	static char* byteutil_readUTF(uint8_t** buffer, size_t* byteLen)
Azure.IoT Build	0:ef4901974abc	138	{
Azure.IoT Build	0:ef4901974abc	139	char* result = NULL;
Azure.IoT Build	0:ef4901974abc	140	if (buffer != NULL)
Azure.IoT Build	0:ef4901974abc	141	{
Azure.IoT Build	0:ef4901974abc	142	// Get the length of the string
AzureIoTClient	8:83bb166aba73	143	uint16_t len = byteutil_read_uint16(buffer, *byteLen);
Azure.IoT Build	0:ef4901974abc	144	if (len > 0)
Azure.IoT Build	0:ef4901974abc	145	{
Azure.IoT Build	0:ef4901974abc	146	result = (char*)malloc(len + 1);
Azure.IoT Build	0:ef4901974abc	147	if (result != NULL)
Azure.IoT Build	0:ef4901974abc	148	{
Azure.IoT Build	0:ef4901974abc	149	(void)memcpy(result, *buffer, len);
Azure.IoT Build	0:ef4901974abc	150	result[len] = '\0';
Azure.IoT Build	0:ef4901974abc	151	*buffer += len;
Azure.IoT Build	0:ef4901974abc	152	if (byteLen != NULL)
Azure.IoT Build	0:ef4901974abc	153	{
Azure.IoT Build	0:ef4901974abc	154	*byteLen = len;
Azure.IoT Build	0:ef4901974abc	155	}
Azure.IoT Build	0:ef4901974abc	156	}
Azure.IoT Build	0:ef4901974abc	157	}
Azure.IoT Build	0:ef4901974abc	158	}
AzureIoTClient	8:83bb166aba73	159	else
AzureIoTClient	8:83bb166aba73	160	{
AzureIoTClient	11:a0a6a4cf7812	161	LOG(AZ_LOG_ERROR, LOG_LINE, "readByte buffer == NULL.");
AzureIoTClient	8:83bb166aba73	162	}
Azure.IoT Build	0:ef4901974abc	163	return result;
Azure.IoT Build	0:ef4901974abc	164	}
Azure.IoT Build	0:ef4901974abc	165
Azure.IoT Build	0:ef4901974abc	166	static uint8_t byteutil_readByte(uint8_t** buffer)
Azure.IoT Build	0:ef4901974abc	167	{
Azure.IoT Build	0:ef4901974abc	168	uint8_t result = 0;
Azure.IoT Build	0:ef4901974abc	169	if (buffer != NULL)
Azure.IoT Build	0:ef4901974abc	170	{
Azure.IoT Build	0:ef4901974abc	171	result = **buffer;
Azure.IoT Build	0:ef4901974abc	172	(*buffer)++;
Azure.IoT Build	0:ef4901974abc	173	}
AzureIoTClient	8:83bb166aba73	174	else
AzureIoTClient	8:83bb166aba73	175	{
AzureIoTClient	11:a0a6a4cf7812	176	LOG(AZ_LOG_ERROR, LOG_LINE, "readByte buffer == NULL.");
AzureIoTClient	8:83bb166aba73	177	}
Azure.IoT Build	0:ef4901974abc	178	return result;
Azure.IoT Build	0:ef4901974abc	179	}
Azure.IoT Build	0:ef4901974abc	180
Azure.IoT Build	0:ef4901974abc	181	static void sendComplete(void* context, IO_SEND_RESULT send_result)
Azure.IoT Build	0:ef4901974abc	182	{
AzureIoTClient	8:83bb166aba73	183	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)context;
AzureIoTClient	9:37d14c31ff6e	184	if (mqtt_client != NULL)
Azure.IoT Build	0:ef4901974abc	185	{
AzureIoTClient	9:37d14c31ff6e	186	if (send_result == IO_SEND_OK)
Azure.IoT Build	0:ef4901974abc	187	{
AzureIoTClient	9:37d14c31ff6e	188	if (mqtt_client->packetState == DISCONNECT_TYPE)
AzureIoTClient	5:34779607059c	189	{
AzureIoTClient	9:37d14c31ff6e	190	/Codes_SRS_MQTT_CLIENT_07_032: [If the actionResult parameter is of type MQTT_CLIENT_ON_DISCONNECT the the msgInfo value shall be NULL.]/
AzureIoTClient	9:37d14c31ff6e	191	if (mqtt_client->fnOperationCallback != NULL)
AzureIoTClient	9:37d14c31ff6e	192	{
AzureIoTClient	9:37d14c31ff6e	193	mqtt_client->fnOperationCallback(mqtt_client, MQTT_CLIENT_ON_DISCONNECT, NULL, mqtt_client->ctx);
AzureIoTClient	9:37d14c31ff6e	194	}
AzureIoTClient	9:37d14c31ff6e	195	// close the xio
AzureIoTClient	9:37d14c31ff6e	196	close_connection(mqtt_client);
AzureIoTClient	5:34779607059c	197	}
AzureIoTClient	9:37d14c31ff6e	198	}
AzureIoTClient	9:37d14c31ff6e	199	else if (send_result == IO_SEND_ERROR)
AzureIoTClient	9:37d14c31ff6e	200	{
AzureIoTClient	11:a0a6a4cf7812	201	LOG(AZ_LOG_ERROR, LOG_LINE, "MQTT Send Complete Failure send_result: %d", (int)send_result);
AzureIoTClient	9:37d14c31ff6e	202	set_error_callback(mqtt_client, MQTT_CLIENT_COMMUNICATION_ERROR);
Azure.IoT Build	0:ef4901974abc	203	}
Azure.IoT Build	0:ef4901974abc	204	}
AzureIoTClient	5:34779607059c	205	else
AzureIoTClient	5:34779607059c	206	{
AzureIoTClient	11:a0a6a4cf7812	207	LOG(AZ_LOG_ERROR, LOG_LINE, "MQTT Send Complete Failure with NULL mqtt_client");
AzureIoTClient	5:34779607059c	208	}
Azure.IoT Build	0:ef4901974abc	209	}
Azure.IoT Build	0:ef4901974abc	210
Azure.IoT Build	0:ef4901974abc	211	static const char* retrievePacketType(CONTROL_PACKET_TYPE packet)
Azure.IoT Build	0:ef4901974abc	212	{
Azure.IoT Build	0:ef4901974abc	213	switch (packet&CONNECT_PACKET_MASK)
Azure.IoT Build	0:ef4901974abc	214	{
Azure.IoT Build	0:ef4901974abc	215	case CONNECT_TYPE: return "CONNECT";
Azure.IoT Build	0:ef4901974abc	216	case CONNACK_TYPE: return "CONNACK";
Azure.IoT Build	0:ef4901974abc	217	case PUBLISH_TYPE: return "PUBLISH";
Azure.IoT Build	0:ef4901974abc	218	case PUBACK_TYPE: return "PUBACK";
Azure.IoT Build	0:ef4901974abc	219	case PUBREC_TYPE: return "PUBREC";
Azure.IoT Build	0:ef4901974abc	220	case PUBREL_TYPE: return "PUBREL";
Azure.IoT Build	0:ef4901974abc	221	case SUBSCRIBE_TYPE: return "SUBSCRIBE";
Azure.IoT Build	0:ef4901974abc	222	case SUBACK_TYPE: return "SUBACK";
Azure.IoT Build	0:ef4901974abc	223	case UNSUBSCRIBE_TYPE: return "UNSUBSCRIBE";
Azure.IoT Build	0:ef4901974abc	224	case UNSUBACK_TYPE: return "UNSUBACK";
Azure.IoT Build	0:ef4901974abc	225	case PINGREQ_TYPE: return "PINGREQ";
Azure.IoT Build	0:ef4901974abc	226	case PINGRESP_TYPE: return "PINGRESP";
Azure.IoT Build	0:ef4901974abc	227	case DISCONNECT_TYPE: return "DISCONNECT";
Azure.IoT Build	0:ef4901974abc	228	default:
Azure.IoT Build	0:ef4901974abc	229	case PACKET_TYPE_ERROR:
Azure.IoT Build	0:ef4901974abc	230	case UNKNOWN_TYPE:
Azure.IoT Build	0:ef4901974abc	231	return "UNKNOWN";
Azure.IoT Build	0:ef4901974abc	232	}
Azure.IoT Build	0:ef4901974abc	233	}
Azure.IoT Build	0:ef4901974abc	234
AzureIoTClient	1:8dba42ff9701	235	static void getLogTime(char* timeResult, size_t len)
AzureIoTClient	1:8dba42ff9701	236	{
AzureIoTClient	1:8dba42ff9701	237	if (timeResult != NULL)
AzureIoTClient	1:8dba42ff9701	238	{
AzureIoTClient	8:83bb166aba73	239	time_t agent_time = get_time(NULL);
AzureIoTClient	8:83bb166aba73	240	if (agent_time == (time_t)-1)
AzureIoTClient	1:8dba42ff9701	241	{
AzureIoTClient	1:8dba42ff9701	242	timeResult[0] = '\0';
AzureIoTClient	1:8dba42ff9701	243	}
AzureIoTClient	8:83bb166aba73	244	else
AzureIoTClient	8:83bb166aba73	245	{
AzureIoTClient	8:83bb166aba73	246	struct tm* tmInfo = localtime(&agent_time);
AzureIoTClient	8:83bb166aba73	247	if (tmInfo == NULL)
AzureIoTClient	8:83bb166aba73	248	{
AzureIoTClient	8:83bb166aba73	249	timeResult[0] = '\0';
AzureIoTClient	8:83bb166aba73	250	}
AzureIoTClient	8:83bb166aba73	251	else
AzureIoTClient	8:83bb166aba73	252	{
AzureIoTClient	8:83bb166aba73	253	if (strftime(timeResult, len, "%H:%M:%S", tmInfo) == 0)
AzureIoTClient	8:83bb166aba73	254	{
AzureIoTClient	8:83bb166aba73	255	timeResult[0] = '\0';
AzureIoTClient	8:83bb166aba73	256	}
AzureIoTClient	8:83bb166aba73	257	}
AzureIoTClient	8:83bb166aba73	258	}
AzureIoTClient	1:8dba42ff9701	259	}
AzureIoTClient	1:8dba42ff9701	260	}
AzureIoTClient	1:8dba42ff9701	261
AzureIoTClient	8:83bb166aba73	262	static void log_outgoing_trace(MQTT_CLIENT* mqtt_client, STRING_HANDLE trace_log)
Azure.IoT Build	0:ef4901974abc	263	{
AzureIoTClient	8:83bb166aba73	264	if (mqtt_client != NULL && mqtt_client->logTrace && trace_log != NULL)
AzureIoTClient	8:83bb166aba73	265	{
AzureIoTClient	8:83bb166aba73	266	char tmBuffer[TIME_MAX_BUFFER];
AzureIoTClient	8:83bb166aba73	267	getLogTime(tmBuffer, TIME_MAX_BUFFER);
AzureIoTClient	11:a0a6a4cf7812	268	LOG(AZ_LOG_TRACE, LOG_LINE, "-> %s %s", tmBuffer, STRING_c_str(trace_log));
AzureIoTClient	8:83bb166aba73	269	}
AzureIoTClient	8:83bb166aba73	270	}
AzureIoTClient	8:83bb166aba73	271
AzureIoTClient	18:6d13ad04e8a0	272	static void logOutgoingRawTrace(MQTT_CLIENT* mqtt_client, const uint8_t* data, size_t length)
AzureIoTClient	8:83bb166aba73	273	{
AzureIoTClient	8:83bb166aba73	274	if (mqtt_client != NULL && data != NULL && length > 0 && mqtt_client->rawBytesTrace)
Azure.IoT Build	0:ef4901974abc	275	{
AzureIoTClient	1:8dba42ff9701	276	char tmBuffer[TIME_MAX_BUFFER];
AzureIoTClient	1:8dba42ff9701	277	getLogTime(tmBuffer, TIME_MAX_BUFFER);
AzureIoTClient	1:8dba42ff9701	278
AzureIoTClient	11:a0a6a4cf7812	279	LOG(AZ_LOG_TRACE, 0, "-> %s %s: ", tmBuffer, retrievePacketType((unsigned char)data[0]));
AzureIoTClient	12:30b08cda82fd	280	size_t index = 0;
AzureIoTClient	12:30b08cda82fd	281	for (index = 0; index < length; index++)
Azure.IoT Build	0:ef4901974abc	282	{
AzureIoTClient	11:a0a6a4cf7812	283	LOG(AZ_LOG_TRACE, 0, "0x%02x ", data[index]);
Azure.IoT Build	0:ef4901974abc	284	}
AzureIoTClient	11:a0a6a4cf7812	285	LOG(AZ_LOG_TRACE, LOG_LINE, "");
Azure.IoT Build	0:ef4901974abc	286	}
Azure.IoT Build	0:ef4901974abc	287	}
Azure.IoT Build	0:ef4901974abc	288
AzureIoTClient	8:83bb166aba73	289	static void log_incoming_trace(MQTT_CLIENT* mqtt_client, STRING_HANDLE trace_log)
AzureIoTClient	8:83bb166aba73	290	{
AzureIoTClient	8:83bb166aba73	291	if (mqtt_client != NULL && mqtt_client->logTrace && trace_log != NULL)
AzureIoTClient	8:83bb166aba73	292	{
AzureIoTClient	8:83bb166aba73	293	char tmBuffer[TIME_MAX_BUFFER];
AzureIoTClient	8:83bb166aba73	294	getLogTime(tmBuffer, TIME_MAX_BUFFER);
AzureIoTClient	11:a0a6a4cf7812	295	LOG(AZ_LOG_TRACE, LOG_LINE, "<- %s %s", tmBuffer, STRING_c_str(trace_log) );
AzureIoTClient	8:83bb166aba73	296	}
AzureIoTClient	8:83bb166aba73	297	}
AzureIoTClient	8:83bb166aba73	298
AzureIoTClient	8:83bb166aba73	299	static void logIncomingRawTrace(MQTT_CLIENT* mqtt_client, CONTROL_PACKET_TYPE packet, uint8_t flags, const uint8_t* data, size_t length)
Azure.IoT Build	0:ef4901974abc	300	{
AzureIoTClient	6:d9c4702f91ca	301	#ifdef NO_LOGGING
AzureIoTClient	8:83bb166aba73	302	UNUSED(flags);
AzureIoTClient	6:d9c4702f91ca	303	#endif
AzureIoTClient	8:83bb166aba73	304	if (mqtt_client != NULL && mqtt_client->rawBytesTrace)
Azure.IoT Build	0:ef4901974abc	305	{
AzureIoTClient	3:9b4e7158ca0d	306	if (data != NULL && length > 0)
AzureIoTClient	3:9b4e7158ca0d	307	{
AzureIoTClient	3:9b4e7158ca0d	308	char tmBuffer[TIME_MAX_BUFFER];
AzureIoTClient	3:9b4e7158ca0d	309	getLogTime(tmBuffer, TIME_MAX_BUFFER);
AzureIoTClient	1:8dba42ff9701	310
AzureIoTClient	11:a0a6a4cf7812	311	LOG(AZ_LOG_TRACE, 0, "<- %s %s: 0x%02x 0x%02x ", tmBuffer, retrievePacketType((CONTROL_PACKET_TYPE)packet), (unsigned char)(packet \| flags), length);
AzureIoTClient	12:30b08cda82fd	312	size_t index = 0;
AzureIoTClient	12:30b08cda82fd	313	for (index = 0; index < length; index++)
AzureIoTClient	3:9b4e7158ca0d	314	{
AzureIoTClient	11:a0a6a4cf7812	315	LOG(AZ_LOG_TRACE, 0, "0x%02x ", data[index]);
AzureIoTClient	3:9b4e7158ca0d	316	}
AzureIoTClient	11:a0a6a4cf7812	317	LOG(AZ_LOG_TRACE, LOG_LINE, "");
AzureIoTClient	3:9b4e7158ca0d	318	}
AzureIoTClient	3:9b4e7158ca0d	319	else if (packet == PINGRESP_TYPE)
Azure.IoT Build	0:ef4901974abc	320	{
AzureIoTClient	3:9b4e7158ca0d	321	char tmBuffer[TIME_MAX_BUFFER];
AzureIoTClient	3:9b4e7158ca0d	322	getLogTime(tmBuffer, TIME_MAX_BUFFER);
AzureIoTClient	11:a0a6a4cf7812	323	LOG(AZ_LOG_TRACE, LOG_LINE, "<- %s %s: 0x%02x 0x%02x ", tmBuffer, retrievePacketType((CONTROL_PACKET_TYPE)packet), (unsigned char)(packet \| flags), length);
Azure.IoT Build	0:ef4901974abc	324	}
Azure.IoT Build	0:ef4901974abc	325	}
Azure.IoT Build	0:ef4901974abc	326	}
Azure.IoT Build	0:ef4901974abc	327
AzureIoTClient	8:83bb166aba73	328	static int sendPacketItem(MQTT_CLIENT* mqtt_client, const unsigned char* data, size_t length)
Azure.IoT Build	0:ef4901974abc	329	{
Azure.IoT Build	0:ef4901974abc	330	int result;
Azure.IoT Build	0:ef4901974abc	331
AzureIoTClient	8:83bb166aba73	332	if (tickcounter_get_current_ms(mqtt_client->packetTickCntr, &mqtt_client->packetSendTimeMs) != 0)
Azure.IoT Build	0:ef4901974abc	333	{
AzureIoTClient	11:a0a6a4cf7812	334	LOG(AZ_LOG_ERROR, LOG_LINE, "Failure getting current ms tickcounter");
AzureIoTClient	15:ec5a36121959	335	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	336	}
Azure.IoT Build	0:ef4901974abc	337	else
Azure.IoT Build	0:ef4901974abc	338	{
AzureIoTClient	8:83bb166aba73	339	result = xio_send(mqtt_client->xioHandle, (const void*)data, length, sendComplete, mqtt_client);
Azure.IoT Build	0:ef4901974abc	340	if (result != 0)
Azure.IoT Build	0:ef4901974abc	341	{
AzureIoTClient	11:a0a6a4cf7812	342	LOG(AZ_LOG_ERROR, LOG_LINE, "%d: Failure sending control packet data", result);
AzureIoTClient	15:ec5a36121959	343	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	344	}
Azure.IoT Build	4:e7167dabd6e4	345	else
Azure.IoT Build	4:e7167dabd6e4	346	{
AzureIoTClient	18:6d13ad04e8a0	347	logOutgoingRawTrace(mqtt_client, (const uint8_t*)data, length);
Azure.IoT Build	4:e7167dabd6e4	348	}
Azure.IoT Build	0:ef4901974abc	349	}
Azure.IoT Build	0:ef4901974abc	350	return result;
Azure.IoT Build	0:ef4901974abc	351	}
Azure.IoT Build	0:ef4901974abc	352
Azure.IoT Build	0:ef4901974abc	353	static void onOpenComplete(void* context, IO_OPEN_RESULT open_result)
Azure.IoT Build	0:ef4901974abc	354	{
AzureIoTClient	8:83bb166aba73	355	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)context;
AzureIoTClient	8:83bb166aba73	356	if (mqtt_client != NULL)
Azure.IoT Build	0:ef4901974abc	357	{
AzureIoTClient	8:83bb166aba73	358	if (open_result == IO_OPEN_OK && !mqtt_client->socketConnected)
Azure.IoT Build	0:ef4901974abc	359	{
AzureIoTClient	8:83bb166aba73	360	mqtt_client->packetState = CONNECT_TYPE;
AzureIoTClient	8:83bb166aba73	361	mqtt_client->socketConnected = true;
AzureIoTClient	8:83bb166aba73	362
AzureIoTClient	8:83bb166aba73	363	STRING_HANDLE trace_log = construct_trace_log_handle(mqtt_client);
AzureIoTClient	8:83bb166aba73	364
Azure.IoT Build	0:ef4901974abc	365	// Send the Connect packet
AzureIoTClient	8:83bb166aba73	366	BUFFER_HANDLE connPacket = mqtt_codec_connect(&mqtt_client->mqttOptions, trace_log);
Azure.IoT Build	0:ef4901974abc	367	if (connPacket == NULL)
Azure.IoT Build	0:ef4901974abc	368	{
AzureIoTClient	11:a0a6a4cf7812	369	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_codec_connect failed");
Azure.IoT Build	0:ef4901974abc	370	}
Azure.IoT Build	0:ef4901974abc	371	else
Azure.IoT Build	0:ef4901974abc	372	{
AzureIoTClient	13:3c202001e4ba	373	size_t size = BUFFER_length(connPacket);
Azure.IoT Build	0:ef4901974abc	374	/Codes_SRS_MQTT_CLIENT_07_009: [On success mqtt_client_connect shall send the MQTT CONNECT to the endpoint.]/
AzureIoTClient	13:3c202001e4ba	375	if (sendPacketItem(mqtt_client, BUFFER_u_char(connPacket), size) != 0)
Azure.IoT Build	0:ef4901974abc	376	{
AzureIoTClient	11:a0a6a4cf7812	377	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_codec_connect failed");
Azure.IoT Build	0:ef4901974abc	378	}
AzureIoTClient	8:83bb166aba73	379	else
AzureIoTClient	8:83bb166aba73	380	{
AzureIoTClient	8:83bb166aba73	381	log_outgoing_trace(mqtt_client, trace_log);
AzureIoTClient	8:83bb166aba73	382	}
Azure.IoT Build	0:ef4901974abc	383	BUFFER_delete(connPacket);
Azure.IoT Build	0:ef4901974abc	384	}
AzureIoTClient	8:83bb166aba73	385	if (trace_log != NULL)
AzureIoTClient	8:83bb166aba73	386	{
AzureIoTClient	8:83bb166aba73	387	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	388	}
Azure.IoT Build	0:ef4901974abc	389	}
AzureIoTClient	8:83bb166aba73	390	else
Azure.IoT Build	0:ef4901974abc	391	{
AzureIoTClient	9:37d14c31ff6e	392	if (mqtt_client->socketConnected == false && mqtt_client->fnOnErrorCallBack)
AzureIoTClient	8:83bb166aba73	393	{
AzureIoTClient	9:37d14c31ff6e	394	mqtt_client->fnOnErrorCallBack(mqtt_client, MQTT_CLIENT_CONNECTION_ERROR, mqtt_client->errorCBCtx);
AzureIoTClient	8:83bb166aba73	395	}
AzureIoTClient	9:37d14c31ff6e	396	close_connection(mqtt_client);
Azure.IoT Build	0:ef4901974abc	397	}
Azure.IoT Build	0:ef4901974abc	398	}
AzureIoTClient	8:83bb166aba73	399	else
AzureIoTClient	8:83bb166aba73	400	{
AzureIoTClient	11:a0a6a4cf7812	401	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_client is NULL");
AzureIoTClient	8:83bb166aba73	402	}
Azure.IoT Build	0:ef4901974abc	403	}
Azure.IoT Build	0:ef4901974abc	404
Azure.IoT Build	0:ef4901974abc	405	static void onBytesReceived(void* context, const unsigned char* buffer, size_t size)
Azure.IoT Build	0:ef4901974abc	406	{
AzureIoTClient	8:83bb166aba73	407	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)context;
AzureIoTClient	8:83bb166aba73	408	if (mqtt_client != NULL)
Azure.IoT Build	0:ef4901974abc	409	{
AzureIoTClient	8:83bb166aba73	410	if (mqtt_codec_bytesReceived(mqtt_client->codec_handle, buffer, size) != 0)
Azure.IoT Build	0:ef4901974abc	411	{
AzureIoTClient	9:37d14c31ff6e	412	set_error_callback(mqtt_client, MQTT_CLIENT_PARSE_ERROR);
Azure.IoT Build	0:ef4901974abc	413	}
Azure.IoT Build	0:ef4901974abc	414	}
AzureIoTClient	8:83bb166aba73	415	else
AzureIoTClient	8:83bb166aba73	416	{
AzureIoTClient	11:a0a6a4cf7812	417	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_client is NULL");
AzureIoTClient	8:83bb166aba73	418	}
Azure.IoT Build	0:ef4901974abc	419	}
Azure.IoT Build	0:ef4901974abc	420
Azure.IoT Build	0:ef4901974abc	421	static void onIoError(void* context)
Azure.IoT Build	0:ef4901974abc	422	{
AzureIoTClient	8:83bb166aba73	423	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)context;
AzureIoTClient	8:83bb166aba73	424	if (mqtt_client != NULL && mqtt_client->fnOperationCallback)
Azure.IoT Build	0:ef4901974abc	425	{
AzureIoTClient	9:37d14c31ff6e	426	/Codes_SRS_MQTT_CLIENT_07_032: [If the actionResult parameter is of type MQTT_CLIENT_ON_DISCONNECT the the msgInfo value shall be NULL.]/
AzureIoTClient	8:83bb166aba73	427	/* Codes_SRS_MQTT_CLIENT_07_036: [ If an error is encountered by the ioHandle the mqtt_client shall call xio_close. ] */
AzureIoTClient	9:37d14c31ff6e	428	set_error_callback(mqtt_client, MQTT_CLIENT_CONNECTION_ERROR);
AzureIoTClient	8:83bb166aba73	429	}
AzureIoTClient	8:83bb166aba73	430	else
AzureIoTClient	8:83bb166aba73	431	{
AzureIoTClient	11:a0a6a4cf7812	432	LOG(AZ_LOG_ERROR, LOG_LINE, "Error invalid parameter: mqtt_client: %p", mqtt_client);
Azure.IoT Build	0:ef4901974abc	433	}
Azure.IoT Build	0:ef4901974abc	434	}
Azure.IoT Build	0:ef4901974abc	435
AzureIoTClient	14:4b5b4dccfc8b	436	static void clear_mqtt_options(MQTT_CLIENT* mqtt_client)
AzureIoTClient	14:4b5b4dccfc8b	437	{
AzureIoTClient	18:6d13ad04e8a0	438	if (mqtt_client->mqttOptions.clientId != NULL)
AzureIoTClient	18:6d13ad04e8a0	439	{
AzureIoTClient	18:6d13ad04e8a0	440	free(mqtt_client->mqttOptions.clientId);
AzureIoTClient	18:6d13ad04e8a0	441	mqtt_client->mqttOptions.clientId = NULL;
AzureIoTClient	18:6d13ad04e8a0	442	}
AzureIoTClient	18:6d13ad04e8a0	443
AzureIoTClient	18:6d13ad04e8a0	444	if (mqtt_client->mqttOptions.willTopic != NULL)
AzureIoTClient	18:6d13ad04e8a0	445	{
AzureIoTClient	18:6d13ad04e8a0	446	free(mqtt_client->mqttOptions.willTopic);
AzureIoTClient	18:6d13ad04e8a0	447	mqtt_client->mqttOptions.willTopic = NULL;
AzureIoTClient	18:6d13ad04e8a0	448	}
AzureIoTClient	18:6d13ad04e8a0	449
AzureIoTClient	18:6d13ad04e8a0	450	if (mqtt_client->mqttOptions.willMessage != NULL)
AzureIoTClient	18:6d13ad04e8a0	451	{
AzureIoTClient	18:6d13ad04e8a0	452	free(mqtt_client->mqttOptions.willMessage);
AzureIoTClient	18:6d13ad04e8a0	453	mqtt_client->mqttOptions.willMessage = NULL;
AzureIoTClient	18:6d13ad04e8a0	454	}
AzureIoTClient	18:6d13ad04e8a0	455
AzureIoTClient	18:6d13ad04e8a0	456	if (mqtt_client->mqttOptions.username != NULL)
AzureIoTClient	18:6d13ad04e8a0	457	{
AzureIoTClient	18:6d13ad04e8a0	458	free(mqtt_client->mqttOptions.username);
AzureIoTClient	18:6d13ad04e8a0	459	mqtt_client->mqttOptions.username = NULL;
AzureIoTClient	18:6d13ad04e8a0	460	}
AzureIoTClient	18:6d13ad04e8a0	461
AzureIoTClient	18:6d13ad04e8a0	462	if (mqtt_client->mqttOptions.password != NULL)
AzureIoTClient	18:6d13ad04e8a0	463	{
AzureIoTClient	18:6d13ad04e8a0	464	free(mqtt_client->mqttOptions.password);
AzureIoTClient	18:6d13ad04e8a0	465	mqtt_client->mqttOptions.password = NULL;
AzureIoTClient	18:6d13ad04e8a0	466	}
AzureIoTClient	14:4b5b4dccfc8b	467	}
AzureIoTClient	14:4b5b4dccfc8b	468
AzureIoTClient	8:83bb166aba73	469	static int cloneMqttOptions(MQTT_CLIENT* mqtt_client, const MQTT_CLIENT_OPTIONS* mqttOptions)
Azure.IoT Build	0:ef4901974abc	470	{
Azure.IoT Build	0:ef4901974abc	471	int result = 0;
AzureIoTClient	18:6d13ad04e8a0	472
Azure.IoT Build	0:ef4901974abc	473	if (mqttOptions->clientId != NULL)
Azure.IoT Build	0:ef4901974abc	474	{
AzureIoTClient	18:6d13ad04e8a0	475	char* clientId;
AzureIoTClient	18:6d13ad04e8a0	476
AzureIoTClient	18:6d13ad04e8a0	477	if (mallocAndStrcpy_s(&clientId, mqttOptions->clientId) != 0)
Azure.IoT Build	0:ef4901974abc	478	{
AzureIoTClient	15:ec5a36121959	479	result = __FAILURE__;
AzureIoTClient	11:a0a6a4cf7812	480	LOG(AZ_LOG_ERROR, LOG_LINE, "mallocAndStrcpy_s clientId");
Azure.IoT Build	0:ef4901974abc	481	}
AzureIoTClient	18:6d13ad04e8a0	482	else
AzureIoTClient	18:6d13ad04e8a0	483	{
AzureIoTClient	18:6d13ad04e8a0	484	if (mqtt_client->mqttOptions.clientId != NULL)
AzureIoTClient	18:6d13ad04e8a0	485	{
AzureIoTClient	18:6d13ad04e8a0	486	free(mqtt_client->mqttOptions.clientId);
AzureIoTClient	18:6d13ad04e8a0	487	}
AzureIoTClient	18:6d13ad04e8a0	488
AzureIoTClient	18:6d13ad04e8a0	489	mqtt_client->mqttOptions.clientId = clientId;
AzureIoTClient	18:6d13ad04e8a0	490	}
Azure.IoT Build	0:ef4901974abc	491	}
Azure.IoT Build	0:ef4901974abc	492	if (result == 0 && mqttOptions->willTopic != NULL)
Azure.IoT Build	0:ef4901974abc	493	{
AzureIoTClient	18:6d13ad04e8a0	494	char* willTopic;
AzureIoTClient	18:6d13ad04e8a0	495
AzureIoTClient	18:6d13ad04e8a0	496	if (mallocAndStrcpy_s(&willTopic, mqttOptions->willTopic) != 0)
Azure.IoT Build	0:ef4901974abc	497	{
AzureIoTClient	15:ec5a36121959	498	result = __FAILURE__;
AzureIoTClient	11:a0a6a4cf7812	499	LOG(AZ_LOG_ERROR, LOG_LINE, "mallocAndStrcpy_s willTopic");
Azure.IoT Build	0:ef4901974abc	500	}
AzureIoTClient	18:6d13ad04e8a0	501	else
AzureIoTClient	18:6d13ad04e8a0	502	{
AzureIoTClient	18:6d13ad04e8a0	503	if (mqtt_client->mqttOptions.willTopic != NULL)
AzureIoTClient	18:6d13ad04e8a0	504	{
AzureIoTClient	18:6d13ad04e8a0	505	free(mqtt_client->mqttOptions.willTopic);
AzureIoTClient	18:6d13ad04e8a0	506	}
AzureIoTClient	18:6d13ad04e8a0	507
AzureIoTClient	18:6d13ad04e8a0	508	mqtt_client->mqttOptions.willTopic = willTopic;
AzureIoTClient	18:6d13ad04e8a0	509	}
Azure.IoT Build	0:ef4901974abc	510	}
Azure.IoT Build	0:ef4901974abc	511	if (result == 0 && mqttOptions->willMessage != NULL)
Azure.IoT Build	0:ef4901974abc	512	{
AzureIoTClient	18:6d13ad04e8a0	513	char* willMessage;
AzureIoTClient	18:6d13ad04e8a0	514
AzureIoTClient	18:6d13ad04e8a0	515	if (mallocAndStrcpy_s(&willMessage, mqttOptions->willMessage) != 0)
Azure.IoT Build	0:ef4901974abc	516	{
AzureIoTClient	11:a0a6a4cf7812	517	LOG(AZ_LOG_ERROR, LOG_LINE, "mallocAndStrcpy_s willMessage");
AzureIoTClient	15:ec5a36121959	518	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	519	}
AzureIoTClient	18:6d13ad04e8a0	520	else
AzureIoTClient	18:6d13ad04e8a0	521	{
AzureIoTClient	18:6d13ad04e8a0	522	if (mqtt_client->mqttOptions.willMessage != NULL)
AzureIoTClient	18:6d13ad04e8a0	523	{
AzureIoTClient	18:6d13ad04e8a0	524	free(mqtt_client->mqttOptions.willMessage);
AzureIoTClient	18:6d13ad04e8a0	525	}
AzureIoTClient	18:6d13ad04e8a0	526
AzureIoTClient	18:6d13ad04e8a0	527	mqtt_client->mqttOptions.willMessage = willMessage;
AzureIoTClient	18:6d13ad04e8a0	528	}
Azure.IoT Build	0:ef4901974abc	529	}
Azure.IoT Build	0:ef4901974abc	530	if (result == 0 && mqttOptions->username != NULL)
Azure.IoT Build	0:ef4901974abc	531	{
AzureIoTClient	18:6d13ad04e8a0	532	char* username;
AzureIoTClient	18:6d13ad04e8a0	533
AzureIoTClient	18:6d13ad04e8a0	534	if (mallocAndStrcpy_s(&username, mqttOptions->username) != 0)
Azure.IoT Build	0:ef4901974abc	535	{
AzureIoTClient	11:a0a6a4cf7812	536	LOG(AZ_LOG_ERROR, LOG_LINE, "mallocAndStrcpy_s username");
AzureIoTClient	15:ec5a36121959	537	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	538	}
AzureIoTClient	18:6d13ad04e8a0	539	else
AzureIoTClient	18:6d13ad04e8a0	540	{
AzureIoTClient	18:6d13ad04e8a0	541	if (mqtt_client->mqttOptions.username != NULL)
AzureIoTClient	18:6d13ad04e8a0	542	{
AzureIoTClient	18:6d13ad04e8a0	543	free(mqtt_client->mqttOptions.username);
AzureIoTClient	18:6d13ad04e8a0	544	}
AzureIoTClient	18:6d13ad04e8a0	545
AzureIoTClient	18:6d13ad04e8a0	546	mqtt_client->mqttOptions.username = username;
AzureIoTClient	18:6d13ad04e8a0	547	}
Azure.IoT Build	0:ef4901974abc	548	}
Azure.IoT Build	0:ef4901974abc	549	if (result == 0 && mqttOptions->password != NULL)
Azure.IoT Build	0:ef4901974abc	550	{
AzureIoTClient	18:6d13ad04e8a0	551	char* password;
AzureIoTClient	18:6d13ad04e8a0	552
AzureIoTClient	18:6d13ad04e8a0	553	if (mallocAndStrcpy_s(&password, mqttOptions->password) != 0)
Azure.IoT Build	0:ef4901974abc	554	{
AzureIoTClient	11:a0a6a4cf7812	555	LOG(AZ_LOG_ERROR, LOG_LINE, "mallocAndStrcpy_s password");
AzureIoTClient	15:ec5a36121959	556	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	557	}
AzureIoTClient	18:6d13ad04e8a0	558	else
AzureIoTClient	18:6d13ad04e8a0	559	{
AzureIoTClient	18:6d13ad04e8a0	560	if (mqtt_client->mqttOptions.password != NULL)
AzureIoTClient	18:6d13ad04e8a0	561	{
AzureIoTClient	18:6d13ad04e8a0	562	free(mqtt_client->mqttOptions.password);
AzureIoTClient	18:6d13ad04e8a0	563	}
AzureIoTClient	18:6d13ad04e8a0	564
AzureIoTClient	18:6d13ad04e8a0	565	mqtt_client->mqttOptions.password = password;
AzureIoTClient	18:6d13ad04e8a0	566	}
Azure.IoT Build	0:ef4901974abc	567	}
Azure.IoT Build	0:ef4901974abc	568	if (result == 0)
Azure.IoT Build	0:ef4901974abc	569	{
AzureIoTClient	8:83bb166aba73	570	mqtt_client->mqttOptions.keepAliveInterval = mqttOptions->keepAliveInterval;
AzureIoTClient	8:83bb166aba73	571	mqtt_client->mqttOptions.messageRetain = mqttOptions->messageRetain;
AzureIoTClient	8:83bb166aba73	572	mqtt_client->mqttOptions.useCleanSession = mqttOptions->useCleanSession;
AzureIoTClient	8:83bb166aba73	573	mqtt_client->mqttOptions.qualityOfServiceValue = mqttOptions->qualityOfServiceValue;
Azure.IoT Build	0:ef4901974abc	574	}
Azure.IoT Build	0:ef4901974abc	575	else
Azure.IoT Build	0:ef4901974abc	576	{
AzureIoTClient	14:4b5b4dccfc8b	577	clear_mqtt_options(mqtt_client);
Azure.IoT Build	0:ef4901974abc	578	}
Azure.IoT Build	0:ef4901974abc	579	return result;
Azure.IoT Build	0:ef4901974abc	580	}
Azure.IoT Build	0:ef4901974abc	581
Azure.IoT Build	0:ef4901974abc	582	static void recvCompleteCallback(void* context, CONTROL_PACKET_TYPE packet, int flags, BUFFER_HANDLE headerData)
Azure.IoT Build	0:ef4901974abc	583	{
AzureIoTClient	8:83bb166aba73	584	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)context;
AzureIoTClient	8:83bb166aba73	585	if ((mqtt_client != NULL && headerData != NULL) \|\| packet == PINGRESP_TYPE)
Azure.IoT Build	0:ef4901974abc	586	{
Azure.IoT Build	0:ef4901974abc	587	size_t len = BUFFER_length(headerData);
Azure.IoT Build	0:ef4901974abc	588	uint8_t* iterator = BUFFER_u_char(headerData);
Azure.IoT Build	0:ef4901974abc	589
AzureIoTClient	8:83bb166aba73	590	logIncomingRawTrace(mqtt_client, packet, (uint8_t)flags, iterator, len);
Azure.IoT Build	0:ef4901974abc	591
AzureIoTClient	3:9b4e7158ca0d	592	if ((iterator != NULL && len > 0) \|\| packet == PINGRESP_TYPE)
Azure.IoT Build	0:ef4901974abc	593	{
Azure.IoT Build	0:ef4901974abc	594	switch (packet)
Azure.IoT Build	0:ef4901974abc	595	{
AzureIoTClient	3:9b4e7158ca0d	596	case CONNACK_TYPE:
Azure.IoT Build	0:ef4901974abc	597	{
AzureIoTClient	8:83bb166aba73	598	if (mqtt_client->fnOperationCallback != NULL)
AzureIoTClient	3:9b4e7158ca0d	599	{
AzureIoTClient	8:83bb166aba73	600	STRING_HANDLE trace_log = NULL;
AzureIoTClient	8:83bb166aba73	601
AzureIoTClient	3:9b4e7158ca0d	602	/Codes_SRS_MQTT_CLIENT_07_028: [If the actionResult parameter is of type CONNECT_ACK then the msgInfo value shall be a CONNECT_ACK structure.]/
AzureIoTClient	3:9b4e7158ca0d	603	CONNECT_ACK connack = { 0 };
AzureIoTClient	3:9b4e7158ca0d	604	connack.isSessionPresent = (byteutil_readByte(&iterator) == 0x1) ? true : false;
AzureIoTClient	3:9b4e7158ca0d	605	connack.returnCode = byteutil_readByte(&iterator);
Azure.IoT Build	0:ef4901974abc	606
AzureIoTClient	8:83bb166aba73	607	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	608	{
AzureIoTClient	8:83bb166aba73	609	trace_log = STRING_construct_sprintf("CONNACK \| SESSION_PRESENT: %s \| RETURN_CODE: 0x%x", connack.isSessionPresent ? TRUE_CONST : FALSE_CONST, connack.returnCode);
AzureIoTClient	8:83bb166aba73	610	log_incoming_trace(mqtt_client, trace_log);
AzureIoTClient	8:83bb166aba73	611	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	612	}
AzureIoTClient	8:83bb166aba73	613	mqtt_client->fnOperationCallback(mqtt_client, MQTT_CLIENT_ON_CONNACK, (void*)&connack, mqtt_client->ctx);
AzureIoTClient	3:9b4e7158ca0d	614
AzureIoTClient	3:9b4e7158ca0d	615	if (connack.returnCode == CONNECTION_ACCEPTED)
AzureIoTClient	3:9b4e7158ca0d	616	{
AzureIoTClient	8:83bb166aba73	617	mqtt_client->clientConnected = true;
AzureIoTClient	3:9b4e7158ca0d	618	}
Azure.IoT Build	0:ef4901974abc	619	}
AzureIoTClient	8:83bb166aba73	620	else
AzureIoTClient	8:83bb166aba73	621	{
AzureIoTClient	11:a0a6a4cf7812	622	LOG(AZ_LOG_ERROR, LOG_LINE, "fnOperationCallback NULL");
AzureIoTClient	8:83bb166aba73	623	}
AzureIoTClient	3:9b4e7158ca0d	624	break;
Azure.IoT Build	0:ef4901974abc	625	}
AzureIoTClient	3:9b4e7158ca0d	626	case PUBLISH_TYPE:
Azure.IoT Build	0:ef4901974abc	627	{
AzureIoTClient	8:83bb166aba73	628	if (mqtt_client->fnMessageRecv != NULL)
AzureIoTClient	3:9b4e7158ca0d	629	{
AzureIoTClient	8:83bb166aba73	630	STRING_HANDLE trace_log = NULL;
AzureIoTClient	8:83bb166aba73	631
AzureIoTClient	3:9b4e7158ca0d	632	bool isDuplicateMsg = (flags & DUPLICATE_FLAG_MASK) ? true : false;
AzureIoTClient	3:9b4e7158ca0d	633	bool isRetainMsg = (flags & RETAIN_FLAG_MASK) ? true : false;
AzureIoTClient	3:9b4e7158ca0d	634	QOS_VALUE qosValue = (flags == 0) ? DELIVER_AT_MOST_ONCE : (flags & QOS_LEAST_ONCE_FLAG_MASK) ? DELIVER_AT_LEAST_ONCE : DELIVER_EXACTLY_ONCE;
AzureIoTClient	3:9b4e7158ca0d	635
AzureIoTClient	8:83bb166aba73	636	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	637	{
AzureIoTClient	8:83bb166aba73	638	trace_log = STRING_construct_sprintf("PUBLISH \| IS_DUP: %s \| RETAIN: %d \| QOS: %s", isDuplicateMsg ? TRUE_CONST : FALSE_CONST,
AzureIoTClient	8:83bb166aba73	639	isRetainMsg ? 1 : 0, ENUM_TO_STRING(QOS_VALUE, qosValue) );
AzureIoTClient	8:83bb166aba73	640	}
AzureIoTClient	8:83bb166aba73	641
AzureIoTClient	3:9b4e7158ca0d	642	uint8_t* initialPos = iterator;
AzureIoTClient	8:83bb166aba73	643	size_t length = len - (iterator - initialPos);
AzureIoTClient	8:83bb166aba73	644	char* topicName = byteutil_readUTF(&iterator, &length);
AzureIoTClient	5:34779607059c	645	if (topicName == NULL)
AzureIoTClient	3:9b4e7158ca0d	646	{
AzureIoTClient	11:a0a6a4cf7812	647	LOG(AZ_LOG_ERROR, LOG_LINE, "Publish MSG: failure reading topic name");
AzureIoTClient	9:37d14c31ff6e	648	set_error_callback(mqtt_client, MQTT_CLIENT_PARSE_ERROR);
AzureIoTClient	8:83bb166aba73	649	if (trace_log != NULL)
AzureIoTClient	8:83bb166aba73	650	{
AzureIoTClient	8:83bb166aba73	651	STRING_delete(trace_log);
AzureIoTClient	5:34779607059c	652	}
AzureIoTClient	3:9b4e7158ca0d	653	}
AzureIoTClient	3:9b4e7158ca0d	654	else
AzureIoTClient	3:9b4e7158ca0d	655	{
AzureIoTClient	8:83bb166aba73	656	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	657	{
AzureIoTClient	8:83bb166aba73	658	STRING_sprintf(trace_log, " \| TOPIC_NAME: %s", topicName);
AzureIoTClient	8:83bb166aba73	659	}
AzureIoTClient	5:34779607059c	660	uint16_t packetId = 0;
AzureIoTClient	8:83bb166aba73	661	length = len - (iterator - initialPos);
AzureIoTClient	5:34779607059c	662	if (qosValue != DELIVER_AT_MOST_ONCE)
AzureIoTClient	5:34779607059c	663	{
AzureIoTClient	8:83bb166aba73	664	packetId = byteutil_read_uint16(&iterator, length);
AzureIoTClient	8:83bb166aba73	665	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	666	{
AzureIoTClient	8:83bb166aba73	667	STRING_sprintf(trace_log, " \| PACKET_ID: %"PRIu16, packetId);
AzureIoTClient	8:83bb166aba73	668	}
AzureIoTClient	5:34779607059c	669	}
AzureIoTClient	8:83bb166aba73	670	length = len - (iterator - initialPos);
AzureIoTClient	3:9b4e7158ca0d	671
AzureIoTClient	5:34779607059c	672	MQTT_MESSAGE_HANDLE msgHandle = mqttmessage_create(packetId, topicName, qosValue, iterator, length);
AzureIoTClient	5:34779607059c	673	if (msgHandle == NULL)
AzureIoTClient	3:9b4e7158ca0d	674	{
AzureIoTClient	11:a0a6a4cf7812	675	LOG(AZ_LOG_ERROR, LOG_LINE, "failure in mqttmessage_create");
AzureIoTClient	9:37d14c31ff6e	676	set_error_callback(mqtt_client, MQTT_CLIENT_MEMORY_ERROR);
AzureIoTClient	8:83bb166aba73	677	if (trace_log != NULL) {
AzureIoTClient	8:83bb166aba73	678	STRING_delete(trace_log);
AzureIoTClient	5:34779607059c	679	}
AzureIoTClient	3:9b4e7158ca0d	680	}
AzureIoTClient	5:34779607059c	681	else
AzureIoTClient	3:9b4e7158ca0d	682	{
AzureIoTClient	5:34779607059c	683	if (mqttmessage_setIsDuplicateMsg(msgHandle, isDuplicateMsg) != 0 \|\|
AzureIoTClient	5:34779607059c	684	mqttmessage_setIsRetained(msgHandle, isRetainMsg) != 0)
AzureIoTClient	5:34779607059c	685	{
AzureIoTClient	11:a0a6a4cf7812	686	LOG(AZ_LOG_ERROR, LOG_LINE, "failure setting mqtt message property");
AzureIoTClient	9:37d14c31ff6e	687	set_error_callback(mqtt_client, MQTT_CLIENT_MEMORY_ERROR);
AzureIoTClient	8:83bb166aba73	688	if (trace_log != NULL) {
AzureIoTClient	8:83bb166aba73	689	STRING_delete(trace_log);
AzureIoTClient	5:34779607059c	690	}
AzureIoTClient	5:34779607059c	691	}
AzureIoTClient	5:34779607059c	692	else
AzureIoTClient	5:34779607059c	693	{
AzureIoTClient	8:83bb166aba73	694	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	695	{
AzureIoTClient	8:83bb166aba73	696	STRING_sprintf(trace_log, " \| PAYLOAD_LEN: %zu", length);
AzureIoTClient	8:83bb166aba73	697	log_incoming_trace(mqtt_client, trace_log);
AzureIoTClient	8:83bb166aba73	698	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	699	}
AzureIoTClient	8:83bb166aba73	700
AzureIoTClient	8:83bb166aba73	701	mqtt_client->fnMessageRecv(msgHandle, mqtt_client->ctx);
AzureIoTClient	5:34779607059c	702
AzureIoTClient	5:34779607059c	703	BUFFER_HANDLE pubRel = NULL;
AzureIoTClient	5:34779607059c	704	if (qosValue == DELIVER_EXACTLY_ONCE)
AzureIoTClient	5:34779607059c	705	{
AzureIoTClient	5:34779607059c	706	pubRel = mqtt_codec_publishReceived(packetId);
AzureIoTClient	5:34779607059c	707	if (pubRel == NULL)
AzureIoTClient	5:34779607059c	708	{
AzureIoTClient	11:a0a6a4cf7812	709	LOG(AZ_LOG_ERROR, LOG_LINE, "Failed to allocate publish receive message.");
AzureIoTClient	9:37d14c31ff6e	710	set_error_callback(mqtt_client, MQTT_CLIENT_MEMORY_ERROR);
AzureIoTClient	5:34779607059c	711	}
AzureIoTClient	5:34779607059c	712	}
AzureIoTClient	5:34779607059c	713	else if (qosValue == DELIVER_AT_LEAST_ONCE)
AzureIoTClient	5:34779607059c	714	{
AzureIoTClient	5:34779607059c	715	pubRel = mqtt_codec_publishAck(packetId);
AzureIoTClient	5:34779607059c	716	if (pubRel == NULL)
AzureIoTClient	5:34779607059c	717	{
AzureIoTClient	11:a0a6a4cf7812	718	LOG(AZ_LOG_ERROR, LOG_LINE, "Failed to allocate publish ack message.");
AzureIoTClient	9:37d14c31ff6e	719	set_error_callback(mqtt_client, MQTT_CLIENT_MEMORY_ERROR);
AzureIoTClient	5:34779607059c	720	}
AzureIoTClient	5:34779607059c	721	}
AzureIoTClient	5:34779607059c	722	if (pubRel != NULL)
AzureIoTClient	5:34779607059c	723	{
AzureIoTClient	13:3c202001e4ba	724	size_t size = BUFFER_length(pubRel);
AzureIoTClient	13:3c202001e4ba	725	(void)sendPacketItem(mqtt_client, BUFFER_u_char(pubRel), size);
AzureIoTClient	5:34779607059c	726	BUFFER_delete(pubRel);
AzureIoTClient	5:34779607059c	727	}
AzureIoTClient	5:34779607059c	728	}
AzureIoTClient	5:34779607059c	729	mqttmessage_destroy(msgHandle);
AzureIoTClient	3:9b4e7158ca0d	730	}
AzureIoTClient	3:9b4e7158ca0d	731	free(topicName);
AzureIoTClient	3:9b4e7158ca0d	732	}
Azure.IoT Build	0:ef4901974abc	733	}
AzureIoTClient	3:9b4e7158ca0d	734	break;
AzureIoTClient	3:9b4e7158ca0d	735	}
AzureIoTClient	3:9b4e7158ca0d	736	case PUBACK_TYPE:
AzureIoTClient	3:9b4e7158ca0d	737	case PUBREC_TYPE:
AzureIoTClient	3:9b4e7158ca0d	738	case PUBREL_TYPE:
AzureIoTClient	3:9b4e7158ca0d	739	case PUBCOMP_TYPE:
AzureIoTClient	3:9b4e7158ca0d	740	{
AzureIoTClient	8:83bb166aba73	741	if (mqtt_client->fnOperationCallback)
Azure.IoT Build	0:ef4901974abc	742	{
AzureIoTClient	8:83bb166aba73	743	STRING_HANDLE trace_log = NULL;
AzureIoTClient	8:83bb166aba73	744
AzureIoTClient	3:9b4e7158ca0d	745	/Codes_SRS_MQTT_CLIENT_07_029: [If the actionResult parameter are of types PUBACK_TYPE, PUBREC_TYPE, PUBREL_TYPE or PUBCOMP_TYPE then the msgInfo value shall be a PUBLISH_ACK structure.]/
AzureIoTClient	3:9b4e7158ca0d	746	MQTT_CLIENT_EVENT_RESULT action = (packet == PUBACK_TYPE) ? MQTT_CLIENT_ON_PUBLISH_ACK :
AzureIoTClient	3:9b4e7158ca0d	747	(packet == PUBREC_TYPE) ? MQTT_CLIENT_ON_PUBLISH_RECV :
AzureIoTClient	3:9b4e7158ca0d	748	(packet == PUBREL_TYPE) ? MQTT_CLIENT_ON_PUBLISH_REL : MQTT_CLIENT_ON_PUBLISH_COMP;
AzureIoTClient	3:9b4e7158ca0d	749
AzureIoTClient	3:9b4e7158ca0d	750	PUBLISH_ACK publish_ack = { 0 };
AzureIoTClient	8:83bb166aba73	751	publish_ack.packetId = byteutil_read_uint16(&iterator, len);
AzureIoTClient	8:83bb166aba73	752
AzureIoTClient	8:83bb166aba73	753	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	754	{
AzureIoTClient	8:83bb166aba73	755	trace_log = STRING_construct_sprintf("%s \| PACKET_ID: %"PRIu16, packet == PUBACK_TYPE ? "PUBACK" : (packet == PUBREC_TYPE) ? "PUBREC" : (packet == PUBREL_TYPE) ? "PUBREL" : "PUBCOMP",
AzureIoTClient	8:83bb166aba73	756	publish_ack.packetId);
AzureIoTClient	8:83bb166aba73	757
AzureIoTClient	8:83bb166aba73	758	log_incoming_trace(mqtt_client, trace_log);
AzureIoTClient	8:83bb166aba73	759	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	760	}
Azure.IoT Build	0:ef4901974abc	761
Azure.IoT Build	0:ef4901974abc	762	BUFFER_HANDLE pubRel = NULL;
AzureIoTClient	8:83bb166aba73	763	mqtt_client->fnOperationCallback(mqtt_client, action, (void*)&publish_ack, mqtt_client->ctx);
AzureIoTClient	3:9b4e7158ca0d	764	if (packet == PUBREC_TYPE)
Azure.IoT Build	0:ef4901974abc	765	{
AzureIoTClient	3:9b4e7158ca0d	766	pubRel = mqtt_codec_publishRelease(publish_ack.packetId);
AzureIoTClient	5:34779607059c	767	if (pubRel == NULL)
AzureIoTClient	5:34779607059c	768	{
AzureIoTClient	11:a0a6a4cf7812	769	LOG(AZ_LOG_ERROR, LOG_LINE, "Failed to allocate publish release message.");
AzureIoTClient	9:37d14c31ff6e	770	set_error_callback(mqtt_client, MQTT_CLIENT_MEMORY_ERROR);
AzureIoTClient	5:34779607059c	771	}
Azure.IoT Build	0:ef4901974abc	772	}
AzureIoTClient	3:9b4e7158ca0d	773	else if (packet == PUBREL_TYPE)
Azure.IoT Build	0:ef4901974abc	774	{
AzureIoTClient	3:9b4e7158ca0d	775	pubRel = mqtt_codec_publishComplete(publish_ack.packetId);
AzureIoTClient	5:34779607059c	776	if (pubRel == NULL)
AzureIoTClient	5:34779607059c	777	{
AzureIoTClient	11:a0a6a4cf7812	778	LOG(AZ_LOG_ERROR, LOG_LINE, "Failed to allocate publish complete message.");
AzureIoTClient	9:37d14c31ff6e	779	set_error_callback(mqtt_client, MQTT_CLIENT_MEMORY_ERROR);
AzureIoTClient	5:34779607059c	780	}
Azure.IoT Build	0:ef4901974abc	781	}
Azure.IoT Build	0:ef4901974abc	782	if (pubRel != NULL)
Azure.IoT Build	0:ef4901974abc	783	{
AzureIoTClient	13:3c202001e4ba	784	size_t size = BUFFER_length(pubRel);
AzureIoTClient	13:3c202001e4ba	785	(void)sendPacketItem(mqtt_client, BUFFER_u_char(pubRel), size);
Azure.IoT Build	0:ef4901974abc	786	BUFFER_delete(pubRel);
Azure.IoT Build	0:ef4901974abc	787	}
Azure.IoT Build	0:ef4901974abc	788	}
AzureIoTClient	3:9b4e7158ca0d	789	break;
Azure.IoT Build	0:ef4901974abc	790	}
AzureIoTClient	3:9b4e7158ca0d	791	case SUBACK_TYPE:
Azure.IoT Build	0:ef4901974abc	792	{
AzureIoTClient	8:83bb166aba73	793	if (mqtt_client->fnOperationCallback)
AzureIoTClient	3:9b4e7158ca0d	794	{
AzureIoTClient	8:83bb166aba73	795	STRING_HANDLE trace_log = NULL;
AzureIoTClient	8:83bb166aba73	796
AzureIoTClient	3:9b4e7158ca0d	797	/Codes_SRS_MQTT_CLIENT_07_030: [If the actionResult parameter is of type SUBACK_TYPE then the msgInfo value shall be a SUBSCRIBE_ACK structure.]/
AzureIoTClient	3:9b4e7158ca0d	798	SUBSCRIBE_ACK suback = { 0 };
AzureIoTClient	3:9b4e7158ca0d	799
AzureIoTClient	3:9b4e7158ca0d	800	size_t remainLen = len;
AzureIoTClient	8:83bb166aba73	801	suback.packetId = byteutil_read_uint16(&iterator, len);
AzureIoTClient	3:9b4e7158ca0d	802	remainLen -= 2;
Azure.IoT Build	0:ef4901974abc	803
AzureIoTClient	8:83bb166aba73	804	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	805	{
AzureIoTClient	8:83bb166aba73	806	trace_log = STRING_construct_sprintf("SUBACK \| PACKET_ID: %"PRIu16, suback.packetId);
AzureIoTClient	8:83bb166aba73	807	}
AzureIoTClient	8:83bb166aba73	808
AzureIoTClient	3:9b4e7158ca0d	809	// Allocate the remaining len
AzureIoTClient	3:9b4e7158ca0d	810	suback.qosReturn = (QOS_VALUE)malloc(sizeof(QOS_VALUE)remainLen);
AzureIoTClient	3:9b4e7158ca0d	811	if (suback.qosReturn != NULL)
Azure.IoT Build	0:ef4901974abc	812	{
AzureIoTClient	3:9b4e7158ca0d	813	while (remainLen > 0)
AzureIoTClient	3:9b4e7158ca0d	814	{
AzureIoTClient	3:9b4e7158ca0d	815	suback.qosReturn[suback.qosCount++] = byteutil_readByte(&iterator);
AzureIoTClient	3:9b4e7158ca0d	816	remainLen--;
AzureIoTClient	8:83bb166aba73	817	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	818	{
AzureIoTClient	8:83bb166aba73	819	STRING_sprintf(trace_log, " \| RETURN_CODE: %"PRIu16, suback.qosReturn[suback.qosCount-1]);
AzureIoTClient	8:83bb166aba73	820	}
AzureIoTClient	3:9b4e7158ca0d	821	}
AzureIoTClient	8:83bb166aba73	822
AzureIoTClient	8:83bb166aba73	823	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	824	{
AzureIoTClient	8:83bb166aba73	825	log_incoming_trace(mqtt_client, trace_log);
AzureIoTClient	8:83bb166aba73	826	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	827	}
AzureIoTClient	8:83bb166aba73	828	mqtt_client->fnOperationCallback(mqtt_client, MQTT_CLIENT_ON_SUBSCRIBE_ACK, (void*)&suback, mqtt_client->ctx);
AzureIoTClient	3:9b4e7158ca0d	829	free(suback.qosReturn);
Azure.IoT Build	0:ef4901974abc	830	}
AzureIoTClient	5:34779607059c	831	else
AzureIoTClient	5:34779607059c	832	{
AzureIoTClient	11:a0a6a4cf7812	833	LOG(AZ_LOG_ERROR, LOG_LINE, "allocation of quality of service value failed.");
AzureIoTClient	9:37d14c31ff6e	834	set_error_callback(mqtt_client, MQTT_CLIENT_MEMORY_ERROR);
AzureIoTClient	5:34779607059c	835	}
Azure.IoT Build	0:ef4901974abc	836	}
AzureIoTClient	3:9b4e7158ca0d	837	break;
Azure.IoT Build	0:ef4901974abc	838	}
AzureIoTClient	3:9b4e7158ca0d	839	case UNSUBACK_TYPE:
Azure.IoT Build	0:ef4901974abc	840	{
AzureIoTClient	8:83bb166aba73	841	if (mqtt_client->fnOperationCallback)
AzureIoTClient	3:9b4e7158ca0d	842	{
AzureIoTClient	8:83bb166aba73	843	STRING_HANDLE trace_log = NULL;
AzureIoTClient	8:83bb166aba73	844
AzureIoTClient	3:9b4e7158ca0d	845	/Codes_SRS_MQTT_CLIENT_07_031: [If the actionResult parameter is of type UNSUBACK_TYPE then the msgInfo value shall be a UNSUBSCRIBE_ACK structure.]/
AzureIoTClient	3:9b4e7158ca0d	846	UNSUBSCRIBE_ACK unsuback = { 0 };
AzureIoTClient	8:83bb166aba73	847	unsuback.packetId = byteutil_read_uint16(&iterator, len);
Azure.IoT Build	0:ef4901974abc	848
AzureIoTClient	8:83bb166aba73	849	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	850	{
AzureIoTClient	8:83bb166aba73	851	trace_log = STRING_construct_sprintf("UNSUBACK \| PACKET_ID: %"PRIu16, unsuback.packetId);
AzureIoTClient	8:83bb166aba73	852	log_incoming_trace(mqtt_client, trace_log);
AzureIoTClient	8:83bb166aba73	853	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	854	}
AzureIoTClient	8:83bb166aba73	855	mqtt_client->fnOperationCallback(mqtt_client, MQTT_CLIENT_ON_UNSUBSCRIBE_ACK, (void*)&unsuback, mqtt_client->ctx);
AzureIoTClient	3:9b4e7158ca0d	856	}
AzureIoTClient	3:9b4e7158ca0d	857	break;
Azure.IoT Build	0:ef4901974abc	858	}
AzureIoTClient	3:9b4e7158ca0d	859	case PINGRESP_TYPE:
AzureIoTClient	8:83bb166aba73	860	mqtt_client->timeSincePing = 0;
AzureIoTClient	8:83bb166aba73	861	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	862	{
AzureIoTClient	8:83bb166aba73	863	STRING_HANDLE trace_log = STRING_construct_sprintf("PINGRESP");
AzureIoTClient	8:83bb166aba73	864	log_incoming_trace(mqtt_client, trace_log);
AzureIoTClient	8:83bb166aba73	865	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	866	}
AzureIoTClient	18:6d13ad04e8a0	867	// Forward ping response to operation callback
AzureIoTClient	18:6d13ad04e8a0	868	if (mqtt_client->fnOperationCallback)
AzureIoTClient	18:6d13ad04e8a0	869	{
AzureIoTClient	18:6d13ad04e8a0	870	mqtt_client->fnOperationCallback(mqtt_client, MQTT_CLIENT_ON_PING_RESPONSE, NULL, mqtt_client->ctx);
AzureIoTClient	18:6d13ad04e8a0	871	}
AzureIoTClient	3:9b4e7158ca0d	872	break;
AzureIoTClient	3:9b4e7158ca0d	873	default:
AzureIoTClient	3:9b4e7158ca0d	874	break;
Azure.IoT Build	0:ef4901974abc	875	}
Azure.IoT Build	0:ef4901974abc	876	}
Azure.IoT Build	0:ef4901974abc	877	}
Azure.IoT Build	0:ef4901974abc	878	}
Azure.IoT Build	0:ef4901974abc	879
AzureIoTClient	9:37d14c31ff6e	880	MQTT_CLIENT_HANDLE mqtt_client_init(ON_MQTT_MESSAGE_RECV_CALLBACK msgRecv, ON_MQTT_OPERATION_CALLBACK opCallback, void* opCallbackCtx, ON_MQTT_ERROR_CALLBACK onErrorCallBack, void* errorCBCtx)
Azure.IoT Build	0:ef4901974abc	881	{
Azure.IoT Build	0:ef4901974abc	882	MQTT_CLIENT* result;
Azure.IoT Build	0:ef4901974abc	883	/Codes_SRS_MQTT_CLIENT_07_001: [If the parameters ON_MQTT_MESSAGE_RECV_CALLBACK is NULL then mqttclient_init shall return NULL.]/
Azure.IoT Build	0:ef4901974abc	884	if (msgRecv == NULL)
Azure.IoT Build	0:ef4901974abc	885	{
Azure.IoT Build	0:ef4901974abc	886	result = NULL;
Azure.IoT Build	0:ef4901974abc	887	}
Azure.IoT Build	0:ef4901974abc	888	else
Azure.IoT Build	0:ef4901974abc	889	{
Azure.IoT Build	0:ef4901974abc	890	result = malloc(sizeof(MQTT_CLIENT));
Azure.IoT Build	0:ef4901974abc	891	if (result == NULL)
Azure.IoT Build	0:ef4901974abc	892	{
Azure.IoT Build	0:ef4901974abc	893	/Codes_SRS_MQTT_CLIENT_07_002: [If any failure is encountered then mqttclient_init shall return NULL.]/
AzureIoTClient	11:a0a6a4cf7812	894	LOG(AZ_LOG_ERROR, LOG_LINE, "mqtt_client_init failure: Allocation Failure");
Azure.IoT Build	0:ef4901974abc	895	}
Azure.IoT Build	0:ef4901974abc	896	else
Azure.IoT Build	0:ef4901974abc	897	{
AzureIoTClient	19:e283dcf26037	898	memset(result, 0, sizeof(MQTT_CLIENT));
Azure.IoT Build	0:ef4901974abc	899	/Codes_SRS_MQTT_CLIENT_07_003: [mqttclient_init shall allocate MQTTCLIENT_DATA_INSTANCE and return the MQTTCLIENT_HANDLE on success.]/
Azure.IoT Build	0:ef4901974abc	900	result->packetState = UNKNOWN_TYPE;
Azure.IoT Build	0:ef4901974abc	901	result->fnOperationCallback = opCallback;
AzureIoTClient	9:37d14c31ff6e	902	result->ctx = opCallbackCtx;
Azure.IoT Build	0:ef4901974abc	903	result->fnMessageRecv = msgRecv;
AzureIoTClient	9:37d14c31ff6e	904	result->fnOnErrorCallBack = onErrorCallBack;
AzureIoTClient	9:37d14c31ff6e	905	result->errorCBCtx = errorCBCtx;
Azure.IoT Build	0:ef4901974abc	906	result->qosValue = DELIVER_AT_MOST_ONCE;
Azure.IoT Build	0:ef4901974abc	907	result->packetTickCntr = tickcounter_create();
AzureIoTClient	3:9b4e7158ca0d	908	result->maxPingRespTime = DEFAULT_MAX_PING_RESPONSE_TIME;
Azure.IoT Build	0:ef4901974abc	909	if (result->packetTickCntr == NULL)
Azure.IoT Build	0:ef4901974abc	910	{
Azure.IoT Build	0:ef4901974abc	911	/Codes_SRS_MQTT_CLIENT_07_002: [If any failure is encountered then mqttclient_init shall return NULL.]/
AzureIoTClient	11:a0a6a4cf7812	912	LOG(AZ_LOG_ERROR, LOG_LINE, "mqtt_client_init failure: tickcounter_create failure");
Azure.IoT Build	0:ef4901974abc	913	free(result);
Azure.IoT Build	0:ef4901974abc	914	result = NULL;
Azure.IoT Build	0:ef4901974abc	915	}
Azure.IoT Build	0:ef4901974abc	916	else
Azure.IoT Build	0:ef4901974abc	917	{
Azure.IoT Build	0:ef4901974abc	918	result->codec_handle = mqtt_codec_create(recvCompleteCallback, result);
Azure.IoT Build	0:ef4901974abc	919	if (result->codec_handle == NULL)
Azure.IoT Build	0:ef4901974abc	920	{
Azure.IoT Build	0:ef4901974abc	921	/Codes_SRS_MQTT_CLIENT_07_002: [If any failure is encountered then mqttclient_init shall return NULL.]/
AzureIoTClient	11:a0a6a4cf7812	922	LOG(AZ_LOG_ERROR, LOG_LINE, "mqtt_client_init failure: mqtt_codec_create failure");
Azure.IoT Build	0:ef4901974abc	923	tickcounter_destroy(result->packetTickCntr);
Azure.IoT Build	0:ef4901974abc	924	free(result);
Azure.IoT Build	0:ef4901974abc	925	result = NULL;
Azure.IoT Build	0:ef4901974abc	926	}
Azure.IoT Build	0:ef4901974abc	927	}
Azure.IoT Build	0:ef4901974abc	928	}
Azure.IoT Build	0:ef4901974abc	929	}
Azure.IoT Build	0:ef4901974abc	930	return result;
Azure.IoT Build	0:ef4901974abc	931	}
Azure.IoT Build	0:ef4901974abc	932
Azure.IoT Build	0:ef4901974abc	933	void mqtt_client_deinit(MQTT_CLIENT_HANDLE handle)
Azure.IoT Build	0:ef4901974abc	934	{
Azure.IoT Build	0:ef4901974abc	935	/Codes_SRS_MQTT_CLIENT_07_004: [If the parameter handle is NULL then function mqtt_client_deinit shall do nothing.]/
Azure.IoT Build	0:ef4901974abc	936	if (handle != NULL)
Azure.IoT Build	0:ef4901974abc	937	{
Azure.IoT Build	0:ef4901974abc	938	/Codes_SRS_MQTT_CLIENT_07_005: [mqtt_client_deinit shall deallocate all memory allocated in this unit.]/
AzureIoTClient	8:83bb166aba73	939	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)handle;
AzureIoTClient	8:83bb166aba73	940	tickcounter_destroy(mqtt_client->packetTickCntr);
AzureIoTClient	8:83bb166aba73	941	mqtt_codec_destroy(mqtt_client->codec_handle);
AzureIoTClient	18:6d13ad04e8a0	942	clear_mqtt_options(mqtt_client);
AzureIoTClient	8:83bb166aba73	943	free(mqtt_client);
Azure.IoT Build	0:ef4901974abc	944	}
Azure.IoT Build	0:ef4901974abc	945	}
Azure.IoT Build	0:ef4901974abc	946
Azure.IoT Build	0:ef4901974abc	947	int mqtt_client_connect(MQTT_CLIENT_HANDLE handle, XIO_HANDLE xioHandle, MQTT_CLIENT_OPTIONS* mqttOptions)
Azure.IoT Build	0:ef4901974abc	948	{
Azure.IoT Build	0:ef4901974abc	949	int result;
Azure.IoT Build	0:ef4901974abc	950	/SRS_MQTT_CLIENT_07_006: [If any of the parameters handle, ioHandle, or mqttOptions are NULL then mqtt_client_connect shall return a non-zero value.]/
Azure.IoT Build	0:ef4901974abc	951	if (handle == NULL \|\| mqttOptions == NULL)
Azure.IoT Build	0:ef4901974abc	952	{
AzureIoTClient	11:a0a6a4cf7812	953	LOG(AZ_LOG_ERROR, LOG_LINE, "mqtt_client_connect: NULL argument (handle = %p, mqttOptions = %p)", handle, mqttOptions);
AzureIoTClient	15:ec5a36121959	954	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	955	}
Azure.IoT Build	0:ef4901974abc	956	else
Azure.IoT Build	0:ef4901974abc	957	{
AzureIoTClient	8:83bb166aba73	958	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)handle;
Azure.IoT Build	0:ef4901974abc	959	if (xioHandle == NULL)
Azure.IoT Build	0:ef4901974abc	960	{
Azure.IoT Build	0:ef4901974abc	961	/Codes_SRS_MQTT_CLIENT_07_007: [If any failure is encountered then mqtt_client_connect shall return a non-zero value.]/
AzureIoTClient	11:a0a6a4cf7812	962	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqttcodec_connect failed");
AzureIoTClient	15:ec5a36121959	963	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	964	}
Azure.IoT Build	0:ef4901974abc	965	else
Azure.IoT Build	0:ef4901974abc	966	{
AzureIoTClient	8:83bb166aba73	967	mqtt_client->xioHandle = xioHandle;
AzureIoTClient	8:83bb166aba73	968	mqtt_client->packetState = UNKNOWN_TYPE;
AzureIoTClient	8:83bb166aba73	969	mqtt_client->qosValue = mqttOptions->qualityOfServiceValue;
AzureIoTClient	8:83bb166aba73	970	mqtt_client->keepAliveInterval = mqttOptions->keepAliveInterval;
AzureIoTClient	8:83bb166aba73	971	mqtt_client->maxPingRespTime = (DEFAULT_MAX_PING_RESPONSE_TIME < mqttOptions->keepAliveInterval/2) ? DEFAULT_MAX_PING_RESPONSE_TIME : mqttOptions->keepAliveInterval/2;
AzureIoTClient	8:83bb166aba73	972	if (cloneMqttOptions(mqtt_client, mqttOptions) != 0)
Azure.IoT Build	0:ef4901974abc	973	{
AzureIoTClient	11:a0a6a4cf7812	974	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: Clone Mqtt Options failed");
AzureIoTClient	15:ec5a36121959	975	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	976	}
Azure.IoT Build	0:ef4901974abc	977	/Codes_SRS_MQTT_CLIENT_07_008: [mqtt_client_connect shall open the XIO_HANDLE by calling into the xio_open interface.]/
AzureIoTClient	8:83bb166aba73	978	else if (xio_open(xioHandle, onOpenComplete, mqtt_client, onBytesReceived, mqtt_client, onIoError, mqtt_client) != 0)
Azure.IoT Build	0:ef4901974abc	979	{
Azure.IoT Build	0:ef4901974abc	980	/Codes_SRS_MQTT_CLIENT_07_007: [If any failure is encountered then mqtt_client_connect shall return a non-zero value.]/
AzureIoTClient	11:a0a6a4cf7812	981	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: io_open failed");
AzureIoTClient	15:ec5a36121959	982	result = __FAILURE__;
AzureIoTClient	14:4b5b4dccfc8b	983	// Remove cloned options
AzureIoTClient	14:4b5b4dccfc8b	984	clear_mqtt_options(mqtt_client);
Azure.IoT Build	0:ef4901974abc	985	}
Azure.IoT Build	0:ef4901974abc	986	else
Azure.IoT Build	0:ef4901974abc	987	{
Azure.IoT Build	0:ef4901974abc	988	result = 0;
Azure.IoT Build	0:ef4901974abc	989	}
Azure.IoT Build	0:ef4901974abc	990	}
Azure.IoT Build	0:ef4901974abc	991	}
Azure.IoT Build	0:ef4901974abc	992	return result;
Azure.IoT Build	0:ef4901974abc	993	}
Azure.IoT Build	0:ef4901974abc	994
Azure.IoT Build	0:ef4901974abc	995	int mqtt_client_publish(MQTT_CLIENT_HANDLE handle, MQTT_MESSAGE_HANDLE msgHandle)
Azure.IoT Build	0:ef4901974abc	996	{
Azure.IoT Build	0:ef4901974abc	997	int result;
AzureIoTClient	8:83bb166aba73	998	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)handle;
AzureIoTClient	8:83bb166aba73	999	if (mqtt_client == NULL \|\| msgHandle == NULL)
Azure.IoT Build	0:ef4901974abc	1000	{
Azure.IoT Build	0:ef4901974abc	1001	/Codes_SRS_MQTT_CLIENT_07_019: [If one of the parameters handle or msgHandle is NULL then mqtt_client_publish shall return a non-zero value.]/
AzureIoTClient	17:73ae81ce481d	1002	LogError("Invalid parameter specified mqtt_client: %p, msgHandle: %p", mqtt_client, msgHandle);
AzureIoTClient	15:ec5a36121959	1003	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1004	}
Azure.IoT Build	0:ef4901974abc	1005	else
Azure.IoT Build	0:ef4901974abc	1006	{
Azure.IoT Build	0:ef4901974abc	1007	/Codes_SRS_MQTT_CLIENT_07_021: [mqtt_client_publish shall get the message information from the MQTT_MESSAGE_HANDLE.]/
Azure.IoT Build	0:ef4901974abc	1008	const APP_PAYLOAD* payload = mqttmessage_getApplicationMsg(msgHandle);
Azure.IoT Build	0:ef4901974abc	1009	if (payload == NULL)
Azure.IoT Build	0:ef4901974abc	1010	{
Azure.IoT Build	0:ef4901974abc	1011	/Codes_SRS_MQTT_CLIENT_07_020: [If any failure is encountered then mqtt_client_unsubscribe shall return a non-zero value.]/
AzureIoTClient	11:a0a6a4cf7812	1012	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqttmessage_getApplicationMsg failed");
AzureIoTClient	15:ec5a36121959	1013	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1014	}
Azure.IoT Build	0:ef4901974abc	1015	else
Azure.IoT Build	0:ef4901974abc	1016	{
AzureIoTClient	8:83bb166aba73	1017	STRING_HANDLE trace_log = construct_trace_log_handle(mqtt_client);
AzureIoTClient	8:83bb166aba73	1018
AzureIoTClient	13:3c202001e4ba	1019	QOS_VALUE qos = mqttmessage_getQosType(msgHandle);
AzureIoTClient	13:3c202001e4ba	1020	bool isDuplicate = mqttmessage_getIsDuplicateMsg(msgHandle);
AzureIoTClient	13:3c202001e4ba	1021	bool isRetained = mqttmessage_getIsRetained(msgHandle);
AzureIoTClient	13:3c202001e4ba	1022	uint16_t packetId = mqttmessage_getPacketId(msgHandle);
AzureIoTClient	13:3c202001e4ba	1023	const char* topicName = mqttmessage_getTopicName(msgHandle);
AzureIoTClient	13:3c202001e4ba	1024	BUFFER_HANDLE publishPacket = mqtt_codec_publish(qos, isDuplicate, isRetained, packetId, topicName, payload->message, payload->length, trace_log);
Azure.IoT Build	0:ef4901974abc	1025	if (publishPacket == NULL)
Azure.IoT Build	0:ef4901974abc	1026	{
Azure.IoT Build	0:ef4901974abc	1027	/Codes_SRS_MQTT_CLIENT_07_020: [If any failure is encountered then mqtt_client_unsubscribe shall return a non-zero value.]/
AzureIoTClient	11:a0a6a4cf7812	1028	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_codec_publish failed");
AzureIoTClient	15:ec5a36121959	1029	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1030	}
Azure.IoT Build	0:ef4901974abc	1031	else
Azure.IoT Build	0:ef4901974abc	1032	{
AzureIoTClient	8:83bb166aba73	1033	mqtt_client->packetState = PUBLISH_TYPE;
Azure.IoT Build	0:ef4901974abc	1034
Azure.IoT Build	0:ef4901974abc	1035	/Codes_SRS_MQTT_CLIENT_07_022: [On success mqtt_client_publish shall send the MQTT SUBCRIBE packet to the endpoint.]/
AzureIoTClient	13:3c202001e4ba	1036	size_t size = BUFFER_length(publishPacket);
AzureIoTClient	13:3c202001e4ba	1037	if (sendPacketItem(mqtt_client, BUFFER_u_char(publishPacket), size) != 0)
Azure.IoT Build	0:ef4901974abc	1038	{
Azure.IoT Build	0:ef4901974abc	1039	/Codes_SRS_MQTT_CLIENT_07_020: [If any failure is encountered then mqtt_client_unsubscribe shall return a non-zero value.]/
AzureIoTClient	11:a0a6a4cf7812	1040	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_client_publish send failed");
AzureIoTClient	15:ec5a36121959	1041	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1042	}
Azure.IoT Build	0:ef4901974abc	1043	else
Azure.IoT Build	0:ef4901974abc	1044	{
AzureIoTClient	8:83bb166aba73	1045	log_outgoing_trace(mqtt_client, trace_log);
Azure.IoT Build	0:ef4901974abc	1046	result = 0;
Azure.IoT Build	0:ef4901974abc	1047	}
Azure.IoT Build	0:ef4901974abc	1048	BUFFER_delete(publishPacket);
Azure.IoT Build	0:ef4901974abc	1049	}
AzureIoTClient	8:83bb166aba73	1050	if (trace_log != NULL)
AzureIoTClient	8:83bb166aba73	1051	{
AzureIoTClient	8:83bb166aba73	1052	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	1053	}
Azure.IoT Build	0:ef4901974abc	1054	}
Azure.IoT Build	0:ef4901974abc	1055	}
Azure.IoT Build	0:ef4901974abc	1056	return result;
Azure.IoT Build	0:ef4901974abc	1057	}
Azure.IoT Build	0:ef4901974abc	1058
Azure.IoT Build	0:ef4901974abc	1059	int mqtt_client_subscribe(MQTT_CLIENT_HANDLE handle, uint16_t packetId, SUBSCRIBE_PAYLOAD* subscribeList, size_t count)
Azure.IoT Build	0:ef4901974abc	1060	{
Azure.IoT Build	0:ef4901974abc	1061	int result;
AzureIoTClient	8:83bb166aba73	1062	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)handle;
AzureIoTClient	17:73ae81ce481d	1063	if (mqtt_client == NULL \|\| subscribeList == NULL \|\| count == 0 \|\| packetId == 0)
Azure.IoT Build	0:ef4901974abc	1064	{
Azure.IoT Build	0:ef4901974abc	1065	/Codes_SRS_MQTT_CLIENT_07_013: [If any of the parameters handle, subscribeList is NULL or count is 0 then mqtt_client_subscribe shall return a non-zero value.]/
AzureIoTClient	17:73ae81ce481d	1066	LogError("Invalid parameter specified mqtt_client: %p, subscribeList: %p, count: %d, packetId: %d", mqtt_client, subscribeList, count, packetId);
AzureIoTClient	15:ec5a36121959	1067	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1068	}
Azure.IoT Build	0:ef4901974abc	1069	else
Azure.IoT Build	0:ef4901974abc	1070	{
AzureIoTClient	8:83bb166aba73	1071	STRING_HANDLE trace_log = construct_trace_log_handle(mqtt_client);
AzureIoTClient	8:83bb166aba73	1072
AzureIoTClient	8:83bb166aba73	1073	BUFFER_HANDLE subPacket = mqtt_codec_subscribe(packetId, subscribeList, count, trace_log);
Azure.IoT Build	0:ef4901974abc	1074	if (subPacket == NULL)
Azure.IoT Build	0:ef4901974abc	1075	{
Azure.IoT Build	0:ef4901974abc	1076	/Codes_SRS_MQTT_CLIENT_07_014: [If any failure is encountered then mqtt_client_subscribe shall return a non-zero value.]/
AzureIoTClient	11:a0a6a4cf7812	1077	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_codec_subscribe failed");
AzureIoTClient	15:ec5a36121959	1078	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1079	}
Azure.IoT Build	0:ef4901974abc	1080	else
Azure.IoT Build	0:ef4901974abc	1081	{
AzureIoTClient	8:83bb166aba73	1082	mqtt_client->packetState = SUBSCRIBE_TYPE;
Azure.IoT Build	0:ef4901974abc	1083
AzureIoTClient	13:3c202001e4ba	1084	size_t size = BUFFER_length(subPacket);
Azure.IoT Build	0:ef4901974abc	1085	/Codes_SRS_MQTT_CLIENT_07_015: [On success mqtt_client_subscribe shall send the MQTT SUBCRIBE packet to the endpoint.]/
AzureIoTClient	13:3c202001e4ba	1086	if (sendPacketItem(mqtt_client, BUFFER_u_char(subPacket), size) != 0)
Azure.IoT Build	0:ef4901974abc	1087	{
Azure.IoT Build	0:ef4901974abc	1088	/Codes_SRS_MQTT_CLIENT_07_014: [If any failure is encountered then mqtt_client_subscribe shall return a non-zero value.]/
AzureIoTClient	11:a0a6a4cf7812	1089	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_client_subscribe send failed");
AzureIoTClient	15:ec5a36121959	1090	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1091	}
Azure.IoT Build	0:ef4901974abc	1092	else
Azure.IoT Build	0:ef4901974abc	1093	{
AzureIoTClient	8:83bb166aba73	1094	log_outgoing_trace(mqtt_client, trace_log);
Azure.IoT Build	0:ef4901974abc	1095	result = 0;
Azure.IoT Build	0:ef4901974abc	1096	}
Azure.IoT Build	0:ef4901974abc	1097	BUFFER_delete(subPacket);
Azure.IoT Build	0:ef4901974abc	1098	}
AzureIoTClient	8:83bb166aba73	1099	if (trace_log != NULL)
AzureIoTClient	8:83bb166aba73	1100	{
AzureIoTClient	8:83bb166aba73	1101	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	1102	}
Azure.IoT Build	0:ef4901974abc	1103	}
Azure.IoT Build	0:ef4901974abc	1104	return result;
Azure.IoT Build	0:ef4901974abc	1105	}
Azure.IoT Build	0:ef4901974abc	1106
Azure.IoT Build	0:ef4901974abc	1107	int mqtt_client_unsubscribe(MQTT_CLIENT_HANDLE handle, uint16_t packetId, const char** unsubscribeList, size_t count)
Azure.IoT Build	0:ef4901974abc	1108	{
Azure.IoT Build	0:ef4901974abc	1109	int result;
AzureIoTClient	8:83bb166aba73	1110	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)handle;
AzureIoTClient	17:73ae81ce481d	1111	if (mqtt_client == NULL \|\| unsubscribeList == NULL \|\| count == 0 \|\| packetId == 0)
Azure.IoT Build	0:ef4901974abc	1112	{
Azure.IoT Build	0:ef4901974abc	1113	/Codes_SRS_MQTT_CLIENT_07_016: [If any of the parameters handle, unsubscribeList is NULL or count is 0 then mqtt_client_unsubscribe shall return a non-zero value.]/
AzureIoTClient	17:73ae81ce481d	1114	LogError("Invalid parameter specified mqtt_client: %p, unsubscribeList: %p, count: %d, packetId: %d", mqtt_client, unsubscribeList, count, packetId);
AzureIoTClient	15:ec5a36121959	1115	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1116	}
Azure.IoT Build	0:ef4901974abc	1117	else
Azure.IoT Build	0:ef4901974abc	1118	{
AzureIoTClient	8:83bb166aba73	1119	STRING_HANDLE trace_log = construct_trace_log_handle(mqtt_client);
AzureIoTClient	8:83bb166aba73	1120
AzureIoTClient	8:83bb166aba73	1121	BUFFER_HANDLE unsubPacket = mqtt_codec_unsubscribe(packetId, unsubscribeList, count, trace_log);
Azure.IoT Build	0:ef4901974abc	1122	if (unsubPacket == NULL)
Azure.IoT Build	0:ef4901974abc	1123	{
Azure.IoT Build	0:ef4901974abc	1124	/Codes_SRS_MQTT_CLIENT_07_017: [If any failure is encountered then mqtt_client_unsubscribe shall return a non-zero value.]/
AzureIoTClient	11:a0a6a4cf7812	1125	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_codec_unsubscribe failed");
AzureIoTClient	15:ec5a36121959	1126	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1127	}
Azure.IoT Build	0:ef4901974abc	1128	else
Azure.IoT Build	0:ef4901974abc	1129	{
AzureIoTClient	8:83bb166aba73	1130	mqtt_client->packetState = UNSUBSCRIBE_TYPE;
Azure.IoT Build	0:ef4901974abc	1131
AzureIoTClient	13:3c202001e4ba	1132	size_t size = BUFFER_length(unsubPacket);
Azure.IoT Build	0:ef4901974abc	1133	/Codes_SRS_MQTT_CLIENT_07_018: [On success mqtt_client_unsubscribe shall send the MQTT SUBCRIBE packet to the endpoint.]/
AzureIoTClient	13:3c202001e4ba	1134	if (sendPacketItem(mqtt_client, BUFFER_u_char(unsubPacket), size) != 0)
Azure.IoT Build	0:ef4901974abc	1135	{
Azure.IoT Build	0:ef4901974abc	1136	/Codes_SRS_MQTT_CLIENT_07_017: [If any failure is encountered then mqtt_client_unsubscribe shall return a non-zero value.].]/
AzureIoTClient	11:a0a6a4cf7812	1137	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_client_unsubscribe send failed");
AzureIoTClient	15:ec5a36121959	1138	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1139	}
Azure.IoT Build	0:ef4901974abc	1140	else
Azure.IoT Build	0:ef4901974abc	1141	{
AzureIoTClient	8:83bb166aba73	1142	log_outgoing_trace(mqtt_client, trace_log);
Azure.IoT Build	0:ef4901974abc	1143	result = 0;
Azure.IoT Build	0:ef4901974abc	1144	}
Azure.IoT Build	0:ef4901974abc	1145	BUFFER_delete(unsubPacket);
Azure.IoT Build	0:ef4901974abc	1146	}
AzureIoTClient	8:83bb166aba73	1147	if (trace_log != NULL)
AzureIoTClient	8:83bb166aba73	1148	{
AzureIoTClient	8:83bb166aba73	1149	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	1150	}
Azure.IoT Build	0:ef4901974abc	1151	}
Azure.IoT Build	0:ef4901974abc	1152	return result;
Azure.IoT Build	0:ef4901974abc	1153	}
Azure.IoT Build	0:ef4901974abc	1154
AzureIoTClient	19:e283dcf26037	1155	int mqtt_client_disconnect(MQTT_CLIENT_HANDLE handle, ON_MQTT_DISCONNECTED_CALLBACK callback, void* ctx)
Azure.IoT Build	0:ef4901974abc	1156	{
Azure.IoT Build	0:ef4901974abc	1157	int result;
AzureIoTClient	8:83bb166aba73	1158	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)handle;
AzureIoTClient	8:83bb166aba73	1159	if (mqtt_client == NULL)
Azure.IoT Build	0:ef4901974abc	1160	{
Azure.IoT Build	0:ef4901974abc	1161	/Codes_SRS_MQTT_CLIENT_07_010: [If the parameters handle is NULL then mqtt_client_disconnect shall return a non-zero value.]/
AzureIoTClient	15:ec5a36121959	1162	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1163	}
Azure.IoT Build	0:ef4901974abc	1164	else
Azure.IoT Build	0:ef4901974abc	1165	{
AzureIoTClient	23:80794cfb3565	1166	if (mqtt_client->clientConnected)
Azure.IoT Build	0:ef4901974abc	1167	{
AzureIoTClient	23:80794cfb3565	1168	BUFFER_HANDLE disconnectPacket = mqtt_codec_disconnect();
AzureIoTClient	23:80794cfb3565	1169	if (disconnectPacket == NULL)
Azure.IoT Build	0:ef4901974abc	1170	{
Azure.IoT Build	0:ef4901974abc	1171	/Codes_SRS_MQTT_CLIENT_07_011: [If any failure is encountered then mqtt_client_disconnect shall return a non-zero value.]/
AzureIoTClient	23:80794cfb3565	1172	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_client_disconnect failed");
AzureIoTClient	23:80794cfb3565	1173	mqtt_client->packetState = PACKET_TYPE_ERROR;
AzureIoTClient	15:ec5a36121959	1174	result = __FAILURE__;
Azure.IoT Build	0:ef4901974abc	1175	}
Azure.IoT Build	0:ef4901974abc	1176	else
Azure.IoT Build	0:ef4901974abc	1177	{
AzureIoTClient	23:80794cfb3565	1178	/* Codes_SRS_MQTT_CLIENT_07_037: [ if callback is not NULL callback shall be called once the mqtt connection has been disconnected ] */
AzureIoTClient	23:80794cfb3565	1179	mqtt_client->disconnect_cb = callback;
AzureIoTClient	23:80794cfb3565	1180	mqtt_client->disconnect_ctx = ctx;
AzureIoTClient	23:80794cfb3565	1181	mqtt_client->packetState = DISCONNECT_TYPE;
AzureIoTClient	23:80794cfb3565	1182
AzureIoTClient	23:80794cfb3565	1183	size_t size = BUFFER_length(disconnectPacket);
AzureIoTClient	23:80794cfb3565	1184	/Codes_SRS_MQTT_CLIENT_07_012: [On success mqtt_client_disconnect shall send the MQTT DISCONNECT packet to the endpoint.]/
AzureIoTClient	23:80794cfb3565	1185	if (sendPacketItem(mqtt_client, BUFFER_u_char(disconnectPacket), size) != 0)
AzureIoTClient	8:83bb166aba73	1186	{
AzureIoTClient	23:80794cfb3565	1187	/Codes_SRS_MQTT_CLIENT_07_011: [If any failure is encountered then mqtt_client_disconnect shall return a non-zero value.]/
AzureIoTClient	23:80794cfb3565	1188	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: mqtt_client_disconnect send failed");
AzureIoTClient	23:80794cfb3565	1189	result = __FAILURE__;
AzureIoTClient	8:83bb166aba73	1190	}
AzureIoTClient	23:80794cfb3565	1191	else
AzureIoTClient	23:80794cfb3565	1192	{
AzureIoTClient	23:80794cfb3565	1193	if (mqtt_client->logTrace)
AzureIoTClient	23:80794cfb3565	1194	{
AzureIoTClient	23:80794cfb3565	1195	STRING_HANDLE trace_log = STRING_construct("DISCONNECT");
AzureIoTClient	23:80794cfb3565	1196	log_outgoing_trace(mqtt_client, trace_log);
AzureIoTClient	23:80794cfb3565	1197	STRING_delete(trace_log);
AzureIoTClient	23:80794cfb3565	1198	}
AzureIoTClient	23:80794cfb3565	1199	result = 0;
AzureIoTClient	23:80794cfb3565	1200	}
AzureIoTClient	23:80794cfb3565	1201	BUFFER_delete(disconnectPacket);
Azure.IoT Build	0:ef4901974abc	1202	}
AzureIoTClient	14:4b5b4dccfc8b	1203	clear_mqtt_options(mqtt_client);
AzureIoTClient	16:4e4835036f27	1204	mqtt_client->xioHandle = NULL;
Azure.IoT Build	0:ef4901974abc	1205	}
AzureIoTClient	23:80794cfb3565	1206	else
AzureIoTClient	23:80794cfb3565	1207	{
AzureIoTClient	23:80794cfb3565	1208	// If the client is not connected then just close the underlying socket
AzureIoTClient	23:80794cfb3565	1209	mqtt_client->disconnect_cb = callback;
AzureIoTClient	23:80794cfb3565	1210	mqtt_client->disconnect_ctx = ctx;
AzureIoTClient	23:80794cfb3565	1211
AzureIoTClient	23:80794cfb3565	1212	close_connection(mqtt_client);
AzureIoTClient	23:80794cfb3565	1213	clear_mqtt_options(mqtt_client);
AzureIoTClient	23:80794cfb3565	1214	result = 0;
AzureIoTClient	23:80794cfb3565	1215	}
Azure.IoT Build	0:ef4901974abc	1216	}
Azure.IoT Build	0:ef4901974abc	1217	return result;
Azure.IoT Build	0:ef4901974abc	1218	}
Azure.IoT Build	0:ef4901974abc	1219
Azure.IoT Build	0:ef4901974abc	1220	void mqtt_client_dowork(MQTT_CLIENT_HANDLE handle)
Azure.IoT Build	0:ef4901974abc	1221	{
AzureIoTClient	8:83bb166aba73	1222	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)handle;
AzureIoTClient	16:4e4835036f27	1223	/Codes_SRS_MQTT_CLIENT_18_001: [If the client is disconnected, mqtt_client_dowork shall do nothing.]/
Azure.IoT Build	0:ef4901974abc	1224	/Codes_SRS_MQTT_CLIENT_07_023: [If the parameter handle is NULL then mqtt_client_dowork shall do nothing.]/
AzureIoTClient	16:4e4835036f27	1225	if (mqtt_client != NULL && mqtt_client->xioHandle != NULL)
Azure.IoT Build	0:ef4901974abc	1226	{
Azure.IoT Build	0:ef4901974abc	1227	/Codes_SRS_MQTT_CLIENT_07_024: [mqtt_client_dowork shall call the xio_dowork function to complete operations.]/
AzureIoTClient	8:83bb166aba73	1228	xio_dowork(mqtt_client->xioHandle);
Azure.IoT Build	0:ef4901974abc	1229
Azure.IoT Build	0:ef4901974abc	1230	/Codes_SRS_MQTT_CLIENT_07_025: [mqtt_client_dowork shall retrieve the the last packet send value and ...]/
AzureIoTClient	8:83bb166aba73	1231	if (mqtt_client->socketConnected && mqtt_client->clientConnected && mqtt_client->keepAliveInterval > 0)
Azure.IoT Build	0:ef4901974abc	1232	{
Azure.IoT.Build	10:2ab268507775	1233	tickcounter_ms_t current_ms;
AzureIoTClient	8:83bb166aba73	1234	if (tickcounter_get_current_ms(mqtt_client->packetTickCntr, &current_ms) != 0)
Azure.IoT Build	0:ef4901974abc	1235	{
AzureIoTClient	11:a0a6a4cf7812	1236	LOG(AZ_LOG_ERROR, LOG_LINE, "Error: tickcounter_get_current_ms failed");
Azure.IoT Build	0:ef4901974abc	1237	}
Azure.IoT Build	0:ef4901974abc	1238	else
Azure.IoT Build	0:ef4901974abc	1239	{
AzureIoTClient	9:37d14c31ff6e	1240	/* Codes_SRS_MQTT_CLIENT_07_035: [If the timeSincePing has expired past the maxPingRespTime then mqtt_client_dowork shall call the Error Callback function with the message MQTT_CLIENT_NO_PING_RESPONSE] */
AzureIoTClient	8:83bb166aba73	1241	if (mqtt_client->timeSincePing > 0 && ((current_ms - mqtt_client->timeSincePing)/1000) > mqtt_client->maxPingRespTime)
AzureIoTClient	3:9b4e7158ca0d	1242	{
AzureIoTClient	3:9b4e7158ca0d	1243	// We haven't gotten a ping response in the alloted time
AzureIoTClient	9:37d14c31ff6e	1244	set_error_callback(mqtt_client, MQTT_CLIENT_NO_PING_RESPONSE);
AzureIoTClient	8:83bb166aba73	1245	mqtt_client->timeSincePing = 0;
AzureIoTClient	8:83bb166aba73	1246	mqtt_client->packetSendTimeMs = 0;
AzureIoTClient	8:83bb166aba73	1247	mqtt_client->packetState = UNKNOWN_TYPE;
AzureIoTClient	3:9b4e7158ca0d	1248	}
AzureIoTClient	23:80794cfb3565	1249	else if (((current_ms - mqtt_client->packetSendTimeMs) / 1000) >= mqtt_client->keepAliveInterval)
Azure.IoT Build	0:ef4901974abc	1250	{
Azure.IoT Build	0:ef4901974abc	1251	/Codes_SRS_MQTT_CLIENT_07_026: [if keepAliveInternal is > 0 and the send time is greater than the MQTT KeepAliveInterval then it shall construct an MQTT PINGREQ packet.]/
Azure.IoT Build	0:ef4901974abc	1252	BUFFER_HANDLE pingPacket = mqtt_codec_ping();
Azure.IoT Build	0:ef4901974abc	1253	if (pingPacket != NULL)
Azure.IoT Build	0:ef4901974abc	1254	{
AzureIoTClient	13:3c202001e4ba	1255	size_t size = BUFFER_length(pingPacket);
AzureIoTClient	13:3c202001e4ba	1256	(void)sendPacketItem(mqtt_client, BUFFER_u_char(pingPacket), size);
Azure.IoT Build	0:ef4901974abc	1257	BUFFER_delete(pingPacket);
AzureIoTClient	8:83bb166aba73	1258	(void)tickcounter_get_current_ms(mqtt_client->packetTickCntr, &mqtt_client->timeSincePing);
AzureIoTClient	8:83bb166aba73	1259
AzureIoTClient	8:83bb166aba73	1260	if (mqtt_client->logTrace)
AzureIoTClient	8:83bb166aba73	1261	{
AzureIoTClient	8:83bb166aba73	1262	STRING_HANDLE trace_log = STRING_construct("PINGREQ");
AzureIoTClient	8:83bb166aba73	1263	log_outgoing_trace(mqtt_client, trace_log);
AzureIoTClient	8:83bb166aba73	1264	STRING_delete(trace_log);
AzureIoTClient	8:83bb166aba73	1265	}
Azure.IoT Build	0:ef4901974abc	1266	}
Azure.IoT Build	0:ef4901974abc	1267	}
Azure.IoT Build	0:ef4901974abc	1268	}
Azure.IoT Build	0:ef4901974abc	1269	}
Azure.IoT Build	0:ef4901974abc	1270	}
Azure.IoT Build	0:ef4901974abc	1271	}
Azure.IoT Build	0:ef4901974abc	1272
Azure.IoT Build	0:ef4901974abc	1273	void mqtt_client_set_trace(MQTT_CLIENT_HANDLE handle, bool traceOn, bool rawBytesOn)
Azure.IoT Build	0:ef4901974abc	1274	{
AzureIoTClient	8:83bb166aba73	1275	MQTT_CLIENT* mqtt_client = (MQTT_CLIENT*)handle;
AzureIoTClient	8:83bb166aba73	1276	if (mqtt_client != NULL)
Azure.IoT Build	0:ef4901974abc	1277	{
AzureIoTClient	8:83bb166aba73	1278	mqtt_client->logTrace = traceOn;
AzureIoTClient	8:83bb166aba73	1279	mqtt_client->rawBytesTrace = rawBytesOn;
Azure.IoT Build	0:ef4901974abc	1280	}
Azure.IoT Build	0:ef4901974abc	1281	}

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	08 Apr 2016
Imports:	92
Forks:	0
Commits:	31
Dependents:	6
Dependencies:	0
Followers:	8

Developers

Azure IoT

Dan Cristoloveanu

The code in this repository is MIT licensed.

mqtt_client.c@27:a2eb9cb1e731, 2018-05-04 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Developers

Important Information for this Arm website

Access Warning