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@18:6d13ad04e8a0, 2017-08-11 (annotated)

Committer:: AzureIoTClient
Date:: Fri Aug 11 14:02:56 2017 -0700
Revision:: 18:6d13ad04e8a0
Parent:: 17:73ae81ce481d
Child:: 19:e283dcf26037

1.1.21

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

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@18:6d13ad04e8a0, 2017-08-11 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Developers

Important Information for this Arm website

Access Warning