iothub_client - Microsoft Azure IoTHub client libraries

Users » AzureIoTClient » Code » iothub_client

Microsoft Azure IoTHub client libraries

Dependents: sht15_remote_monitoring RobotArmDemo iothub_client_sample_amqp f767zi_mqtt ... more

This library implements the Microsoft Azure IoTHub client library. The code is replicated from https://github.com/Azure/azure-iot-sdks

iothub_client_core.c@89:a2ed767a532e, 2018-06-26 (annotated)

Committer:: AzureIoTClient
Date:: Tue Jun 26 19:14:28 2018 -0700
Revision:: 89:a2ed767a532e
Parent:: 88:248736be106e
Child:: 91:bbf806070c5f

1.2.6

Who changed what in which revision?

User	Revision	Line number	New contents of line
AzureIoTClient	88:248736be106e	1	// Copyright (c) Microsoft. All rights reserved.
AzureIoTClient	88:248736be106e	2	// Licensed under the MIT license. See LICENSE file in the project root for full license information.
AzureIoTClient	88:248736be106e	3
AzureIoTClient	88:248736be106e	4	#include <stdlib.h>
AzureIoTClient	88:248736be106e	5	#include "azure_c_shared_utility/umock_c_prod.h"
AzureIoTClient	88:248736be106e	6	#include "azure_c_shared_utility/gballoc.h"
AzureIoTClient	88:248736be106e	7
AzureIoTClient	88:248736be106e	8	#include <signal.h>
AzureIoTClient	88:248736be106e	9	#include <stddef.h>
AzureIoTClient	88:248736be106e	10	#include "azure_c_shared_utility/optimize_size.h"
AzureIoTClient	88:248736be106e	11	#include "azure_c_shared_utility/crt_abstractions.h"
AzureIoTClient	88:248736be106e	12	#include "iothub_client_core.h"
AzureIoTClient	88:248736be106e	13	#include "iothub_client_core_ll.h"
AzureIoTClient	88:248736be106e	14	#include "internal/iothubtransport.h"
AzureIoTClient	88:248736be106e	15	#include "internal/iothub_client_private.h"
AzureIoTClient	88:248736be106e	16	#include "internal/iothubtransport.h"
AzureIoTClient	88:248736be106e	17	#include "azure_c_shared_utility/threadapi.h"
AzureIoTClient	88:248736be106e	18	#include "azure_c_shared_utility/lock.h"
AzureIoTClient	88:248736be106e	19	#include "azure_c_shared_utility/xlogging.h"
AzureIoTClient	88:248736be106e	20	#include "azure_c_shared_utility/singlylinkedlist.h"
AzureIoTClient	88:248736be106e	21	#include "azure_c_shared_utility/vector.h"
AzureIoTClient	88:248736be106e	22
AzureIoTClient	89:a2ed767a532e	23	#ifdef USE_EDGE_MODULES
AzureIoTClient	89:a2ed767a532e	24	#include "iothub_client_ll_edge.h"
AzureIoTClient	89:a2ed767a532e	25	#endif
AzureIoTClient	89:a2ed767a532e	26
AzureIoTClient	88:248736be106e	27	struct IOTHUB_QUEUE_CONTEXT_TAG;
AzureIoTClient	88:248736be106e	28
AzureIoTClient	88:248736be106e	29	typedef struct IOTHUB_CLIENT_CORE_INSTANCE_TAG
AzureIoTClient	88:248736be106e	30	{
AzureIoTClient	88:248736be106e	31	IOTHUB_CLIENT_CORE_LL_HANDLE IoTHubClientLLHandle;
AzureIoTClient	88:248736be106e	32	TRANSPORT_HANDLE TransportHandle;
AzureIoTClient	88:248736be106e	33	THREAD_HANDLE ThreadHandle;
AzureIoTClient	88:248736be106e	34	LOCK_HANDLE LockHandle;
AzureIoTClient	88:248736be106e	35	sig_atomic_t StopThread;
AzureIoTClient	88:248736be106e	36	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	37	SINGLYLINKEDLIST_HANDLE savedDataToBeCleaned; /list containing UPLOADTOBLOB_SAVED_DATA/
AzureIoTClient	88:248736be106e	38	#endif
AzureIoTClient	88:248736be106e	39	int created_with_transport_handle;
AzureIoTClient	88:248736be106e	40	VECTOR_HANDLE saved_user_callback_list;
AzureIoTClient	88:248736be106e	41	IOTHUB_CLIENT_DEVICE_TWIN_CALLBACK desired_state_callback;
AzureIoTClient	88:248736be106e	42	IOTHUB_CLIENT_EVENT_CONFIRMATION_CALLBACK event_confirm_callback;
AzureIoTClient	88:248736be106e	43	IOTHUB_CLIENT_REPORTED_STATE_CALLBACK reported_state_callback;
AzureIoTClient	88:248736be106e	44	IOTHUB_CLIENT_CONNECTION_STATUS_CALLBACK connection_status_callback;
AzureIoTClient	88:248736be106e	45	IOTHUB_CLIENT_DEVICE_METHOD_CALLBACK_ASYNC device_method_callback;
AzureIoTClient	88:248736be106e	46	IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK inbound_device_method_callback;
AzureIoTClient	88:248736be106e	47	IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC message_callback;
AzureIoTClient	88:248736be106e	48	struct IOTHUB_QUEUE_CONTEXT_TAG* devicetwin_user_context;
AzureIoTClient	88:248736be106e	49	struct IOTHUB_QUEUE_CONTEXT_TAG* connection_status_user_context;
AzureIoTClient	88:248736be106e	50	struct IOTHUB_QUEUE_CONTEXT_TAG* message_user_context;
AzureIoTClient	88:248736be106e	51	struct IOTHUB_QUEUE_CONTEXT_TAG* method_user_context;
AzureIoTClient	88:248736be106e	52	} IOTHUB_CLIENT_CORE_INSTANCE;
AzureIoTClient	88:248736be106e	53
AzureIoTClient	88:248736be106e	54	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	55	typedef struct UPLOADTOBLOB_SAVED_DATA_TAG
AzureIoTClient	88:248736be106e	56	{
AzureIoTClient	88:248736be106e	57	unsigned char* source;
AzureIoTClient	88:248736be106e	58	size_t size;
AzureIoTClient	88:248736be106e	59	IOTHUB_CLIENT_FILE_UPLOAD_CALLBACK iotHubClientFileUploadCallback;
AzureIoTClient	88:248736be106e	60	}UPLOADTOBLOB_SAVED_DATA;
AzureIoTClient	88:248736be106e	61
AzureIoTClient	88:248736be106e	62	typedef struct UPLOADTOBLOB_MULTIBLOCK_SAVED_DATA_TAG
AzureIoTClient	88:248736be106e	63	{
AzureIoTClient	88:248736be106e	64	IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_CALLBACK getDataCallback;
AzureIoTClient	88:248736be106e	65	IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_CALLBACK_EX getDataCallbackEx;
AzureIoTClient	88:248736be106e	66	}UPLOADTOBLOB_MULTIBLOCK_SAVED_DATA;
AzureIoTClient	88:248736be106e	67
AzureIoTClient	88:248736be106e	68	typedef struct UPLOADTOBLOB_THREAD_INFO_TAG
AzureIoTClient	88:248736be106e	69	{
AzureIoTClient	88:248736be106e	70	char* destinationFileName;
AzureIoTClient	88:248736be106e	71	THREAD_HANDLE uploadingThreadHandle;
AzureIoTClient	88:248736be106e	72	LOCK_HANDLE lockGarbage;
AzureIoTClient	88:248736be106e	73	int canBeGarbageCollected; /flag indicating that the UPLOADTOBLOB_SAVED_DATA structure can be freed because the thread deadling with it finished/
AzureIoTClient	88:248736be106e	74	IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle;
AzureIoTClient	88:248736be106e	75	void* context;
AzureIoTClient	88:248736be106e	76	UPLOADTOBLOB_SAVED_DATA uploadBlobSavedData;
AzureIoTClient	88:248736be106e	77	UPLOADTOBLOB_MULTIBLOCK_SAVED_DATA uploadBlobMultiblockSavedData;
AzureIoTClient	88:248736be106e	78	}UPLOADTOBLOB_THREAD_INFO;
AzureIoTClient	88:248736be106e	79
AzureIoTClient	88:248736be106e	80	#endif
AzureIoTClient	88:248736be106e	81
AzureIoTClient	88:248736be106e	82	#define USER_CALLBACK_TYPE_VALUES \
AzureIoTClient	88:248736be106e	83	CALLBACK_TYPE_DEVICE_TWIN, \
AzureIoTClient	88:248736be106e	84	CALLBACK_TYPE_EVENT_CONFIRM, \
AzureIoTClient	88:248736be106e	85	CALLBACK_TYPE_REPORTED_STATE, \
AzureIoTClient	88:248736be106e	86	CALLBACK_TYPE_CONNECTION_STATUS, \
AzureIoTClient	88:248736be106e	87	CALLBACK_TYPE_DEVICE_METHOD, \
AzureIoTClient	88:248736be106e	88	CALLBACK_TYPE_INBOUD_DEVICE_METHOD, \
AzureIoTClient	89:a2ed767a532e	89	CALLBACK_TYPE_MESSAGE, \
AzureIoTClient	89:a2ed767a532e	90	CALLBACK_TYPE_INPUTMESSAGE
AzureIoTClient	88:248736be106e	91
AzureIoTClient	88:248736be106e	92	DEFINE_ENUM(USER_CALLBACK_TYPE, USER_CALLBACK_TYPE_VALUES)
AzureIoTClient	88:248736be106e	93	DEFINE_ENUM_STRINGS(USER_CALLBACK_TYPE, USER_CALLBACK_TYPE_VALUES)
AzureIoTClient	88:248736be106e	94
AzureIoTClient	88:248736be106e	95	typedef struct DEVICE_TWIN_CALLBACK_INFO_TAG
AzureIoTClient	88:248736be106e	96	{
AzureIoTClient	88:248736be106e	97	DEVICE_TWIN_UPDATE_STATE update_state;
AzureIoTClient	88:248736be106e	98	unsigned char* payLoad;
AzureIoTClient	88:248736be106e	99	size_t size;
AzureIoTClient	88:248736be106e	100	} DEVICE_TWIN_CALLBACK_INFO;
AzureIoTClient	88:248736be106e	101
AzureIoTClient	88:248736be106e	102	typedef struct EVENT_CONFIRM_CALLBACK_INFO_TAG
AzureIoTClient	88:248736be106e	103	{
AzureIoTClient	88:248736be106e	104	IOTHUB_CLIENT_CONFIRMATION_RESULT confirm_result;
AzureIoTClient	88:248736be106e	105	} EVENT_CONFIRM_CALLBACK_INFO;
AzureIoTClient	88:248736be106e	106
AzureIoTClient	88:248736be106e	107	typedef struct REPORTED_STATE_CALLBACK_INFO_TAG
AzureIoTClient	88:248736be106e	108	{
AzureIoTClient	88:248736be106e	109	int status_code;
AzureIoTClient	88:248736be106e	110	} REPORTED_STATE_CALLBACK_INFO;
AzureIoTClient	88:248736be106e	111
AzureIoTClient	88:248736be106e	112	typedef struct CONNECTION_STATUS_CALLBACK_INFO_TAG
AzureIoTClient	88:248736be106e	113	{
AzureIoTClient	88:248736be106e	114	IOTHUB_CLIENT_CONNECTION_STATUS connection_status;
AzureIoTClient	88:248736be106e	115	IOTHUB_CLIENT_CONNECTION_STATUS_REASON status_reason;
AzureIoTClient	88:248736be106e	116	} CONNECTION_STATUS_CALLBACK_INFO;
AzureIoTClient	88:248736be106e	117
AzureIoTClient	88:248736be106e	118	typedef struct METHOD_CALLBACK_INFO_TAG
AzureIoTClient	88:248736be106e	119	{
AzureIoTClient	88:248736be106e	120	STRING_HANDLE method_name;
AzureIoTClient	88:248736be106e	121	BUFFER_HANDLE payload;
AzureIoTClient	88:248736be106e	122	METHOD_HANDLE method_id;
AzureIoTClient	88:248736be106e	123	} METHOD_CALLBACK_INFO;
AzureIoTClient	88:248736be106e	124
AzureIoTClient	89:a2ed767a532e	125	typedef struct INPUTMESSAGE_CALLBACK_INFO_TAG
AzureIoTClient	89:a2ed767a532e	126	{
AzureIoTClient	89:a2ed767a532e	127	IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC eventHandlerCallback;
AzureIoTClient	89:a2ed767a532e	128	MESSAGE_CALLBACK_INFO* message_cb_info;
AzureIoTClient	89:a2ed767a532e	129	} INPUTMESSAGE_CALLBACK_INFO;
AzureIoTClient	89:a2ed767a532e	130
AzureIoTClient	88:248736be106e	131	typedef struct USER_CALLBACK_INFO_TAG
AzureIoTClient	88:248736be106e	132	{
AzureIoTClient	88:248736be106e	133	USER_CALLBACK_TYPE type;
AzureIoTClient	88:248736be106e	134	void* userContextCallback;
AzureIoTClient	88:248736be106e	135	union IOTHUB_CALLBACK
AzureIoTClient	88:248736be106e	136	{
AzureIoTClient	88:248736be106e	137	DEVICE_TWIN_CALLBACK_INFO dev_twin_cb_info;
AzureIoTClient	88:248736be106e	138	EVENT_CONFIRM_CALLBACK_INFO event_confirm_cb_info;
AzureIoTClient	88:248736be106e	139	REPORTED_STATE_CALLBACK_INFO reported_state_cb_info;
AzureIoTClient	88:248736be106e	140	CONNECTION_STATUS_CALLBACK_INFO connection_status_cb_info;
AzureIoTClient	88:248736be106e	141	METHOD_CALLBACK_INFO method_cb_info;
AzureIoTClient	88:248736be106e	142	MESSAGE_CALLBACK_INFO* message_cb_info;
AzureIoTClient	89:a2ed767a532e	143	INPUTMESSAGE_CALLBACK_INFO inputmessage_cb_info;
AzureIoTClient	88:248736be106e	144	} iothub_callback;
AzureIoTClient	88:248736be106e	145	} USER_CALLBACK_INFO;
AzureIoTClient	88:248736be106e	146
AzureIoTClient	88:248736be106e	147	typedef struct IOTHUB_QUEUE_CONTEXT_TAG
AzureIoTClient	88:248736be106e	148	{
AzureIoTClient	88:248736be106e	149	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientHandle;
AzureIoTClient	88:248736be106e	150	void* userContextCallback;
AzureIoTClient	88:248736be106e	151	} IOTHUB_QUEUE_CONTEXT;
AzureIoTClient	88:248736be106e	152
AzureIoTClient	89:a2ed767a532e	153	typedef struct IOTHUB_INPUTMESSAGE_CALLBACK_CONTEXT_TAG
AzureIoTClient	89:a2ed767a532e	154	{
AzureIoTClient	89:a2ed767a532e	155	IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle;
AzureIoTClient	89:a2ed767a532e	156	IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC eventHandlerCallback;
AzureIoTClient	89:a2ed767a532e	157	void* userContextCallback;
AzureIoTClient	89:a2ed767a532e	158	} IOTHUB_INPUTMESSAGE_CALLBACK_CONTEXT;
AzureIoTClient	89:a2ed767a532e	159
AzureIoTClient	88:248736be106e	160	/used by unittests only/
AzureIoTClient	88:248736be106e	161	const size_t IoTHubClientCore_ThreadTerminationOffset = offsetof(IOTHUB_CLIENT_CORE_INSTANCE, StopThread);
AzureIoTClient	88:248736be106e	162
AzureIoTClient	89:a2ed767a532e	163	typedef enum CREATE_HUB_INSTANCE_TYPE_TAG
AzureIoTClient	89:a2ed767a532e	164	{
AzureIoTClient	89:a2ed767a532e	165	CREATE_HUB_INSTANCE_FROM_CONNECTION_STRING,
AzureIoTClient	89:a2ed767a532e	166	CREATE_HUB_INSTANCE_FROM_EDGE_ENVIRONMENT,
AzureIoTClient	89:a2ed767a532e	167	CREATE_HUB_INSTANCE_FROM_TRANSPORT,
AzureIoTClient	89:a2ed767a532e	168	CREATE_HUB_INSTANCE_FROM_CLIENT_CONFIG,
AzureIoTClient	89:a2ed767a532e	169	CREATE_HUB_INSTANCE_FROM_DEVICE_AUTH
AzureIoTClient	89:a2ed767a532e	170	} CREATE_HUB_INSTANCE_TYPE;
AzureIoTClient	89:a2ed767a532e	171
AzureIoTClient	88:248736be106e	172	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	173	static void freeUploadToBlobThreadInfo(UPLOADTOBLOB_THREAD_INFO* threadInfo)
AzureIoTClient	88:248736be106e	174	{
AzureIoTClient	88:248736be106e	175	Lock_Deinit(threadInfo->lockGarbage);
AzureIoTClient	88:248736be106e	176	free(threadInfo->uploadBlobSavedData.source);
AzureIoTClient	88:248736be106e	177	free(threadInfo->destinationFileName);
AzureIoTClient	88:248736be106e	178	free(threadInfo);
AzureIoTClient	88:248736be106e	179	}
AzureIoTClient	88:248736be106e	180
AzureIoTClient	88:248736be106e	181	/this function is called from _Destroy and from ScheduleWork_Thread to join finished blobUpload threads and free that memory/
AzureIoTClient	88:248736be106e	182	static void garbageCollectorImpl(IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance)
AzureIoTClient	88:248736be106e	183	{
AzureIoTClient	88:248736be106e	184	/see if any savedData structures can be disposed of/
AzureIoTClient	88:248736be106e	185	/Codes_SRS_IOTHUBCLIENT_02_072: [ All threads marked as disposable (upon completion of a file upload) shall be joined and the data structures build for them shall be freed. ]/
AzureIoTClient	88:248736be106e	186	LIST_ITEM_HANDLE item = singlylinkedlist_get_head_item(iotHubClientInstance->savedDataToBeCleaned);
AzureIoTClient	88:248736be106e	187	while (item != NULL)
AzureIoTClient	88:248736be106e	188	{
AzureIoTClient	88:248736be106e	189	UPLOADTOBLOB_THREAD_INFO* threadInfo = (UPLOADTOBLOB_THREAD_INFO*)singlylinkedlist_item_get_value(item);
AzureIoTClient	88:248736be106e	190	LIST_ITEM_HANDLE old_item = item;
AzureIoTClient	88:248736be106e	191	item = singlylinkedlist_get_next_item(item);
AzureIoTClient	88:248736be106e	192
AzureIoTClient	88:248736be106e	193	if (Lock(threadInfo->lockGarbage) != LOCK_OK)
AzureIoTClient	88:248736be106e	194	{
AzureIoTClient	88:248736be106e	195	LogError("unable to Lock");
AzureIoTClient	88:248736be106e	196	}
AzureIoTClient	88:248736be106e	197	else
AzureIoTClient	88:248736be106e	198	{
AzureIoTClient	88:248736be106e	199	if (threadInfo->canBeGarbageCollected == 1)
AzureIoTClient	88:248736be106e	200	{
AzureIoTClient	88:248736be106e	201	int notUsed;
AzureIoTClient	88:248736be106e	202	if (ThreadAPI_Join(threadInfo->uploadingThreadHandle, &notUsed) != THREADAPI_OK)
AzureIoTClient	88:248736be106e	203	{
AzureIoTClient	88:248736be106e	204	LogError("unable to ThreadAPI_Join");
AzureIoTClient	88:248736be106e	205	}
AzureIoTClient	88:248736be106e	206	(void)singlylinkedlist_remove(iotHubClientInstance->savedDataToBeCleaned, old_item);
AzureIoTClient	88:248736be106e	207
AzureIoTClient	88:248736be106e	208	if (Unlock(threadInfo->lockGarbage) != LOCK_OK)
AzureIoTClient	88:248736be106e	209	{
AzureIoTClient	88:248736be106e	210	LogError("unable to unlock after locking");
AzureIoTClient	88:248736be106e	211	}
AzureIoTClient	88:248736be106e	212	freeUploadToBlobThreadInfo(threadInfo);
AzureIoTClient	88:248736be106e	213	}
AzureIoTClient	88:248736be106e	214	else
AzureIoTClient	88:248736be106e	215	{
AzureIoTClient	88:248736be106e	216	if (Unlock(threadInfo->lockGarbage) != LOCK_OK)
AzureIoTClient	88:248736be106e	217	{
AzureIoTClient	88:248736be106e	218	LogError("unable to unlock after locking");
AzureIoTClient	88:248736be106e	219	}
AzureIoTClient	88:248736be106e	220	}
AzureIoTClient	88:248736be106e	221	}
AzureIoTClient	88:248736be106e	222	}
AzureIoTClient	88:248736be106e	223	}
AzureIoTClient	88:248736be106e	224	#endif
AzureIoTClient	88:248736be106e	225
AzureIoTClient	88:248736be106e	226	static bool iothub_ll_message_callback(MESSAGE_CALLBACK_INFO* messageData, void* userContextCallback)
AzureIoTClient	88:248736be106e	227	{
AzureIoTClient	88:248736be106e	228	bool result;
AzureIoTClient	88:248736be106e	229	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)userContextCallback;
AzureIoTClient	88:248736be106e	230	if (queue_context == NULL)
AzureIoTClient	88:248736be106e	231	{
AzureIoTClient	88:248736be106e	232	LogError("invalid parameter userContextCallback(NULL)");
AzureIoTClient	88:248736be106e	233	result = false;
AzureIoTClient	88:248736be106e	234	}
AzureIoTClient	88:248736be106e	235	else
AzureIoTClient	88:248736be106e	236	{
AzureIoTClient	88:248736be106e	237	USER_CALLBACK_INFO queue_cb_info;
AzureIoTClient	88:248736be106e	238	queue_cb_info.type = CALLBACK_TYPE_MESSAGE;
AzureIoTClient	88:248736be106e	239	queue_cb_info.userContextCallback = queue_context->userContextCallback;
AzureIoTClient	88:248736be106e	240	queue_cb_info.iothub_callback.message_cb_info = messageData;
AzureIoTClient	88:248736be106e	241	if (VECTOR_push_back(queue_context->iotHubClientHandle->saved_user_callback_list, &queue_cb_info, 1) == 0)
AzureIoTClient	88:248736be106e	242	{
AzureIoTClient	88:248736be106e	243	result = true;
AzureIoTClient	88:248736be106e	244	}
AzureIoTClient	88:248736be106e	245	else
AzureIoTClient	88:248736be106e	246	{
AzureIoTClient	88:248736be106e	247	LogError("message callback vector push failed.");
AzureIoTClient	88:248736be106e	248	result = false;
AzureIoTClient	88:248736be106e	249	}
AzureIoTClient	88:248736be106e	250	}
AzureIoTClient	88:248736be106e	251	return result;
AzureIoTClient	88:248736be106e	252	}
AzureIoTClient	88:248736be106e	253
AzureIoTClient	89:a2ed767a532e	254	static bool iothub_ll_inputmessage_callback(MESSAGE_CALLBACK_INFO* message_cb_info, void* userContextCallback)
AzureIoTClient	89:a2ed767a532e	255	{
AzureIoTClient	89:a2ed767a532e	256	bool result;
AzureIoTClient	89:a2ed767a532e	257	IOTHUB_INPUTMESSAGE_CALLBACK_CONTEXT inputMessageCallbackContext = (IOTHUB_INPUTMESSAGE_CALLBACK_CONTEXT )userContextCallback;
AzureIoTClient	89:a2ed767a532e	258	if (inputMessageCallbackContext == NULL)
AzureIoTClient	89:a2ed767a532e	259	{
AzureIoTClient	89:a2ed767a532e	260	LogError("invalid parameter userContextCallback(NULL)");
AzureIoTClient	89:a2ed767a532e	261	result = false;
AzureIoTClient	89:a2ed767a532e	262	}
AzureIoTClient	89:a2ed767a532e	263	else
AzureIoTClient	89:a2ed767a532e	264	{
AzureIoTClient	89:a2ed767a532e	265	USER_CALLBACK_INFO queue_cb_info;
AzureIoTClient	89:a2ed767a532e	266	queue_cb_info.type = CALLBACK_TYPE_INPUTMESSAGE;
AzureIoTClient	89:a2ed767a532e	267	queue_cb_info.userContextCallback = inputMessageCallbackContext->userContextCallback;
AzureIoTClient	89:a2ed767a532e	268	queue_cb_info.iothub_callback.inputmessage_cb_info.eventHandlerCallback = inputMessageCallbackContext->eventHandlerCallback;
AzureIoTClient	89:a2ed767a532e	269	queue_cb_info.iothub_callback.inputmessage_cb_info.message_cb_info = message_cb_info;
AzureIoTClient	89:a2ed767a532e	270
AzureIoTClient	89:a2ed767a532e	271	if (VECTOR_push_back(inputMessageCallbackContext->iotHubClientHandle->saved_user_callback_list, &queue_cb_info, 1) == 0)
AzureIoTClient	89:a2ed767a532e	272	{
AzureIoTClient	89:a2ed767a532e	273	result = true;
AzureIoTClient	89:a2ed767a532e	274	}
AzureIoTClient	89:a2ed767a532e	275	else
AzureIoTClient	89:a2ed767a532e	276	{
AzureIoTClient	89:a2ed767a532e	277	LogError("message callback vector push failed.");
AzureIoTClient	89:a2ed767a532e	278	result = false;
AzureIoTClient	89:a2ed767a532e	279	}
AzureIoTClient	89:a2ed767a532e	280	}
AzureIoTClient	89:a2ed767a532e	281
AzureIoTClient	89:a2ed767a532e	282	return result;
AzureIoTClient	89:a2ed767a532e	283	}
AzureIoTClient	89:a2ed767a532e	284
AzureIoTClient	88:248736be106e	285	static int make_method_calback_queue_context(USER_CALLBACK_INFO* queue_cb_info, const char* method_name, const unsigned char* payload, size_t size, METHOD_HANDLE method_id, IOTHUB_QUEUE_CONTEXT* queue_context)
AzureIoTClient	88:248736be106e	286	{
AzureIoTClient	88:248736be106e	287	int result;
AzureIoTClient	88:248736be106e	288	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_002: [ IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK shall copy the method_name and payload. ] */
AzureIoTClient	88:248736be106e	289	queue_cb_info->userContextCallback = queue_context->userContextCallback;
AzureIoTClient	88:248736be106e	290	queue_cb_info->iothub_callback.method_cb_info.method_id = method_id;
AzureIoTClient	88:248736be106e	291	if ((queue_cb_info->iothub_callback.method_cb_info.method_name = STRING_construct(method_name)) == NULL)
AzureIoTClient	88:248736be106e	292	{
AzureIoTClient	88:248736be106e	293	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_003: [ If a failure is encountered IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK shall return a non-NULL value. ]*/
AzureIoTClient	88:248736be106e	294	LogError("STRING_construct failed");
AzureIoTClient	88:248736be106e	295	result = __FAILURE__;
AzureIoTClient	88:248736be106e	296	}
AzureIoTClient	88:248736be106e	297	else
AzureIoTClient	88:248736be106e	298	{
AzureIoTClient	88:248736be106e	299	if ((queue_cb_info->iothub_callback.method_cb_info.payload = BUFFER_create(payload, size)) == NULL)
AzureIoTClient	88:248736be106e	300	{
AzureIoTClient	88:248736be106e	301	STRING_delete(queue_cb_info->iothub_callback.method_cb_info.method_name);
AzureIoTClient	88:248736be106e	302	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_003: [ If a failure is encountered IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK shall return a non-NULL value. ]*/
AzureIoTClient	88:248736be106e	303	LogError("BUFFER_create failed");
AzureIoTClient	88:248736be106e	304	result = __FAILURE__;
AzureIoTClient	88:248736be106e	305	}
AzureIoTClient	88:248736be106e	306	else
AzureIoTClient	88:248736be106e	307	{
AzureIoTClient	88:248736be106e	308	if (VECTOR_push_back(queue_context->iotHubClientHandle->saved_user_callback_list, queue_cb_info, 1) == 0)
AzureIoTClient	88:248736be106e	309	{
AzureIoTClient	88:248736be106e	310	result = 0;
AzureIoTClient	88:248736be106e	311	}
AzureIoTClient	88:248736be106e	312	else
AzureIoTClient	88:248736be106e	313	{
AzureIoTClient	88:248736be106e	314	STRING_delete(queue_cb_info->iothub_callback.method_cb_info.method_name);
AzureIoTClient	88:248736be106e	315	BUFFER_delete(queue_cb_info->iothub_callback.method_cb_info.payload);
AzureIoTClient	88:248736be106e	316	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_003: [ If a failure is encountered IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK shall return a non-NULL value. ]*/
AzureIoTClient	88:248736be106e	317	LogError("VECTOR_push_back failed");
AzureIoTClient	88:248736be106e	318	result = __FAILURE__;
AzureIoTClient	88:248736be106e	319	}
AzureIoTClient	88:248736be106e	320	}
AzureIoTClient	88:248736be106e	321	}
AzureIoTClient	88:248736be106e	322	return result;
AzureIoTClient	88:248736be106e	323	}
AzureIoTClient	88:248736be106e	324
AzureIoTClient	88:248736be106e	325	static int iothub_ll_device_method_callback(const char* method_name, const unsigned char* payload, size_t size, METHOD_HANDLE method_id, void* userContextCallback)
AzureIoTClient	88:248736be106e	326	{
AzureIoTClient	88:248736be106e	327	int result;
AzureIoTClient	88:248736be106e	328	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_001: [ if userContextCallback is NULL, IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK shall return a nonNULL value. ] */
AzureIoTClient	88:248736be106e	329	if (userContextCallback == NULL)
AzureIoTClient	88:248736be106e	330	{
AzureIoTClient	88:248736be106e	331	LogError("invalid parameter userContextCallback(NULL)");
AzureIoTClient	88:248736be106e	332	result = __FAILURE__;
AzureIoTClient	88:248736be106e	333	}
AzureIoTClient	88:248736be106e	334	else
AzureIoTClient	88:248736be106e	335	{
AzureIoTClient	88:248736be106e	336	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)userContextCallback;
AzureIoTClient	88:248736be106e	337
AzureIoTClient	88:248736be106e	338	USER_CALLBACK_INFO queue_cb_info;
AzureIoTClient	88:248736be106e	339	queue_cb_info.type = CALLBACK_TYPE_DEVICE_METHOD;
AzureIoTClient	88:248736be106e	340
AzureIoTClient	88:248736be106e	341	result = make_method_calback_queue_context(&queue_cb_info, method_name, payload, size, method_id, queue_context);
AzureIoTClient	88:248736be106e	342	if (result != 0)
AzureIoTClient	88:248736be106e	343	{
AzureIoTClient	88:248736be106e	344	LogError("construction of method calback queue context failed");
AzureIoTClient	88:248736be106e	345	result = __FAILURE__;
AzureIoTClient	88:248736be106e	346	}
AzureIoTClient	88:248736be106e	347	}
AzureIoTClient	88:248736be106e	348	return result;
AzureIoTClient	88:248736be106e	349	}
AzureIoTClient	88:248736be106e	350
AzureIoTClient	88:248736be106e	351	static int iothub_ll_inbound_device_method_callback(const char* method_name, const unsigned char* payload, size_t size, METHOD_HANDLE method_id, void* userContextCallback)
AzureIoTClient	88:248736be106e	352	{
AzureIoTClient	88:248736be106e	353	int result;
AzureIoTClient	88:248736be106e	354	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_001: [ if userContextCallback is NULL, IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK shall return a nonNULL value. ] */
AzureIoTClient	88:248736be106e	355	if (userContextCallback == NULL)
AzureIoTClient	88:248736be106e	356	{
AzureIoTClient	88:248736be106e	357	LogError("invalid parameter userContextCallback(NULL)");
AzureIoTClient	88:248736be106e	358	result = __FAILURE__;
AzureIoTClient	88:248736be106e	359	}
AzureIoTClient	88:248736be106e	360	else
AzureIoTClient	88:248736be106e	361	{
AzureIoTClient	88:248736be106e	362	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)userContextCallback;
AzureIoTClient	88:248736be106e	363
AzureIoTClient	88:248736be106e	364	USER_CALLBACK_INFO queue_cb_info;
AzureIoTClient	88:248736be106e	365	queue_cb_info.type = CALLBACK_TYPE_INBOUD_DEVICE_METHOD;
AzureIoTClient	88:248736be106e	366
AzureIoTClient	88:248736be106e	367	result = make_method_calback_queue_context(&queue_cb_info, method_name, payload, size, method_id, queue_context);
AzureIoTClient	88:248736be106e	368	if (result != 0)
AzureIoTClient	88:248736be106e	369	{
AzureIoTClient	88:248736be106e	370	LogError("construction of method calback queue context failed");
AzureIoTClient	88:248736be106e	371	result = __FAILURE__;
AzureIoTClient	88:248736be106e	372	}
AzureIoTClient	88:248736be106e	373	}
AzureIoTClient	88:248736be106e	374	return result;
AzureIoTClient	88:248736be106e	375	}
AzureIoTClient	88:248736be106e	376
AzureIoTClient	88:248736be106e	377	static void iothub_ll_connection_status_callback(IOTHUB_CLIENT_CONNECTION_STATUS result, IOTHUB_CLIENT_CONNECTION_STATUS_REASON reason, void* userContextCallback)
AzureIoTClient	88:248736be106e	378	{
AzureIoTClient	88:248736be106e	379	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)userContextCallback;
AzureIoTClient	88:248736be106e	380	if (queue_context != NULL)
AzureIoTClient	88:248736be106e	381	{
AzureIoTClient	88:248736be106e	382	USER_CALLBACK_INFO queue_cb_info;
AzureIoTClient	88:248736be106e	383	queue_cb_info.type = CALLBACK_TYPE_CONNECTION_STATUS;
AzureIoTClient	88:248736be106e	384	queue_cb_info.userContextCallback = queue_context->userContextCallback;
AzureIoTClient	88:248736be106e	385	queue_cb_info.iothub_callback.connection_status_cb_info.status_reason = reason;
AzureIoTClient	88:248736be106e	386	queue_cb_info.iothub_callback.connection_status_cb_info.connection_status = result;
AzureIoTClient	88:248736be106e	387	if (VECTOR_push_back(queue_context->iotHubClientHandle->saved_user_callback_list, &queue_cb_info, 1) != 0)
AzureIoTClient	88:248736be106e	388	{
AzureIoTClient	88:248736be106e	389	LogError("connection status callback vector push failed.");
AzureIoTClient	88:248736be106e	390	}
AzureIoTClient	88:248736be106e	391	}
AzureIoTClient	88:248736be106e	392	}
AzureIoTClient	88:248736be106e	393
AzureIoTClient	88:248736be106e	394	static void iothub_ll_event_confirm_callback(IOTHUB_CLIENT_CONFIRMATION_RESULT result, void* userContextCallback)
AzureIoTClient	88:248736be106e	395	{
AzureIoTClient	88:248736be106e	396	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)userContextCallback;
AzureIoTClient	88:248736be106e	397	if (queue_context != NULL)
AzureIoTClient	88:248736be106e	398	{
AzureIoTClient	88:248736be106e	399	USER_CALLBACK_INFO queue_cb_info;
AzureIoTClient	88:248736be106e	400	queue_cb_info.type = CALLBACK_TYPE_EVENT_CONFIRM;
AzureIoTClient	88:248736be106e	401	queue_cb_info.userContextCallback = queue_context->userContextCallback;
AzureIoTClient	88:248736be106e	402	queue_cb_info.iothub_callback.event_confirm_cb_info.confirm_result = result;
AzureIoTClient	88:248736be106e	403	if (VECTOR_push_back(queue_context->iotHubClientHandle->saved_user_callback_list, &queue_cb_info, 1) != 0)
AzureIoTClient	88:248736be106e	404	{
AzureIoTClient	88:248736be106e	405	LogError("event confirm callback vector push failed.");
AzureIoTClient	88:248736be106e	406	}
AzureIoTClient	88:248736be106e	407	free(queue_context);
AzureIoTClient	88:248736be106e	408	}
AzureIoTClient	88:248736be106e	409	}
AzureIoTClient	88:248736be106e	410
AzureIoTClient	88:248736be106e	411	static void iothub_ll_reported_state_callback(int status_code, void* userContextCallback)
AzureIoTClient	88:248736be106e	412	{
AzureIoTClient	88:248736be106e	413	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)userContextCallback;
AzureIoTClient	88:248736be106e	414	if (queue_context != NULL)
AzureIoTClient	88:248736be106e	415	{
AzureIoTClient	88:248736be106e	416	USER_CALLBACK_INFO queue_cb_info;
AzureIoTClient	88:248736be106e	417	queue_cb_info.type = CALLBACK_TYPE_REPORTED_STATE;
AzureIoTClient	88:248736be106e	418	queue_cb_info.userContextCallback = queue_context->userContextCallback;
AzureIoTClient	88:248736be106e	419	queue_cb_info.iothub_callback.reported_state_cb_info.status_code = status_code;
AzureIoTClient	88:248736be106e	420	if (VECTOR_push_back(queue_context->iotHubClientHandle->saved_user_callback_list, &queue_cb_info, 1) != 0)
AzureIoTClient	88:248736be106e	421	{
AzureIoTClient	88:248736be106e	422	LogError("reported state callback vector push failed.");
AzureIoTClient	88:248736be106e	423	}
AzureIoTClient	88:248736be106e	424	free(queue_context);
AzureIoTClient	88:248736be106e	425	}
AzureIoTClient	88:248736be106e	426	}
AzureIoTClient	88:248736be106e	427
AzureIoTClient	88:248736be106e	428	static void iothub_ll_device_twin_callback(DEVICE_TWIN_UPDATE_STATE update_state, const unsigned char* payLoad, size_t size, void* userContextCallback)
AzureIoTClient	88:248736be106e	429	{
AzureIoTClient	88:248736be106e	430	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)userContextCallback;
AzureIoTClient	88:248736be106e	431	if (queue_context != NULL)
AzureIoTClient	88:248736be106e	432	{
AzureIoTClient	88:248736be106e	433	int push_to_vector;
AzureIoTClient	88:248736be106e	434
AzureIoTClient	88:248736be106e	435	USER_CALLBACK_INFO queue_cb_info;
AzureIoTClient	88:248736be106e	436	queue_cb_info.type = CALLBACK_TYPE_DEVICE_TWIN;
AzureIoTClient	88:248736be106e	437	queue_cb_info.userContextCallback = queue_context->userContextCallback;
AzureIoTClient	88:248736be106e	438	queue_cb_info.iothub_callback.dev_twin_cb_info.update_state = update_state;
AzureIoTClient	88:248736be106e	439	if (payLoad == NULL)
AzureIoTClient	88:248736be106e	440	{
AzureIoTClient	88:248736be106e	441	queue_cb_info.iothub_callback.dev_twin_cb_info.payLoad = NULL;
AzureIoTClient	88:248736be106e	442	queue_cb_info.iothub_callback.dev_twin_cb_info.size = 0;
AzureIoTClient	88:248736be106e	443	push_to_vector = 0;
AzureIoTClient	88:248736be106e	444	}
AzureIoTClient	88:248736be106e	445	else
AzureIoTClient	88:248736be106e	446	{
AzureIoTClient	88:248736be106e	447	queue_cb_info.iothub_callback.dev_twin_cb_info.payLoad = (unsigned char*)malloc(size);
AzureIoTClient	88:248736be106e	448	if (queue_cb_info.iothub_callback.dev_twin_cb_info.payLoad == NULL)
AzureIoTClient	88:248736be106e	449	{
AzureIoTClient	88:248736be106e	450	LogError("failure allocating payload in device twin callback.");
AzureIoTClient	88:248736be106e	451	queue_cb_info.iothub_callback.dev_twin_cb_info.size = 0;
AzureIoTClient	88:248736be106e	452	push_to_vector = __FAILURE__;
AzureIoTClient	88:248736be106e	453	}
AzureIoTClient	88:248736be106e	454	else
AzureIoTClient	88:248736be106e	455	{
AzureIoTClient	88:248736be106e	456	(void)memcpy(queue_cb_info.iothub_callback.dev_twin_cb_info.payLoad, payLoad, size);
AzureIoTClient	88:248736be106e	457	queue_cb_info.iothub_callback.dev_twin_cb_info.size = size;
AzureIoTClient	88:248736be106e	458	push_to_vector = 0;
AzureIoTClient	88:248736be106e	459	}
AzureIoTClient	88:248736be106e	460	}
AzureIoTClient	88:248736be106e	461	if (push_to_vector == 0)
AzureIoTClient	88:248736be106e	462	{
AzureIoTClient	88:248736be106e	463	if (VECTOR_push_back(queue_context->iotHubClientHandle->saved_user_callback_list, &queue_cb_info, 1) != 0)
AzureIoTClient	88:248736be106e	464	{
AzureIoTClient	88:248736be106e	465	if (queue_cb_info.iothub_callback.dev_twin_cb_info.payLoad != NULL)
AzureIoTClient	88:248736be106e	466	{
AzureIoTClient	88:248736be106e	467	free(queue_cb_info.iothub_callback.dev_twin_cb_info.payLoad);
AzureIoTClient	88:248736be106e	468	}
AzureIoTClient	88:248736be106e	469	LogError("device twin callback userContextCallback vector push failed.");
AzureIoTClient	88:248736be106e	470	}
AzureIoTClient	88:248736be106e	471	}
AzureIoTClient	88:248736be106e	472	}
AzureIoTClient	88:248736be106e	473	else
AzureIoTClient	88:248736be106e	474	{
AzureIoTClient	88:248736be106e	475	LogError("device twin callback userContextCallback NULL");
AzureIoTClient	88:248736be106e	476	}
AzureIoTClient	88:248736be106e	477	}
AzureIoTClient	88:248736be106e	478
AzureIoTClient	88:248736be106e	479	static void dispatch_user_callbacks(IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance, VECTOR_HANDLE call_backs)
AzureIoTClient	88:248736be106e	480	{
AzureIoTClient	88:248736be106e	481	size_t callbacks_length = VECTOR_size(call_backs);
AzureIoTClient	88:248736be106e	482	size_t index;
AzureIoTClient	88:248736be106e	483
AzureIoTClient	88:248736be106e	484	IOTHUB_CLIENT_DEVICE_TWIN_CALLBACK desired_state_callback = NULL;
AzureIoTClient	88:248736be106e	485	IOTHUB_CLIENT_EVENT_CONFIRMATION_CALLBACK event_confirm_callback = NULL;
AzureIoTClient	88:248736be106e	486	IOTHUB_CLIENT_REPORTED_STATE_CALLBACK reported_state_callback = NULL;
AzureIoTClient	88:248736be106e	487	IOTHUB_CLIENT_CONNECTION_STATUS_CALLBACK connection_status_callback = NULL;
AzureIoTClient	88:248736be106e	488	IOTHUB_CLIENT_DEVICE_METHOD_CALLBACK_ASYNC device_method_callback = NULL;
AzureIoTClient	88:248736be106e	489	IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK inbound_device_method_callback = NULL;
AzureIoTClient	88:248736be106e	490	IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC message_callback = NULL;
AzureIoTClient	88:248736be106e	491	IOTHUB_CLIENT_CORE_HANDLE message_user_context_handle = NULL;
AzureIoTClient	88:248736be106e	492	IOTHUB_CLIENT_CORE_HANDLE method_user_context_handle = NULL;
AzureIoTClient	88:248736be106e	493
AzureIoTClient	88:248736be106e	494	// Make a local copy of these callbacks, as we don't run with a lock held and iotHubClientInstance may change mid-run.
AzureIoTClient	88:248736be106e	495	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	496	{
AzureIoTClient	88:248736be106e	497	LogError("failed locking for dispatch_user_callbacks");
AzureIoTClient	88:248736be106e	498	}
AzureIoTClient	88:248736be106e	499	else
AzureIoTClient	88:248736be106e	500	{
AzureIoTClient	88:248736be106e	501	desired_state_callback = iotHubClientInstance->desired_state_callback;
AzureIoTClient	88:248736be106e	502	event_confirm_callback = iotHubClientInstance->event_confirm_callback;
AzureIoTClient	88:248736be106e	503	reported_state_callback = iotHubClientInstance->reported_state_callback;
AzureIoTClient	88:248736be106e	504	connection_status_callback = iotHubClientInstance->connection_status_callback;
AzureIoTClient	88:248736be106e	505	device_method_callback = iotHubClientInstance->device_method_callback;
AzureIoTClient	88:248736be106e	506	inbound_device_method_callback = iotHubClientInstance->inbound_device_method_callback;
AzureIoTClient	88:248736be106e	507	message_callback = iotHubClientInstance->message_callback;
AzureIoTClient	88:248736be106e	508	if (iotHubClientInstance->method_user_context)
AzureIoTClient	88:248736be106e	509	{
AzureIoTClient	88:248736be106e	510	method_user_context_handle = iotHubClientInstance->method_user_context->iotHubClientHandle;
AzureIoTClient	88:248736be106e	511	}
AzureIoTClient	88:248736be106e	512	if (iotHubClientInstance->message_user_context)
AzureIoTClient	88:248736be106e	513	{
AzureIoTClient	88:248736be106e	514	message_user_context_handle = iotHubClientInstance->message_user_context->iotHubClientHandle;
AzureIoTClient	88:248736be106e	515	}
AzureIoTClient	88:248736be106e	516
AzureIoTClient	88:248736be106e	517	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	518	}
AzureIoTClient	88:248736be106e	519
AzureIoTClient	88:248736be106e	520
AzureIoTClient	88:248736be106e	521	for (index = 0; index < callbacks_length; index++)
AzureIoTClient	88:248736be106e	522	{
AzureIoTClient	88:248736be106e	523	USER_CALLBACK_INFO* queued_cb = (USER_CALLBACK_INFO*)VECTOR_element(call_backs, index);
AzureIoTClient	88:248736be106e	524	if (queued_cb == NULL)
AzureIoTClient	88:248736be106e	525	{
AzureIoTClient	88:248736be106e	526	LogError("VECTOR_element at index %zd is NULL.", index);
AzureIoTClient	88:248736be106e	527	}
AzureIoTClient	88:248736be106e	528	else
AzureIoTClient	88:248736be106e	529	{
AzureIoTClient	88:248736be106e	530	switch (queued_cb->type)
AzureIoTClient	88:248736be106e	531	{
AzureIoTClient	88:248736be106e	532	case CALLBACK_TYPE_DEVICE_TWIN:
AzureIoTClient	88:248736be106e	533	{
AzureIoTClient	88:248736be106e	534	if (desired_state_callback)
AzureIoTClient	88:248736be106e	535	{
AzureIoTClient	88:248736be106e	536	desired_state_callback(queued_cb->iothub_callback.dev_twin_cb_info.update_state, queued_cb->iothub_callback.dev_twin_cb_info.payLoad, queued_cb->iothub_callback.dev_twin_cb_info.size, queued_cb->userContextCallback);
AzureIoTClient	88:248736be106e	537	}
AzureIoTClient	88:248736be106e	538
AzureIoTClient	88:248736be106e	539	if (queued_cb->iothub_callback.dev_twin_cb_info.payLoad)
AzureIoTClient	88:248736be106e	540	{
AzureIoTClient	88:248736be106e	541	free(queued_cb->iothub_callback.dev_twin_cb_info.payLoad);
AzureIoTClient	88:248736be106e	542	}
AzureIoTClient	88:248736be106e	543	break;
AzureIoTClient	88:248736be106e	544	}
AzureIoTClient	88:248736be106e	545	case CALLBACK_TYPE_EVENT_CONFIRM:
AzureIoTClient	88:248736be106e	546	if (event_confirm_callback)
AzureIoTClient	88:248736be106e	547	{
AzureIoTClient	88:248736be106e	548	event_confirm_callback(queued_cb->iothub_callback.event_confirm_cb_info.confirm_result, queued_cb->userContextCallback);
AzureIoTClient	88:248736be106e	549	}
AzureIoTClient	88:248736be106e	550	break;
AzureIoTClient	88:248736be106e	551	case CALLBACK_TYPE_REPORTED_STATE:
AzureIoTClient	88:248736be106e	552	if (reported_state_callback)
AzureIoTClient	88:248736be106e	553	{
AzureIoTClient	88:248736be106e	554	reported_state_callback(queued_cb->iothub_callback.reported_state_cb_info.status_code, queued_cb->userContextCallback);
AzureIoTClient	88:248736be106e	555	}
AzureIoTClient	88:248736be106e	556	break;
AzureIoTClient	88:248736be106e	557	case CALLBACK_TYPE_CONNECTION_STATUS:
AzureIoTClient	88:248736be106e	558	if (connection_status_callback)
AzureIoTClient	88:248736be106e	559	{
AzureIoTClient	88:248736be106e	560	connection_status_callback(queued_cb->iothub_callback.connection_status_cb_info.connection_status, queued_cb->iothub_callback.connection_status_cb_info.status_reason, queued_cb->userContextCallback);
AzureIoTClient	88:248736be106e	561	}
AzureIoTClient	88:248736be106e	562	break;
AzureIoTClient	88:248736be106e	563	case CALLBACK_TYPE_DEVICE_METHOD:
AzureIoTClient	88:248736be106e	564	if (device_method_callback)
AzureIoTClient	88:248736be106e	565	{
AzureIoTClient	88:248736be106e	566	const char* method_name = STRING_c_str(queued_cb->iothub_callback.method_cb_info.method_name);
AzureIoTClient	88:248736be106e	567	const unsigned char* payload = BUFFER_u_char(queued_cb->iothub_callback.method_cb_info.payload);
AzureIoTClient	88:248736be106e	568	size_t payload_len = BUFFER_length(queued_cb->iothub_callback.method_cb_info.payload);
AzureIoTClient	88:248736be106e	569
AzureIoTClient	88:248736be106e	570	unsigned char* payload_resp = NULL;
AzureIoTClient	88:248736be106e	571	size_t response_size = 0;
AzureIoTClient	88:248736be106e	572	int status = device_method_callback(method_name, payload, payload_len, &payload_resp, &response_size, queued_cb->userContextCallback);
AzureIoTClient	88:248736be106e	573
AzureIoTClient	88:248736be106e	574	if (payload_resp && (response_size > 0))
AzureIoTClient	88:248736be106e	575	{
AzureIoTClient	88:248736be106e	576	IOTHUB_CLIENT_RESULT result = IoTHubClientCore_DeviceMethodResponse(method_user_context_handle, queued_cb->iothub_callback.method_cb_info.method_id, (const unsigned char*)payload_resp, response_size, status);
AzureIoTClient	88:248736be106e	577	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	578	{
AzureIoTClient	88:248736be106e	579	LogError("IoTHubClientCore_LL_DeviceMethodResponse failed");
AzureIoTClient	88:248736be106e	580	}
AzureIoTClient	88:248736be106e	581	}
AzureIoTClient	88:248736be106e	582
AzureIoTClient	88:248736be106e	583	BUFFER_delete(queued_cb->iothub_callback.method_cb_info.payload);
AzureIoTClient	88:248736be106e	584	STRING_delete(queued_cb->iothub_callback.method_cb_info.method_name);
AzureIoTClient	88:248736be106e	585
AzureIoTClient	88:248736be106e	586	if (payload_resp)
AzureIoTClient	88:248736be106e	587	{
AzureIoTClient	88:248736be106e	588	free(payload_resp);
AzureIoTClient	88:248736be106e	589	}
AzureIoTClient	88:248736be106e	590	}
AzureIoTClient	88:248736be106e	591	break;
AzureIoTClient	88:248736be106e	592	case CALLBACK_TYPE_INBOUD_DEVICE_METHOD:
AzureIoTClient	88:248736be106e	593	if (inbound_device_method_callback)
AzureIoTClient	88:248736be106e	594	{
AzureIoTClient	88:248736be106e	595	const char* method_name = STRING_c_str(queued_cb->iothub_callback.method_cb_info.method_name);
AzureIoTClient	88:248736be106e	596	const unsigned char* payload = BUFFER_u_char(queued_cb->iothub_callback.method_cb_info.payload);
AzureIoTClient	88:248736be106e	597	size_t payload_len = BUFFER_length(queued_cb->iothub_callback.method_cb_info.payload);
AzureIoTClient	88:248736be106e	598
AzureIoTClient	88:248736be106e	599	inbound_device_method_callback(method_name, payload, payload_len, queued_cb->iothub_callback.method_cb_info.method_id, queued_cb->userContextCallback);
AzureIoTClient	88:248736be106e	600
AzureIoTClient	88:248736be106e	601	BUFFER_delete(queued_cb->iothub_callback.method_cb_info.payload);
AzureIoTClient	88:248736be106e	602	STRING_delete(queued_cb->iothub_callback.method_cb_info.method_name);
AzureIoTClient	88:248736be106e	603	}
AzureIoTClient	88:248736be106e	604	break;
AzureIoTClient	88:248736be106e	605	case CALLBACK_TYPE_MESSAGE:
AzureIoTClient	88:248736be106e	606	if (message_callback)
AzureIoTClient	88:248736be106e	607	{
AzureIoTClient	88:248736be106e	608	IOTHUBMESSAGE_DISPOSITION_RESULT disposition = message_callback(queued_cb->iothub_callback.message_cb_info->messageHandle, queued_cb->userContextCallback);
AzureIoTClient	88:248736be106e	609
AzureIoTClient	88:248736be106e	610	if (Lock(message_user_context_handle->LockHandle) == LOCK_OK)
AzureIoTClient	88:248736be106e	611	{
AzureIoTClient	88:248736be106e	612	IOTHUB_CLIENT_RESULT result = IoTHubClientCore_LL_SendMessageDisposition(message_user_context_handle->IoTHubClientLLHandle, queued_cb->iothub_callback.message_cb_info, disposition);
AzureIoTClient	88:248736be106e	613	(void)Unlock(message_user_context_handle->LockHandle);
AzureIoTClient	88:248736be106e	614	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	615	{
AzureIoTClient	88:248736be106e	616	LogError("IoTHubClientCore_LL_SendMessageDisposition failed");
AzureIoTClient	88:248736be106e	617	}
AzureIoTClient	88:248736be106e	618	}
AzureIoTClient	88:248736be106e	619	else
AzureIoTClient	88:248736be106e	620	{
AzureIoTClient	88:248736be106e	621	LogError("Lock failed");
AzureIoTClient	88:248736be106e	622	}
AzureIoTClient	88:248736be106e	623	}
AzureIoTClient	88:248736be106e	624	break;
AzureIoTClient	89:a2ed767a532e	625
AzureIoTClient	89:a2ed767a532e	626	case CALLBACK_TYPE_INPUTMESSAGE:
AzureIoTClient	89:a2ed767a532e	627	{
AzureIoTClient	89:a2ed767a532e	628	const INPUTMESSAGE_CALLBACK_INFO *inputmessage_cb_info = &queued_cb->iothub_callback.inputmessage_cb_info;
AzureIoTClient	89:a2ed767a532e	629	IOTHUBMESSAGE_DISPOSITION_RESULT disposition = inputmessage_cb_info->eventHandlerCallback(inputmessage_cb_info->message_cb_info->messageHandle, queued_cb->userContextCallback);
AzureIoTClient	89:a2ed767a532e	630
AzureIoTClient	89:a2ed767a532e	631	if (Lock(iotHubClientInstance->LockHandle) == LOCK_OK)
AzureIoTClient	89:a2ed767a532e	632	{
AzureIoTClient	89:a2ed767a532e	633	IOTHUB_CLIENT_RESULT result = IoTHubClientCore_LL_SendMessageDisposition(iotHubClientInstance->IoTHubClientLLHandle, inputmessage_cb_info->message_cb_info, disposition);
AzureIoTClient	89:a2ed767a532e	634	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	89:a2ed767a532e	635	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	89:a2ed767a532e	636	{
AzureIoTClient	89:a2ed767a532e	637	LogError("IoTHubClient_LL_SendMessageDisposition failed");
AzureIoTClient	89:a2ed767a532e	638	}
AzureIoTClient	89:a2ed767a532e	639	}
AzureIoTClient	89:a2ed767a532e	640	else
AzureIoTClient	89:a2ed767a532e	641	{
AzureIoTClient	89:a2ed767a532e	642	LogError("Lock failed");
AzureIoTClient	89:a2ed767a532e	643	}
AzureIoTClient	89:a2ed767a532e	644	}
AzureIoTClient	89:a2ed767a532e	645	break;
AzureIoTClient	89:a2ed767a532e	646
AzureIoTClient	88:248736be106e	647	default:
AzureIoTClient	88:248736be106e	648	LogError("Invalid callback type '%s'", ENUM_TO_STRING(USER_CALLBACK_TYPE, queued_cb->type));
AzureIoTClient	88:248736be106e	649	break;
AzureIoTClient	88:248736be106e	650	}
AzureIoTClient	88:248736be106e	651	}
AzureIoTClient	88:248736be106e	652	}
AzureIoTClient	88:248736be106e	653	VECTOR_destroy(call_backs);
AzureIoTClient	88:248736be106e	654	}
AzureIoTClient	88:248736be106e	655
AzureIoTClient	88:248736be106e	656	static void ScheduleWork_Thread_ForMultiplexing(void* iotHubClientHandle)
AzureIoTClient	88:248736be106e	657	{
AzureIoTClient	88:248736be106e	658	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	659
AzureIoTClient	88:248736be106e	660	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	661	garbageCollectorImpl(iotHubClientInstance);
AzureIoTClient	88:248736be106e	662	#endif
AzureIoTClient	88:248736be106e	663	if (Lock(iotHubClientInstance->LockHandle) == LOCK_OK)
AzureIoTClient	88:248736be106e	664	{
AzureIoTClient	88:248736be106e	665	VECTOR_HANDLE call_backs = VECTOR_move(iotHubClientInstance->saved_user_callback_list);
AzureIoTClient	88:248736be106e	666	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	667
AzureIoTClient	88:248736be106e	668	if (call_backs == NULL)
AzureIoTClient	88:248736be106e	669	{
AzureIoTClient	88:248736be106e	670	LogError("Failed moving user callbacks");
AzureIoTClient	88:248736be106e	671	}
AzureIoTClient	88:248736be106e	672	else
AzureIoTClient	88:248736be106e	673	{
AzureIoTClient	88:248736be106e	674	dispatch_user_callbacks(iotHubClientInstance, call_backs);
AzureIoTClient	88:248736be106e	675	}
AzureIoTClient	88:248736be106e	676	}
AzureIoTClient	88:248736be106e	677	else
AzureIoTClient	88:248736be106e	678	{
AzureIoTClient	88:248736be106e	679	LogError("failed locking for ScheduleWork_Thread_ForMultiplexing");
AzureIoTClient	88:248736be106e	680	}
AzureIoTClient	88:248736be106e	681	}
AzureIoTClient	88:248736be106e	682
AzureIoTClient	88:248736be106e	683	static int ScheduleWork_Thread(void* threadArgument)
AzureIoTClient	88:248736be106e	684	{
AzureIoTClient	88:248736be106e	685	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)threadArgument;
AzureIoTClient	88:248736be106e	686
AzureIoTClient	88:248736be106e	687	while (1)
AzureIoTClient	88:248736be106e	688	{
AzureIoTClient	88:248736be106e	689	if (Lock(iotHubClientInstance->LockHandle) == LOCK_OK)
AzureIoTClient	88:248736be106e	690	{
AzureIoTClient	88:248736be106e	691	/Codes_SRS_IOTHUBCLIENT_01_038: [ The thread shall exit when IoTHubClient_Destroy is called. ]/
AzureIoTClient	88:248736be106e	692	if (iotHubClientInstance->StopThread)
AzureIoTClient	88:248736be106e	693	{
AzureIoTClient	88:248736be106e	694	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	695	break; /gets out of the thread/
AzureIoTClient	88:248736be106e	696	}
AzureIoTClient	88:248736be106e	697	else
AzureIoTClient	88:248736be106e	698	{
AzureIoTClient	88:248736be106e	699	/* Codes_SRS_IOTHUBCLIENT_01_037: [The thread created by IoTHubClient_SendEvent or IoTHubClient_SetMessageCallback shall call IoTHubClientCore_LL_DoWork every 1 ms.] */
AzureIoTClient	88:248736be106e	700	/* Codes_SRS_IOTHUBCLIENT_01_039: [All calls to IoTHubClientCore_LL_DoWork shall be protected by the lock created in IotHubClient_Create.] */
AzureIoTClient	88:248736be106e	701	IoTHubClientCore_LL_DoWork(iotHubClientInstance->IoTHubClientLLHandle);
AzureIoTClient	88:248736be106e	702
AzureIoTClient	88:248736be106e	703	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	704	garbageCollectorImpl(iotHubClientInstance);
AzureIoTClient	88:248736be106e	705	#endif
AzureIoTClient	88:248736be106e	706	VECTOR_HANDLE call_backs = VECTOR_move(iotHubClientInstance->saved_user_callback_list);
AzureIoTClient	88:248736be106e	707	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	708	if (call_backs == NULL)
AzureIoTClient	88:248736be106e	709	{
AzureIoTClient	88:248736be106e	710	LogError("VECTOR_move failed");
AzureIoTClient	88:248736be106e	711	}
AzureIoTClient	88:248736be106e	712	else
AzureIoTClient	88:248736be106e	713	{
AzureIoTClient	88:248736be106e	714	dispatch_user_callbacks(iotHubClientInstance, call_backs);
AzureIoTClient	88:248736be106e	715	}
AzureIoTClient	88:248736be106e	716	}
AzureIoTClient	88:248736be106e	717	}
AzureIoTClient	88:248736be106e	718	else
AzureIoTClient	88:248736be106e	719	{
AzureIoTClient	88:248736be106e	720	/Codes_SRS_IOTHUBCLIENT_01_040: [If acquiring the lock fails, IoTHubClientCore_LL_DoWork shall not be called.]/
AzureIoTClient	88:248736be106e	721	/no code, shall retry/
AzureIoTClient	88:248736be106e	722	}
AzureIoTClient	88:248736be106e	723	(void)ThreadAPI_Sleep(1);
AzureIoTClient	88:248736be106e	724	}
AzureIoTClient	88:248736be106e	725
AzureIoTClient	88:248736be106e	726	ThreadAPI_Exit(0);
AzureIoTClient	88:248736be106e	727	return 0;
AzureIoTClient	88:248736be106e	728	}
AzureIoTClient	88:248736be106e	729
AzureIoTClient	88:248736be106e	730	static IOTHUB_CLIENT_RESULT StartWorkerThreadIfNeeded(IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance)
AzureIoTClient	88:248736be106e	731	{
AzureIoTClient	88:248736be106e	732	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	733	if (iotHubClientInstance->TransportHandle == NULL)
AzureIoTClient	88:248736be106e	734	{
AzureIoTClient	88:248736be106e	735	if (iotHubClientInstance->ThreadHandle == NULL)
AzureIoTClient	88:248736be106e	736	{
AzureIoTClient	88:248736be106e	737	iotHubClientInstance->StopThread = 0;
AzureIoTClient	88:248736be106e	738	if (ThreadAPI_Create(&iotHubClientInstance->ThreadHandle, ScheduleWork_Thread, iotHubClientInstance) != THREADAPI_OK)
AzureIoTClient	88:248736be106e	739	{
AzureIoTClient	88:248736be106e	740	LogError("ThreadAPI_Create failed");
AzureIoTClient	88:248736be106e	741	iotHubClientInstance->ThreadHandle = NULL;
AzureIoTClient	88:248736be106e	742	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	743	}
AzureIoTClient	88:248736be106e	744	else
AzureIoTClient	88:248736be106e	745	{
AzureIoTClient	88:248736be106e	746	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	747	}
AzureIoTClient	88:248736be106e	748	}
AzureIoTClient	88:248736be106e	749	else
AzureIoTClient	88:248736be106e	750	{
AzureIoTClient	88:248736be106e	751	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	752	}
AzureIoTClient	88:248736be106e	753	}
AzureIoTClient	88:248736be106e	754	else
AzureIoTClient	88:248736be106e	755	{
AzureIoTClient	88:248736be106e	756	/Codes_SRS_IOTHUBCLIENT_17_012: [ If the transport connection is shared, the thread shall be started by calling IoTHubTransport_StartWorkerThread. ]/
AzureIoTClient	88:248736be106e	757	/Codes_SRS_IOTHUBCLIENT_17_011: [ If the transport connection is shared, the thread shall be started by calling IoTHubTransport_StartWorkerThread/
AzureIoTClient	88:248736be106e	758	result = IoTHubTransport_StartWorkerThread(iotHubClientInstance->TransportHandle, iotHubClientInstance, ScheduleWork_Thread_ForMultiplexing);
AzureIoTClient	88:248736be106e	759	}
AzureIoTClient	88:248736be106e	760	return result;
AzureIoTClient	88:248736be106e	761	}
AzureIoTClient	88:248736be106e	762
AzureIoTClient	89:a2ed767a532e	763	static IOTHUB_CLIENT_CORE_INSTANCE* create_iothub_instance(CREATE_HUB_INSTANCE_TYPE create_hub_instance_type, const IOTHUB_CLIENT_CONFIG* config, TRANSPORT_HANDLE transportHandle, const char* connectionString, IOTHUB_CLIENT_TRANSPORT_PROVIDER protocol, const char* iothub_uri, const char* device_id)
AzureIoTClient	88:248736be106e	764	{
AzureIoTClient	88:248736be106e	765	/* Codes_SRS_IOTHUBCLIENT_12_020: [ `IoTHubClient_CreateFromDeviceAuth` shall allocate a new `IoTHubClient` instance. ] */
AzureIoTClient	88:248736be106e	766	IOTHUB_CLIENT_CORE_INSTANCE* result = (IOTHUB_CLIENT_CORE_INSTANCE*)malloc(sizeof(IOTHUB_CLIENT_CORE_INSTANCE));
AzureIoTClient	89:a2ed767a532e	767	(void)create_hub_instance_type;
AzureIoTClient	88:248736be106e	768
AzureIoTClient	88:248736be106e	769	/* Codes_SRS_IOTHUBCLIENT_12_021: [ If allocating memory for the new `IoTHubClient` instance fails, then `IoTHubClient_CreateFromDeviceAuth` shall return `NULL`. ] */
AzureIoTClient	88:248736be106e	770	/* Codes_SRS_IOTHUBCLIENT_01_004: [If allocating memory for the new IoTHubClient instance fails, then IoTHubClient_Create shall return NULL.] */
AzureIoTClient	88:248736be106e	771	if (result != NULL)
AzureIoTClient	88:248736be106e	772	{
AzureIoTClient	88:248736be106e	773	/* Codes_SRS_IOTHUBCLIENT_01_029: [IoTHubClient_Create shall create a lock object to be used later for serializing IoTHubClient calls.] */
AzureIoTClient	88:248736be106e	774	if ((result->saved_user_callback_list = VECTOR_create(sizeof(USER_CALLBACK_INFO))) == NULL)
AzureIoTClient	88:248736be106e	775	{
AzureIoTClient	88:248736be106e	776	LogError("Failed creating VECTOR");
AzureIoTClient	88:248736be106e	777	free(result);
AzureIoTClient	88:248736be106e	778	result = NULL;
AzureIoTClient	88:248736be106e	779	}
AzureIoTClient	88:248736be106e	780	else
AzureIoTClient	88:248736be106e	781	{
AzureIoTClient	88:248736be106e	782	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	783	/Codes_SRS_IOTHUBCLIENT_02_060: [ IoTHubClient_Create shall create a SINGLYLINKEDLIST_HANDLE containing THREAD_HANDLE (created by future calls to IoTHubClient_UploadToBlobAsync). ]/
AzureIoTClient	88:248736be106e	784	if ((result->savedDataToBeCleaned = singlylinkedlist_create()) == NULL)
AzureIoTClient	88:248736be106e	785	{
AzureIoTClient	88:248736be106e	786	/Codes_SRS_IOTHUBCLIENT_02_061: [ If creating the SINGLYLINKEDLIST_HANDLE fails then IoTHubClient_Create shall fail and return NULL. ]/
AzureIoTClient	88:248736be106e	787	LogError("unable to singlylinkedlist_create");
AzureIoTClient	88:248736be106e	788	VECTOR_destroy(result->saved_user_callback_list);
AzureIoTClient	88:248736be106e	789	free(result);
AzureIoTClient	88:248736be106e	790	result = NULL;
AzureIoTClient	88:248736be106e	791	}
AzureIoTClient	88:248736be106e	792	else
AzureIoTClient	88:248736be106e	793	#endif
AzureIoTClient	88:248736be106e	794	{
AzureIoTClient	88:248736be106e	795	result->TransportHandle = transportHandle;
AzureIoTClient	88:248736be106e	796	result->created_with_transport_handle = 0;
AzureIoTClient	88:248736be106e	797	if (config != NULL)
AzureIoTClient	88:248736be106e	798	{
AzureIoTClient	88:248736be106e	799	if (transportHandle != NULL)
AzureIoTClient	88:248736be106e	800	{
AzureIoTClient	88:248736be106e	801	/Codes_SRS_IOTHUBCLIENT_17_005: [ IoTHubClient_CreateWithTransport shall call IoTHubTransport_GetLock to get the transport lock to be used later for serializing IoTHubClient calls. ]/
AzureIoTClient	88:248736be106e	802	result->LockHandle = IoTHubTransport_GetLock(transportHandle);
AzureIoTClient	88:248736be106e	803	if (result->LockHandle == NULL)
AzureIoTClient	88:248736be106e	804	{
AzureIoTClient	88:248736be106e	805	LogError("unable to IoTHubTransport_GetLock");
AzureIoTClient	88:248736be106e	806	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	88:248736be106e	807	}
AzureIoTClient	88:248736be106e	808	else
AzureIoTClient	88:248736be106e	809	{
AzureIoTClient	88:248736be106e	810	IOTHUB_CLIENT_DEVICE_CONFIG deviceConfig;
AzureIoTClient	88:248736be106e	811	deviceConfig.deviceId = config->deviceId;
AzureIoTClient	88:248736be106e	812	deviceConfig.deviceKey = config->deviceKey;
AzureIoTClient	88:248736be106e	813	deviceConfig.protocol = config->protocol;
AzureIoTClient	88:248736be106e	814	deviceConfig.deviceSasToken = config->deviceSasToken;
AzureIoTClient	88:248736be106e	815
AzureIoTClient	88:248736be106e	816	/Codes_SRS_IOTHUBCLIENT_17_003: [ IoTHubClient_CreateWithTransport shall call IoTHubTransport_GetLLTransport on transportHandle to get lower layer transport. ]/
AzureIoTClient	88:248736be106e	817	deviceConfig.transportHandle = IoTHubTransport_GetLLTransport(transportHandle);
AzureIoTClient	88:248736be106e	818	if (deviceConfig.transportHandle == NULL)
AzureIoTClient	88:248736be106e	819	{
AzureIoTClient	88:248736be106e	820	LogError("unable to IoTHubTransport_GetLLTransport");
AzureIoTClient	88:248736be106e	821	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	88:248736be106e	822	}
AzureIoTClient	88:248736be106e	823	else
AzureIoTClient	88:248736be106e	824	{
AzureIoTClient	88:248736be106e	825	if (Lock(result->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	826	{
AzureIoTClient	88:248736be106e	827	LogError("unable to Lock");
AzureIoTClient	88:248736be106e	828	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	88:248736be106e	829	}
AzureIoTClient	88:248736be106e	830	else
AzureIoTClient	88:248736be106e	831	{
AzureIoTClient	88:248736be106e	832	/Codes_SRS_IOTHUBCLIENT_17_007: [ IoTHubClient_CreateWithTransport shall instantiate a new IoTHubClientCore_LL instance by calling IoTHubClientCore_LL_CreateWithTransport and passing the lower layer transport and config argument. ]/
AzureIoTClient	88:248736be106e	833	result->IoTHubClientLLHandle = IoTHubClientCore_LL_CreateWithTransport(&deviceConfig);
AzureIoTClient	88:248736be106e	834	result->created_with_transport_handle = 1;
AzureIoTClient	88:248736be106e	835	if (Unlock(result->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	836	{
AzureIoTClient	88:248736be106e	837	LogError("unable to Unlock");
AzureIoTClient	88:248736be106e	838	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	88:248736be106e	839	}
AzureIoTClient	88:248736be106e	840	}
AzureIoTClient	88:248736be106e	841	}
AzureIoTClient	88:248736be106e	842	}
AzureIoTClient	88:248736be106e	843	}
AzureIoTClient	88:248736be106e	844	else
AzureIoTClient	88:248736be106e	845	{
AzureIoTClient	88:248736be106e	846	result->LockHandle = Lock_Init();
AzureIoTClient	88:248736be106e	847	if (result->LockHandle == NULL)
AzureIoTClient	88:248736be106e	848	{
AzureIoTClient	88:248736be106e	849	/* Codes_SRS_IOTHUBCLIENT_01_030: [If creating the lock fails, then IoTHubClient_Create shall return NULL.] */
AzureIoTClient	88:248736be106e	850	/* Codes_SRS_IOTHUBCLIENT_01_031: [If IoTHubClient_Create fails, all resources allocated by it shall be freed.] */
AzureIoTClient	88:248736be106e	851	LogError("Failure creating Lock object");
AzureIoTClient	88:248736be106e	852	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	88:248736be106e	853	}
AzureIoTClient	88:248736be106e	854	else
AzureIoTClient	88:248736be106e	855	{
AzureIoTClient	88:248736be106e	856	/* Codes_SRS_IOTHUBCLIENT_01_002: [IoTHubClient_Create shall instantiate a new IoTHubClientCore_LL instance by calling IoTHubClientCore_LL_Create and passing the config argument.] */
AzureIoTClient	88:248736be106e	857	result->IoTHubClientLLHandle = IoTHubClientCore_LL_Create(config);
AzureIoTClient	88:248736be106e	858	}
AzureIoTClient	88:248736be106e	859	}
AzureIoTClient	88:248736be106e	860	}
AzureIoTClient	88:248736be106e	861	else if (iothub_uri != NULL)
AzureIoTClient	88:248736be106e	862	{
AzureIoTClient	88:248736be106e	863	#ifdef USE_PROV_MODULE
AzureIoTClient	88:248736be106e	864	/* Codes_SRS_IOTHUBCLIENT_12_022: [ `IoTHubClient_CreateFromDeviceAuth` shall create a lock object to be used later for serializing IoTHubClient calls. ] */
AzureIoTClient	88:248736be106e	865	result->LockHandle = Lock_Init();
AzureIoTClient	88:248736be106e	866	if (result->LockHandle == NULL)
AzureIoTClient	88:248736be106e	867	{
AzureIoTClient	88:248736be106e	868	/* Codes_SRS_IOTHUBCLIENT_12_023: [ If creating the lock fails, then IoTHubClient_CreateFromDeviceAuth shall return NULL. ] */
AzureIoTClient	88:248736be106e	869	LogError("Failure creating Lock object");
AzureIoTClient	88:248736be106e	870	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	88:248736be106e	871	}
AzureIoTClient	88:248736be106e	872	else
AzureIoTClient	88:248736be106e	873	{
AzureIoTClient	88:248736be106e	874	/* Codes_SRS_IOTHUBCLIENT_12_025: [ `IoTHubClient_CreateFromDeviceAuth` shall instantiate a new `IoTHubClientCore_LL` instance by calling `IoTHubClientCore_LL_CreateFromDeviceAuth` and passing iothub_uri, device_id and protocol argument. ] */
AzureIoTClient	88:248736be106e	875	result->IoTHubClientLLHandle = IoTHubClientCore_LL_CreateFromDeviceAuth(iothub_uri, device_id, protocol);
AzureIoTClient	88:248736be106e	876	}
AzureIoTClient	88:248736be106e	877	#else
AzureIoTClient	88:248736be106e	878	(void)device_id;
AzureIoTClient	88:248736be106e	879	LogError("Provisioning is not enabled for the build");
AzureIoTClient	88:248736be106e	880	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	88:248736be106e	881	#endif
AzureIoTClient	88:248736be106e	882	}
AzureIoTClient	89:a2ed767a532e	883	#ifdef USE_EDGE_MODULES
AzureIoTClient	89:a2ed767a532e	884	else if (create_hub_instance_type == CREATE_HUB_INSTANCE_FROM_EDGE_ENVIRONMENT)
AzureIoTClient	89:a2ed767a532e	885	{
AzureIoTClient	89:a2ed767a532e	886	result->LockHandle = Lock_Init();
AzureIoTClient	89:a2ed767a532e	887	if (result->LockHandle == NULL)
AzureIoTClient	89:a2ed767a532e	888	{
AzureIoTClient	89:a2ed767a532e	889	/* Codes_SRS_IOTHUBCLIENT_01_030: [If creating the lock fails, then IoTHubClient_Create shall return NULL.] */
AzureIoTClient	89:a2ed767a532e	890	/* Codes_SRS_IOTHUBCLIENT_01_031: [If IoTHubClient_Create fails, all resources allocated by it shall be freed.] */
AzureIoTClient	89:a2ed767a532e	891	LogError("Failure creating Lock object");
AzureIoTClient	89:a2ed767a532e	892	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	89:a2ed767a532e	893	}
AzureIoTClient	89:a2ed767a532e	894	else
AzureIoTClient	89:a2ed767a532e	895	{
AzureIoTClient	89:a2ed767a532e	896	result->IoTHubClientLLHandle = IoTHubModuleClient_LL_CreateFromEnvironment(protocol);
AzureIoTClient	89:a2ed767a532e	897	}
AzureIoTClient	89:a2ed767a532e	898	}
AzureIoTClient	89:a2ed767a532e	899	#endif
AzureIoTClient	88:248736be106e	900	else
AzureIoTClient	88:248736be106e	901	{
AzureIoTClient	88:248736be106e	902	result->LockHandle = Lock_Init();
AzureIoTClient	88:248736be106e	903	if (result->LockHandle == NULL)
AzureIoTClient	88:248736be106e	904	{
AzureIoTClient	88:248736be106e	905	/* Codes_SRS_IOTHUBCLIENT_01_030: [If creating the lock fails, then IoTHubClient_Create shall return NULL.] */
AzureIoTClient	88:248736be106e	906	/* Codes_SRS_IOTHUBCLIENT_01_031: [If IoTHubClient_Create fails, all resources allocated by it shall be freed.] */
AzureIoTClient	88:248736be106e	907	LogError("Failure creating Lock object");
AzureIoTClient	88:248736be106e	908	result->IoTHubClientLLHandle = NULL;
AzureIoTClient	88:248736be106e	909	}
AzureIoTClient	88:248736be106e	910	else
AzureIoTClient	88:248736be106e	911	{
AzureIoTClient	88:248736be106e	912	result->IoTHubClientLLHandle = IoTHubClientCore_LL_CreateFromConnectionString(connectionString, protocol);
AzureIoTClient	88:248736be106e	913	}
AzureIoTClient	88:248736be106e	914	}
AzureIoTClient	88:248736be106e	915
AzureIoTClient	88:248736be106e	916	if (result->IoTHubClientLLHandle == NULL)
AzureIoTClient	88:248736be106e	917	{
AzureIoTClient	88:248736be106e	918	/* Codes_SRS_IOTHUBCLIENT_01_003: [If IoTHubClientCore_LL_Create fails, then IoTHubClient_Create shall return NULL.] */
AzureIoTClient	88:248736be106e	919	/* Codes_SRS_IOTHUBCLIENT_01_031: [If IoTHubClient_Create fails, all resources allocated by it shall be freed.] */
AzureIoTClient	88:248736be106e	920	/* Codes_SRS_IOTHUBCLIENT_17_006: [ If IoTHubTransport_GetLock fails, then IoTHubClient_CreateWithTransport shall return NULL. ]*/
AzureIoTClient	88:248736be106e	921	if (transportHandle == NULL)
AzureIoTClient	88:248736be106e	922	{
AzureIoTClient	88:248736be106e	923	Lock_Deinit(result->LockHandle);
AzureIoTClient	88:248736be106e	924	}
AzureIoTClient	88:248736be106e	925	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	926	singlylinkedlist_destroy(result->savedDataToBeCleaned);
AzureIoTClient	88:248736be106e	927	#endif
AzureIoTClient	88:248736be106e	928	LogError("Failure creating iothub handle");
AzureIoTClient	88:248736be106e	929	VECTOR_destroy(result->saved_user_callback_list);
AzureIoTClient	88:248736be106e	930	free(result);
AzureIoTClient	88:248736be106e	931	result = NULL;
AzureIoTClient	88:248736be106e	932	}
AzureIoTClient	88:248736be106e	933	else
AzureIoTClient	88:248736be106e	934	{
AzureIoTClient	88:248736be106e	935	result->ThreadHandle = NULL;
AzureIoTClient	88:248736be106e	936	result->desired_state_callback = NULL;
AzureIoTClient	88:248736be106e	937	result->event_confirm_callback = NULL;
AzureIoTClient	88:248736be106e	938	result->reported_state_callback = NULL;
AzureIoTClient	88:248736be106e	939	result->devicetwin_user_context = NULL;
AzureIoTClient	88:248736be106e	940	result->connection_status_callback = NULL;
AzureIoTClient	88:248736be106e	941	result->connection_status_user_context = NULL;
AzureIoTClient	88:248736be106e	942	result->message_callback = NULL;
AzureIoTClient	88:248736be106e	943	result->message_user_context = NULL;
AzureIoTClient	88:248736be106e	944	result->method_user_context = NULL;
AzureIoTClient	88:248736be106e	945	}
AzureIoTClient	88:248736be106e	946	}
AzureIoTClient	88:248736be106e	947	}
AzureIoTClient	88:248736be106e	948	}
AzureIoTClient	88:248736be106e	949	return result;
AzureIoTClient	88:248736be106e	950	}
AzureIoTClient	88:248736be106e	951
AzureIoTClient	88:248736be106e	952	IOTHUB_CLIENT_CORE_HANDLE IoTHubClientCore_CreateFromConnectionString(const char* connectionString, IOTHUB_CLIENT_TRANSPORT_PROVIDER protocol)
AzureIoTClient	88:248736be106e	953	{
AzureIoTClient	88:248736be106e	954	IOTHUB_CLIENT_CORE_INSTANCE* result;
AzureIoTClient	88:248736be106e	955
AzureIoTClient	88:248736be106e	956	if (connectionString == NULL)
AzureIoTClient	88:248736be106e	957	{
AzureIoTClient	88:248736be106e	958	LogError("Input parameter is NULL: connectionString");
AzureIoTClient	88:248736be106e	959	result = NULL;
AzureIoTClient	88:248736be106e	960	}
AzureIoTClient	88:248736be106e	961	else if (protocol == NULL)
AzureIoTClient	88:248736be106e	962	{
AzureIoTClient	88:248736be106e	963	LogError("Input parameter is NULL: protocol");
AzureIoTClient	88:248736be106e	964	result = NULL;
AzureIoTClient	88:248736be106e	965	}
AzureIoTClient	88:248736be106e	966	else
AzureIoTClient	88:248736be106e	967	{
AzureIoTClient	89:a2ed767a532e	968	result = create_iothub_instance(CREATE_HUB_INSTANCE_FROM_CONNECTION_STRING, NULL, NULL, connectionString, protocol, NULL, NULL);
AzureIoTClient	88:248736be106e	969	}
AzureIoTClient	88:248736be106e	970	return result;
AzureIoTClient	88:248736be106e	971	}
AzureIoTClient	88:248736be106e	972
AzureIoTClient	88:248736be106e	973	IOTHUB_CLIENT_CORE_HANDLE IoTHubClientCore_Create(const IOTHUB_CLIENT_CONFIG* config)
AzureIoTClient	88:248736be106e	974	{
AzureIoTClient	88:248736be106e	975	IOTHUB_CLIENT_CORE_INSTANCE* result;
AzureIoTClient	88:248736be106e	976	if (config == NULL)
AzureIoTClient	88:248736be106e	977	{
AzureIoTClient	88:248736be106e	978	LogError("Input parameter is NULL: IOTHUB_CLIENT_CONFIG");
AzureIoTClient	88:248736be106e	979	result = NULL;
AzureIoTClient	88:248736be106e	980	}
AzureIoTClient	88:248736be106e	981	else
AzureIoTClient	88:248736be106e	982	{
AzureIoTClient	89:a2ed767a532e	983	result = create_iothub_instance(CREATE_HUB_INSTANCE_FROM_CLIENT_CONFIG, config, NULL, NULL, NULL, NULL, NULL);
AzureIoTClient	88:248736be106e	984	}
AzureIoTClient	88:248736be106e	985	return result;
AzureIoTClient	88:248736be106e	986	}
AzureIoTClient	88:248736be106e	987
AzureIoTClient	88:248736be106e	988	IOTHUB_CLIENT_CORE_HANDLE IoTHubClientCore_CreateWithTransport(TRANSPORT_HANDLE transportHandle, const IOTHUB_CLIENT_CONFIG* config)
AzureIoTClient	88:248736be106e	989	{
AzureIoTClient	88:248736be106e	990	IOTHUB_CLIENT_CORE_INSTANCE* result;
AzureIoTClient	88:248736be106e	991	/Codes_SRS_IOTHUBCLIENT_17_013: [ IoTHubClient_CreateWithTransport shall return NULL if transportHandle is NULL. ]/
AzureIoTClient	88:248736be106e	992	/Codes_SRS_IOTHUBCLIENT_17_014: [ IoTHubClient_CreateWithTransport shall return NULL if config is NULL. ]/
AzureIoTClient	88:248736be106e	993	if (transportHandle == NULL \|\| config == NULL)
AzureIoTClient	88:248736be106e	994	{
AzureIoTClient	88:248736be106e	995	LogError("invalid parameter TRANSPORT_HANDLE transportHandle=%p, const IOTHUB_CLIENT_CONFIG* config=%p", transportHandle, config);
AzureIoTClient	88:248736be106e	996	result = NULL;
AzureIoTClient	88:248736be106e	997	}
AzureIoTClient	88:248736be106e	998	else
AzureIoTClient	88:248736be106e	999	{
AzureIoTClient	89:a2ed767a532e	1000	result = create_iothub_instance(CREATE_HUB_INSTANCE_FROM_TRANSPORT, config, transportHandle, NULL, NULL, NULL, NULL);
AzureIoTClient	88:248736be106e	1001	}
AzureIoTClient	88:248736be106e	1002	return result;
AzureIoTClient	88:248736be106e	1003	}
AzureIoTClient	88:248736be106e	1004
AzureIoTClient	88:248736be106e	1005	IOTHUB_CLIENT_CORE_HANDLE IoTHubClientCore_CreateFromDeviceAuth(const char* iothub_uri, const char* device_id, IOTHUB_CLIENT_TRANSPORT_PROVIDER protocol)
AzureIoTClient	88:248736be106e	1006	{
AzureIoTClient	88:248736be106e	1007	IOTHUB_CLIENT_CORE_INSTANCE* result;
AzureIoTClient	88:248736be106e	1008
AzureIoTClient	88:248736be106e	1009	/* Codes_SRS_IOTHUBCLIENT_12_019: [ `IoTHubClient_CreateFromDeviceAuth` shall verify the input parameters and if any of them `NULL` then return `NULL`. ] */
AzureIoTClient	88:248736be106e	1010	if (iothub_uri == NULL)
AzureIoTClient	88:248736be106e	1011	{
AzureIoTClient	88:248736be106e	1012	LogError("Input parameter is NULL: iothub_uri");
AzureIoTClient	88:248736be106e	1013	result = NULL;
AzureIoTClient	88:248736be106e	1014	}
AzureIoTClient	88:248736be106e	1015	else if (device_id == NULL)
AzureIoTClient	88:248736be106e	1016	{
AzureIoTClient	88:248736be106e	1017	LogError("Input parameter is NULL: device_id");
AzureIoTClient	88:248736be106e	1018	result = NULL;
AzureIoTClient	88:248736be106e	1019	}
AzureIoTClient	88:248736be106e	1020	else if (protocol == NULL)
AzureIoTClient	88:248736be106e	1021	{
AzureIoTClient	88:248736be106e	1022	LogError("Input parameter is NULL: protocol");
AzureIoTClient	88:248736be106e	1023	result = NULL;
AzureIoTClient	88:248736be106e	1024	}
AzureIoTClient	88:248736be106e	1025	else
AzureIoTClient	88:248736be106e	1026	{
AzureIoTClient	88:248736be106e	1027	/* Codes_SRS_IOTHUBCLIENT_12_020: [ `IoTHubClient_CreateFromDeviceAuth` shall allocate a new `IoTHubClient` instance. ] */
AzureIoTClient	88:248736be106e	1028	/* Codes_SRS_IOTHUBCLIENT_12_021: [ If allocating memory for the new `IoTHubClient` instance fails, then `IoTHubClient_CreateFromDeviceAuth` shall return `NULL`. ] */
AzureIoTClient	88:248736be106e	1029	/* Codes_SRS_IOTHUBCLIENT_12_022: [ `IoTHubClient_CreateFromDeviceAuth` shall create a lock object to be used later for serializing IoTHubClient calls. ] */
AzureIoTClient	88:248736be106e	1030	/* Codes_SRS_IOTHUBCLIENT_12_023: [ If creating the lock fails, then IoTHubClient_CreateFromDeviceAuth shall return NULL. ] */
AzureIoTClient	88:248736be106e	1031	/* Codes_SRS_IOTHUBCLIENT_12_024: [ If IoTHubClient_CreateFromDeviceAuth fails, all resources allocated by it shall be freed. ] */
AzureIoTClient	89:a2ed767a532e	1032	/* Codes_SRS_IOTHUBCLIENT_12_025: [ `IoTHubClient_CreateFromDeviceAuth` shall instantiate a new `IoTHubClientCore_LL` instance by calling `IoTHubClientCore_LL_CreateFromDeviceAuth` and passing iothub_uri, device_id and protocol argument. ] */
AzureIoTClient	89:a2ed767a532e	1033	result = create_iothub_instance(CREATE_HUB_INSTANCE_FROM_DEVICE_AUTH, NULL, NULL, NULL, protocol, iothub_uri, device_id);
AzureIoTClient	88:248736be106e	1034	}
AzureIoTClient	88:248736be106e	1035	return result;
AzureIoTClient	88:248736be106e	1036	}
AzureIoTClient	88:248736be106e	1037
AzureIoTClient	89:a2ed767a532e	1038	#ifdef USE_EDGE_MODULES
AzureIoTClient	89:a2ed767a532e	1039	IOTHUB_CLIENT_CORE_HANDLE IoTHubClientCore_CreateFromEnvironment(IOTHUB_CLIENT_TRANSPORT_PROVIDER protocol)
AzureIoTClient	89:a2ed767a532e	1040	{
AzureIoTClient	89:a2ed767a532e	1041	return create_iothub_instance(CREATE_HUB_INSTANCE_FROM_EDGE_ENVIRONMENT, NULL, NULL, NULL, protocol, NULL, NULL);
AzureIoTClient	89:a2ed767a532e	1042	}
AzureIoTClient	89:a2ed767a532e	1043	#endif
AzureIoTClient	89:a2ed767a532e	1044
AzureIoTClient	89:a2ed767a532e	1045
AzureIoTClient	88:248736be106e	1046	/* Codes_SRS_IOTHUBCLIENT_01_005: [IoTHubClient_Destroy shall free all resources associated with the iotHubClientHandle instance.] */
AzureIoTClient	88:248736be106e	1047	void IoTHubClientCore_Destroy(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle)
AzureIoTClient	88:248736be106e	1048	{
AzureIoTClient	88:248736be106e	1049	/* Codes_SRS_IOTHUBCLIENT_01_008: [IoTHubClient_Destroy shall do nothing if parameter iotHubClientHandle is NULL.] */
AzureIoTClient	88:248736be106e	1050	if (iotHubClientHandle != NULL)
AzureIoTClient	88:248736be106e	1051	{
AzureIoTClient	88:248736be106e	1052	bool joinClientThread;
AzureIoTClient	88:248736be106e	1053	bool joinTransportThread;
AzureIoTClient	88:248736be106e	1054	size_t vector_size;
AzureIoTClient	88:248736be106e	1055
AzureIoTClient	88:248736be106e	1056	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1057
AzureIoTClient	88:248736be106e	1058	if (iotHubClientInstance->TransportHandle != NULL)
AzureIoTClient	88:248736be106e	1059	{
AzureIoTClient	88:248736be106e	1060	/Codes_SRS_IOTHUBCLIENT_01_007: [ The thread created as part of executing IoTHubClient_SendEventAsync or IoTHubClient_SetNotificationMessageCallback shall be joined. ]/
AzureIoTClient	88:248736be106e	1061	joinTransportThread = IoTHubTransport_SignalEndWorkerThread(iotHubClientInstance->TransportHandle, iotHubClientHandle);
AzureIoTClient	88:248736be106e	1062	}
AzureIoTClient	88:248736be106e	1063	else
AzureIoTClient	88:248736be106e	1064	{
AzureIoTClient	88:248736be106e	1065	joinTransportThread = false;
AzureIoTClient	88:248736be106e	1066	}
AzureIoTClient	88:248736be106e	1067
AzureIoTClient	88:248736be106e	1068	/Codes_SRS_IOTHUBCLIENT_02_043: [ IoTHubClient_Destroy shall lock the serializing lock and signal the worker thread (if any) to end ]/
AzureIoTClient	88:248736be106e	1069	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1070	{
AzureIoTClient	88:248736be106e	1071	LogError("unable to Lock - - will still proceed to try to end the thread without locking");
AzureIoTClient	88:248736be106e	1072	}
AzureIoTClient	88:248736be106e	1073
AzureIoTClient	88:248736be106e	1074	if (iotHubClientInstance->ThreadHandle != NULL)
AzureIoTClient	88:248736be106e	1075	{
AzureIoTClient	88:248736be106e	1076	iotHubClientInstance->StopThread = 1;
AzureIoTClient	88:248736be106e	1077	joinClientThread = true;
AzureIoTClient	88:248736be106e	1078	}
AzureIoTClient	88:248736be106e	1079	else
AzureIoTClient	88:248736be106e	1080	{
AzureIoTClient	88:248736be106e	1081	joinClientThread = false;
AzureIoTClient	88:248736be106e	1082	}
AzureIoTClient	88:248736be106e	1083
AzureIoTClient	88:248736be106e	1084	/Codes_SRS_IOTHUBCLIENT_02_045: [ IoTHubClient_Destroy shall unlock the serializing lock. ]/
AzureIoTClient	88:248736be106e	1085	if (Unlock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1086	{
AzureIoTClient	88:248736be106e	1087	LogError("unable to Unlock");
AzureIoTClient	88:248736be106e	1088	}
AzureIoTClient	88:248736be106e	1089
AzureIoTClient	88:248736be106e	1090	if (joinClientThread == true)
AzureIoTClient	88:248736be106e	1091	{
AzureIoTClient	88:248736be106e	1092	int res;
AzureIoTClient	88:248736be106e	1093	/Codes_SRS_IOTHUBCLIENT_01_007: [ The thread created as part of executing IoTHubClient_SendEventAsync or IoTHubClient_SetNotificationMessageCallback shall be joined. ]/
AzureIoTClient	88:248736be106e	1094	if (ThreadAPI_Join(iotHubClientInstance->ThreadHandle, &res) != THREADAPI_OK)
AzureIoTClient	88:248736be106e	1095	{
AzureIoTClient	88:248736be106e	1096	LogError("ThreadAPI_Join failed");
AzureIoTClient	88:248736be106e	1097	}
AzureIoTClient	88:248736be106e	1098	}
AzureIoTClient	88:248736be106e	1099
AzureIoTClient	88:248736be106e	1100	if (joinTransportThread == true)
AzureIoTClient	88:248736be106e	1101	{
AzureIoTClient	88:248736be106e	1102	/Codes_SRS_IOTHUBCLIENT_01_007: [ The thread created as part of executing IoTHubClient_SendEventAsync or IoTHubClient_SetNotificationMessageCallback shall be joined. ]/
AzureIoTClient	88:248736be106e	1103	IoTHubTransport_JoinWorkerThread(iotHubClientInstance->TransportHandle, iotHubClientHandle);
AzureIoTClient	88:248736be106e	1104	}
AzureIoTClient	88:248736be106e	1105
AzureIoTClient	88:248736be106e	1106	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1107	{
AzureIoTClient	88:248736be106e	1108	LogError("unable to Lock - - will still proceed to try to end the thread without locking");
AzureIoTClient	88:248736be106e	1109	}
AzureIoTClient	88:248736be106e	1110
AzureIoTClient	88:248736be106e	1111	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	1112	/Codes_SRS_IOTHUBCLIENT_02_069: [ IoTHubClient_Destroy shall free all data created by IoTHubClient_UploadToBlobAsync ]/
AzureIoTClient	88:248736be106e	1113	/wait for all uploading threads to finish/
AzureIoTClient	88:248736be106e	1114	while (singlylinkedlist_get_head_item(iotHubClientInstance->savedDataToBeCleaned) != NULL)
AzureIoTClient	88:248736be106e	1115	{
AzureIoTClient	88:248736be106e	1116	garbageCollectorImpl(iotHubClientInstance);
AzureIoTClient	88:248736be106e	1117	}
AzureIoTClient	88:248736be106e	1118
AzureIoTClient	88:248736be106e	1119	if (iotHubClientInstance->savedDataToBeCleaned != NULL)
AzureIoTClient	88:248736be106e	1120	{
AzureIoTClient	88:248736be106e	1121	singlylinkedlist_destroy(iotHubClientInstance->savedDataToBeCleaned);
AzureIoTClient	88:248736be106e	1122	}
AzureIoTClient	88:248736be106e	1123	#endif
AzureIoTClient	88:248736be106e	1124
AzureIoTClient	88:248736be106e	1125	/* Codes_SRS_IOTHUBCLIENT_01_006: [That includes destroying the IoTHubClientCore_LL instance by calling IoTHubClientCore_LL_Destroy.] */
AzureIoTClient	88:248736be106e	1126	IoTHubClientCore_LL_Destroy(iotHubClientInstance->IoTHubClientLLHandle);
AzureIoTClient	88:248736be106e	1127
AzureIoTClient	88:248736be106e	1128	if (Unlock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1129	{
AzureIoTClient	88:248736be106e	1130	LogError("unable to Unlock");
AzureIoTClient	88:248736be106e	1131	}
AzureIoTClient	88:248736be106e	1132
AzureIoTClient	88:248736be106e	1133
AzureIoTClient	88:248736be106e	1134	vector_size = VECTOR_size(iotHubClientInstance->saved_user_callback_list);
AzureIoTClient	88:248736be106e	1135	size_t index = 0;
AzureIoTClient	88:248736be106e	1136	for (index = 0; index < vector_size; index++)
AzureIoTClient	88:248736be106e	1137	{
AzureIoTClient	88:248736be106e	1138	USER_CALLBACK_INFO* queue_cb_info = (USER_CALLBACK_INFO*)VECTOR_element(iotHubClientInstance->saved_user_callback_list, index);
AzureIoTClient	88:248736be106e	1139	if (queue_cb_info != NULL)
AzureIoTClient	88:248736be106e	1140	{
AzureIoTClient	88:248736be106e	1141	if ((queue_cb_info->type == CALLBACK_TYPE_DEVICE_METHOD) \|\| (queue_cb_info->type == CALLBACK_TYPE_INBOUD_DEVICE_METHOD))
AzureIoTClient	88:248736be106e	1142	{
AzureIoTClient	88:248736be106e	1143	STRING_delete(queue_cb_info->iothub_callback.method_cb_info.method_name);
AzureIoTClient	88:248736be106e	1144	BUFFER_delete(queue_cb_info->iothub_callback.method_cb_info.payload);
AzureIoTClient	88:248736be106e	1145	}
AzureIoTClient	88:248736be106e	1146	else if (queue_cb_info->type == CALLBACK_TYPE_DEVICE_TWIN)
AzureIoTClient	88:248736be106e	1147	{
AzureIoTClient	88:248736be106e	1148	if (queue_cb_info->iothub_callback.dev_twin_cb_info.payLoad != NULL)
AzureIoTClient	88:248736be106e	1149	{
AzureIoTClient	88:248736be106e	1150	free(queue_cb_info->iothub_callback.dev_twin_cb_info.payLoad);
AzureIoTClient	88:248736be106e	1151	}
AzureIoTClient	88:248736be106e	1152	}
AzureIoTClient	88:248736be106e	1153	else if (queue_cb_info->type == CALLBACK_TYPE_EVENT_CONFIRM)
AzureIoTClient	88:248736be106e	1154	{
AzureIoTClient	88:248736be106e	1155	if (iotHubClientInstance->event_confirm_callback)
AzureIoTClient	88:248736be106e	1156	{
AzureIoTClient	88:248736be106e	1157	iotHubClientInstance->event_confirm_callback(queue_cb_info->iothub_callback.event_confirm_cb_info.confirm_result, queue_cb_info->userContextCallback);
AzureIoTClient	88:248736be106e	1158	}
AzureIoTClient	88:248736be106e	1159	}
AzureIoTClient	88:248736be106e	1160	}
AzureIoTClient	88:248736be106e	1161	}
AzureIoTClient	88:248736be106e	1162	VECTOR_destroy(iotHubClientInstance->saved_user_callback_list);
AzureIoTClient	88:248736be106e	1163
AzureIoTClient	88:248736be106e	1164	if (iotHubClientInstance->TransportHandle == NULL)
AzureIoTClient	88:248736be106e	1165	{
AzureIoTClient	88:248736be106e	1166	/* Codes_SRS_IOTHUBCLIENT_01_032: [If the lock was allocated in IoTHubClient_Create, it shall be also freed..] */
AzureIoTClient	88:248736be106e	1167	Lock_Deinit(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1168	}
AzureIoTClient	88:248736be106e	1169	if (iotHubClientInstance->devicetwin_user_context != NULL)
AzureIoTClient	88:248736be106e	1170	{
AzureIoTClient	88:248736be106e	1171	free(iotHubClientInstance->devicetwin_user_context);
AzureIoTClient	88:248736be106e	1172	}
AzureIoTClient	88:248736be106e	1173	if (iotHubClientInstance->connection_status_user_context != NULL)
AzureIoTClient	88:248736be106e	1174	{
AzureIoTClient	88:248736be106e	1175	free(iotHubClientInstance->connection_status_user_context);
AzureIoTClient	88:248736be106e	1176	}
AzureIoTClient	88:248736be106e	1177	if (iotHubClientInstance->message_user_context != NULL)
AzureIoTClient	88:248736be106e	1178	{
AzureIoTClient	88:248736be106e	1179	free(iotHubClientInstance->message_user_context);
AzureIoTClient	88:248736be106e	1180	}
AzureIoTClient	88:248736be106e	1181	if (iotHubClientInstance->method_user_context != NULL)
AzureIoTClient	88:248736be106e	1182	{
AzureIoTClient	88:248736be106e	1183	free(iotHubClientInstance->method_user_context);
AzureIoTClient	88:248736be106e	1184	}
AzureIoTClient	88:248736be106e	1185	free(iotHubClientInstance);
AzureIoTClient	88:248736be106e	1186	}
AzureIoTClient	88:248736be106e	1187	}
AzureIoTClient	88:248736be106e	1188
AzureIoTClient	88:248736be106e	1189	IOTHUB_CLIENT_RESULT IoTHubClientCore_SendEventAsync(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_MESSAGE_HANDLE eventMessageHandle, IOTHUB_CLIENT_EVENT_CONFIRMATION_CALLBACK eventConfirmationCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1190	{
AzureIoTClient	88:248736be106e	1191	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1192
AzureIoTClient	88:248736be106e	1193	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1194	{
AzureIoTClient	88:248736be106e	1195	/* Codes_SRS_IOTHUBCLIENT_01_011: [If iotHubClientHandle is NULL, IoTHubClient_SendEventAsync shall return IOTHUB_CLIENT_INVALID_ARG.] */
AzureIoTClient	88:248736be106e	1196	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1197	LogError("NULL iothubClientHandle");
AzureIoTClient	88:248736be106e	1198	}
AzureIoTClient	88:248736be106e	1199	else
AzureIoTClient	88:248736be106e	1200	{
AzureIoTClient	88:248736be106e	1201	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1202
AzureIoTClient	88:248736be106e	1203	/* Codes_SRS_IOTHUBCLIENT_01_009: [IoTHubClient_SendEventAsync shall start the worker thread if it was not previously started.] */
AzureIoTClient	88:248736be106e	1204	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1205	{
AzureIoTClient	88:248736be106e	1206	/* Codes_SRS_IOTHUBCLIENT_01_010: [If starting the thread fails, IoTHubClient_SendEventAsync shall return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	1207	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1208	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1209	}
AzureIoTClient	88:248736be106e	1210	else
AzureIoTClient	88:248736be106e	1211	{
AzureIoTClient	88:248736be106e	1212	/* Codes_SRS_IOTHUBCLIENT_01_025: [IoTHubClient_SendEventAsync shall be made thread-safe by using the lock created in IoTHubClient_Create.] */
AzureIoTClient	88:248736be106e	1213	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1214	{
AzureIoTClient	88:248736be106e	1215	/* Codes_SRS_IOTHUBCLIENT_01_026: [If acquiring the lock fails, IoTHubClient_SendEventAsync shall return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	1216	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1217	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1218	}
AzureIoTClient	88:248736be106e	1219	else
AzureIoTClient	88:248736be106e	1220	{
AzureIoTClient	88:248736be106e	1221	if (iotHubClientInstance->created_with_transport_handle == 0)
AzureIoTClient	88:248736be106e	1222	{
AzureIoTClient	88:248736be106e	1223	iotHubClientInstance->event_confirm_callback = eventConfirmationCallback;
AzureIoTClient	88:248736be106e	1224	}
AzureIoTClient	88:248736be106e	1225
AzureIoTClient	88:248736be106e	1226	if (iotHubClientInstance->created_with_transport_handle != 0 \|\| eventConfirmationCallback == NULL)
AzureIoTClient	88:248736be106e	1227	{
AzureIoTClient	88:248736be106e	1228	result = IoTHubClientCore_LL_SendEventAsync(iotHubClientInstance->IoTHubClientLLHandle, eventMessageHandle, eventConfirmationCallback, userContextCallback);
AzureIoTClient	88:248736be106e	1229	}
AzureIoTClient	88:248736be106e	1230	else
AzureIoTClient	88:248736be106e	1231	{
AzureIoTClient	88:248736be106e	1232	/* Codes_SRS_IOTHUBCLIENT_07_001: [ IoTHubClient_SendEventAsync shall allocate a IOTHUB_QUEUE_CONTEXT object to be sent to the IoTHubClientCore_LL_SendEventAsync function as a user context. ] */
AzureIoTClient	88:248736be106e	1233	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)malloc(sizeof(IOTHUB_QUEUE_CONTEXT));
AzureIoTClient	88:248736be106e	1234	if (queue_context == NULL)
AzureIoTClient	88:248736be106e	1235	{
AzureIoTClient	88:248736be106e	1236	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1237	LogError("Failed allocating QUEUE_CONTEXT");
AzureIoTClient	88:248736be106e	1238	}
AzureIoTClient	88:248736be106e	1239	else
AzureIoTClient	88:248736be106e	1240	{
AzureIoTClient	88:248736be106e	1241	queue_context->iotHubClientHandle = iotHubClientInstance;
AzureIoTClient	88:248736be106e	1242	queue_context->userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1243	/* Codes_SRS_IOTHUBCLIENT_01_012: [IoTHubClient_SendEventAsync shall call IoTHubClientCore_LL_SendEventAsync, while passing the IoTHubClientCore_LL handle created by IoTHubClient_Create and the parameters eventMessageHandle, eventConfirmationCallback and userContextCallback.] */
AzureIoTClient	88:248736be106e	1244	/* Codes_SRS_IOTHUBCLIENT_01_013: [When IoTHubClientCore_LL_SendEventAsync is called, IoTHubClient_SendEventAsync shall return the result of IoTHubClientCore_LL_SendEventAsync.] */
AzureIoTClient	88:248736be106e	1245	result = IoTHubClientCore_LL_SendEventAsync(iotHubClientInstance->IoTHubClientLLHandle, eventMessageHandle, iothub_ll_event_confirm_callback, queue_context);
AzureIoTClient	88:248736be106e	1246	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1247	{
AzureIoTClient	88:248736be106e	1248	LogError("IoTHubClientCore_LL_SendEventAsync failed");
AzureIoTClient	88:248736be106e	1249	free(queue_context);
AzureIoTClient	88:248736be106e	1250	}
AzureIoTClient	88:248736be106e	1251	}
AzureIoTClient	88:248736be106e	1252	}
AzureIoTClient	88:248736be106e	1253
AzureIoTClient	88:248736be106e	1254	/* Codes_SRS_IOTHUBCLIENT_01_025: [IoTHubClient_SendEventAsync shall be made thread-safe by using the lock created in IoTHubClient_Create.] */
AzureIoTClient	88:248736be106e	1255	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1256	}
AzureIoTClient	88:248736be106e	1257	}
AzureIoTClient	88:248736be106e	1258	}
AzureIoTClient	88:248736be106e	1259
AzureIoTClient	88:248736be106e	1260	return result;
AzureIoTClient	88:248736be106e	1261	}
AzureIoTClient	88:248736be106e	1262
AzureIoTClient	88:248736be106e	1263	IOTHUB_CLIENT_RESULT IoTHubClientCore_GetSendStatus(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_CLIENT_STATUS *iotHubClientStatus)
AzureIoTClient	88:248736be106e	1264	{
AzureIoTClient	88:248736be106e	1265	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1266
AzureIoTClient	88:248736be106e	1267	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1268	{
AzureIoTClient	88:248736be106e	1269	/* Codes_SRS_IOTHUBCLIENT_01_023: [If iotHubClientHandle is NULL, IoTHubClient_ GetSendStatus shall return IOTHUB_CLIENT_INVALID_ARG.] */
AzureIoTClient	88:248736be106e	1270	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1271	LogError("NULL iothubClientHandle");
AzureIoTClient	88:248736be106e	1272	}
AzureIoTClient	88:248736be106e	1273	else
AzureIoTClient	88:248736be106e	1274	{
AzureIoTClient	88:248736be106e	1275	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1276
AzureIoTClient	88:248736be106e	1277	/* Codes_SRS_IOTHUBCLIENT_01_033: [IoTHubClient_GetSendStatus shall be made thread-safe by using the lock created in IoTHubClient_Create.] */
AzureIoTClient	88:248736be106e	1278	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1279	{
AzureIoTClient	88:248736be106e	1280	/* Codes_SRS_IOTHUBCLIENT_01_034: [If acquiring the lock fails, IoTHubClient_GetSendStatus shall return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	1281	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1282	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1283	}
AzureIoTClient	88:248736be106e	1284	else
AzureIoTClient	88:248736be106e	1285	{
AzureIoTClient	88:248736be106e	1286	/* Codes_SRS_IOTHUBCLIENT_01_022: [IoTHubClient_GetSendStatus shall call IoTHubClientCore_LL_GetSendStatus, while passing the IoTHubClientCore_LL handle created by IoTHubClient_Create and the parameter iotHubClientStatus.] */
AzureIoTClient	88:248736be106e	1287	/* Codes_SRS_IOTHUBCLIENT_01_024: [Otherwise, IoTHubClient_GetSendStatus shall return the result of IoTHubClientCore_LL_GetSendStatus.] */
AzureIoTClient	88:248736be106e	1288	result = IoTHubClientCore_LL_GetSendStatus(iotHubClientInstance->IoTHubClientLLHandle, iotHubClientStatus);
AzureIoTClient	88:248736be106e	1289
AzureIoTClient	88:248736be106e	1290	/* Codes_SRS_IOTHUBCLIENT_01_033: [IoTHubClient_GetSendStatus shall be made thread-safe by using the lock created in IoTHubClient_Create.] */
AzureIoTClient	88:248736be106e	1291	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1292	}
AzureIoTClient	88:248736be106e	1293	}
AzureIoTClient	88:248736be106e	1294
AzureIoTClient	88:248736be106e	1295	return result;
AzureIoTClient	88:248736be106e	1296	}
AzureIoTClient	88:248736be106e	1297
AzureIoTClient	88:248736be106e	1298	IOTHUB_CLIENT_RESULT IoTHubClientCore_SetMessageCallback(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC messageCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1299	{
AzureIoTClient	88:248736be106e	1300	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1301
AzureIoTClient	88:248736be106e	1302	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1303	{
AzureIoTClient	88:248736be106e	1304	/* Codes_SRS_IOTHUBCLIENT_01_016: [If iotHubClientHandle is NULL, IoTHubClient_SetMessageCallback shall return IOTHUB_CLIENT_INVALID_ARG.] */
AzureIoTClient	88:248736be106e	1305	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1306	LogError("NULL iothubClientHandle");
AzureIoTClient	88:248736be106e	1307	}
AzureIoTClient	88:248736be106e	1308	else
AzureIoTClient	88:248736be106e	1309	{
AzureIoTClient	88:248736be106e	1310	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1311
AzureIoTClient	88:248736be106e	1312	/* Codes_SRS_IOTHUBCLIENT_01_014: [IoTHubClient_SetMessageCallback shall start the worker thread if it was not previously started.] */
AzureIoTClient	88:248736be106e	1313	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1314	{
AzureIoTClient	88:248736be106e	1315	/* Codes_SRS_IOTHUBCLIENT_01_015: [If starting the thread fails, IoTHubClient_SetMessageCallback shall return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	1316	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1317	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1318	}
AzureIoTClient	88:248736be106e	1319	else
AzureIoTClient	88:248736be106e	1320	{
AzureIoTClient	88:248736be106e	1321	/* Codes_SRS_IOTHUBCLIENT_01_027: [IoTHubClient_SetMessageCallback shall be made thread-safe by using the lock created in IoTHubClient_Create.] */
AzureIoTClient	88:248736be106e	1322	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1323	{
AzureIoTClient	88:248736be106e	1324	/* Codes_SRS_IOTHUBCLIENT_01_028: [If acquiring the lock fails, IoTHubClient_SetMessageCallback shall return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	1325	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1326	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1327	}
AzureIoTClient	88:248736be106e	1328	else
AzureIoTClient	88:248736be106e	1329	{
AzureIoTClient	88:248736be106e	1330	if (iotHubClientInstance->created_with_transport_handle == 0)
AzureIoTClient	88:248736be106e	1331	{
AzureIoTClient	88:248736be106e	1332	iotHubClientInstance->message_callback = messageCallback;
AzureIoTClient	88:248736be106e	1333	}
AzureIoTClient	88:248736be106e	1334	if (iotHubClientInstance->message_user_context != NULL)
AzureIoTClient	88:248736be106e	1335	{
AzureIoTClient	88:248736be106e	1336	free(iotHubClientInstance->message_user_context);
AzureIoTClient	88:248736be106e	1337	iotHubClientInstance->message_user_context = NULL;
AzureIoTClient	88:248736be106e	1338	}
AzureIoTClient	88:248736be106e	1339	if (messageCallback == NULL)
AzureIoTClient	88:248736be106e	1340	{
AzureIoTClient	88:248736be106e	1341	result = IoTHubClientCore_LL_SetMessageCallback_Ex(iotHubClientInstance->IoTHubClientLLHandle, NULL, iotHubClientInstance->message_user_context);
AzureIoTClient	88:248736be106e	1342	}
AzureIoTClient	88:248736be106e	1343	else if (iotHubClientInstance->created_with_transport_handle != 0)
AzureIoTClient	88:248736be106e	1344	{
AzureIoTClient	88:248736be106e	1345	result = IoTHubClientCore_LL_SetMessageCallback(iotHubClientInstance->IoTHubClientLLHandle, messageCallback, userContextCallback);
AzureIoTClient	88:248736be106e	1346	}
AzureIoTClient	88:248736be106e	1347	else
AzureIoTClient	88:248736be106e	1348	{
AzureIoTClient	88:248736be106e	1349	iotHubClientInstance->message_user_context = (IOTHUB_QUEUE_CONTEXT*)malloc(sizeof(IOTHUB_QUEUE_CONTEXT));
AzureIoTClient	88:248736be106e	1350	if (iotHubClientInstance->message_user_context == NULL)
AzureIoTClient	88:248736be106e	1351	{
AzureIoTClient	88:248736be106e	1352	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1353	LogError("Failed allocating QUEUE_CONTEXT");
AzureIoTClient	88:248736be106e	1354	}
AzureIoTClient	88:248736be106e	1355	else
AzureIoTClient	88:248736be106e	1356	{
AzureIoTClient	88:248736be106e	1357	iotHubClientInstance->message_user_context->iotHubClientHandle = iotHubClientHandle;
AzureIoTClient	88:248736be106e	1358	iotHubClientInstance->message_user_context->userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1359
AzureIoTClient	88:248736be106e	1360	/* Codes_SRS_IOTHUBCLIENT_01_017: [IoTHubClient_SetMessageCallback shall call IoTHubClientCore_LL_SetMessageCallback_Ex, while passing the IoTHubClientCore_LL handle created by IoTHubClient_Create and the local iothub_ll_message_callback wrapper of messageCallback and userContextCallback.] */
AzureIoTClient	88:248736be106e	1361	/* Codes_SRS_IOTHUBCLIENT_01_018: [When IoTHubClientCore_LL_SetMessageCallback_Ex is called, IoTHubClient_SetMessageCallback shall return the result of IoTHubClientCore_LL_SetMessageCallback_Ex.] */
AzureIoTClient	88:248736be106e	1362	result = IoTHubClientCore_LL_SetMessageCallback_Ex(iotHubClientInstance->IoTHubClientLLHandle, iothub_ll_message_callback, iotHubClientInstance->message_user_context);
AzureIoTClient	88:248736be106e	1363	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1364	{
AzureIoTClient	88:248736be106e	1365	LogError("IoTHubClientCore_LL_SetMessageCallback failed");
AzureIoTClient	88:248736be106e	1366	free(iotHubClientInstance->message_user_context);
AzureIoTClient	88:248736be106e	1367	iotHubClientInstance->message_user_context = NULL;
AzureIoTClient	88:248736be106e	1368	}
AzureIoTClient	88:248736be106e	1369	}
AzureIoTClient	88:248736be106e	1370	}
AzureIoTClient	88:248736be106e	1371
AzureIoTClient	88:248736be106e	1372	/* Codes_SRS_IOTHUBCLIENT_01_027: [IoTHubClient_SetMessageCallback shall be made thread-safe by using the lock created in IoTHubClient_Create.] */
AzureIoTClient	88:248736be106e	1373	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1374	}
AzureIoTClient	88:248736be106e	1375	}
AzureIoTClient	88:248736be106e	1376	}
AzureIoTClient	88:248736be106e	1377
AzureIoTClient	88:248736be106e	1378	return result;
AzureIoTClient	88:248736be106e	1379	}
AzureIoTClient	88:248736be106e	1380
AzureIoTClient	88:248736be106e	1381	IOTHUB_CLIENT_RESULT IoTHubClientCore_SetConnectionStatusCallback(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_CLIENT_CONNECTION_STATUS_CALLBACK connectionStatusCallback, void * userContextCallback)
AzureIoTClient	88:248736be106e	1382	{
AzureIoTClient	88:248736be106e	1383	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1384
AzureIoTClient	88:248736be106e	1385	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1386	{
AzureIoTClient	88:248736be106e	1387	/* Codes_SRS_IOTHUBCLIENT_25_076: [** If `iotHubClientHandle` is `NULL`, `IoTHubClient_SetRetryPolicy` shall return `IOTHUB_CLIENT_INVALID_ARG`. ] */
AzureIoTClient	88:248736be106e	1388	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1389	LogError("NULL iothubClientHandle");
AzureIoTClient	88:248736be106e	1390	}
AzureIoTClient	88:248736be106e	1391	else
AzureIoTClient	88:248736be106e	1392	{
AzureIoTClient	88:248736be106e	1393	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1394
AzureIoTClient	88:248736be106e	1395	/* Codes_SRS_IOTHUBCLIENT_25_081: [ `IoTHubClient_SetConnectionStatusCallback` shall start the worker thread if it was not previously started. ]*/
AzureIoTClient	88:248736be106e	1396	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1397	{
AzureIoTClient	88:248736be106e	1398	/* Codes_SRS_IOTHUBCLIENT_25_083: [ If starting the thread fails, `IoTHubClient_SetConnectionStatusCallback` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1399	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1400	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1401	}
AzureIoTClient	88:248736be106e	1402	else
AzureIoTClient	88:248736be106e	1403	{
AzureIoTClient	88:248736be106e	1404	/* Codes_SRS_IOTHUBCLIENT_25_087: [ `IoTHubClient_SetConnectionStatusCallback` shall be made thread-safe by using the lock created in `IoTHubClient_Create`. ] */
AzureIoTClient	88:248736be106e	1405	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1406	{
AzureIoTClient	88:248736be106e	1407	/* Codes_SRS_IOTHUBCLIENT_25_088: [ If acquiring the lock fails, `IoTHubClient_SetConnectionStatusCallback` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1408	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1409	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1410	}
AzureIoTClient	88:248736be106e	1411	else
AzureIoTClient	88:248736be106e	1412	{
AzureIoTClient	88:248736be106e	1413	if (iotHubClientInstance->created_with_transport_handle == 0)
AzureIoTClient	88:248736be106e	1414	{
AzureIoTClient	88:248736be106e	1415	iotHubClientInstance->connection_status_callback = connectionStatusCallback;
AzureIoTClient	88:248736be106e	1416	}
AzureIoTClient	88:248736be106e	1417
AzureIoTClient	88:248736be106e	1418	if (iotHubClientInstance->created_with_transport_handle != 0 \|\| connectionStatusCallback == NULL)
AzureIoTClient	88:248736be106e	1419	{
AzureIoTClient	88:248736be106e	1420	/* Codes_SRS_IOTHUBCLIENT_25_085: [ `IoTHubClient_SetConnectionStatusCallback` shall call `IoTHubClientCore_LL_SetConnectionStatusCallback`, while passing the `IoTHubClientCore_LL` handle created by `IoTHubClient_Create` and the parameters `connectionStatusCallback` and `userContextCallback`. ]*/
AzureIoTClient	88:248736be106e	1421	result = IoTHubClientCore_LL_SetConnectionStatusCallback(iotHubClientInstance->IoTHubClientLLHandle, connectionStatusCallback, userContextCallback);
AzureIoTClient	88:248736be106e	1422	}
AzureIoTClient	88:248736be106e	1423	else
AzureIoTClient	88:248736be106e	1424	{
AzureIoTClient	88:248736be106e	1425	if (iotHubClientInstance->connection_status_user_context != NULL)
AzureIoTClient	88:248736be106e	1426	{
AzureIoTClient	88:248736be106e	1427	free(iotHubClientInstance->connection_status_user_context);
AzureIoTClient	88:248736be106e	1428	}
AzureIoTClient	88:248736be106e	1429	iotHubClientInstance->connection_status_user_context = (IOTHUB_QUEUE_CONTEXT*)malloc(sizeof(IOTHUB_QUEUE_CONTEXT));
AzureIoTClient	88:248736be106e	1430	if (iotHubClientInstance->connection_status_user_context == NULL)
AzureIoTClient	88:248736be106e	1431	{
AzureIoTClient	88:248736be106e	1432	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1433	LogError("Failed allocating QUEUE_CONTEXT");
AzureIoTClient	88:248736be106e	1434	}
AzureIoTClient	88:248736be106e	1435	else
AzureIoTClient	88:248736be106e	1436	{
AzureIoTClient	88:248736be106e	1437	iotHubClientInstance->connection_status_user_context->iotHubClientHandle = iotHubClientInstance;
AzureIoTClient	88:248736be106e	1438	iotHubClientInstance->connection_status_user_context->userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1439
AzureIoTClient	88:248736be106e	1440	/* Codes_SRS_IOTHUBCLIENT_25_085: [ `IoTHubClient_SetConnectionStatusCallback` shall call `IoTHubClientCore_LL_SetConnectionStatusCallback`, while passing the `IoTHubClientCore_LL` handle created by `IoTHubClient_Create` and the parameters `connectionStatusCallback` and `userContextCallback`. ]*/
AzureIoTClient	88:248736be106e	1441	result = IoTHubClientCore_LL_SetConnectionStatusCallback(iotHubClientInstance->IoTHubClientLLHandle, iothub_ll_connection_status_callback, iotHubClientInstance->connection_status_user_context);
AzureIoTClient	88:248736be106e	1442	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1443	{
AzureIoTClient	88:248736be106e	1444	LogError("IoTHubClientCore_LL_SetConnectionStatusCallback failed");
AzureIoTClient	88:248736be106e	1445	free(iotHubClientInstance->connection_status_user_context);
AzureIoTClient	88:248736be106e	1446	iotHubClientInstance->connection_status_user_context = NULL;
AzureIoTClient	88:248736be106e	1447	}
AzureIoTClient	88:248736be106e	1448	}
AzureIoTClient	88:248736be106e	1449	}
AzureIoTClient	88:248736be106e	1450	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1451	}
AzureIoTClient	88:248736be106e	1452	}
AzureIoTClient	88:248736be106e	1453	}
AzureIoTClient	88:248736be106e	1454	return result;
AzureIoTClient	88:248736be106e	1455	}
AzureIoTClient	88:248736be106e	1456
AzureIoTClient	88:248736be106e	1457	IOTHUB_CLIENT_RESULT IoTHubClientCore_SetRetryPolicy(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_CLIENT_RETRY_POLICY retryPolicy, size_t retryTimeoutLimitInSeconds)
AzureIoTClient	88:248736be106e	1458	{
AzureIoTClient	88:248736be106e	1459	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1460
AzureIoTClient	88:248736be106e	1461	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1462	{
AzureIoTClient	88:248736be106e	1463	/* Codes_SRS_IOTHUBCLIENT_25_076: [** If `iotHubClientHandle` is `NULL`, `IoTHubClient_SetRetryPolicy` shall return `IOTHUB_CLIENT_INVALID_ARG`. ] */
AzureIoTClient	88:248736be106e	1464	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1465	LogError("NULL iothubClientHandle");
AzureIoTClient	88:248736be106e	1466	}
AzureIoTClient	88:248736be106e	1467	else
AzureIoTClient	88:248736be106e	1468	{
AzureIoTClient	88:248736be106e	1469	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1470
AzureIoTClient	88:248736be106e	1471	/* Codes_SRS_IOTHUBCLIENT_25_073: [ `IoTHubClient_SetRetryPolicy` shall start the worker thread if it was not previously started. ] */
AzureIoTClient	88:248736be106e	1472	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1473	{
AzureIoTClient	88:248736be106e	1474	/* Codes_SRS_IOTHUBCLIENT_25_075: [ If starting the thread fails, `IoTHubClient_SetRetryPolicy` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1475	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1476	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1477	}
AzureIoTClient	88:248736be106e	1478	else
AzureIoTClient	88:248736be106e	1479	{
AzureIoTClient	88:248736be106e	1480	/* Codes_SRS_IOTHUBCLIENT_25_079: [ `IoTHubClient_SetRetryPolicy` shall be made thread-safe by using the lock created in `IoTHubClient_Create`.] */
AzureIoTClient	88:248736be106e	1481	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1482	{
AzureIoTClient	88:248736be106e	1483	/* Codes_SRS_IOTHUBCLIENT_25_080: [ If acquiring the lock fails, `IoTHubClient_SetRetryPolicy` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1484	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1485	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1486	}
AzureIoTClient	88:248736be106e	1487	else
AzureIoTClient	88:248736be106e	1488	{
AzureIoTClient	88:248736be106e	1489	/* Codes_SRS_IOTHUBCLIENT_25_077: [ `IoTHubClient_SetRetryPolicy` shall call `IoTHubClientCore_LL_SetRetryPolicy`, while passing the `IoTHubClientCore_LL` handle created by `IoTHubClient_Create` and the parameters `retryPolicy` and `retryTimeoutLimitinSeconds`.]*/
AzureIoTClient	88:248736be106e	1490	result = IoTHubClientCore_LL_SetRetryPolicy(iotHubClientInstance->IoTHubClientLLHandle, retryPolicy, retryTimeoutLimitInSeconds);
AzureIoTClient	88:248736be106e	1491	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1492	}
AzureIoTClient	88:248736be106e	1493
AzureIoTClient	88:248736be106e	1494	}
AzureIoTClient	88:248736be106e	1495	}
AzureIoTClient	88:248736be106e	1496
AzureIoTClient	88:248736be106e	1497	return result;
AzureIoTClient	88:248736be106e	1498	}
AzureIoTClient	88:248736be106e	1499
AzureIoTClient	88:248736be106e	1500	IOTHUB_CLIENT_RESULT IoTHubClientCore_GetRetryPolicy(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_CLIENT_RETRY_POLICY* retryPolicy, size_t* retryTimeoutLimitInSeconds)
AzureIoTClient	88:248736be106e	1501	{
AzureIoTClient	88:248736be106e	1502	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1503
AzureIoTClient	88:248736be106e	1504	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1505	{
AzureIoTClient	88:248736be106e	1506	/* Codes_SRS_IOTHUBCLIENT_25_092: [ If `iotHubClientHandle` is `NULL`, `IoTHubClient_GetRetryPolicy` shall return `IOTHUB_CLIENT_INVALID_ARG`. ]*/
AzureIoTClient	88:248736be106e	1507	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1508	LogError("NULL iothubClientHandle");
AzureIoTClient	88:248736be106e	1509	}
AzureIoTClient	88:248736be106e	1510	else
AzureIoTClient	88:248736be106e	1511	{
AzureIoTClient	88:248736be106e	1512	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1513
AzureIoTClient	88:248736be106e	1514	/* Codes_SRS_IOTHUBCLIENT_25_089: [ `IoTHubClient_GetRetryPolicy` shall start the worker thread if it was not previously started.]*/
AzureIoTClient	88:248736be106e	1515	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1516	{
AzureIoTClient	88:248736be106e	1517	/* Codes_SRS_IOTHUBCLIENT_25_091: [ If starting the thread fails, `IoTHubClient_GetRetryPolicy` shall return `IOTHUB_CLIENT_ERROR`.]*/
AzureIoTClient	88:248736be106e	1518	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1519	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1520	}
AzureIoTClient	88:248736be106e	1521	else
AzureIoTClient	88:248736be106e	1522	{
AzureIoTClient	88:248736be106e	1523	/* Codes_SRS_IOTHUBCLIENT_25_095: [ `IoTHubClient_GetRetryPolicy` shall be made thread-safe by using the lock created in `IoTHubClient_Create`. ]*/
AzureIoTClient	88:248736be106e	1524	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1525	{
AzureIoTClient	88:248736be106e	1526	/* Codes_SRS_IOTHUBCLIENT_25_096: [ If acquiring the lock fails, `IoTHubClient_GetRetryPolicy` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1527	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1528	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1529	}
AzureIoTClient	88:248736be106e	1530	else
AzureIoTClient	88:248736be106e	1531	{
AzureIoTClient	88:248736be106e	1532	/* Codes_SRS_IOTHUBCLIENT_25_093: [ `IoTHubClient_GetRetryPolicy` shall call `IoTHubClientCore_LL_GetRetryPolicy`, while passing the `IoTHubClientCore_LL` handle created by `IoTHubClient_Create` and the parameters `connectionStatusCallback` and `userContextCallback`.]*/
AzureIoTClient	88:248736be106e	1533	result = IoTHubClientCore_LL_GetRetryPolicy(iotHubClientInstance->IoTHubClientLLHandle, retryPolicy, retryTimeoutLimitInSeconds);
AzureIoTClient	88:248736be106e	1534	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1535	}
AzureIoTClient	88:248736be106e	1536	}
AzureIoTClient	88:248736be106e	1537	}
AzureIoTClient	88:248736be106e	1538
AzureIoTClient	88:248736be106e	1539	return result;
AzureIoTClient	88:248736be106e	1540	}
AzureIoTClient	88:248736be106e	1541
AzureIoTClient	88:248736be106e	1542	IOTHUB_CLIENT_RESULT IoTHubClientCore_GetLastMessageReceiveTime(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, time_t* lastMessageReceiveTime)
AzureIoTClient	88:248736be106e	1543	{
AzureIoTClient	88:248736be106e	1544	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1545
AzureIoTClient	88:248736be106e	1546	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1547	{
AzureIoTClient	88:248736be106e	1548	/* Codes_SRS_IOTHUBCLIENT_01_020: [If iotHubClientHandle is NULL, IoTHubClient_GetLastMessageReceiveTime shall return IOTHUB_CLIENT_INVALID_ARG.] */
AzureIoTClient	88:248736be106e	1549	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1550	LogError("NULL iothubClientHandle");
AzureIoTClient	88:248736be106e	1551	}
AzureIoTClient	88:248736be106e	1552	else
AzureIoTClient	88:248736be106e	1553	{
AzureIoTClient	88:248736be106e	1554	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1555
AzureIoTClient	88:248736be106e	1556	/* Codes_SRS_IOTHUBCLIENT_01_035: [IoTHubClient_GetLastMessageReceiveTime shall be made thread-safe by using the lock created in IoTHubClient_Create.] */
AzureIoTClient	88:248736be106e	1557	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1558	{
AzureIoTClient	88:248736be106e	1559	/* Codes_SRS_IOTHUBCLIENT_01_036: [If acquiring the lock fails, IoTHubClient_GetLastMessageReceiveTime shall return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	1560	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1561	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1562	}
AzureIoTClient	88:248736be106e	1563	else
AzureIoTClient	88:248736be106e	1564	{
AzureIoTClient	88:248736be106e	1565	/* Codes_SRS_IOTHUBCLIENT_01_019: [IoTHubClient_GetLastMessageReceiveTime shall call IoTHubClientCore_LL_GetLastMessageReceiveTime, while passing the IoTHubClientCore_LL handle created by IoTHubClient_Create and the parameter lastMessageReceiveTime.] */
AzureIoTClient	88:248736be106e	1566	/* Codes_SRS_IOTHUBCLIENT_01_021: [Otherwise, IoTHubClient_GetLastMessageReceiveTime shall return the result of IoTHubClientCore_LL_GetLastMessageReceiveTime.] */
AzureIoTClient	88:248736be106e	1567	result = IoTHubClientCore_LL_GetLastMessageReceiveTime(iotHubClientInstance->IoTHubClientLLHandle, lastMessageReceiveTime);
AzureIoTClient	88:248736be106e	1568
AzureIoTClient	88:248736be106e	1569	/* Codes_SRS_IOTHUBCLIENT_01_035: [IoTHubClient_GetLastMessageReceiveTime shall be made thread-safe by using the lock created in IoTHubClient_Create.] */
AzureIoTClient	88:248736be106e	1570	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1571	}
AzureIoTClient	88:248736be106e	1572	}
AzureIoTClient	88:248736be106e	1573
AzureIoTClient	88:248736be106e	1574	return result;
AzureIoTClient	88:248736be106e	1575	}
AzureIoTClient	88:248736be106e	1576
AzureIoTClient	88:248736be106e	1577	IOTHUB_CLIENT_RESULT IoTHubClientCore_SetOption(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, const char* optionName, const void* value)
AzureIoTClient	88:248736be106e	1578	{
AzureIoTClient	88:248736be106e	1579	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1580	/Codes_SRS_IOTHUBCLIENT_02_034: [If parameter iotHubClientHandle is NULL then IoTHubClient_SetOption shall return IOTHUB_CLIENT_INVALID_ARG.] /
AzureIoTClient	88:248736be106e	1581	/Codes_SRS_IOTHUBCLIENT_02_035: [ If parameter optionName is NULL then IoTHubClient_SetOption shall return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	1582	/Codes_SRS_IOTHUBCLIENT_02_036: [ If parameter value is NULL then IoTHubClient_SetOption shall return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	1583	if (
AzureIoTClient	88:248736be106e	1584	(iotHubClientHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	1585	(optionName == NULL) \|\|
AzureIoTClient	88:248736be106e	1586	(value == NULL)
AzureIoTClient	88:248736be106e	1587	)
AzureIoTClient	88:248736be106e	1588	{
AzureIoTClient	88:248736be106e	1589	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1590	LogError("invalid arg (NULL)");
AzureIoTClient	88:248736be106e	1591	}
AzureIoTClient	88:248736be106e	1592	else
AzureIoTClient	88:248736be106e	1593	{
AzureIoTClient	88:248736be106e	1594	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1595
AzureIoTClient	88:248736be106e	1596	/* Codes_SRS_IOTHUBCLIENT_01_041: [ IoTHubClient_SetOption shall be made thread-safe by using the lock created in IoTHubClient_Create. ]*/
AzureIoTClient	88:248736be106e	1597	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1598	{
AzureIoTClient	88:248736be106e	1599	/* Codes_SRS_IOTHUBCLIENT_01_042: [ If acquiring the lock fails, IoTHubClient_SetOption shall return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient	88:248736be106e	1600	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1601	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1602	}
AzureIoTClient	88:248736be106e	1603	else
AzureIoTClient	88:248736be106e	1604	{
AzureIoTClient	88:248736be106e	1605	/Codes_SRS_IOTHUBCLIENT_02_038: [If optionName doesn't match one of the options handled by this module then IoTHubClient_SetOption shall call IoTHubClientCore_LL_SetOption passing the same parameters and return what IoTHubClientCore_LL_SetOption returns.] /
AzureIoTClient	88:248736be106e	1606	result = IoTHubClientCore_LL_SetOption(iotHubClientInstance->IoTHubClientLLHandle, optionName, value);
AzureIoTClient	88:248736be106e	1607	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1608	{
AzureIoTClient	88:248736be106e	1609	LogError("IoTHubClientCore_LL_SetOption failed");
AzureIoTClient	88:248736be106e	1610	}
AzureIoTClient	88:248736be106e	1611
AzureIoTClient	88:248736be106e	1612	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1613	}
AzureIoTClient	88:248736be106e	1614	}
AzureIoTClient	88:248736be106e	1615	return result;
AzureIoTClient	88:248736be106e	1616	}
AzureIoTClient	88:248736be106e	1617
AzureIoTClient	88:248736be106e	1618	IOTHUB_CLIENT_RESULT IoTHubClientCore_SetDeviceTwinCallback(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_CLIENT_DEVICE_TWIN_CALLBACK deviceTwinCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1619	{
AzureIoTClient	88:248736be106e	1620	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1621
AzureIoTClient	88:248736be106e	1622	/Codes_SRS_IOTHUBCLIENT_10_001: [* `IoTHubClient_SetDeviceTwinCallback` shall fail and return `IOTHUB_CLIENT_INVALID_ARG` if parameter `iotHubClientHandle` is `NULL`. ]*/
AzureIoTClient	88:248736be106e	1623	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1624	{
AzureIoTClient	88:248736be106e	1625	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1626	LogError("invalid arg (NULL)");
AzureIoTClient	88:248736be106e	1627	}
AzureIoTClient	88:248736be106e	1628	else
AzureIoTClient	88:248736be106e	1629	{
AzureIoTClient	88:248736be106e	1630	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1631
AzureIoTClient	88:248736be106e	1632	/Codes_SRS_IOTHUBCLIENT_10_003: [* If the transport connection is shared, the thread shall be started by calling `IoTHubTransport_StartWorkerThread`. ]*/
AzureIoTClient	88:248736be106e	1633	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1634	{
AzureIoTClient	88:248736be106e	1635	/Codes_SRS_IOTHUBCLIENT_10_004: [* If starting the thread fails, `IoTHubClient_SetDeviceTwinCallback` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1636	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1637	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1638	}
AzureIoTClient	88:248736be106e	1639	else
AzureIoTClient	88:248736be106e	1640	{
AzureIoTClient	88:248736be106e	1641	/Codes_SRS_IOTHUBCLIENT_10_020: [* `IoTHubClient_SetDeviceTwinCallback` shall be made thread - safe by using the lock created in IoTHubClient_Create. ]*/
AzureIoTClient	88:248736be106e	1642	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1643	{
AzureIoTClient	88:248736be106e	1644	/Codes_SRS_IOTHUBCLIENT_10_002: [* If acquiring the lock fails, `IoTHubClient_SetDeviceTwinCallback` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1645	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1646	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1647	}
AzureIoTClient	88:248736be106e	1648	else
AzureIoTClient	88:248736be106e	1649	{
AzureIoTClient	88:248736be106e	1650	if (iotHubClientInstance->created_with_transport_handle == 0)
AzureIoTClient	88:248736be106e	1651	{
AzureIoTClient	88:248736be106e	1652	iotHubClientInstance->desired_state_callback = deviceTwinCallback;
AzureIoTClient	88:248736be106e	1653	}
AzureIoTClient	88:248736be106e	1654
AzureIoTClient	88:248736be106e	1655	if (iotHubClientInstance->created_with_transport_handle != 0 \|\| deviceTwinCallback == NULL)
AzureIoTClient	88:248736be106e	1656	{
AzureIoTClient	88:248736be106e	1657	/Codes_SRS_IOTHUBCLIENT_10_005: [* `IoTHubClientCore_LL_SetDeviceTwinCallback` shall call `IoTHubClientCore_LL_SetDeviceTwinCallback`, while passing the `IoTHubClientCore_LL handle` created by `IoTHubClientCore_LL_Create` along with the parameters `reportedStateCallback` and `userContextCallback`. ]*/
AzureIoTClient	88:248736be106e	1658	result = IoTHubClientCore_LL_SetDeviceTwinCallback(iotHubClientInstance->IoTHubClientLLHandle, deviceTwinCallback, userContextCallback);
AzureIoTClient	88:248736be106e	1659	}
AzureIoTClient	88:248736be106e	1660	else
AzureIoTClient	88:248736be106e	1661	{
AzureIoTClient	88:248736be106e	1662	if (iotHubClientInstance->devicetwin_user_context != NULL)
AzureIoTClient	88:248736be106e	1663	{
AzureIoTClient	88:248736be106e	1664	free(iotHubClientInstance->devicetwin_user_context);
AzureIoTClient	88:248736be106e	1665	}
AzureIoTClient	88:248736be106e	1666
AzureIoTClient	88:248736be106e	1667	/Codes_SRS_IOTHUBCLIENT_07_002: [ IoTHubClient_SetDeviceTwinCallback shall allocate a IOTHUB_QUEUE_CONTEXT object to be sent to the IoTHubClientCore_LL_SetDeviceTwinCallback function as a user context. ]/
AzureIoTClient	88:248736be106e	1668	iotHubClientInstance->devicetwin_user_context = (IOTHUB_QUEUE_CONTEXT*)malloc(sizeof(IOTHUB_QUEUE_CONTEXT));
AzureIoTClient	88:248736be106e	1669	if (iotHubClientInstance->devicetwin_user_context == NULL)
AzureIoTClient	88:248736be106e	1670	{
AzureIoTClient	88:248736be106e	1671	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1672	LogError("Failed allocating QUEUE_CONTEXT");
AzureIoTClient	88:248736be106e	1673	}
AzureIoTClient	88:248736be106e	1674	else
AzureIoTClient	88:248736be106e	1675	{
AzureIoTClient	88:248736be106e	1676	/Codes_SRS_IOTHUBCLIENT_10_005: [* `IoTHubClientCore_LL_SetDeviceTwinCallback` shall call `IoTHubClientCore_LL_SetDeviceTwinCallback`, while passing the `IoTHubClientCore_LL handle` created by `IoTHubClientCore_LL_Create` along with the parameters `iothub_ll_device_twin_callback` and IOTHUB_QUEUE_CONTEXT variable. ]*/
AzureIoTClient	88:248736be106e	1677	iotHubClientInstance->devicetwin_user_context->iotHubClientHandle = iotHubClientInstance;
AzureIoTClient	88:248736be106e	1678	iotHubClientInstance->devicetwin_user_context->userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1679	result = IoTHubClientCore_LL_SetDeviceTwinCallback(iotHubClientInstance->IoTHubClientLLHandle, iothub_ll_device_twin_callback, iotHubClientInstance->devicetwin_user_context);
AzureIoTClient	88:248736be106e	1680	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1681	{
AzureIoTClient	88:248736be106e	1682	LogError("IoTHubClientCore_LL_SetDeviceTwinCallback failed");
AzureIoTClient	88:248736be106e	1683	free(iotHubClientInstance->devicetwin_user_context);
AzureIoTClient	88:248736be106e	1684	iotHubClientInstance->devicetwin_user_context = NULL;
AzureIoTClient	88:248736be106e	1685	}
AzureIoTClient	88:248736be106e	1686	}
AzureIoTClient	88:248736be106e	1687	}
AzureIoTClient	88:248736be106e	1688
AzureIoTClient	88:248736be106e	1689	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1690	}
AzureIoTClient	88:248736be106e	1691	}
AzureIoTClient	88:248736be106e	1692	}
AzureIoTClient	88:248736be106e	1693	return result;
AzureIoTClient	88:248736be106e	1694	}
AzureIoTClient	88:248736be106e	1695
AzureIoTClient	88:248736be106e	1696	IOTHUB_CLIENT_RESULT IoTHubClientCore_SendReportedState(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, const unsigned char* reportedState, size_t size, IOTHUB_CLIENT_REPORTED_STATE_CALLBACK reportedStateCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1697	{
AzureIoTClient	88:248736be106e	1698	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1699
AzureIoTClient	88:248736be106e	1700	/Codes_SRS_IOTHUBCLIENT_10_013: [* If `iotHubClientHandle` is `NULL`, `IoTHubClient_SendReportedState` shall return `IOTHUB_CLIENT_INVALID_ARG`. ]*/
AzureIoTClient	88:248736be106e	1701	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1702	{
AzureIoTClient	88:248736be106e	1703	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1704	LogError("invalid arg (NULL)");
AzureIoTClient	88:248736be106e	1705	}
AzureIoTClient	88:248736be106e	1706	else
AzureIoTClient	88:248736be106e	1707	{
AzureIoTClient	88:248736be106e	1708	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1709
AzureIoTClient	88:248736be106e	1710	/Codes_SRS_IOTHUBCLIENT_10_015: [* If the transport connection is shared, the thread shall be started by calling `IoTHubTransport_StartWorkerThread`. ]*/
AzureIoTClient	88:248736be106e	1711	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1712	{
AzureIoTClient	88:248736be106e	1713	/Codes_SRS_IOTHUBCLIENT_10_016: [* If starting the thread fails, `IoTHubClient_SendReportedState` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1714	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1715	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1716	}
AzureIoTClient	88:248736be106e	1717	else
AzureIoTClient	88:248736be106e	1718	{
AzureIoTClient	88:248736be106e	1719	/Codes_SRS_IOTHUBCLIENT_10_021: [* `IoTHubClient_SendReportedState` shall be made thread-safe by using the lock created in IoTHubClient_Create. ]*/
AzureIoTClient	88:248736be106e	1720	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1721	{
AzureIoTClient	88:248736be106e	1722	/Codes_SRS_IOTHUBCLIENT_10_014: [* If acquiring the lock fails, `IoTHubClient_SendReportedState` shall return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	88:248736be106e	1723	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1724	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1725	}
AzureIoTClient	88:248736be106e	1726	else
AzureIoTClient	88:248736be106e	1727	{
AzureIoTClient	88:248736be106e	1728	if (iotHubClientInstance->created_with_transport_handle == 0)
AzureIoTClient	88:248736be106e	1729	{
AzureIoTClient	88:248736be106e	1730	iotHubClientInstance->reported_state_callback = reportedStateCallback;
AzureIoTClient	88:248736be106e	1731	}
AzureIoTClient	88:248736be106e	1732
AzureIoTClient	88:248736be106e	1733	if (iotHubClientInstance->created_with_transport_handle != 0 \|\| reportedStateCallback == NULL)
AzureIoTClient	88:248736be106e	1734	{
AzureIoTClient	88:248736be106e	1735	/Codes_SRS_IOTHUBCLIENT_10_017: [* `IoTHubClient_SendReportedState` shall call `IoTHubClientCore_LL_SendReportedState`, while passing the `IoTHubClientCore_LL handle` created by `IoTHubClientCore_LL_Create` along with the parameters `reportedState`, `size`, `reportedStateCallback`, and `userContextCallback`. ]*/
AzureIoTClient	88:248736be106e	1736	/Codes_SRS_IOTHUBCLIENT_10_018: [* When `IoTHubClientCore_LL_SendReportedState` is called, `IoTHubClient_SendReportedState` shall return the result of `IoTHubClientCore_LL_SendReportedState`. *]/
AzureIoTClient	88:248736be106e	1737	result = IoTHubClientCore_LL_SendReportedState(iotHubClientInstance->IoTHubClientLLHandle, reportedState, size, reportedStateCallback, userContextCallback);
AzureIoTClient	88:248736be106e	1738	}
AzureIoTClient	88:248736be106e	1739	else
AzureIoTClient	88:248736be106e	1740	{
AzureIoTClient	88:248736be106e	1741	/* Codes_SRS_IOTHUBCLIENT_07_003: [ IoTHubClient_SendReportedState shall allocate a IOTHUB_QUEUE_CONTEXT object to be sent to the IoTHubClientCore_LL_SendReportedState function as a user context. ] */
AzureIoTClient	88:248736be106e	1742	IOTHUB_QUEUE_CONTEXT* queue_context = (IOTHUB_QUEUE_CONTEXT*)malloc(sizeof(IOTHUB_QUEUE_CONTEXT));
AzureIoTClient	88:248736be106e	1743	if (queue_context == NULL)
AzureIoTClient	88:248736be106e	1744	{
AzureIoTClient	88:248736be106e	1745	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1746	LogError("Failed allocating QUEUE_CONTEXT");
AzureIoTClient	88:248736be106e	1747	}
AzureIoTClient	88:248736be106e	1748	else
AzureIoTClient	88:248736be106e	1749	{
AzureIoTClient	88:248736be106e	1750	queue_context->iotHubClientHandle = iotHubClientInstance;
AzureIoTClient	88:248736be106e	1751	queue_context->userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1752	/Codes_SRS_IOTHUBCLIENT_10_017: [* `IoTHubClient_SendReportedState` shall call `IoTHubClientCore_LL_SendReportedState`, while passing the `IoTHubClientCore_LL handle` created by `IoTHubClientCore_LL_Create` along with the parameters `reportedState`, `size`, `iothub_ll_reported_state_callback` and IOTHUB_QUEUE_CONTEXT variable. ]*/
AzureIoTClient	88:248736be106e	1753	/Codes_SRS_IOTHUBCLIENT_10_018: [* When `IoTHubClientCore_LL_SendReportedState` is called, `IoTHubClient_SendReportedState` shall return the result of `IoTHubClientCore_LL_SendReportedState`. *]/
AzureIoTClient	88:248736be106e	1754	result = IoTHubClientCore_LL_SendReportedState(iotHubClientInstance->IoTHubClientLLHandle, reportedState, size, iothub_ll_reported_state_callback, queue_context);
AzureIoTClient	88:248736be106e	1755	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1756	{
AzureIoTClient	88:248736be106e	1757	LogError("IoTHubClientCore_LL_SendReportedState failed");
AzureIoTClient	88:248736be106e	1758	free(queue_context);
AzureIoTClient	88:248736be106e	1759	}
AzureIoTClient	88:248736be106e	1760	}
AzureIoTClient	88:248736be106e	1761	}
AzureIoTClient	88:248736be106e	1762
AzureIoTClient	88:248736be106e	1763	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1764	}
AzureIoTClient	88:248736be106e	1765	}
AzureIoTClient	88:248736be106e	1766	}
AzureIoTClient	88:248736be106e	1767	return result;
AzureIoTClient	88:248736be106e	1768	}
AzureIoTClient	88:248736be106e	1769
AzureIoTClient	88:248736be106e	1770	IOTHUB_CLIENT_RESULT IoTHubClientCore_SetDeviceMethodCallback(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_CLIENT_DEVICE_METHOD_CALLBACK_ASYNC deviceMethodCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1771	{
AzureIoTClient	88:248736be106e	1772	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1773
AzureIoTClient	88:248736be106e	1774	/Codes_SRS_IOTHUBCLIENT_12_012: [ If iotHubClientHandle is NULL, IoTHubClient_SetDeviceMethodCallback shall return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	1775	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1776	{
AzureIoTClient	88:248736be106e	1777	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1778	LogError("invalid arg (NULL)");
AzureIoTClient	88:248736be106e	1779	}
AzureIoTClient	88:248736be106e	1780	else
AzureIoTClient	88:248736be106e	1781	{
AzureIoTClient	88:248736be106e	1782	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1783
AzureIoTClient	88:248736be106e	1784	/Codes_SRS_IOTHUBCLIENT_12_014: [ If the transport handle is null and the worker thread is not initialized, the thread shall be started by calling IoTHubTransport_StartWorkerThread. ]/
AzureIoTClient	88:248736be106e	1785	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1786	{
AzureIoTClient	88:248736be106e	1787	/Codes_SRS_IOTHUBCLIENT_12_015: [ If starting the thread fails, IoTHubClient_SetDeviceMethodCallback shall return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	1788	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1789	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1790	}
AzureIoTClient	88:248736be106e	1791	else
AzureIoTClient	88:248736be106e	1792	{
AzureIoTClient	88:248736be106e	1793	/Codes_SRS_IOTHUBCLIENT_12_018: [ IoTHubClient_SetDeviceMethodCallback shall be made thread-safe by using the lock created in IoTHubClient_Create. ]/
AzureIoTClient	88:248736be106e	1794	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1795	{
AzureIoTClient	88:248736be106e	1796	/Codes_SRS_IOTHUBCLIENT_12_013: [ If acquiring the lock fails, IoTHubClient_SetDeviceMethodCallback shall return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	1797	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1798	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1799	}
AzureIoTClient	88:248736be106e	1800	else
AzureIoTClient	88:248736be106e	1801	{
AzureIoTClient	88:248736be106e	1802	if (iotHubClientInstance->created_with_transport_handle == 0)
AzureIoTClient	88:248736be106e	1803	{
AzureIoTClient	88:248736be106e	1804	iotHubClientInstance->device_method_callback = deviceMethodCallback;
AzureIoTClient	88:248736be106e	1805	}
AzureIoTClient	88:248736be106e	1806
AzureIoTClient	88:248736be106e	1807	if (iotHubClientInstance->method_user_context)
AzureIoTClient	88:248736be106e	1808	{
AzureIoTClient	88:248736be106e	1809	free(iotHubClientInstance->method_user_context);
AzureIoTClient	88:248736be106e	1810	iotHubClientInstance->method_user_context = NULL;
AzureIoTClient	88:248736be106e	1811	}
AzureIoTClient	88:248736be106e	1812	if (deviceMethodCallback == NULL)
AzureIoTClient	88:248736be106e	1813	{
AzureIoTClient	88:248736be106e	1814	result = IoTHubClientCore_LL_SetDeviceMethodCallback_Ex(iotHubClientInstance->IoTHubClientLLHandle, NULL, NULL);
AzureIoTClient	88:248736be106e	1815	}
AzureIoTClient	88:248736be106e	1816	else
AzureIoTClient	88:248736be106e	1817	{
AzureIoTClient	88:248736be106e	1818	iotHubClientInstance->method_user_context = (IOTHUB_QUEUE_CONTEXT*)malloc(sizeof(IOTHUB_QUEUE_CONTEXT));
AzureIoTClient	88:248736be106e	1819	if (iotHubClientInstance->method_user_context == NULL)
AzureIoTClient	88:248736be106e	1820	{
AzureIoTClient	88:248736be106e	1821	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1822	LogError("Failed allocating QUEUE_CONTEXT");
AzureIoTClient	88:248736be106e	1823	}
AzureIoTClient	88:248736be106e	1824	else
AzureIoTClient	88:248736be106e	1825	{
AzureIoTClient	88:248736be106e	1826	iotHubClientInstance->method_user_context->iotHubClientHandle = iotHubClientHandle;
AzureIoTClient	88:248736be106e	1827	iotHubClientInstance->method_user_context->userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1828
AzureIoTClient	88:248736be106e	1829	/Codes_SRS_IOTHUBCLIENT_12_016: [ IoTHubClient_SetDeviceMethodCallback shall call IoTHubClientCore_LL_SetDeviceMethodCallback, while passing the IoTHubClientCore_LL_handle created by IoTHubClientCore_LL_Create along with the parameters deviceMethodCallback and userContextCallback. ]/
AzureIoTClient	88:248736be106e	1830	/Codes_SRS_IOTHUBCLIENT_12_017: [ When IoTHubClientCore_LL_SetDeviceMethodCallback is called, IoTHubClient_SetDeviceMethodCallback shall return the result of IoTHubClientCore_LL_SetDeviceMethodCallback. ]/
AzureIoTClient	88:248736be106e	1831	result = IoTHubClientCore_LL_SetDeviceMethodCallback_Ex(iotHubClientInstance->IoTHubClientLLHandle, iothub_ll_device_method_callback, iotHubClientInstance->method_user_context);
AzureIoTClient	88:248736be106e	1832	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1833	{
AzureIoTClient	88:248736be106e	1834	LogError("IoTHubClientCore_LL_SetDeviceMethodCallback_Ex failed");
AzureIoTClient	88:248736be106e	1835	free(iotHubClientInstance->method_user_context);
AzureIoTClient	88:248736be106e	1836	iotHubClientInstance->method_user_context = NULL;
AzureIoTClient	88:248736be106e	1837	}
AzureIoTClient	88:248736be106e	1838	else
AzureIoTClient	88:248736be106e	1839	{
AzureIoTClient	88:248736be106e	1840	iotHubClientInstance->device_method_callback = deviceMethodCallback;
AzureIoTClient	88:248736be106e	1841	}
AzureIoTClient	88:248736be106e	1842	}
AzureIoTClient	88:248736be106e	1843	}
AzureIoTClient	88:248736be106e	1844
AzureIoTClient	88:248736be106e	1845	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1846	}
AzureIoTClient	88:248736be106e	1847
AzureIoTClient	88:248736be106e	1848	}
AzureIoTClient	88:248736be106e	1849	}
AzureIoTClient	88:248736be106e	1850	return result;
AzureIoTClient	88:248736be106e	1851	}
AzureIoTClient	88:248736be106e	1852
AzureIoTClient	88:248736be106e	1853	IOTHUB_CLIENT_RESULT IoTHubClientCore_SetDeviceMethodCallback_Ex(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK inboundDeviceMethodCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1854	{
AzureIoTClient	88:248736be106e	1855	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1856
AzureIoTClient	88:248736be106e	1857	/Codes_SRS_IOTHUBCLIENT_07_001: [ If iotHubClientHandle is NULL, IoTHubClient_SetDeviceMethodCallback_Ex shall return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	1858	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1859	{
AzureIoTClient	88:248736be106e	1860	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1861	LogError("invalid arg (NULL)");
AzureIoTClient	88:248736be106e	1862	}
AzureIoTClient	88:248736be106e	1863	else
AzureIoTClient	88:248736be106e	1864	{
AzureIoTClient	88:248736be106e	1865	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1866
AzureIoTClient	88:248736be106e	1867	/Codes_SRS_IOTHUBCLIENT_07_003: [ If the transport handle is NULL and the worker thread is not initialized, the thread shall be started by calling IoTHubTransport_StartWorkerThread. ]/
AzureIoTClient	88:248736be106e	1868	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1869	{
AzureIoTClient	88:248736be106e	1870	/Codes_SRS_IOTHUBCLIENT_07_004: [ If starting the thread fails, IoTHubClient_SetDeviceMethodCallback_Ex shall return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	1871	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1872	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	1873	}
AzureIoTClient	88:248736be106e	1874	else
AzureIoTClient	88:248736be106e	1875	{
AzureIoTClient	88:248736be106e	1876	/Codes_SRS_IOTHUBCLIENT_07_007: [ IoTHubClient_SetDeviceMethodCallback_Ex shall be made thread-safe by using the lock created in IoTHubClient_Create. ]/
AzureIoTClient	88:248736be106e	1877	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1878	{
AzureIoTClient	88:248736be106e	1879	/Codes_SRS_IOTHUBCLIENT_07_002: [ If acquiring the lock fails, IoTHubClient_SetDeviceMethodCallback_Ex shall return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	1880	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1881	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1882	}
AzureIoTClient	88:248736be106e	1883	else
AzureIoTClient	88:248736be106e	1884	{
AzureIoTClient	88:248736be106e	1885	if (iotHubClientInstance->created_with_transport_handle == 0)
AzureIoTClient	88:248736be106e	1886	{
AzureIoTClient	88:248736be106e	1887	iotHubClientInstance->inbound_device_method_callback = inboundDeviceMethodCallback;
AzureIoTClient	88:248736be106e	1888	}
AzureIoTClient	88:248736be106e	1889
AzureIoTClient	88:248736be106e	1890	if (iotHubClientInstance->method_user_context)
AzureIoTClient	88:248736be106e	1891	{
AzureIoTClient	88:248736be106e	1892	free(iotHubClientInstance->method_user_context);
AzureIoTClient	88:248736be106e	1893	iotHubClientInstance->method_user_context = NULL;
AzureIoTClient	88:248736be106e	1894	}
AzureIoTClient	88:248736be106e	1895	if (inboundDeviceMethodCallback == NULL)
AzureIoTClient	88:248736be106e	1896	{
AzureIoTClient	88:248736be106e	1897	/* Codes_SRS_IOTHUBCLIENT_07_008: [ If inboundDeviceMethodCallback is NULL, IoTHubClient_SetDeviceMethodCallback_Ex shall call IoTHubClientCore_LL_SetDeviceMethodCallback_Ex, passing NULL for the iothub_ll_inbound_device_method_callback. ] */
AzureIoTClient	88:248736be106e	1898	result = IoTHubClientCore_LL_SetDeviceMethodCallback_Ex(iotHubClientInstance->IoTHubClientLLHandle, NULL, NULL);
AzureIoTClient	88:248736be106e	1899	}
AzureIoTClient	88:248736be106e	1900	else
AzureIoTClient	88:248736be106e	1901	{
AzureIoTClient	88:248736be106e	1902	iotHubClientInstance->method_user_context = (IOTHUB_QUEUE_CONTEXT*)malloc(sizeof(IOTHUB_QUEUE_CONTEXT));
AzureIoTClient	88:248736be106e	1903	if (iotHubClientInstance->method_user_context == NULL)
AzureIoTClient	88:248736be106e	1904	{
AzureIoTClient	88:248736be106e	1905	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1906	LogError("Failed allocating QUEUE_CONTEXT");
AzureIoTClient	88:248736be106e	1907	}
AzureIoTClient	88:248736be106e	1908	else
AzureIoTClient	88:248736be106e	1909	{
AzureIoTClient	88:248736be106e	1910	/Codes_SRS_IOTHUBCLIENT_07_005: [ IoTHubClient_SetDeviceMethodCallback_Ex shall call IoTHubClientCore_LL_SetDeviceMethodCallback_Ex, while passing the IoTHubClientCore_LL_handle created by IoTHubClientCore_LL_Create along with the parameters iothub_ll_inbound_device_method_callback and IOTHUB_QUEUE_CONTEXT. ]/
AzureIoTClient	88:248736be106e	1911	iotHubClientInstance->method_user_context->iotHubClientHandle = iotHubClientHandle;
AzureIoTClient	88:248736be106e	1912	iotHubClientInstance->method_user_context->userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1913
AzureIoTClient	88:248736be106e	1914	/* Codes_SRS_IOTHUBCLIENT_07_006: [ When IoTHubClientCore_LL_SetDeviceMethodCallback_Ex is called, IoTHubClient_SetDeviceMethodCallback_Ex shall return the result of IoTHubClientCore_LL_SetDeviceMethodCallback_Ex. ] */
AzureIoTClient	88:248736be106e	1915	result = IoTHubClientCore_LL_SetDeviceMethodCallback_Ex(iotHubClientInstance->IoTHubClientLLHandle, iothub_ll_inbound_device_method_callback, iotHubClientInstance->method_user_context);
AzureIoTClient	88:248736be106e	1916	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1917	{
AzureIoTClient	88:248736be106e	1918	LogError("IoTHubClientCore_LL_SetDeviceMethodCallback_Ex failed");
AzureIoTClient	88:248736be106e	1919	free(iotHubClientInstance->method_user_context);
AzureIoTClient	88:248736be106e	1920	iotHubClientInstance->method_user_context = NULL;
AzureIoTClient	88:248736be106e	1921	}
AzureIoTClient	88:248736be106e	1922	else
AzureIoTClient	88:248736be106e	1923	{
AzureIoTClient	88:248736be106e	1924	iotHubClientInstance->inbound_device_method_callback = inboundDeviceMethodCallback;
AzureIoTClient	88:248736be106e	1925	}
AzureIoTClient	88:248736be106e	1926	}
AzureIoTClient	88:248736be106e	1927	}
AzureIoTClient	88:248736be106e	1928
AzureIoTClient	88:248736be106e	1929	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1930	}
AzureIoTClient	88:248736be106e	1931	}
AzureIoTClient	88:248736be106e	1932	}
AzureIoTClient	88:248736be106e	1933	return result;
AzureIoTClient	88:248736be106e	1934	}
AzureIoTClient	88:248736be106e	1935
AzureIoTClient	88:248736be106e	1936	IOTHUB_CLIENT_RESULT IoTHubClientCore_DeviceMethodResponse(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, METHOD_HANDLE methodId, const unsigned char* response, size_t respSize, int statusCode)
AzureIoTClient	88:248736be106e	1937	{
AzureIoTClient	88:248736be106e	1938	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1939
AzureIoTClient	88:248736be106e	1940	/Codes_SRS_IOTHUBCLIENT_12_012: [ If iotHubClientHandle is NULL, IoTHubClient_SetDeviceMethodCallback shall return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	1941	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1942	{
AzureIoTClient	88:248736be106e	1943	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1944	LogError("invalid arg (NULL)");
AzureIoTClient	88:248736be106e	1945	}
AzureIoTClient	88:248736be106e	1946	else
AzureIoTClient	88:248736be106e	1947	{
AzureIoTClient	88:248736be106e	1948	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1949
AzureIoTClient	88:248736be106e	1950	/Codes_SRS_IOTHUBCLIENT_12_018: [ IoTHubClient_SetDeviceMethodCallback shall be made thread-safe by using the lock created in IoTHubClient_Create. ]/
AzureIoTClient	88:248736be106e	1951	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1952	{
AzureIoTClient	88:248736be106e	1953	/Codes_SRS_IOTHUBCLIENT_12_013: [ If acquiring the lock fails, IoTHubClient_SetDeviceMethodCallback shall return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	1954	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1955	LogError("Could not acquire lock");
AzureIoTClient	88:248736be106e	1956	}
AzureIoTClient	88:248736be106e	1957	else
AzureIoTClient	88:248736be106e	1958	{
AzureIoTClient	88:248736be106e	1959	result = IoTHubClientCore_LL_DeviceMethodResponse(iotHubClientInstance->IoTHubClientLLHandle, methodId, response, respSize, statusCode);
AzureIoTClient	88:248736be106e	1960	if (result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	1961	{
AzureIoTClient	88:248736be106e	1962	LogError("IoTHubClientCore_LL_DeviceMethodResponse failed");
AzureIoTClient	88:248736be106e	1963	}
AzureIoTClient	88:248736be106e	1964	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	88:248736be106e	1965	}
AzureIoTClient	88:248736be106e	1966	}
AzureIoTClient	88:248736be106e	1967	return result;
AzureIoTClient	88:248736be106e	1968	}
AzureIoTClient	88:248736be106e	1969
AzureIoTClient	88:248736be106e	1970	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	1971	static IOTHUB_CLIENT_RESULT startUploadToBlobWorkerThread(UPLOADTOBLOB_THREAD_INFO* threadInfo, THREAD_START_FUNC uploadThreadFunc)
AzureIoTClient	88:248736be106e	1972	{
AzureIoTClient	88:248736be106e	1973	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1974
AzureIoTClient	88:248736be106e	1975	LIST_ITEM_HANDLE item;
AzureIoTClient	88:248736be106e	1976
AzureIoTClient	88:248736be106e	1977	if (Lock(threadInfo->iotHubClientHandle->LockHandle) != LOCK_OK)
AzureIoTClient	88:248736be106e	1978	{
AzureIoTClient	88:248736be106e	1979	LogError("Lock failed");
AzureIoTClient	88:248736be106e	1980	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1981	}
AzureIoTClient	88:248736be106e	1982	else
AzureIoTClient	88:248736be106e	1983	{
AzureIoTClient	88:248736be106e	1984	if ((item = singlylinkedlist_add(threadInfo->iotHubClientHandle->savedDataToBeCleaned, threadInfo)) == NULL)
AzureIoTClient	88:248736be106e	1985	{
AzureIoTClient	88:248736be106e	1986	LogError("Adding item to list failed");
AzureIoTClient	88:248736be106e	1987	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1988	}
AzureIoTClient	88:248736be106e	1989	else if (ThreadAPI_Create(&threadInfo->uploadingThreadHandle, uploadThreadFunc, threadInfo) != THREADAPI_OK)
AzureIoTClient	88:248736be106e	1990	{
AzureIoTClient	88:248736be106e	1991	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	1992	LogError("unable to ThreadAPI_Create");
AzureIoTClient	88:248736be106e	1993	// Remove the item from linked list here, while we're still under lock. Final garbage collector also does it under lock.
AzureIoTClient	88:248736be106e	1994	(void)singlylinkedlist_remove(threadInfo->iotHubClientHandle->savedDataToBeCleaned, item);
AzureIoTClient	88:248736be106e	1995	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1996	}
AzureIoTClient	88:248736be106e	1997	else
AzureIoTClient	88:248736be106e	1998	{
AzureIoTClient	88:248736be106e	1999	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2000	}
AzureIoTClient	88:248736be106e	2001	(void)Unlock(threadInfo->iotHubClientHandle->LockHandle);
AzureIoTClient	88:248736be106e	2002	}
AzureIoTClient	88:248736be106e	2003
AzureIoTClient	88:248736be106e	2004	return result;
AzureIoTClient	88:248736be106e	2005	}
AzureIoTClient	88:248736be106e	2006
AzureIoTClient	88:248736be106e	2007	static UPLOADTOBLOB_THREAD_INFO* allocateUploadToBlob(const char* destinationFileName, IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, void* context)
AzureIoTClient	88:248736be106e	2008	{
AzureIoTClient	88:248736be106e	2009	UPLOADTOBLOB_THREAD_INFO* threadInfo = (UPLOADTOBLOB_THREAD_INFO*)malloc(sizeof(UPLOADTOBLOB_THREAD_INFO));
AzureIoTClient	88:248736be106e	2010	if (threadInfo == NULL)
AzureIoTClient	88:248736be106e	2011	{
AzureIoTClient	88:248736be106e	2012	LogError("unable to allocate thread object");
AzureIoTClient	88:248736be106e	2013	}
AzureIoTClient	88:248736be106e	2014	else
AzureIoTClient	88:248736be106e	2015	{
AzureIoTClient	88:248736be106e	2016	memset(threadInfo, 0, sizeof(UPLOADTOBLOB_THREAD_INFO));
AzureIoTClient	88:248736be106e	2017	threadInfo->iotHubClientHandle = iotHubClientHandle;
AzureIoTClient	88:248736be106e	2018	threadInfo->context = context;
AzureIoTClient	88:248736be106e	2019
AzureIoTClient	88:248736be106e	2020	if (mallocAndStrcpy_s(&threadInfo->destinationFileName, destinationFileName) != 0)
AzureIoTClient	88:248736be106e	2021	{
AzureIoTClient	88:248736be106e	2022	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2023	LogError("unable to mallocAndStrcpy_s");
AzureIoTClient	88:248736be106e	2024	freeUploadToBlobThreadInfo(threadInfo);
AzureIoTClient	88:248736be106e	2025	threadInfo = NULL;
AzureIoTClient	88:248736be106e	2026	}
AzureIoTClient	88:248736be106e	2027	else if ((threadInfo->lockGarbage = Lock_Init()) == NULL)
AzureIoTClient	88:248736be106e	2028	{
AzureIoTClient	88:248736be106e	2029	LogError("unable to allocate a lock");
AzureIoTClient	88:248736be106e	2030	freeUploadToBlobThreadInfo(threadInfo);
AzureIoTClient	88:248736be106e	2031	threadInfo = NULL;
AzureIoTClient	88:248736be106e	2032	}
AzureIoTClient	88:248736be106e	2033	}
AzureIoTClient	88:248736be106e	2034
AzureIoTClient	88:248736be106e	2035	return threadInfo;
AzureIoTClient	88:248736be106e	2036	}
AzureIoTClient	88:248736be106e	2037
AzureIoTClient	88:248736be106e	2038	static int markThreadReadyToBeGarbageCollected(UPLOADTOBLOB_THREAD_INFO* threadInfo)
AzureIoTClient	88:248736be106e	2039	{
AzureIoTClient	88:248736be106e	2040	/Codes_SRS_IOTHUBCLIENT_02_071: [ The thread shall mark itself as disposable. ]/
AzureIoTClient	88:248736be106e	2041	if (Lock(threadInfo->lockGarbage) != LOCK_OK)
AzureIoTClient	88:248736be106e	2042	{
AzureIoTClient	88:248736be106e	2043	LogError("unable to Lock - trying anyway");
AzureIoTClient	88:248736be106e	2044	threadInfo->canBeGarbageCollected = 1;
AzureIoTClient	88:248736be106e	2045	}
AzureIoTClient	88:248736be106e	2046	else
AzureIoTClient	88:248736be106e	2047	{
AzureIoTClient	88:248736be106e	2048	threadInfo->canBeGarbageCollected = 1;
AzureIoTClient	88:248736be106e	2049
AzureIoTClient	88:248736be106e	2050	if (Unlock(threadInfo->lockGarbage) != LOCK_OK)
AzureIoTClient	88:248736be106e	2051	{
AzureIoTClient	88:248736be106e	2052	LogError("unable to Unlock after locking");
AzureIoTClient	88:248736be106e	2053	}
AzureIoTClient	88:248736be106e	2054	}
AzureIoTClient	88:248736be106e	2055
AzureIoTClient	88:248736be106e	2056	ThreadAPI_Exit(0);
AzureIoTClient	88:248736be106e	2057	return 0;
AzureIoTClient	88:248736be106e	2058	}
AzureIoTClient	88:248736be106e	2059
AzureIoTClient	88:248736be106e	2060	static IOTHUB_CLIENT_RESULT initializeUploadToBlobData(UPLOADTOBLOB_THREAD_INFO* threadInfo, const unsigned char* source, size_t size, IOTHUB_CLIENT_FILE_UPLOAD_CALLBACK iotHubClientFileUploadCallback)
AzureIoTClient	88:248736be106e	2061	{
AzureIoTClient	88:248736be106e	2062	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2063
AzureIoTClient	88:248736be106e	2064	threadInfo->uploadBlobSavedData.size = size;
AzureIoTClient	88:248736be106e	2065	threadInfo->uploadBlobSavedData.iotHubClientFileUploadCallback = iotHubClientFileUploadCallback;
AzureIoTClient	88:248736be106e	2066
AzureIoTClient	88:248736be106e	2067	if (size != 0)
AzureIoTClient	88:248736be106e	2068	{
AzureIoTClient	88:248736be106e	2069	if ((threadInfo->uploadBlobSavedData.source = (unsigned char*)malloc(size)) == NULL)
AzureIoTClient	88:248736be106e	2070	{
AzureIoTClient	88:248736be106e	2071	LogError("Cannot allocate source field");
AzureIoTClient	88:248736be106e	2072	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2073	}
AzureIoTClient	88:248736be106e	2074	else
AzureIoTClient	88:248736be106e	2075	{
AzureIoTClient	88:248736be106e	2076	memcpy(threadInfo->uploadBlobSavedData.source, source, size);
AzureIoTClient	88:248736be106e	2077	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2078	}
AzureIoTClient	88:248736be106e	2079	}
AzureIoTClient	88:248736be106e	2080	else
AzureIoTClient	88:248736be106e	2081	{
AzureIoTClient	88:248736be106e	2082	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2083	}
AzureIoTClient	88:248736be106e	2084
AzureIoTClient	88:248736be106e	2085	return result;
AzureIoTClient	88:248736be106e	2086	}
AzureIoTClient	88:248736be106e	2087
AzureIoTClient	88:248736be106e	2088
AzureIoTClient	88:248736be106e	2089	static int uploadingThread(void *data)
AzureIoTClient	88:248736be106e	2090	{
AzureIoTClient	88:248736be106e	2091	IOTHUB_CLIENT_FILE_UPLOAD_RESULT upload_result;
AzureIoTClient	88:248736be106e	2092	UPLOADTOBLOB_THREAD_INFO* threadInfo = (UPLOADTOBLOB_THREAD_INFO*)data;
AzureIoTClient	88:248736be106e	2093
AzureIoTClient	88:248736be106e	2094	/it so happens that IoTHubClientCore_LL_UploadToBlob is thread-safe because there's no saved state in the handle and there are no globals, so no need to protect it/
AzureIoTClient	88:248736be106e	2095	/not having it protected means multiple simultaneous uploads can happen/
AzureIoTClient	88:248736be106e	2096	/Codes_SRS_IOTHUBCLIENT_02_054: [ The thread shall call IoTHubClientCore_LL_UploadToBlob passing the information packed in the structure. ]/
AzureIoTClient	88:248736be106e	2097	if (IoTHubClientCore_LL_UploadToBlob(threadInfo->iotHubClientHandle->IoTHubClientLLHandle, threadInfo->destinationFileName, threadInfo->uploadBlobSavedData.source, threadInfo->uploadBlobSavedData.size) == IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	2098	{
AzureIoTClient	88:248736be106e	2099	upload_result = FILE_UPLOAD_OK;
AzureIoTClient	88:248736be106e	2100	}
AzureIoTClient	88:248736be106e	2101	else
AzureIoTClient	88:248736be106e	2102	{
AzureIoTClient	88:248736be106e	2103	LogError("unable to IoTHubClientCore_LL_UploadToBlob");
AzureIoTClient	88:248736be106e	2104	upload_result = FILE_UPLOAD_ERROR;
AzureIoTClient	88:248736be106e	2105	}
AzureIoTClient	88:248736be106e	2106
AzureIoTClient	88:248736be106e	2107	if (threadInfo->uploadBlobSavedData.iotHubClientFileUploadCallback != NULL)
AzureIoTClient	88:248736be106e	2108	{
AzureIoTClient	88:248736be106e	2109	/Codes_SRS_IOTHUBCLIENT_02_055: [ If IoTHubClientCore_LL_UploadToBlob fails then the thread shall call iotHubClientFileUploadCallbackInternal passing as result FILE_UPLOAD_ERROR and as context the structure from SRS IOTHUBCLIENT 02 051. ]/
AzureIoTClient	88:248736be106e	2110	threadInfo->uploadBlobSavedData.iotHubClientFileUploadCallback(upload_result, threadInfo->context);
AzureIoTClient	88:248736be106e	2111	}
AzureIoTClient	88:248736be106e	2112
AzureIoTClient	88:248736be106e	2113	return markThreadReadyToBeGarbageCollected(threadInfo);
AzureIoTClient	88:248736be106e	2114	}
AzureIoTClient	88:248736be106e	2115
AzureIoTClient	88:248736be106e	2116	IOTHUB_CLIENT_RESULT IoTHubClientCore_UploadToBlobAsync(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, const char* destinationFileName, const unsigned char* source, size_t size, IOTHUB_CLIENT_FILE_UPLOAD_CALLBACK iotHubClientFileUploadCallback, void* context)
AzureIoTClient	88:248736be106e	2117	{
AzureIoTClient	88:248736be106e	2118	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2119	/Codes_SRS_IOTHUBCLIENT_02_047: [ If iotHubClientHandle is NULL then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	2120	/Codes_SRS_IOTHUBCLIENT_02_048: [ If destinationFileName is NULL then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	2121	/Codes_SRS_IOTHUBCLIENT_02_049: [ If source is NULL and size is greated than 0 then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	2122	if (
AzureIoTClient	88:248736be106e	2123	(iotHubClientHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	2124	(destinationFileName == NULL) \|\|
AzureIoTClient	88:248736be106e	2125	((source == NULL) && (size > 0))
AzureIoTClient	88:248736be106e	2126	)
AzureIoTClient	88:248736be106e	2127	{
AzureIoTClient	88:248736be106e	2128	LogError("invalid parameters IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle = %p , const char* destinationFileName = %s, const unsigned char* source= %p, size_t size = %zu, IOTHUB_CLIENT_FILE_UPLOAD_CALLBACK iotHubClientFileUploadCallback = %p, void* context = %p",
AzureIoTClient	88:248736be106e	2129	iotHubClientHandle,
AzureIoTClient	88:248736be106e	2130	destinationFileName,
AzureIoTClient	88:248736be106e	2131	source,
AzureIoTClient	88:248736be106e	2132	size,
AzureIoTClient	88:248736be106e	2133	iotHubClientFileUploadCallback,
AzureIoTClient	88:248736be106e	2134	context
AzureIoTClient	88:248736be106e	2135	);
AzureIoTClient	88:248736be106e	2136	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2137	}
AzureIoTClient	88:248736be106e	2138	else
AzureIoTClient	88:248736be106e	2139	{
AzureIoTClient	88:248736be106e	2140	/Codes_SRS_IOTHUBCLIENT_02_051: [IoTHubClient_UploadToBlobAsync shall copy the souce, size, iotHubClientFileUploadCallback, context into a structure.]/
AzureIoTClient	88:248736be106e	2141	UPLOADTOBLOB_THREAD_INFO *threadInfo = allocateUploadToBlob(destinationFileName, iotHubClientHandle, context);
AzureIoTClient	88:248736be106e	2142	if (threadInfo == NULL)
AzureIoTClient	88:248736be106e	2143	{
AzureIoTClient	88:248736be106e	2144	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2145	LogError("unable to create upload thread info");
AzureIoTClient	88:248736be106e	2146	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2147	}
AzureIoTClient	88:248736be106e	2148	else if ((result = initializeUploadToBlobData(threadInfo, source, size, iotHubClientFileUploadCallback)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	2149	{
AzureIoTClient	88:248736be106e	2150	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2151	LogError("unable to initialize upload blob info");
AzureIoTClient	88:248736be106e	2152	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2153	}
AzureIoTClient	88:248736be106e	2154	else if ((result = StartWorkerThreadIfNeeded(iotHubClientHandle)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	2155	{
AzureIoTClient	88:248736be106e	2156	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2157	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	2158	freeUploadToBlobThreadInfo(threadInfo);
AzureIoTClient	88:248736be106e	2159	}
AzureIoTClient	88:248736be106e	2160	/Codes_SRS_IOTHUBCLIENT_02_052: [ IoTHubClient_UploadToBlobAsync shall spawn a thread passing the structure build in SRS IOTHUBCLIENT 02 051 as thread data.]/
AzureIoTClient	88:248736be106e	2161	else if ((result = startUploadToBlobWorkerThread(threadInfo, uploadingThread)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	2162	{
AzureIoTClient	88:248736be106e	2163	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2164	LogError("unable to start upload thread");
AzureIoTClient	88:248736be106e	2165	freeUploadToBlobThreadInfo(threadInfo);
AzureIoTClient	88:248736be106e	2166	}
AzureIoTClient	88:248736be106e	2167	else
AzureIoTClient	88:248736be106e	2168	{
AzureIoTClient	88:248736be106e	2169	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2170	}
AzureIoTClient	88:248736be106e	2171	}
AzureIoTClient	88:248736be106e	2172
AzureIoTClient	88:248736be106e	2173	return result;
AzureIoTClient	88:248736be106e	2174	}
AzureIoTClient	88:248736be106e	2175
AzureIoTClient	88:248736be106e	2176	static int uploadMultipleBlock_thread(void* data)
AzureIoTClient	88:248736be106e	2177	{
AzureIoTClient	88:248736be106e	2178	UPLOADTOBLOB_THREAD_INFO* threadInfo = (UPLOADTOBLOB_THREAD_INFO*)data;
AzureIoTClient	88:248736be106e	2179	IOTHUB_CLIENT_CORE_LL_HANDLE llHandle = threadInfo->iotHubClientHandle->IoTHubClientLLHandle;
AzureIoTClient	88:248736be106e	2180
AzureIoTClient	88:248736be106e	2181	/Codes_SRS_IOTHUBCLIENT_99_078: [ The thread shall call `IoTHubClientCore_LL_UploadMultipleBlocksToBlob` or `IoTHubClientCore_LL_UploadMultipleBlocksToBlobEx` passing the information packed in the structure. ]/
AzureIoTClient	88:248736be106e	2182	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2183
AzureIoTClient	88:248736be106e	2184	if (threadInfo->uploadBlobMultiblockSavedData.getDataCallback != NULL)
AzureIoTClient	88:248736be106e	2185	{
AzureIoTClient	88:248736be106e	2186	result = IoTHubClientCore_LL_UploadMultipleBlocksToBlob(llHandle, threadInfo->destinationFileName, threadInfo->uploadBlobMultiblockSavedData.getDataCallback, threadInfo->context);
AzureIoTClient	88:248736be106e	2187	}
AzureIoTClient	88:248736be106e	2188	else
AzureIoTClient	88:248736be106e	2189	{
AzureIoTClient	88:248736be106e	2190	result = IoTHubClientCore_LL_UploadMultipleBlocksToBlobEx(llHandle, threadInfo->destinationFileName, threadInfo->uploadBlobMultiblockSavedData.getDataCallbackEx, threadInfo->context);
AzureIoTClient	88:248736be106e	2191	}
AzureIoTClient	88:248736be106e	2192	(void)markThreadReadyToBeGarbageCollected(threadInfo);
AzureIoTClient	88:248736be106e	2193
AzureIoTClient	88:248736be106e	2194	return result;
AzureIoTClient	88:248736be106e	2195	}
AzureIoTClient	88:248736be106e	2196
AzureIoTClient	88:248736be106e	2197	IOTHUB_CLIENT_RESULT IoTHubClientCore_UploadMultipleBlocksToBlobAsync(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, const char* destinationFileName, IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_CALLBACK getDataCallback, IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_CALLBACK_EX getDataCallbackEx, void* context)
AzureIoTClient	88:248736be106e	2198	{
AzureIoTClient	88:248736be106e	2199	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2200
AzureIoTClient	88:248736be106e	2201	/Codes_SRS_IOTHUBCLIENT_99_072: [ If `iotHubClientHandle` is `NULL` then `IoTHubClient_UploadMultipleBlocksToBlobAsync(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2202	/Codes_SRS_IOTHUBCLIENT_99_073: [ If `destinationFileName` is `NULL` then `IoTHubClient_UploadMultipleBlocksToBlobAsync(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2203	/Codes_SRS_IOTHUBCLIENT_99_074: [ If `getDataCallback` is `NULL` then `IoTHubClient_UploadMultipleBlocksToBlobAsync(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2204	if (
AzureIoTClient	88:248736be106e	2205	(iotHubClientHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	2206	(destinationFileName == NULL) \|\|
AzureIoTClient	88:248736be106e	2207	((getDataCallback == NULL) && (getDataCallbackEx == NULL))
AzureIoTClient	88:248736be106e	2208	)
AzureIoTClient	88:248736be106e	2209	{
AzureIoTClient	88:248736be106e	2210	LogError("invalid parameters iotHubClientHandle = %p , destinationFileName = %p, getDataCallback = %p, getDataCallbackEx = %p",
AzureIoTClient	88:248736be106e	2211	iotHubClientHandle,
AzureIoTClient	88:248736be106e	2212	destinationFileName,
AzureIoTClient	88:248736be106e	2213	getDataCallback,
AzureIoTClient	88:248736be106e	2214	getDataCallbackEx
AzureIoTClient	88:248736be106e	2215	);
AzureIoTClient	88:248736be106e	2216	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2217	}
AzureIoTClient	88:248736be106e	2218	else
AzureIoTClient	88:248736be106e	2219	{
AzureIoTClient	88:248736be106e	2220	/Codes_SRS_IOTHUBCLIENT_99_075: [ `IoTHubClient_UploadMultipleBlocksToBlobAsync(Ex)` shall copy the `destinationFileName`, `getDataCallback`, `context` and `iotHubClientHandle` into a structure. ]/
AzureIoTClient	88:248736be106e	2221	UPLOADTOBLOB_THREAD_INFO *threadInfo = allocateUploadToBlob(destinationFileName, iotHubClientHandle, context);
AzureIoTClient	88:248736be106e	2222	if (threadInfo == NULL)
AzureIoTClient	88:248736be106e	2223	{
AzureIoTClient	88:248736be106e	2224	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2225	LogError("unable to create upload thread info");
AzureIoTClient	88:248736be106e	2226	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2227	}
AzureIoTClient	88:248736be106e	2228	else
AzureIoTClient	88:248736be106e	2229	{
AzureIoTClient	88:248736be106e	2230	/Codes_SRS_IOTHUBCLIENT_99_075: [ `IoTHubClient_UploadMultipleBlocksToBlobAsync(Ex)` shall copy the `destinationFileName`, `getDataCallback`, `context` and `iotHubClientHandle` into a structure. ]/
AzureIoTClient	88:248736be106e	2231	threadInfo->uploadBlobMultiblockSavedData.getDataCallback = getDataCallback;
AzureIoTClient	88:248736be106e	2232	threadInfo->uploadBlobMultiblockSavedData.getDataCallbackEx = getDataCallbackEx;
AzureIoTClient	88:248736be106e	2233
AzureIoTClient	88:248736be106e	2234	if ((result = StartWorkerThreadIfNeeded(iotHubClientHandle)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	2235	{
AzureIoTClient	88:248736be106e	2236	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2237	LogError("Could not start worker thread");
AzureIoTClient	88:248736be106e	2238	freeUploadToBlobThreadInfo(threadInfo);
AzureIoTClient	88:248736be106e	2239	}
AzureIoTClient	88:248736be106e	2240	else if ((result = startUploadToBlobWorkerThread(threadInfo, uploadMultipleBlock_thread)) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	2241	{
AzureIoTClient	88:248736be106e	2242	/Codes_SRS_IOTHUBCLIENT_02_053: [ If copying to the structure or spawning the thread fails, then IoTHubClient_UploadToBlobAsync shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2243	LogError("unable to start upload thread");
AzureIoTClient	88:248736be106e	2244	freeUploadToBlobThreadInfo(threadInfo);
AzureIoTClient	88:248736be106e	2245	}
AzureIoTClient	88:248736be106e	2246	else
AzureIoTClient	88:248736be106e	2247	{
AzureIoTClient	88:248736be106e	2248	/Codes_SRS_IOTHUBCLIENT_99_077: [ If copying to the structure and spawning the thread succeeds, then `IoTHubClient_UploadMultipleBlocksToBlobAsync(Ex)` shall return `IOTHUB_CLIENT_OK`. ]/
AzureIoTClient	88:248736be106e	2249	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2250	}
AzureIoTClient	88:248736be106e	2251	}
AzureIoTClient	88:248736be106e	2252	}
AzureIoTClient	88:248736be106e	2253	return result;
AzureIoTClient	88:248736be106e	2254	}
AzureIoTClient	88:248736be106e	2255
AzureIoTClient	88:248736be106e	2256	#endif /DONT_USE_UPLOADTOBLOB/
AzureIoTClient	89:a2ed767a532e	2257
AzureIoTClient	89:a2ed767a532e	2258	IOTHUB_CLIENT_RESULT IoTHubClientCore_SendEventToOutputAsync(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, IOTHUB_MESSAGE_HANDLE eventMessageHandle, const char* outputName, IOTHUB_CLIENT_EVENT_CONFIRMATION_CALLBACK eventConfirmationCallback, void* userContextCallback)
AzureIoTClient	89:a2ed767a532e	2259	{
AzureIoTClient	89:a2ed767a532e	2260	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	89:a2ed767a532e	2261
AzureIoTClient	89:a2ed767a532e	2262	if ((iotHubClientHandle == NULL) \|\| (outputName == NULL) \|\| (eventMessageHandle == NULL))
AzureIoTClient	89:a2ed767a532e	2263	{
AzureIoTClient	89:a2ed767a532e	2264	// Codes_SRS_IOTHUBCLIENT_31_100: [ If `iotHubClientHandle`, `outputName`, or `eventConfirmationCallback` is `NULL`, `IoTHubClient_SendEventToOutputAsync` shall return `IOTHUB_CLIENT_INVALID_ARG`. ]
AzureIoTClient	89:a2ed767a532e	2265	LogError("Invalid argument (iotHubClientHandle=%p, outputName=%p, eventMessageHandle=%p)", iotHubClientHandle, outputName, eventMessageHandle);
AzureIoTClient	89:a2ed767a532e	2266	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	89:a2ed767a532e	2267	}
AzureIoTClient	89:a2ed767a532e	2268	else
AzureIoTClient	89:a2ed767a532e	2269	{
AzureIoTClient	89:a2ed767a532e	2270	// Codes_SRS_IOTHUBCLIENT_31_101: [ `IoTHubClient_SendEventToOutputAsync` shall set the outputName of the message to send. ]
AzureIoTClient	89:a2ed767a532e	2271	if (IoTHubMessage_SetOutputName(eventMessageHandle, outputName) != IOTHUB_MESSAGE_OK)
AzureIoTClient	89:a2ed767a532e	2272	{
AzureIoTClient	89:a2ed767a532e	2273	LogError("IoTHubMessage_SetOutputName failed");
AzureIoTClient	89:a2ed767a532e	2274	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2275	}
AzureIoTClient	89:a2ed767a532e	2276	// Codes_SRS_IOTHUBCLIENT_31_102: [ `IoTHubClient_SendEventToOutputAsync` shall invoke `IoTHubClient_SendEventAsync` to send the message. ]
AzureIoTClient	89:a2ed767a532e	2277	else if ((result = IoTHubClientCore_SendEventAsync(iotHubClientHandle, eventMessageHandle, eventConfirmationCallback, userContextCallback)) != IOTHUB_CLIENT_OK)
AzureIoTClient	89:a2ed767a532e	2278	{
AzureIoTClient	89:a2ed767a532e	2279	LogError("Call into IoTHubClient_SendEventAsync failed, result=%d", result);
AzureIoTClient	89:a2ed767a532e	2280	}
AzureIoTClient	89:a2ed767a532e	2281	}
AzureIoTClient	89:a2ed767a532e	2282
AzureIoTClient	89:a2ed767a532e	2283	return result;
AzureIoTClient	89:a2ed767a532e	2284	}
AzureIoTClient	89:a2ed767a532e	2285
AzureIoTClient	89:a2ed767a532e	2286
AzureIoTClient	89:a2ed767a532e	2287	IOTHUB_CLIENT_RESULT IoTHubClientCore_SetInputMessageCallback(IOTHUB_CLIENT_CORE_HANDLE iotHubClientHandle, const char* inputName, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC eventHandlerCallback, void* userContextCallback)
AzureIoTClient	89:a2ed767a532e	2288	{
AzureIoTClient	89:a2ed767a532e	2289	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	89:a2ed767a532e	2290
AzureIoTClient	89:a2ed767a532e	2291	if (iotHubClientHandle == NULL)
AzureIoTClient	89:a2ed767a532e	2292	{
AzureIoTClient	89:a2ed767a532e	2293	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	89:a2ed767a532e	2294	LogError("NULL iothubClientHandle");
AzureIoTClient	89:a2ed767a532e	2295	}
AzureIoTClient	89:a2ed767a532e	2296	else
AzureIoTClient	89:a2ed767a532e	2297	{
AzureIoTClient	89:a2ed767a532e	2298	IOTHUB_CLIENT_CORE_INSTANCE* iotHubClientInstance = (IOTHUB_CLIENT_CORE_INSTANCE*)iotHubClientHandle;
AzureIoTClient	89:a2ed767a532e	2299
AzureIoTClient	89:a2ed767a532e	2300	// Codes_SRS_IOTHUBCLIENT_31_098: [ `IoTHubClient_SetMessageCallback` shall start the worker thread if it was not previously started. ]
AzureIoTClient	89:a2ed767a532e	2301	if ((result = StartWorkerThreadIfNeeded(iotHubClientInstance)) != IOTHUB_CLIENT_OK)
AzureIoTClient	89:a2ed767a532e	2302	{
AzureIoTClient	89:a2ed767a532e	2303	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2304	LogError("Could not start worker thread");
AzureIoTClient	89:a2ed767a532e	2305	}
AzureIoTClient	89:a2ed767a532e	2306	else
AzureIoTClient	89:a2ed767a532e	2307	{
AzureIoTClient	89:a2ed767a532e	2308	if (Lock(iotHubClientInstance->LockHandle) != LOCK_OK)
AzureIoTClient	89:a2ed767a532e	2309	{
AzureIoTClient	89:a2ed767a532e	2310	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2311	LogError("Could not acquire lock");
AzureIoTClient	89:a2ed767a532e	2312	}
AzureIoTClient	89:a2ed767a532e	2313	else
AzureIoTClient	89:a2ed767a532e	2314	{
AzureIoTClient	89:a2ed767a532e	2315	// Codes_SRS_IOTHUBCLIENT_31_099: [ `IoTHubClient_SetMessageCallback` shall call `IoTHubClient_LL_SetInputMessageCallback`, passing its input arguments ]
AzureIoTClient	89:a2ed767a532e	2316	IOTHUB_INPUTMESSAGE_CALLBACK_CONTEXT inputMessageCallbackContext;
AzureIoTClient	89:a2ed767a532e	2317	inputMessageCallbackContext.iotHubClientHandle = iotHubClientHandle;
AzureIoTClient	89:a2ed767a532e	2318	inputMessageCallbackContext.eventHandlerCallback = eventHandlerCallback;
AzureIoTClient	89:a2ed767a532e	2319	inputMessageCallbackContext.userContextCallback = userContextCallback;
AzureIoTClient	89:a2ed767a532e	2320
AzureIoTClient	89:a2ed767a532e	2321	result = IoTHubClientCore_LL_SetInputMessageCallbackEx(iotHubClientInstance->IoTHubClientLLHandle, inputName, iothub_ll_inputmessage_callback, (void*)&inputMessageCallbackContext, sizeof(inputMessageCallbackContext));
AzureIoTClient	89:a2ed767a532e	2322	(void)Unlock(iotHubClientInstance->LockHandle);
AzureIoTClient	89:a2ed767a532e	2323	}
AzureIoTClient	89:a2ed767a532e	2324	}
AzureIoTClient	89:a2ed767a532e	2325	}
AzureIoTClient	89:a2ed767a532e	2326
AzureIoTClient	89:a2ed767a532e	2327	return result;
AzureIoTClient	89:a2ed767a532e	2328	}
AzureIoTClient	89:a2ed767a532e	2329
AzureIoTClient	89:a2ed767a532e	2330

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	15 Sep 2015
Imports:	235
Forks:	1
Commits:	94
Dependents:	12
Dependencies:	0
Followers:	11

Developers

Azure IoT

Dan Cristoloveanu

The code in this repository is MIT licensed.

iothub_client_core.c@89:a2ed767a532e, 2018-06-26 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Developers

Important Information for this Arm website

Access Warning