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_ll.c@91:bbf806070c5f, 2018-07-12 (annotated)

Committer:: AzureIoTClient
Date:: Thu Jul 12 18:09:13 2018 -0700
Revision:: 91:bbf806070c5f
Parent:: 89:a2ed767a532e
Child:: 92:97148cf9aa2a

1.2.8

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 <stdint.h>
AzureIoTClient	88:248736be106e	6	#include <string.h>
AzureIoTClient	88:248736be106e	7	#include "azure_c_shared_utility/optimize_size.h"
AzureIoTClient	88:248736be106e	8	#include "azure_c_shared_utility/gballoc.h"
AzureIoTClient	88:248736be106e	9	#include "azure_c_shared_utility/string_tokenizer.h"
AzureIoTClient	88:248736be106e	10	#include "azure_c_shared_utility/doublylinkedlist.h"
AzureIoTClient	88:248736be106e	11	#include "azure_c_shared_utility/xlogging.h"
AzureIoTClient	88:248736be106e	12	#include "azure_c_shared_utility/tickcounter.h"
AzureIoTClient	88:248736be106e	13	#include "azure_c_shared_utility/constbuffer.h"
AzureIoTClient	88:248736be106e	14	#include "azure_c_shared_utility/platform.h"
AzureIoTClient	89:a2ed767a532e	15	#include "azure_c_shared_utility/singlylinkedlist.h"
AzureIoTClient	89:a2ed767a532e	16	#include "azure_c_shared_utility/shared_util_options.h"
AzureIoTClient	89:a2ed767a532e	17	#include "azure_c_shared_utility/agenttime.h"
AzureIoTClient	88:248736be106e	18
AzureIoTClient	88:248736be106e	19	#include "iothub_client_core_ll.h"
AzureIoTClient	88:248736be106e	20	#include "internal/iothub_client_authorization.h"
AzureIoTClient	88:248736be106e	21	#include "iothub_transport_ll.h"
AzureIoTClient	88:248736be106e	22	#include "internal/iothub_client_private.h"
AzureIoTClient	88:248736be106e	23	#include "iothub_client_options.h"
AzureIoTClient	88:248736be106e	24	#include "iothub_client_version.h"
AzureIoTClient	88:248736be106e	25	#include "internal/iothub_client_diagnostic.h"
AzureIoTClient	89:a2ed767a532e	26	#include <stdint.h>
AzureIoTClient	88:248736be106e	27	#include "internal/iothubtransport.h"
AzureIoTClient	88:248736be106e	28
AzureIoTClient	88:248736be106e	29	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	30	#include "internal/iothub_client_ll_uploadtoblob.h"
AzureIoTClient	88:248736be106e	31	#endif
AzureIoTClient	88:248736be106e	32
AzureIoTClient	91:bbf806070c5f	33	#ifdef USE_EDGE_MODULES
AzureIoTClient	91:bbf806070c5f	34	#include "azure_c_shared_utility/envvariable.h"
AzureIoTClient	91:bbf806070c5f	35	#include "azure_prov_client/iothub_security_factory.h"
AzureIoTClient	91:bbf806070c5f	36	#include "internal/iothub_client_edge.h"
AzureIoTClient	91:bbf806070c5f	37	#endif
AzureIoTClient	91:bbf806070c5f	38
AzureIoTClient	88:248736be106e	39	#define LOG_ERROR_RESULT LogError("result = %s", ENUM_TO_STRING(IOTHUB_CLIENT_RESULT, result));
AzureIoTClient	88:248736be106e	40	#define INDEFINITE_TIME ((time_t)(-1))
AzureIoTClient	88:248736be106e	41
AzureIoTClient	88:248736be106e	42	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_FILE_UPLOAD_RESULT, IOTHUB_CLIENT_FILE_UPLOAD_RESULT_VALUES);
AzureIoTClient	88:248736be106e	43	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_RESULT, IOTHUB_CLIENT_RESULT_VALUES);
AzureIoTClient	88:248736be106e	44	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_RETRY_POLICY, IOTHUB_CLIENT_RETRY_POLICY_VALUES);
AzureIoTClient	88:248736be106e	45	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_STATUS, IOTHUB_CLIENT_STATUS_VALUES);
AzureIoTClient	88:248736be106e	46	DEFINE_ENUM_STRINGS(IOTHUB_IDENTITY_TYPE, IOTHUB_IDENTITY_TYPE_VALUE);
AzureIoTClient	88:248736be106e	47	DEFINE_ENUM_STRINGS(IOTHUB_PROCESS_ITEM_RESULT, IOTHUB_PROCESS_ITEM_RESULT_VALUE);
AzureIoTClient	88:248736be106e	48	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_IOTHUB_METHOD_STATUS, IOTHUB_CLIENT_IOTHUB_METHOD_STATUS_VALUES);
AzureIoTClient	88:248736be106e	49	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_CONFIRMATION_RESULT, IOTHUB_CLIENT_CONFIRMATION_RESULT_VALUES);
AzureIoTClient	88:248736be106e	50	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_CONNECTION_STATUS, IOTHUB_CLIENT_CONNECTION_STATUS_VALUES);
AzureIoTClient	88:248736be106e	51	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_CONNECTION_STATUS_REASON, IOTHUB_CLIENT_CONNECTION_STATUS_REASON_VALUES);
AzureIoTClient	88:248736be106e	52	DEFINE_ENUM_STRINGS(TRANSPORT_TYPE, TRANSPORT_TYPE_VALUES);
AzureIoTClient	88:248736be106e	53	DEFINE_ENUM_STRINGS(DEVICE_TWIN_UPDATE_STATE, DEVICE_TWIN_UPDATE_STATE_VALUES);
AzureIoTClient	88:248736be106e	54	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	55	DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_RESULT, IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_RESULT_VALUES);
AzureIoTClient	88:248736be106e	56	#endif // DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	57
AzureIoTClient	88:248736be106e	58	#define CALLBACK_TYPE_VALUES \
AzureIoTClient	88:248736be106e	59	CALLBACK_TYPE_NONE, \
AzureIoTClient	88:248736be106e	60	CALLBACK_TYPE_SYNC, \
AzureIoTClient	88:248736be106e	61	CALLBACK_TYPE_ASYNC
AzureIoTClient	88:248736be106e	62
AzureIoTClient	88:248736be106e	63	DEFINE_ENUM(CALLBACK_TYPE, CALLBACK_TYPE_VALUES)
AzureIoTClient	88:248736be106e	64	DEFINE_ENUM_STRINGS(CALLBACK_TYPE, CALLBACK_TYPE_VALUES)
AzureIoTClient	88:248736be106e	65
AzureIoTClient	88:248736be106e	66	typedef struct IOTHUB_METHOD_CALLBACK_DATA_TAG
AzureIoTClient	88:248736be106e	67	{
AzureIoTClient	88:248736be106e	68	CALLBACK_TYPE type;
AzureIoTClient	88:248736be106e	69	IOTHUB_CLIENT_DEVICE_METHOD_CALLBACK_ASYNC callbackSync;
AzureIoTClient	88:248736be106e	70	IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK callbackAsync;
AzureIoTClient	88:248736be106e	71	void* userContextCallback;
AzureIoTClient	88:248736be106e	72	}IOTHUB_METHOD_CALLBACK_DATA;
AzureIoTClient	88:248736be106e	73
AzureIoTClient	89:a2ed767a532e	74	typedef struct IOTHUB_EVENT_CALLBACK_TAG
AzureIoTClient	89:a2ed767a532e	75	{
AzureIoTClient	89:a2ed767a532e	76	STRING_HANDLE inputName;
AzureIoTClient	89:a2ed767a532e	77	IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC callbackAsync;
AzureIoTClient	89:a2ed767a532e	78	IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX callbackAsyncEx;
AzureIoTClient	89:a2ed767a532e	79	void* userContextCallback;
AzureIoTClient	89:a2ed767a532e	80	void* userContextCallbackEx;
AzureIoTClient	89:a2ed767a532e	81	}IOTHUB_EVENT_CALLBACK;
AzureIoTClient	89:a2ed767a532e	82
AzureIoTClient	88:248736be106e	83	typedef struct IOTHUB_MESSAGE_CALLBACK_DATA_TAG
AzureIoTClient	88:248736be106e	84	{
AzureIoTClient	88:248736be106e	85	CALLBACK_TYPE type;
AzureIoTClient	88:248736be106e	86	IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC callbackSync;
AzureIoTClient	88:248736be106e	87	IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX callbackAsync;
AzureIoTClient	88:248736be106e	88	void* userContextCallback;
AzureIoTClient	88:248736be106e	89	}IOTHUB_MESSAGE_CALLBACK_DATA;
AzureIoTClient	88:248736be106e	90
AzureIoTClient	88:248736be106e	91	typedef struct IOTHUB_CLIENT_CORE_LL_HANDLE_DATA_TAG
AzureIoTClient	88:248736be106e	92	{
AzureIoTClient	88:248736be106e	93	DLIST_ENTRY waitingToSend;
AzureIoTClient	88:248736be106e	94	DLIST_ENTRY iot_msg_queue;
AzureIoTClient	88:248736be106e	95	DLIST_ENTRY iot_ack_queue;
AzureIoTClient	88:248736be106e	96	TRANSPORT_LL_HANDLE transportHandle;
AzureIoTClient	88:248736be106e	97	bool isSharedTransport;
AzureIoTClient	88:248736be106e	98	IOTHUB_DEVICE_HANDLE deviceHandle;
AzureIoTClient	88:248736be106e	99	TRANSPORT_PROVIDER_FIELDS;
AzureIoTClient	88:248736be106e	100	IOTHUB_MESSAGE_CALLBACK_DATA messageCallback;
AzureIoTClient	88:248736be106e	101	IOTHUB_METHOD_CALLBACK_DATA methodCallback;
AzureIoTClient	88:248736be106e	102	IOTHUB_CLIENT_CONNECTION_STATUS_CALLBACK conStatusCallback;
AzureIoTClient	88:248736be106e	103	void* conStatusUserContextCallback;
AzureIoTClient	88:248736be106e	104	time_t lastMessageReceiveTime;
AzureIoTClient	88:248736be106e	105	TICK_COUNTER_HANDLE tickCounter; /shared tickcounter used to track message timeouts in waitingToSend list/
AzureIoTClient	88:248736be106e	106	tickcounter_ms_t currentMessageTimeout;
AzureIoTClient	88:248736be106e	107	uint64_t current_device_twin_timeout;
AzureIoTClient	88:248736be106e	108	IOTHUB_CLIENT_DEVICE_TWIN_CALLBACK deviceTwinCallback;
AzureIoTClient	88:248736be106e	109	void* deviceTwinContextCallback;
AzureIoTClient	88:248736be106e	110	IOTHUB_CLIENT_RETRY_POLICY retryPolicy;
AzureIoTClient	88:248736be106e	111	size_t retryTimeoutLimitInSeconds;
AzureIoTClient	88:248736be106e	112	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	113	IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE uploadToBlobHandle;
AzureIoTClient	88:248736be106e	114	#endif
AzureIoTClient	91:bbf806070c5f	115	#ifdef USE_EDGE_MODULES
AzureIoTClient	91:bbf806070c5f	116	IOTHUB_CLIENT_EDGE_HANDLE methodHandle;
AzureIoTClient	91:bbf806070c5f	117	#endif
AzureIoTClient	88:248736be106e	118	uint32_t data_msg_id;
AzureIoTClient	88:248736be106e	119	bool complete_twin_update_encountered;
AzureIoTClient	88:248736be106e	120	IOTHUB_AUTHORIZATION_HANDLE authorization_module;
AzureIoTClient	88:248736be106e	121	STRING_HANDLE product_info;
AzureIoTClient	88:248736be106e	122	IOTHUB_DIAGNOSTIC_SETTING_DATA diagnostic_setting;
AzureIoTClient	89:a2ed767a532e	123	SINGLYLINKEDLIST_HANDLE event_callbacks; // List of IOTHUB_EVENT_CALLBACK's
AzureIoTClient	88:248736be106e	124	}IOTHUB_CLIENT_CORE_LL_HANDLE_DATA;
AzureIoTClient	88:248736be106e	125
AzureIoTClient	88:248736be106e	126	static const char HOSTNAME_TOKEN[] = "HostName";
AzureIoTClient	88:248736be106e	127	static const char DEVICEID_TOKEN[] = "DeviceId";
AzureIoTClient	88:248736be106e	128	static const char X509_TOKEN[] = "x509";
AzureIoTClient	88:248736be106e	129	static const char X509_TOKEN_ONLY_ACCEPTABLE_VALUE[] = "true";
AzureIoTClient	88:248736be106e	130	static const char DEVICEKEY_TOKEN[] = "SharedAccessKey";
AzureIoTClient	88:248736be106e	131	static const char DEVICESAS_TOKEN[] = "SharedAccessSignature";
AzureIoTClient	89:a2ed767a532e	132	static const char PROTOCOL_GATEWAY_HOST_TOKEN[] = "GatewayHostName";
AzureIoTClient	89:a2ed767a532e	133	static const char MODULE_ID_TOKEN[] = "ModuleId";
AzureIoTClient	88:248736be106e	134	static const char PROVISIONING_TOKEN[] = "UseProvisioning";
AzureIoTClient	88:248736be106e	135	static const char PROVISIONING_ACCEPTABLE_VALUE[] = "true";
AzureIoTClient	88:248736be106e	136
AzureIoTClient	91:bbf806070c5f	137
AzureIoTClient	91:bbf806070c5f	138	#ifdef USE_EDGE_MODULES
AzureIoTClient	91:bbf806070c5f	139	/The following section should be moved to iothub_module_client_ll.c during impending refactor/
AzureIoTClient	91:bbf806070c5f	140
AzureIoTClient	91:bbf806070c5f	141	static const char* ENVIRONMENT_VAR_EDGEHUBCONNECTIONSTRING = "EdgeHubConnectionString";
AzureIoTClient	91:bbf806070c5f	142	static const char* ENVIRONMENT_VAR_EDGEAUTHSCHEME = "IOTEDGE_AUTHSCHEME";
AzureIoTClient	91:bbf806070c5f	143	static const char* ENVIRONMENT_VAR_EDGEDEVICEID = "IOTEDGE_DEVICEID";
AzureIoTClient	91:bbf806070c5f	144	static const char* ENVIRONMENT_VAR_EDGEMODULEID = "IOTEDGE_MODULEID";
AzureIoTClient	91:bbf806070c5f	145	static const char* ENVIRONMENT_VAR_EDGEHUBHOSTNAME = "IOTEDGE_IOTHUBHOSTNAME";
AzureIoTClient	91:bbf806070c5f	146	static const char* ENVIRONMENT_VAR_EDGEGATEWAYHOST = "IOTEDGE_GATEWAYHOSTNAME";
AzureIoTClient	91:bbf806070c5f	147
AzureIoTClient	91:bbf806070c5f	148	static const char* SAS_TOKEN_AUTH = "sasToken";
AzureIoTClient	91:bbf806070c5f	149
AzureIoTClient	91:bbf806070c5f	150	typedef struct EDGE_ENVIRONMENT_VARIABLES_TAG
AzureIoTClient	91:bbf806070c5f	151	{
AzureIoTClient	91:bbf806070c5f	152	const char* connection_string;
AzureIoTClient	91:bbf806070c5f	153	const char* auth_scheme;
AzureIoTClient	91:bbf806070c5f	154	const char* device_id;
AzureIoTClient	91:bbf806070c5f	155	const char* iothub_name;
AzureIoTClient	91:bbf806070c5f	156	const char* iothub_suffix;
AzureIoTClient	91:bbf806070c5f	157	const char* gatewayhostname;
AzureIoTClient	91:bbf806070c5f	158	const char* module_id;
AzureIoTClient	91:bbf806070c5f	159	char* iothub_buffer;
AzureIoTClient	91:bbf806070c5f	160	} EDGE_ENVIRONMENT_VARIABLES;
AzureIoTClient	91:bbf806070c5f	161
AzureIoTClient	91:bbf806070c5f	162	static int retrieve_edge_environment_variabes(EDGE_ENVIRONMENT_VARIABLES *edge_environment_variables)
AzureIoTClient	91:bbf806070c5f	163	{
AzureIoTClient	91:bbf806070c5f	164	int result;
AzureIoTClient	91:bbf806070c5f	165	const char* edgehubhostname;
AzureIoTClient	91:bbf806070c5f	166	char* edgehubhostname_separator;
AzureIoTClient	91:bbf806070c5f	167
AzureIoTClient	91:bbf806070c5f	168	if ((edge_environment_variables->connection_string = environment_get_variable(ENVIRONMENT_VAR_EDGEHUBCONNECTIONSTRING)) != NULL)
AzureIoTClient	91:bbf806070c5f	169	{
AzureIoTClient	91:bbf806070c5f	170	// If a connection string is set, we use it and ignore all other environment variables.
AzureIoTClient	91:bbf806070c5f	171	result = 0;
AzureIoTClient	91:bbf806070c5f	172	}
AzureIoTClient	91:bbf806070c5f	173	else
AzureIoTClient	91:bbf806070c5f	174	{
AzureIoTClient	91:bbf806070c5f	175	if ((edge_environment_variables->auth_scheme = environment_get_variable(ENVIRONMENT_VAR_EDGEAUTHSCHEME)) == NULL)
AzureIoTClient	91:bbf806070c5f	176	{
AzureIoTClient	91:bbf806070c5f	177	LogError("Environment %s not set", ENVIRONMENT_VAR_EDGEAUTHSCHEME);
AzureIoTClient	91:bbf806070c5f	178	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	179	}
AzureIoTClient	91:bbf806070c5f	180	else if (strcmp(edge_environment_variables->auth_scheme, SAS_TOKEN_AUTH) != 0)
AzureIoTClient	91:bbf806070c5f	181	{
AzureIoTClient	91:bbf806070c5f	182	LogError("Environment %s was set to %s, but only support for %s", ENVIRONMENT_VAR_EDGEAUTHSCHEME, edge_environment_variables->auth_scheme, SAS_TOKEN_AUTH);
AzureIoTClient	91:bbf806070c5f	183	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	184	}
AzureIoTClient	91:bbf806070c5f	185	else if ((edge_environment_variables->device_id = environment_get_variable(ENVIRONMENT_VAR_EDGEDEVICEID)) == NULL)
AzureIoTClient	91:bbf806070c5f	186	{
AzureIoTClient	91:bbf806070c5f	187	LogError("Environment %s not set", ENVIRONMENT_VAR_EDGEDEVICEID);
AzureIoTClient	91:bbf806070c5f	188	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	189	}
AzureIoTClient	91:bbf806070c5f	190	else if ((edgehubhostname = environment_get_variable(ENVIRONMENT_VAR_EDGEHUBHOSTNAME)) == NULL)
AzureIoTClient	91:bbf806070c5f	191	{
AzureIoTClient	91:bbf806070c5f	192	LogError("Environment %s not set", ENVIRONMENT_VAR_EDGEHUBHOSTNAME);
AzureIoTClient	91:bbf806070c5f	193	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	194	}
AzureIoTClient	91:bbf806070c5f	195	else if ((edge_environment_variables->gatewayhostname = environment_get_variable(ENVIRONMENT_VAR_EDGEGATEWAYHOST)) == NULL)
AzureIoTClient	91:bbf806070c5f	196	{
AzureIoTClient	91:bbf806070c5f	197	LogError("Environment %s not set", ENVIRONMENT_VAR_EDGEGATEWAYHOST);
AzureIoTClient	91:bbf806070c5f	198	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	199	}
AzureIoTClient	91:bbf806070c5f	200	else if ((edge_environment_variables->module_id = environment_get_variable(ENVIRONMENT_VAR_EDGEMODULEID)) == NULL)
AzureIoTClient	91:bbf806070c5f	201	{
AzureIoTClient	91:bbf806070c5f	202	LogError("Environment %s not set", ENVIRONMENT_VAR_EDGEMODULEID);
AzureIoTClient	91:bbf806070c5f	203	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	204	}
AzureIoTClient	91:bbf806070c5f	205	// Make a copy of just ENVIRONMENT_VAR_EDGEHUBHOSTNAME. We need to make changes in place (namely inserting a '\0')
AzureIoTClient	91:bbf806070c5f	206	// and can't do this with system environment variable safely.
AzureIoTClient	91:bbf806070c5f	207	else if (mallocAndStrcpy_s(&edge_environment_variables->iothub_buffer, edgehubhostname) != 0)
AzureIoTClient	91:bbf806070c5f	208	{
AzureIoTClient	91:bbf806070c5f	209	LogError("Unable to copy buffer");
AzureIoTClient	91:bbf806070c5f	210	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	211	}
AzureIoTClient	91:bbf806070c5f	212	else if ((edgehubhostname_separator = strchr(edge_environment_variables->iothub_buffer, '.')) == NULL)
AzureIoTClient	91:bbf806070c5f	213	{
AzureIoTClient	91:bbf806070c5f	214	LogError("Environment edgehub %s invalid, requires '.' separator", edge_environment_variables->iothub_buffer);
AzureIoTClient	91:bbf806070c5f	215	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	216	}
AzureIoTClient	91:bbf806070c5f	217	else if (*(edgehubhostname_separator + 1) == 0)
AzureIoTClient	91:bbf806070c5f	218	{
AzureIoTClient	91:bbf806070c5f	219	LogError("Environment edgehub %s invalid, no content after '.' separator", edge_environment_variables->iothub_buffer);
AzureIoTClient	91:bbf806070c5f	220	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	221	}
AzureIoTClient	91:bbf806070c5f	222	else
AzureIoTClient	91:bbf806070c5f	223	{
AzureIoTClient	91:bbf806070c5f	224	edge_environment_variables->iothub_name = edge_environment_variables->iothub_buffer;
AzureIoTClient	91:bbf806070c5f	225	*edgehubhostname_separator = 0;
AzureIoTClient	91:bbf806070c5f	226	edge_environment_variables->iothub_suffix = edgehubhostname_separator + 1;
AzureIoTClient	91:bbf806070c5f	227	result = 0;
AzureIoTClient	91:bbf806070c5f	228	}
AzureIoTClient	91:bbf806070c5f	229	}
AzureIoTClient	91:bbf806070c5f	230
AzureIoTClient	91:bbf806070c5f	231	return result;
AzureIoTClient	91:bbf806070c5f	232	}
AzureIoTClient	91:bbf806070c5f	233
AzureIoTClient	91:bbf806070c5f	234	IOTHUB_CLIENT_EDGE_HANDLE IoTHubClientCore_LL_GetEdgeHandle(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle)
AzureIoTClient	91:bbf806070c5f	235	{
AzureIoTClient	91:bbf806070c5f	236	IOTHUB_CLIENT_EDGE_HANDLE result;
AzureIoTClient	91:bbf806070c5f	237	if (iotHubClientHandle != NULL)
AzureIoTClient	91:bbf806070c5f	238	{
AzureIoTClient	91:bbf806070c5f	239	result = iotHubClientHandle->methodHandle;
AzureIoTClient	91:bbf806070c5f	240	}
AzureIoTClient	91:bbf806070c5f	241	else
AzureIoTClient	91:bbf806070c5f	242	{
AzureIoTClient	91:bbf806070c5f	243	result = NULL;
AzureIoTClient	91:bbf806070c5f	244	}
AzureIoTClient	91:bbf806070c5f	245
AzureIoTClient	91:bbf806070c5f	246	return result;
AzureIoTClient	91:bbf806070c5f	247	}
AzureIoTClient	91:bbf806070c5f	248	#endif /* USE_EDGE_MODULES */
AzureIoTClient	91:bbf806070c5f	249
AzureIoTClient	88:248736be106e	250	static void setTransportProtocol(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData, TRANSPORT_PROVIDER* protocol)
AzureIoTClient	88:248736be106e	251	{
AzureIoTClient	88:248736be106e	252	handleData->IoTHubTransport_SendMessageDisposition = protocol->IoTHubTransport_SendMessageDisposition;
AzureIoTClient	88:248736be106e	253	handleData->IoTHubTransport_GetHostname = protocol->IoTHubTransport_GetHostname;
AzureIoTClient	88:248736be106e	254	handleData->IoTHubTransport_SetOption = protocol->IoTHubTransport_SetOption;
AzureIoTClient	88:248736be106e	255	handleData->IoTHubTransport_Create = protocol->IoTHubTransport_Create;
AzureIoTClient	88:248736be106e	256	handleData->IoTHubTransport_Destroy = protocol->IoTHubTransport_Destroy;
AzureIoTClient	88:248736be106e	257	handleData->IoTHubTransport_Register = protocol->IoTHubTransport_Register;
AzureIoTClient	88:248736be106e	258	handleData->IoTHubTransport_Unregister = protocol->IoTHubTransport_Unregister;
AzureIoTClient	88:248736be106e	259	handleData->IoTHubTransport_Subscribe = protocol->IoTHubTransport_Subscribe;
AzureIoTClient	88:248736be106e	260	handleData->IoTHubTransport_Unsubscribe = protocol->IoTHubTransport_Unsubscribe;
AzureIoTClient	88:248736be106e	261	handleData->IoTHubTransport_DoWork = protocol->IoTHubTransport_DoWork;
AzureIoTClient	88:248736be106e	262	handleData->IoTHubTransport_SetRetryPolicy = protocol->IoTHubTransport_SetRetryPolicy;
AzureIoTClient	88:248736be106e	263	handleData->IoTHubTransport_GetSendStatus = protocol->IoTHubTransport_GetSendStatus;
AzureIoTClient	88:248736be106e	264	handleData->IoTHubTransport_ProcessItem = protocol->IoTHubTransport_ProcessItem;
AzureIoTClient	88:248736be106e	265	handleData->IoTHubTransport_Subscribe_DeviceTwin = protocol->IoTHubTransport_Subscribe_DeviceTwin;
AzureIoTClient	88:248736be106e	266	handleData->IoTHubTransport_Unsubscribe_DeviceTwin = protocol->IoTHubTransport_Unsubscribe_DeviceTwin;
AzureIoTClient	88:248736be106e	267	handleData->IoTHubTransport_Subscribe_DeviceMethod = protocol->IoTHubTransport_Subscribe_DeviceMethod;
AzureIoTClient	88:248736be106e	268	handleData->IoTHubTransport_Unsubscribe_DeviceMethod = protocol->IoTHubTransport_Unsubscribe_DeviceMethod;
AzureIoTClient	88:248736be106e	269	handleData->IoTHubTransport_DeviceMethod_Response = protocol->IoTHubTransport_DeviceMethod_Response;
AzureIoTClient	89:a2ed767a532e	270	handleData->IoTHubTransport_Subscribe_InputQueue = protocol->IoTHubTransport_Subscribe_InputQueue;
AzureIoTClient	89:a2ed767a532e	271	handleData->IoTHubTransport_Unsubscribe_InputQueue = protocol->IoTHubTransport_Unsubscribe_InputQueue;
AzureIoTClient	88:248736be106e	272	}
AzureIoTClient	88:248736be106e	273
AzureIoTClient	88:248736be106e	274	static void device_twin_data_destroy(IOTHUB_DEVICE_TWIN* client_item)
AzureIoTClient	88:248736be106e	275	{
AzureIoTClient	88:248736be106e	276	CONSTBUFFER_Destroy(client_item->report_data_handle);
AzureIoTClient	88:248736be106e	277	free(client_item);
AzureIoTClient	88:248736be106e	278	}
AzureIoTClient	88:248736be106e	279
AzureIoTClient	91:bbf806070c5f	280	static int create_edge_handle(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handle_data, const IOTHUB_CLIENT_CONFIG* config, const char* module_id)
AzureIoTClient	91:bbf806070c5f	281	{
AzureIoTClient	91:bbf806070c5f	282	int result;
AzureIoTClient	91:bbf806070c5f	283	(void)config;
AzureIoTClient	91:bbf806070c5f	284	(void)module_id;
AzureIoTClient	91:bbf806070c5f	285	#ifdef USE_EDGE_MODULES
AzureIoTClient	91:bbf806070c5f	286	/* There is no way to currently distinguish a regular module from a edge module, so this handle is created regardless of if appropriate.
AzureIoTClient	91:bbf806070c5f	287	However, as a gateway hostname is required in order to create an Edge Handle, we need to at least make sure that exists
AzureIoTClient	91:bbf806070c5f	288	in order to prevent errors.
AzureIoTClient	91:bbf806070c5f	289
AzureIoTClient	91:bbf806070c5f	290	The end result is that all edge modules will have an EdgeHandle, but only some non-edge modules will have it.
AzureIoTClient	91:bbf806070c5f	291	Regardless, non-edge modules will never be able to use the handle.
AzureIoTClient	91:bbf806070c5f	292	*/
AzureIoTClient	91:bbf806070c5f	293	if (config->protocolGatewayHostName != NULL)
AzureIoTClient	91:bbf806070c5f	294	{
AzureIoTClient	91:bbf806070c5f	295	handle_data->methodHandle = IoTHubClient_EdgeHandle_Create(config, handle_data->authorization_module, module_id);
AzureIoTClient	91:bbf806070c5f	296
AzureIoTClient	91:bbf806070c5f	297	if (handle_data->methodHandle == NULL)
AzureIoTClient	91:bbf806070c5f	298	{
AzureIoTClient	91:bbf806070c5f	299	LogError("Unable to IoTHubModuleClient_LL_MethodHandle_Create");
AzureIoTClient	91:bbf806070c5f	300	result = __FAILURE__;
AzureIoTClient	91:bbf806070c5f	301	}
AzureIoTClient	91:bbf806070c5f	302	else
AzureIoTClient	91:bbf806070c5f	303	{
AzureIoTClient	91:bbf806070c5f	304	result = 0;
AzureIoTClient	91:bbf806070c5f	305	}
AzureIoTClient	91:bbf806070c5f	306	}
AzureIoTClient	91:bbf806070c5f	307	else
AzureIoTClient	91:bbf806070c5f	308	{
AzureIoTClient	91:bbf806070c5f	309	result = 0;
AzureIoTClient	91:bbf806070c5f	310	}
AzureIoTClient	91:bbf806070c5f	311
AzureIoTClient	91:bbf806070c5f	312	#else
AzureIoTClient	91:bbf806070c5f	313	(void)handle_data;
AzureIoTClient	91:bbf806070c5f	314	result = 0;
AzureIoTClient	91:bbf806070c5f	315	#endif
AzureIoTClient	91:bbf806070c5f	316	return result;
AzureIoTClient	91:bbf806070c5f	317	}
AzureIoTClient	91:bbf806070c5f	318
AzureIoTClient	88:248736be106e	319	static int create_blob_upload_module(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handle_data, const IOTHUB_CLIENT_CONFIG* config)
AzureIoTClient	88:248736be106e	320	{
AzureIoTClient	88:248736be106e	321	int result;
AzureIoTClient	88:248736be106e	322	(void)handle_data;
AzureIoTClient	88:248736be106e	323	(void)config;
AzureIoTClient	88:248736be106e	324	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	325	handle_data->uploadToBlobHandle = IoTHubClient_LL_UploadToBlob_Create(config);
AzureIoTClient	88:248736be106e	326	if (handle_data->uploadToBlobHandle == NULL)
AzureIoTClient	88:248736be106e	327	{
AzureIoTClient	88:248736be106e	328	LogError("unable to IoTHubClientCore_LL_UploadToBlob_Create");
AzureIoTClient	88:248736be106e	329	result = __FAILURE__;
AzureIoTClient	88:248736be106e	330	}
AzureIoTClient	88:248736be106e	331	else
AzureIoTClient	88:248736be106e	332	{
AzureIoTClient	88:248736be106e	333	result = 0;
AzureIoTClient	88:248736be106e	334	}
AzureIoTClient	88:248736be106e	335	#else
AzureIoTClient	88:248736be106e	336	result = 0;
AzureIoTClient	88:248736be106e	337	#endif
AzureIoTClient	88:248736be106e	338	return result;
AzureIoTClient	88:248736be106e	339	}
AzureIoTClient	88:248736be106e	340
AzureIoTClient	88:248736be106e	341	static void destroy_blob_upload_module(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handle_data)
AzureIoTClient	88:248736be106e	342	{
AzureIoTClient	88:248736be106e	343	(void)handle_data;
AzureIoTClient	88:248736be106e	344	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	345	/Codes_SRS_IOTHUBCLIENT_LL_02_046: [ If creating the TICK_COUNTER_HANDLE fails then IoTHubClientCore_LL_Create shall fail and return NULL. ]/
AzureIoTClient	88:248736be106e	346	IoTHubClient_LL_UploadToBlob_Destroy(handle_data->uploadToBlobHandle);
AzureIoTClient	88:248736be106e	347	#endif
AzureIoTClient	88:248736be106e	348	}
AzureIoTClient	88:248736be106e	349
AzureIoTClient	91:bbf806070c5f	350	static void destroy_module_method_module(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handle_data)
AzureIoTClient	91:bbf806070c5f	351	{
AzureIoTClient	91:bbf806070c5f	352	(void)handle_data;
AzureIoTClient	91:bbf806070c5f	353	#ifdef USE_EDGE_MODULES
AzureIoTClient	91:bbf806070c5f	354	IoTHubClient_EdgeHandle_Destroy(handle_data->methodHandle);
AzureIoTClient	91:bbf806070c5f	355	#endif
AzureIoTClient	91:bbf806070c5f	356	}
AzureIoTClient	91:bbf806070c5f	357
AzureIoTClient	88:248736be106e	358	/Codes_SRS_IOTHUBCLIENT_LL_10_032: ["product_info" - takes a char string as an argument to specify the product information(e.g. `"ProductName/ProductVersion"`). ]/
AzureIoTClient	88:248736be106e	359	/Codes_SRS_IOTHUBCLIENT_LL_10_034: ["product_info" - shall store the given string concatenated with the sdk information and the platform information in the form(ProductInfo DeviceSDKName / DeviceSDKVersion(OSName OSVersion; Architecture). ]/
AzureIoTClient	88:248736be106e	360	static STRING_HANDLE make_product_info(const char* product)
AzureIoTClient	88:248736be106e	361	{
AzureIoTClient	88:248736be106e	362	STRING_HANDLE result;
AzureIoTClient	88:248736be106e	363	STRING_HANDLE pfi = platform_get_platform_info();
AzureIoTClient	88:248736be106e	364	if (pfi == NULL)
AzureIoTClient	88:248736be106e	365	{
AzureIoTClient	88:248736be106e	366	result = NULL;
AzureIoTClient	88:248736be106e	367	}
AzureIoTClient	88:248736be106e	368	else
AzureIoTClient	88:248736be106e	369	{
AzureIoTClient	88:248736be106e	370	if (product == NULL)
AzureIoTClient	88:248736be106e	371	{
AzureIoTClient	88:248736be106e	372	result = STRING_construct_sprintf("%s %s", CLIENT_DEVICE_TYPE_PREFIX CLIENT_DEVICE_BACKSLASH IOTHUB_SDK_VERSION, STRING_c_str(pfi));
AzureIoTClient	88:248736be106e	373	}
AzureIoTClient	88:248736be106e	374	else
AzureIoTClient	88:248736be106e	375	{
AzureIoTClient	88:248736be106e	376	result = STRING_construct_sprintf("%s %s %s", product, CLIENT_DEVICE_TYPE_PREFIX CLIENT_DEVICE_BACKSLASH IOTHUB_SDK_VERSION, STRING_c_str(pfi));
AzureIoTClient	88:248736be106e	377	}
AzureIoTClient	88:248736be106e	378	STRING_delete(pfi);
AzureIoTClient	88:248736be106e	379	}
AzureIoTClient	88:248736be106e	380	return result;
AzureIoTClient	88:248736be106e	381	}
AzureIoTClient	88:248736be106e	382
AzureIoTClient	89:a2ed767a532e	383	static IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* initialize_iothub_client(const IOTHUB_CLIENT_CONFIG* client_config, const IOTHUB_CLIENT_DEVICE_CONFIG* device_config, bool use_dev_auth, const char* module_id)
AzureIoTClient	88:248736be106e	384	{
AzureIoTClient	88:248736be106e	385	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* result;
AzureIoTClient	88:248736be106e	386	srand((unsigned int)time(NULL));
AzureIoTClient	88:248736be106e	387	STRING_HANDLE product_info = make_product_info(NULL);
AzureIoTClient	88:248736be106e	388	if (product_info == NULL)
AzureIoTClient	88:248736be106e	389	{
AzureIoTClient	88:248736be106e	390	LogError("failed to initialize product info");
AzureIoTClient	88:248736be106e	391	result = NULL;
AzureIoTClient	88:248736be106e	392	}
AzureIoTClient	88:248736be106e	393	else
AzureIoTClient	88:248736be106e	394	{
AzureIoTClient	88:248736be106e	395	result = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)malloc(sizeof(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA));
AzureIoTClient	88:248736be106e	396	if (result == NULL)
AzureIoTClient	88:248736be106e	397	{
AzureIoTClient	88:248736be106e	398	LogError("failure allocating IOTHUB_CLIENT_CORE_LL_HANDLE_DATA");
AzureIoTClient	88:248736be106e	399	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	400	}
AzureIoTClient	88:248736be106e	401	else
AzureIoTClient	88:248736be106e	402	{
AzureIoTClient	88:248736be106e	403	IOTHUB_CLIENT_CONFIG actual_config;
AzureIoTClient	88:248736be106e	404	const IOTHUB_CLIENT_CONFIG* config = NULL;
AzureIoTClient	88:248736be106e	405	char* IoTHubName = NULL;
AzureIoTClient	88:248736be106e	406	char* IoTHubSuffix = NULL;
AzureIoTClient	88:248736be106e	407
AzureIoTClient	88:248736be106e	408	memset(result, 0, sizeof(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA));
AzureIoTClient	88:248736be106e	409	if (use_dev_auth)
AzureIoTClient	88:248736be106e	410	{
AzureIoTClient	89:a2ed767a532e	411	if ((result->authorization_module = IoTHubClient_Auth_CreateFromDeviceAuth(client_config->deviceId, module_id)) == NULL)
AzureIoTClient	88:248736be106e	412	{
AzureIoTClient	88:248736be106e	413	LogError("Failed create authorization module");
AzureIoTClient	88:248736be106e	414	free(result);
AzureIoTClient	88:248736be106e	415	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	416	result = NULL;
AzureIoTClient	88:248736be106e	417	}
AzureIoTClient	88:248736be106e	418	}
AzureIoTClient	88:248736be106e	419	else
AzureIoTClient	88:248736be106e	420	{
AzureIoTClient	88:248736be106e	421	const char* device_key;
AzureIoTClient	88:248736be106e	422	const char* device_id;
AzureIoTClient	88:248736be106e	423	const char* sas_token;
AzureIoTClient	88:248736be106e	424	if (device_config == NULL)
AzureIoTClient	88:248736be106e	425	{
AzureIoTClient	88:248736be106e	426	device_key = client_config->deviceKey;
AzureIoTClient	88:248736be106e	427	device_id = client_config->deviceId;
AzureIoTClient	88:248736be106e	428	sas_token = client_config->deviceSasToken;
AzureIoTClient	88:248736be106e	429	}
AzureIoTClient	88:248736be106e	430	else
AzureIoTClient	88:248736be106e	431	{
AzureIoTClient	88:248736be106e	432	device_key = device_config->deviceKey;
AzureIoTClient	88:248736be106e	433	device_id = device_config->deviceId;
AzureIoTClient	88:248736be106e	434	sas_token = device_config->deviceSasToken;
AzureIoTClient	88:248736be106e	435	}
AzureIoTClient	88:248736be106e	436
AzureIoTClient	88:248736be106e	437	/* Codes_SRS_IOTHUBCLIENT_LL_07_029: [ IoTHubClientCore_LL_Create shall create the Auth module with the device_key, device_id, and/or deviceSasToken values ] */
AzureIoTClient	89:a2ed767a532e	438	if ((result->authorization_module = IoTHubClient_Auth_Create(device_key, device_id, sas_token, module_id)) == NULL)
AzureIoTClient	88:248736be106e	439	{
AzureIoTClient	88:248736be106e	440	LogError("Failed create authorization module");
AzureIoTClient	88:248736be106e	441	free(result);
AzureIoTClient	88:248736be106e	442	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	443	result = NULL;
AzureIoTClient	88:248736be106e	444	}
AzureIoTClient	88:248736be106e	445	}
AzureIoTClient	88:248736be106e	446
AzureIoTClient	88:248736be106e	447	if (result != NULL)
AzureIoTClient	88:248736be106e	448	{
AzureIoTClient	88:248736be106e	449	if (client_config != NULL)
AzureIoTClient	88:248736be106e	450	{
AzureIoTClient	88:248736be106e	451	IOTHUBTRANSPORT_CONFIG lowerLayerConfig;
AzureIoTClient	88:248736be106e	452	memset(&lowerLayerConfig, 0, sizeof(IOTHUBTRANSPORT_CONFIG));
AzureIoTClient	88:248736be106e	453	/Codes_SRS_IOTHUBCLIENT_LL_02_006: [IoTHubClientCore_LL_Create shall populate a structure of type IOTHUBTRANSPORT_CONFIG with the information from config parameter and the previous DLIST and shall pass that to the underlying layer _Create function.]/
AzureIoTClient	88:248736be106e	454	lowerLayerConfig.upperConfig = client_config;
AzureIoTClient	88:248736be106e	455	lowerLayerConfig.waitingToSend = &(result->waitingToSend);
AzureIoTClient	88:248736be106e	456	lowerLayerConfig.auth_module_handle = result->authorization_module;
AzureIoTClient	89:a2ed767a532e	457	lowerLayerConfig.moduleId = module_id;
AzureIoTClient	88:248736be106e	458
AzureIoTClient	88:248736be106e	459	setTransportProtocol(result, (TRANSPORT_PROVIDER*)client_config->protocol());
AzureIoTClient	88:248736be106e	460	if ((result->transportHandle = result->IoTHubTransport_Create(&lowerLayerConfig)) == NULL)
AzureIoTClient	88:248736be106e	461	{
AzureIoTClient	88:248736be106e	462	/Codes_SRS_IOTHUBCLIENT_LL_02_007: [If the underlaying layer _Create function fails them IoTHubClientCore_LL_Create shall fail and return NULL.] /
AzureIoTClient	88:248736be106e	463	LogError("underlying transport failed");
AzureIoTClient	88:248736be106e	464	destroy_blob_upload_module(result);
AzureIoTClient	91:bbf806070c5f	465	destroy_module_method_module(result);
AzureIoTClient	88:248736be106e	466	tickcounter_destroy(result->tickCounter);
AzureIoTClient	88:248736be106e	467	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	468	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	469	free(result);
AzureIoTClient	88:248736be106e	470	result = NULL;
AzureIoTClient	88:248736be106e	471	}
AzureIoTClient	88:248736be106e	472	else
AzureIoTClient	88:248736be106e	473	{
AzureIoTClient	88:248736be106e	474	/Codes_SRS_IOTHUBCLIENT_LL_02_008: [Otherwise, IoTHubClientCore_LL_Create shall succeed and return a non-NULL handle.] /
AzureIoTClient	88:248736be106e	475	result->isSharedTransport = false;
AzureIoTClient	88:248736be106e	476	config = client_config;
AzureIoTClient	88:248736be106e	477	}
AzureIoTClient	88:248736be106e	478	}
AzureIoTClient	88:248736be106e	479	else
AzureIoTClient	88:248736be106e	480	{
AzureIoTClient	88:248736be106e	481	STRING_HANDLE transport_hostname = NULL;
AzureIoTClient	88:248736be106e	482
AzureIoTClient	88:248736be106e	483	result->transportHandle = device_config->transportHandle;
AzureIoTClient	88:248736be106e	484	setTransportProtocol(result, (TRANSPORT_PROVIDER*)device_config->protocol());
AzureIoTClient	88:248736be106e	485
AzureIoTClient	88:248736be106e	486	transport_hostname = result->IoTHubTransport_GetHostname(result->transportHandle);
AzureIoTClient	88:248736be106e	487	if (transport_hostname == NULL)
AzureIoTClient	88:248736be106e	488	{
AzureIoTClient	88:248736be106e	489	/Codes_SRS_IOTHUBCLIENT_LL_02_097: [ If creating the data structures fails or instantiating the IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE fails then IoTHubClientCore_LL_CreateWithTransport shall fail and return NULL. ]/
AzureIoTClient	88:248736be106e	490	LogError("unable to determine the transport IoTHub name");
AzureIoTClient	88:248736be106e	491	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	492	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	493	free(result);
AzureIoTClient	88:248736be106e	494	result = NULL;
AzureIoTClient	88:248736be106e	495	}
AzureIoTClient	88:248736be106e	496	else
AzureIoTClient	88:248736be106e	497	{
AzureIoTClient	88:248736be106e	498	const char* hostname = STRING_c_str(transport_hostname);
AzureIoTClient	88:248736be106e	499	/Codes_SRS_IOTHUBCLIENT_LL_02_096: [ IoTHubClientCore_LL_CreateWithTransport shall create the data structures needed to instantiate a IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE. ]/
AzureIoTClient	88:248736be106e	500	/the first '.' says where the iothubname finishes/
AzureIoTClient	88:248736be106e	501	const char* whereIsDot = strchr(hostname, '.');
AzureIoTClient	88:248736be106e	502	if (whereIsDot == NULL)
AzureIoTClient	88:248736be106e	503	{
AzureIoTClient	88:248736be106e	504	/Codes_SRS_IOTHUBCLIENT_LL_02_097: [ If creating the data structures fails or instantiating the IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE fails then IoTHubClientCore_LL_CreateWithTransport shall fail and return NULL. ]/
AzureIoTClient	88:248736be106e	505	LogError("unable to determine the IoTHub name");
AzureIoTClient	88:248736be106e	506	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	507	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	508	free(result);
AzureIoTClient	88:248736be106e	509	result = NULL;
AzureIoTClient	88:248736be106e	510	}
AzureIoTClient	88:248736be106e	511	else
AzureIoTClient	88:248736be106e	512	{
AzureIoTClient	88:248736be106e	513	size_t suffix_len = strlen(whereIsDot);
AzureIoTClient	88:248736be106e	514	/Codes_SRS_IOTHUBCLIENT_LL_02_096: [ IoTHubClientCore_LL_CreateWithTransport shall create the data structures needed to instantiate a IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE. ]/
AzureIoTClient	88:248736be106e	515	IoTHubName = (char*)malloc(whereIsDot - hostname + 1);
AzureIoTClient	88:248736be106e	516	if (IoTHubName == NULL)
AzureIoTClient	88:248736be106e	517	{
AzureIoTClient	88:248736be106e	518	/Codes_SRS_IOTHUBCLIENT_LL_02_097: [ If creating the data structures fails or instantiating the IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE fails then IoTHubClientCore_LL_CreateWithTransport shall fail and return NULL. ]/
AzureIoTClient	88:248736be106e	519	LogError("unable to malloc");
AzureIoTClient	88:248736be106e	520	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	521	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	522	free(result);
AzureIoTClient	88:248736be106e	523	result = NULL;
AzureIoTClient	88:248736be106e	524	}
AzureIoTClient	88:248736be106e	525	else if ((IoTHubSuffix = (char*)malloc(suffix_len + 1)) == NULL)
AzureIoTClient	88:248736be106e	526	{
AzureIoTClient	88:248736be106e	527	/Codes_SRS_IOTHUBCLIENT_LL_02_097: [ If creating the data structures fails or instantiating the IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE fails then IoTHubClientCore_LL_CreateWithTransport shall fail and return NULL. ]/
AzureIoTClient	88:248736be106e	528	LogError("unable to malloc");
AzureIoTClient	88:248736be106e	529	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	530	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	531	free(result);
AzureIoTClient	88:248736be106e	532	result = NULL;
AzureIoTClient	88:248736be106e	533	}
AzureIoTClient	88:248736be106e	534	else
AzureIoTClient	88:248736be106e	535	{
AzureIoTClient	88:248736be106e	536	memset(IoTHubName, 0, whereIsDot - hostname + 1);
AzureIoTClient	88:248736be106e	537	(void)strncpy(IoTHubName, hostname, whereIsDot - hostname);
AzureIoTClient	88:248736be106e	538	(void)strcpy(IoTHubSuffix, whereIsDot+1);
AzureIoTClient	88:248736be106e	539
AzureIoTClient	88:248736be106e	540	actual_config.deviceId = device_config->deviceId;
AzureIoTClient	88:248736be106e	541	actual_config.deviceKey = device_config->deviceKey;
AzureIoTClient	88:248736be106e	542	actual_config.deviceSasToken = device_config->deviceSasToken;
AzureIoTClient	88:248736be106e	543	actual_config.iotHubName = IoTHubName;
AzureIoTClient	88:248736be106e	544	actual_config.iotHubSuffix = IoTHubSuffix;
AzureIoTClient	88:248736be106e	545	actual_config.protocol = NULL; /irrelevant to IoTHubClientCore_LL_UploadToBlob/
AzureIoTClient	88:248736be106e	546	actual_config.protocolGatewayHostName = NULL; /irrelevant to IoTHubClientCore_LL_UploadToBlob/
AzureIoTClient	88:248736be106e	547
AzureIoTClient	88:248736be106e	548	config = &actual_config;
AzureIoTClient	88:248736be106e	549
AzureIoTClient	88:248736be106e	550	/Codes_SRS_IOTHUBCLIENT_LL_02_008: [Otherwise, IoTHubClientCore_LL_Create shall succeed and return a non-NULL handle.] /
AzureIoTClient	88:248736be106e	551	result->isSharedTransport = true;
AzureIoTClient	88:248736be106e	552	}
AzureIoTClient	88:248736be106e	553	}
AzureIoTClient	88:248736be106e	554	}
AzureIoTClient	88:248736be106e	555	STRING_delete(transport_hostname);
AzureIoTClient	88:248736be106e	556	}
AzureIoTClient	88:248736be106e	557	}
AzureIoTClient	88:248736be106e	558	if (result != NULL)
AzureIoTClient	88:248736be106e	559	{
AzureIoTClient	88:248736be106e	560	if (create_blob_upload_module(result, config) != 0)
AzureIoTClient	88:248736be106e	561	{
AzureIoTClient	88:248736be106e	562	LogError("unable to create blob upload");
AzureIoTClient	88:248736be106e	563	// Codes_SRS_IOTHUBCLIENT_LL_09_010: [ If any failure occurs `IoTHubClientCore_LL_Create` shall destroy the `transportHandle` only if it has created it ]
AzureIoTClient	88:248736be106e	564	if (!result->isSharedTransport)
AzureIoTClient	88:248736be106e	565	{
AzureIoTClient	88:248736be106e	566	result->IoTHubTransport_Destroy(result->transportHandle);
AzureIoTClient	88:248736be106e	567	}
AzureIoTClient	88:248736be106e	568	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	569	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	570	free(result);
AzureIoTClient	88:248736be106e	571	result = NULL;
AzureIoTClient	88:248736be106e	572	}
AzureIoTClient	91:bbf806070c5f	573	else if ((module_id != NULL) && create_edge_handle(result, config, module_id) != 0)
AzureIoTClient	91:bbf806070c5f	574	{
AzureIoTClient	91:bbf806070c5f	575	LogError("unable to create module method handle");
AzureIoTClient	91:bbf806070c5f	576	if (!result->isSharedTransport)
AzureIoTClient	91:bbf806070c5f	577	{
AzureIoTClient	91:bbf806070c5f	578	result->IoTHubTransport_Destroy(result->transportHandle);
AzureIoTClient	91:bbf806070c5f	579	}
AzureIoTClient	91:bbf806070c5f	580	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	91:bbf806070c5f	581	STRING_delete(product_info);
AzureIoTClient	91:bbf806070c5f	582	free(result);
AzureIoTClient	91:bbf806070c5f	583	result = NULL;
AzureIoTClient	91:bbf806070c5f	584	}
AzureIoTClient	88:248736be106e	585	else
AzureIoTClient	88:248736be106e	586	{
AzureIoTClient	88:248736be106e	587	if ((result->tickCounter = tickcounter_create()) == NULL)
AzureIoTClient	88:248736be106e	588	{
AzureIoTClient	88:248736be106e	589	LogError("unable to get a tickcounter");
AzureIoTClient	88:248736be106e	590	// Codes_SRS_IOTHUBCLIENT_LL_09_010: [ If any failure occurs `IoTHubClientCore_LL_Create` shall destroy the `transportHandle` only if it has created it ]
AzureIoTClient	88:248736be106e	591	if (!result->isSharedTransport)
AzureIoTClient	88:248736be106e	592	{
AzureIoTClient	88:248736be106e	593	result->IoTHubTransport_Destroy(result->transportHandle);
AzureIoTClient	88:248736be106e	594	}
AzureIoTClient	88:248736be106e	595	destroy_blob_upload_module(result);
AzureIoTClient	91:bbf806070c5f	596	destroy_module_method_module(result);
AzureIoTClient	88:248736be106e	597	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	598	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	599	free(result);
AzureIoTClient	88:248736be106e	600	result = NULL;
AzureIoTClient	88:248736be106e	601	}
AzureIoTClient	88:248736be106e	602	else
AzureIoTClient	88:248736be106e	603	{
AzureIoTClient	88:248736be106e	604	/Codes_SRS_IOTHUBCLIENT_LL_02_004: [Otherwise IoTHubClientCore_LL_Create shall initialize a new DLIST (further called "waitingToSend") containing records with fields of the following types: IOTHUB_MESSAGE_HANDLE, IOTHUB_CLIENT_EVENT_CONFIRMATION_CALLBACK, void.]*/
AzureIoTClient	88:248736be106e	605	DList_InitializeListHead(&(result->waitingToSend));
AzureIoTClient	88:248736be106e	606	DList_InitializeListHead(&(result->iot_msg_queue));
AzureIoTClient	88:248736be106e	607	DList_InitializeListHead(&(result->iot_ack_queue));
AzureIoTClient	88:248736be106e	608	result->messageCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	609	result->lastMessageReceiveTime = INDEFINITE_TIME;
AzureIoTClient	88:248736be106e	610	result->data_msg_id = 1;
AzureIoTClient	88:248736be106e	611	result->product_info = product_info;
AzureIoTClient	88:248736be106e	612
AzureIoTClient	88:248736be106e	613	IOTHUB_DEVICE_CONFIG deviceConfig;
AzureIoTClient	88:248736be106e	614	deviceConfig.deviceId = config->deviceId;
AzureIoTClient	88:248736be106e	615	deviceConfig.deviceKey = config->deviceKey;
AzureIoTClient	88:248736be106e	616	deviceConfig.deviceSasToken = config->deviceSasToken;
AzureIoTClient	88:248736be106e	617	deviceConfig.authorization_module = result->authorization_module;
AzureIoTClient	89:a2ed767a532e	618	deviceConfig.moduleId = module_id;
AzureIoTClient	88:248736be106e	619
AzureIoTClient	88:248736be106e	620	/Codes_SRS_IOTHUBCLIENT_LL_17_008: [IoTHubClientCore_LL_Create shall call the transport _Register function with a populated structure of type IOTHUB_DEVICE_CONFIG and waitingToSend list.] /
AzureIoTClient	88:248736be106e	621	if ((result->deviceHandle = result->IoTHubTransport_Register(result->transportHandle, &deviceConfig, result, &(result->waitingToSend))) == NULL)
AzureIoTClient	88:248736be106e	622	{
AzureIoTClient	88:248736be106e	623	LogError("Registering device in transport failed");
AzureIoTClient	88:248736be106e	624	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	625	// Codes_SRS_IOTHUBCLIENT_LL_09_010: [ If any failure occurs `IoTHubClientCore_LL_Create` shall destroy the `transportHandle` only if it has created it ]
AzureIoTClient	88:248736be106e	626	if (!result->isSharedTransport)
AzureIoTClient	88:248736be106e	627	{
AzureIoTClient	88:248736be106e	628	result->IoTHubTransport_Destroy(result->transportHandle);
AzureIoTClient	88:248736be106e	629	}
AzureIoTClient	88:248736be106e	630	destroy_blob_upload_module(result);
AzureIoTClient	91:bbf806070c5f	631	destroy_module_method_module(result);
AzureIoTClient	88:248736be106e	632	tickcounter_destroy(result->tickCounter);
AzureIoTClient	88:248736be106e	633	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	634	free(result);
AzureIoTClient	88:248736be106e	635	result = NULL;
AzureIoTClient	88:248736be106e	636	}
AzureIoTClient	88:248736be106e	637	else
AzureIoTClient	88:248736be106e	638	{
AzureIoTClient	88:248736be106e	639	/Codes_SRS_IOTHUBCLIENT_LL_02_042: [ By default, messages shall not timeout. ]/
AzureIoTClient	88:248736be106e	640	result->currentMessageTimeout = 0;
AzureIoTClient	88:248736be106e	641	result->current_device_twin_timeout = 0;
AzureIoTClient	88:248736be106e	642
AzureIoTClient	88:248736be106e	643	result->diagnostic_setting.currentMessageNumber = 0;
AzureIoTClient	88:248736be106e	644	result->diagnostic_setting.diagSamplingPercentage = 0;
AzureIoTClient	88:248736be106e	645	/Codes_SRS_IOTHUBCLIENT_LL_25_124: [ `IoTHubClientCore_LL_Create` shall set the default retry policy as Exponential backoff with jitter and if succeed and return a `non-NULL` handle. ]/
AzureIoTClient	88:248736be106e	646	if (IoTHubClientCore_LL_SetRetryPolicy(result, IOTHUB_CLIENT_RETRY_EXPONENTIAL_BACKOFF_WITH_JITTER, 0) != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	647	{
AzureIoTClient	88:248736be106e	648	LogError("Setting default retry policy in transport failed");
AzureIoTClient	88:248736be106e	649	result->IoTHubTransport_Unregister(result->deviceHandle);
AzureIoTClient	88:248736be106e	650	IoTHubClient_Auth_Destroy(result->authorization_module);
AzureIoTClient	88:248736be106e	651	// Codes_SRS_IOTHUBCLIENT_LL_09_010: [ If any failure occurs `IoTHubClientCore_LL_Create` shall destroy the `transportHandle` only if it has created it ]
AzureIoTClient	88:248736be106e	652	if (!result->isSharedTransport)
AzureIoTClient	88:248736be106e	653	{
AzureIoTClient	88:248736be106e	654	result->IoTHubTransport_Destroy(result->transportHandle);
AzureIoTClient	88:248736be106e	655	}
AzureIoTClient	88:248736be106e	656	destroy_blob_upload_module(result);
AzureIoTClient	91:bbf806070c5f	657	destroy_module_method_module(result);
AzureIoTClient	88:248736be106e	658	tickcounter_destroy(result->tickCounter);
AzureIoTClient	88:248736be106e	659	STRING_delete(product_info);
AzureIoTClient	88:248736be106e	660	free(result);
AzureIoTClient	88:248736be106e	661	result = NULL;
AzureIoTClient	88:248736be106e	662	}
AzureIoTClient	88:248736be106e	663	}
AzureIoTClient	88:248736be106e	664	}
AzureIoTClient	88:248736be106e	665	}
AzureIoTClient	88:248736be106e	666	}
AzureIoTClient	88:248736be106e	667	if (IoTHubName)
AzureIoTClient	88:248736be106e	668	{
AzureIoTClient	88:248736be106e	669	free(IoTHubName);
AzureIoTClient	88:248736be106e	670	}
AzureIoTClient	88:248736be106e	671	if (IoTHubSuffix)
AzureIoTClient	88:248736be106e	672	{
AzureIoTClient	88:248736be106e	673	free(IoTHubSuffix);
AzureIoTClient	88:248736be106e	674	}
AzureIoTClient	88:248736be106e	675	}
AzureIoTClient	88:248736be106e	676	}
AzureIoTClient	88:248736be106e	677	return result;
AzureIoTClient	88:248736be106e	678	}
AzureIoTClient	88:248736be106e	679
AzureIoTClient	88:248736be106e	680	static uint32_t get_next_item_id(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData)
AzureIoTClient	88:248736be106e	681	{
AzureIoTClient	88:248736be106e	682	if (handleData->data_msg_id+1 >= UINT32_MAX)
AzureIoTClient	88:248736be106e	683	{
AzureIoTClient	88:248736be106e	684	handleData->data_msg_id = 1;
AzureIoTClient	88:248736be106e	685	}
AzureIoTClient	88:248736be106e	686	else
AzureIoTClient	88:248736be106e	687	{
AzureIoTClient	88:248736be106e	688	handleData->data_msg_id++;
AzureIoTClient	88:248736be106e	689	}
AzureIoTClient	88:248736be106e	690	return handleData->data_msg_id;
AzureIoTClient	88:248736be106e	691	}
AzureIoTClient	88:248736be106e	692
AzureIoTClient	88:248736be106e	693	static IOTHUB_DEVICE_TWIN* dev_twin_data_create(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData, uint32_t id, const unsigned char* reportedState, size_t size, IOTHUB_CLIENT_REPORTED_STATE_CALLBACK reportedStateCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	694	{
AzureIoTClient	88:248736be106e	695	IOTHUB_DEVICE_TWIN* result = (IOTHUB_DEVICE_TWIN*)malloc(sizeof(IOTHUB_DEVICE_TWIN) );
AzureIoTClient	88:248736be106e	696	if (result != NULL)
AzureIoTClient	88:248736be106e	697	{
AzureIoTClient	88:248736be106e	698	result->report_data_handle = CONSTBUFFER_Create(reportedState, size);
AzureIoTClient	88:248736be106e	699	if (result->report_data_handle == NULL)
AzureIoTClient	88:248736be106e	700	{
AzureIoTClient	88:248736be106e	701	LogError("Failure allocating reported state data");
AzureIoTClient	88:248736be106e	702	free(result);
AzureIoTClient	88:248736be106e	703	result = NULL;
AzureIoTClient	88:248736be106e	704	}
AzureIoTClient	88:248736be106e	705	else if (tickcounter_get_current_ms(handleData->tickCounter, &result->ms_timesOutAfter) != 0)
AzureIoTClient	88:248736be106e	706	{
AzureIoTClient	88:248736be106e	707	LogError("Failure getting tickcount info");
AzureIoTClient	88:248736be106e	708	CONSTBUFFER_Destroy(result->report_data_handle);
AzureIoTClient	88:248736be106e	709	free(result);
AzureIoTClient	88:248736be106e	710	result = NULL;
AzureIoTClient	88:248736be106e	711	}
AzureIoTClient	88:248736be106e	712	else
AzureIoTClient	88:248736be106e	713	{
AzureIoTClient	88:248736be106e	714	result->item_id = id;
AzureIoTClient	88:248736be106e	715	result->ms_timesOutAfter = 0;
AzureIoTClient	88:248736be106e	716	result->context = userContextCallback;
AzureIoTClient	88:248736be106e	717	result->reported_state_callback = reportedStateCallback;
AzureIoTClient	88:248736be106e	718	result->client_handle = handleData;
AzureIoTClient	88:248736be106e	719	result->device_handle = handleData->deviceHandle;
AzureIoTClient	88:248736be106e	720	}
AzureIoTClient	88:248736be106e	721	}
AzureIoTClient	88:248736be106e	722	else
AzureIoTClient	88:248736be106e	723	{
AzureIoTClient	88:248736be106e	724	LogError("Failure allocating device twin information");
AzureIoTClient	88:248736be106e	725	}
AzureIoTClient	88:248736be106e	726	return result;
AzureIoTClient	88:248736be106e	727	}
AzureIoTClient	88:248736be106e	728
AzureIoTClient	89:a2ed767a532e	729	static void delete_event(IOTHUB_EVENT_CALLBACK* event_callback)
AzureIoTClient	89:a2ed767a532e	730	{
AzureIoTClient	89:a2ed767a532e	731	STRING_delete(event_callback->inputName);
AzureIoTClient	89:a2ed767a532e	732	free(event_callback->userContextCallbackEx);
AzureIoTClient	89:a2ed767a532e	733	free(event_callback);
AzureIoTClient	89:a2ed767a532e	734	}
AzureIoTClient	89:a2ed767a532e	735
AzureIoTClient	89:a2ed767a532e	736	static void delete_event_callback(const void* item, const void* action_context, bool* continue_processing)
AzureIoTClient	89:a2ed767a532e	737	{
AzureIoTClient	89:a2ed767a532e	738	(void)action_context;
AzureIoTClient	89:a2ed767a532e	739	delete_event((IOTHUB_EVENT_CALLBACK*)item);
AzureIoTClient	89:a2ed767a532e	740	*continue_processing = true;
AzureIoTClient	89:a2ed767a532e	741	}
AzureIoTClient	89:a2ed767a532e	742
AzureIoTClient	89:a2ed767a532e	743	static void delete_event_callback_list(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData)
AzureIoTClient	89:a2ed767a532e	744	{
AzureIoTClient	89:a2ed767a532e	745	if (handleData->event_callbacks != NULL)
AzureIoTClient	89:a2ed767a532e	746	{
AzureIoTClient	89:a2ed767a532e	747	singlylinkedlist_foreach(handleData->event_callbacks, delete_event_callback, NULL);
AzureIoTClient	89:a2ed767a532e	748	singlylinkedlist_destroy(handleData->event_callbacks);
AzureIoTClient	89:a2ed767a532e	749	handleData->event_callbacks = NULL;
AzureIoTClient	89:a2ed767a532e	750	}
AzureIoTClient	89:a2ed767a532e	751	}
AzureIoTClient	89:a2ed767a532e	752
AzureIoTClient	89:a2ed767a532e	753
AzureIoTClient	88:248736be106e	754	IOTHUB_CLIENT_CORE_LL_HANDLE IoTHubClientCore_LL_CreateFromDeviceAuth(const char* iothub_uri, const char* device_id, IOTHUB_CLIENT_TRANSPORT_PROVIDER protocol)
AzureIoTClient	88:248736be106e	755	{
AzureIoTClient	88:248736be106e	756	IOTHUB_CLIENT_CORE_LL_HANDLE result;
AzureIoTClient	88:248736be106e	757	if (iothub_uri == NULL \|\| protocol == NULL \|\| device_id == NULL)
AzureIoTClient	88:248736be106e	758	{
AzureIoTClient	88:248736be106e	759	LogError("Input parameter is NULL: iothub_uri: %p protocol: %p device_id: %p", iothub_uri, protocol, device_id);
AzureIoTClient	88:248736be106e	760	result = NULL;
AzureIoTClient	88:248736be106e	761	}
AzureIoTClient	88:248736be106e	762	else
AzureIoTClient	88:248736be106e	763	{
AzureIoTClient	88:248736be106e	764	#ifdef USE_PROV_MODULE
AzureIoTClient	88:248736be106e	765	IOTHUB_CLIENT_CONFIG* config = (IOTHUB_CLIENT_CONFIG*)malloc(sizeof(IOTHUB_CLIENT_CONFIG));
AzureIoTClient	88:248736be106e	766	if (config == NULL)
AzureIoTClient	88:248736be106e	767	{
AzureIoTClient	88:248736be106e	768	/* Codes_SRS_IOTHUBCLIENT_LL_12_012: [If the allocation failed IoTHubClientCore_LL_CreateFromConnectionString returns NULL] */
AzureIoTClient	88:248736be106e	769	LogError("Malloc failed");
AzureIoTClient	88:248736be106e	770	result = NULL;
AzureIoTClient	88:248736be106e	771	}
AzureIoTClient	88:248736be106e	772	else
AzureIoTClient	88:248736be106e	773	{
AzureIoTClient	88:248736be106e	774	const char* iterator;
AzureIoTClient	88:248736be106e	775	const char* initial;
AzureIoTClient	88:248736be106e	776	char* iothub_name = NULL;
AzureIoTClient	88:248736be106e	777	char* iothub_suffix = NULL;
AzureIoTClient	88:248736be106e	778
AzureIoTClient	88:248736be106e	779	memset(config, 0, sizeof(IOTHUB_CLIENT_CONFIG));
AzureIoTClient	88:248736be106e	780	config->protocol = protocol;
AzureIoTClient	88:248736be106e	781	config->deviceId = device_id;
AzureIoTClient	88:248736be106e	782
AzureIoTClient	88:248736be106e	783	// Find the iothub suffix
AzureIoTClient	88:248736be106e	784	initial = iterator = iothub_uri;
AzureIoTClient	88:248736be106e	785	while (iterator != NULL && *iterator != '\0')
AzureIoTClient	88:248736be106e	786	{
AzureIoTClient	88:248736be106e	787	if (*iterator == '.')
AzureIoTClient	88:248736be106e	788	{
AzureIoTClient	88:248736be106e	789	size_t length = iterator - initial;
AzureIoTClient	88:248736be106e	790	iothub_name = (char*)malloc(length + 1);
AzureIoTClient	88:248736be106e	791	if (iothub_name != NULL)
AzureIoTClient	88:248736be106e	792	{
AzureIoTClient	88:248736be106e	793	memset(iothub_name, 0, length + 1);
AzureIoTClient	88:248736be106e	794	memcpy(iothub_name, initial, length);
AzureIoTClient	88:248736be106e	795	config->iotHubName = iothub_name;
AzureIoTClient	88:248736be106e	796
AzureIoTClient	88:248736be106e	797	length = strlen(initial) - length - 1;
AzureIoTClient	88:248736be106e	798	iothub_suffix = (char*)malloc(length + 1);
AzureIoTClient	88:248736be106e	799	if (iothub_suffix != NULL)
AzureIoTClient	88:248736be106e	800	{
AzureIoTClient	88:248736be106e	801	memset(iothub_suffix, 0, length + 1);
AzureIoTClient	88:248736be106e	802	memcpy(iothub_suffix, iterator + 1, length);
AzureIoTClient	88:248736be106e	803	config->iotHubSuffix = iothub_suffix;
AzureIoTClient	88:248736be106e	804	break;
AzureIoTClient	88:248736be106e	805	}
AzureIoTClient	88:248736be106e	806	else
AzureIoTClient	88:248736be106e	807	{
AzureIoTClient	88:248736be106e	808	LogError("Failed to allocate iothub suffix");
AzureIoTClient	88:248736be106e	809	free(iothub_name);
AzureIoTClient	88:248736be106e	810	iothub_name = NULL;
AzureIoTClient	88:248736be106e	811	result = NULL;
AzureIoTClient	88:248736be106e	812	}
AzureIoTClient	88:248736be106e	813	}
AzureIoTClient	88:248736be106e	814	else
AzureIoTClient	88:248736be106e	815	{
AzureIoTClient	88:248736be106e	816	LogError("Failed to allocate iothub name");
AzureIoTClient	88:248736be106e	817	result = NULL;
AzureIoTClient	88:248736be106e	818	}
AzureIoTClient	88:248736be106e	819	}
AzureIoTClient	88:248736be106e	820	iterator++;
AzureIoTClient	88:248736be106e	821	}
AzureIoTClient	88:248736be106e	822
AzureIoTClient	88:248736be106e	823	if (config->iotHubName == NULL \|\| config->iotHubSuffix == NULL)
AzureIoTClient	88:248736be106e	824	{
AzureIoTClient	88:248736be106e	825	LogError("initialize iothub client");
AzureIoTClient	88:248736be106e	826	result = NULL;
AzureIoTClient	88:248736be106e	827	}
AzureIoTClient	88:248736be106e	828	else
AzureIoTClient	88:248736be106e	829	{
AzureIoTClient	89:a2ed767a532e	830	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = initialize_iothub_client(config, NULL, true, NULL);
AzureIoTClient	88:248736be106e	831	if (handleData == NULL)
AzureIoTClient	88:248736be106e	832	{
AzureIoTClient	88:248736be106e	833	LogError("initialize iothub client");
AzureIoTClient	88:248736be106e	834	result = NULL;
AzureIoTClient	88:248736be106e	835	}
AzureIoTClient	88:248736be106e	836	else
AzureIoTClient	88:248736be106e	837	{
AzureIoTClient	88:248736be106e	838	result = handleData;
AzureIoTClient	88:248736be106e	839	}
AzureIoTClient	88:248736be106e	840	}
AzureIoTClient	88:248736be106e	841
AzureIoTClient	88:248736be106e	842	free(iothub_name);
AzureIoTClient	88:248736be106e	843	free(iothub_suffix);
AzureIoTClient	88:248736be106e	844	free(config);
AzureIoTClient	88:248736be106e	845	}
AzureIoTClient	88:248736be106e	846	#else
AzureIoTClient	88:248736be106e	847	LogError("HSM module is not included");
AzureIoTClient	88:248736be106e	848	result = NULL;
AzureIoTClient	88:248736be106e	849	#endif
AzureIoTClient	88:248736be106e	850	}
AzureIoTClient	88:248736be106e	851	return result;
AzureIoTClient	88:248736be106e	852	}
AzureIoTClient	88:248736be106e	853
AzureIoTClient	88:248736be106e	854	IOTHUB_CLIENT_CORE_LL_HANDLE IoTHubClientCore_LL_CreateFromConnectionString(const char* connectionString, IOTHUB_CLIENT_TRANSPORT_PROVIDER protocol)
AzureIoTClient	88:248736be106e	855	{
AzureIoTClient	88:248736be106e	856	IOTHUB_CLIENT_CORE_LL_HANDLE result;
AzureIoTClient	88:248736be106e	857
AzureIoTClient	88:248736be106e	858	/* Codes_SRS_IOTHUBCLIENT_LL_12_003: [IoTHubClientCore_LL_CreateFromConnectionString shall verify the input parameter and if it is NULL then return NULL] */
AzureIoTClient	88:248736be106e	859	if (connectionString == NULL)
AzureIoTClient	88:248736be106e	860	{
AzureIoTClient	88:248736be106e	861	LogError("Input parameter is NULL: connectionString");
AzureIoTClient	88:248736be106e	862	result = NULL;
AzureIoTClient	88:248736be106e	863	}
AzureIoTClient	88:248736be106e	864	else if (protocol == NULL)
AzureIoTClient	88:248736be106e	865	{
AzureIoTClient	88:248736be106e	866	LogError("Input parameter is NULL: protocol");
AzureIoTClient	88:248736be106e	867	result = NULL;
AzureIoTClient	88:248736be106e	868	}
AzureIoTClient	88:248736be106e	869	else
AzureIoTClient	88:248736be106e	870	{
AzureIoTClient	88:248736be106e	871	/* Codes_SRS_IOTHUBCLIENT_LL_12_004: [IoTHubClientCore_LL_CreateFromConnectionString shall allocate IOTHUB_CLIENT_CONFIG structure] */
AzureIoTClient	88:248736be106e	872	IOTHUB_CLIENT_CONFIG* config = (IOTHUB_CLIENT_CONFIG*) malloc(sizeof(IOTHUB_CLIENT_CONFIG));
AzureIoTClient	88:248736be106e	873	if (config == NULL)
AzureIoTClient	88:248736be106e	874	{
AzureIoTClient	88:248736be106e	875	/* Codes_SRS_IOTHUBCLIENT_LL_12_012: [If the allocation failed IoTHubClientCore_LL_CreateFromConnectionString returns NULL] */
AzureIoTClient	88:248736be106e	876	LogError("Malloc failed");
AzureIoTClient	88:248736be106e	877	result = NULL;
AzureIoTClient	88:248736be106e	878	}
AzureIoTClient	88:248736be106e	879	else
AzureIoTClient	88:248736be106e	880	{
AzureIoTClient	88:248736be106e	881	STRING_TOKENIZER_HANDLE tokenizer1 = NULL;
AzureIoTClient	88:248736be106e	882	STRING_HANDLE connString = NULL;
AzureIoTClient	88:248736be106e	883	STRING_HANDLE tokenString = NULL;
AzureIoTClient	88:248736be106e	884	STRING_HANDLE valueString = NULL;
AzureIoTClient	88:248736be106e	885	STRING_HANDLE hostNameString = NULL;
AzureIoTClient	88:248736be106e	886	STRING_HANDLE hostSuffixString = NULL;
AzureIoTClient	88:248736be106e	887	STRING_HANDLE deviceIdString = NULL;
AzureIoTClient	88:248736be106e	888	STRING_HANDLE deviceKeyString = NULL;
AzureIoTClient	88:248736be106e	889	STRING_HANDLE deviceSasTokenString = NULL;
AzureIoTClient	88:248736be106e	890	STRING_HANDLE protocolGateway = NULL;
AzureIoTClient	89:a2ed767a532e	891	STRING_HANDLE moduleId = NULL;
AzureIoTClient	88:248736be106e	892
AzureIoTClient	89:a2ed767a532e	893	memset(config, 0, sizeof(*config));
AzureIoTClient	89:a2ed767a532e	894	config->protocol = protocol;
AzureIoTClient	88:248736be106e	895
AzureIoTClient	88:248736be106e	896	/* Codes_SRS_IOTHUBCLIENT_LL_04_002: [If it does not, it shall pass the protocolGatewayHostName NULL.] */
AzureIoTClient	88:248736be106e	897	config->protocolGatewayHostName = NULL;
AzureIoTClient	88:248736be106e	898
AzureIoTClient	88:248736be106e	899	if ((connString = STRING_construct(connectionString)) == NULL)
AzureIoTClient	88:248736be106e	900	{
AzureIoTClient	88:248736be106e	901	LogError("Error constructing connectiong String");
AzureIoTClient	88:248736be106e	902	result = NULL;
AzureIoTClient	88:248736be106e	903	}
AzureIoTClient	88:248736be106e	904	else if ((tokenizer1 = STRING_TOKENIZER_create(connString)) == NULL)
AzureIoTClient	88:248736be106e	905	{
AzureIoTClient	88:248736be106e	906	LogError("Error creating Tokenizer");
AzureIoTClient	88:248736be106e	907	result = NULL;
AzureIoTClient	88:248736be106e	908	}
AzureIoTClient	88:248736be106e	909	else if ((tokenString = STRING_new()) == NULL)
AzureIoTClient	88:248736be106e	910	{
AzureIoTClient	88:248736be106e	911	LogError("Error creating Token String");
AzureIoTClient	88:248736be106e	912	result = NULL;
AzureIoTClient	88:248736be106e	913	}
AzureIoTClient	88:248736be106e	914	else if ((valueString = STRING_new()) == NULL)
AzureIoTClient	88:248736be106e	915	{
AzureIoTClient	88:248736be106e	916	LogError("Error creating Value String");
AzureIoTClient	88:248736be106e	917	result = NULL;
AzureIoTClient	88:248736be106e	918	}
AzureIoTClient	88:248736be106e	919	else if ((hostNameString = STRING_new()) == NULL)
AzureIoTClient	88:248736be106e	920	{
AzureIoTClient	88:248736be106e	921	LogError("Error creating HostName String");
AzureIoTClient	88:248736be106e	922	result = NULL;
AzureIoTClient	88:248736be106e	923	}
AzureIoTClient	88:248736be106e	924	else if ((hostSuffixString = STRING_new()) == NULL)
AzureIoTClient	88:248736be106e	925	{
AzureIoTClient	88:248736be106e	926	LogError("Error creating HostSuffix String");
AzureIoTClient	88:248736be106e	927	result = NULL;
AzureIoTClient	88:248736be106e	928	}
AzureIoTClient	88:248736be106e	929	/* Codes_SRS_IOTHUBCLIENT_LL_12_005: [IoTHubClientCore_LL_CreateFromConnectionString shall try to parse the connectionString input parameter for the following structure: "Key1=value1;key2=value2;key3=value3..."] */
AzureIoTClient	88:248736be106e	930	/* Codes_SRS_IOTHUBCLIENT_LL_12_006: [IoTHubClientCore_LL_CreateFromConnectionString shall verify the existence of the following Key/Value pairs in the connection string: HostName, DeviceId, SharedAccessKey, SharedAccessSignature or x509] */
AzureIoTClient	88:248736be106e	931	else
AzureIoTClient	88:248736be106e	932	{
AzureIoTClient	88:248736be106e	933	int isx509found = 0;
AzureIoTClient	88:248736be106e	934	bool use_provisioning = false;
AzureIoTClient	88:248736be106e	935	while ((STRING_TOKENIZER_get_next_token(tokenizer1, tokenString, "=") == 0))
AzureIoTClient	88:248736be106e	936	{
AzureIoTClient	88:248736be106e	937	if (STRING_TOKENIZER_get_next_token(tokenizer1, valueString, ";") != 0)
AzureIoTClient	88:248736be106e	938	{
AzureIoTClient	88:248736be106e	939	LogError("Tokenizer error");
AzureIoTClient	88:248736be106e	940	break;
AzureIoTClient	88:248736be106e	941	}
AzureIoTClient	88:248736be106e	942	else
AzureIoTClient	88:248736be106e	943	{
AzureIoTClient	88:248736be106e	944	if (tokenString != NULL)
AzureIoTClient	88:248736be106e	945	{
AzureIoTClient	88:248736be106e	946	/* Codes_SRS_IOTHUBCLIENT_LL_12_010: [IoTHubClientCore_LL_CreateFromConnectionString shall fill up the IOTHUB_CLIENT_CONFIG structure using the following mapping: iotHubName = Name, iotHubSuffix = Suffix, deviceId = DeviceId, deviceKey = SharedAccessKey or deviceSasToken = SharedAccessSignature] */
AzureIoTClient	88:248736be106e	947	const char* s_token = STRING_c_str(tokenString);
AzureIoTClient	88:248736be106e	948	if (strcmp(s_token, HOSTNAME_TOKEN) == 0)
AzureIoTClient	88:248736be106e	949	{
AzureIoTClient	88:248736be106e	950	/* Codes_SRS_IOTHUBCLIENT_LL_12_009: [IoTHubClientCore_LL_CreateFromConnectionString shall split the value of HostName to Name and Suffix using the first "." as a separator] */
AzureIoTClient	88:248736be106e	951	STRING_TOKENIZER_HANDLE tokenizer2 = NULL;
AzureIoTClient	88:248736be106e	952	if ((tokenizer2 = STRING_TOKENIZER_create(valueString)) == NULL)
AzureIoTClient	88:248736be106e	953	{
AzureIoTClient	88:248736be106e	954	LogError("Error creating Tokenizer");
AzureIoTClient	88:248736be106e	955	break;
AzureIoTClient	88:248736be106e	956	}
AzureIoTClient	88:248736be106e	957	else
AzureIoTClient	88:248736be106e	958	{
AzureIoTClient	88:248736be106e	959	/* Codes_SRS_IOTHUBCLIENT_LL_12_015: [If the string split failed, IoTHubClientCore_LL_CreateFromConnectionString returns NULL ] */
AzureIoTClient	88:248736be106e	960	if (STRING_TOKENIZER_get_next_token(tokenizer2, hostNameString, ".") != 0)
AzureIoTClient	88:248736be106e	961	{
AzureIoTClient	88:248736be106e	962	LogError("Tokenizer error");
AzureIoTClient	88:248736be106e	963	STRING_TOKENIZER_destroy(tokenizer2);
AzureIoTClient	88:248736be106e	964	break;
AzureIoTClient	88:248736be106e	965	}
AzureIoTClient	88:248736be106e	966	else
AzureIoTClient	88:248736be106e	967	{
AzureIoTClient	88:248736be106e	968	config->iotHubName = STRING_c_str(hostNameString);
AzureIoTClient	88:248736be106e	969	if (STRING_TOKENIZER_get_next_token(tokenizer2, hostSuffixString, ";") != 0)
AzureIoTClient	88:248736be106e	970	{
AzureIoTClient	88:248736be106e	971	LogError("Tokenizer error");
AzureIoTClient	88:248736be106e	972	STRING_TOKENIZER_destroy(tokenizer2);
AzureIoTClient	88:248736be106e	973	break;
AzureIoTClient	88:248736be106e	974	}
AzureIoTClient	88:248736be106e	975	else
AzureIoTClient	88:248736be106e	976	{
AzureIoTClient	88:248736be106e	977	config->iotHubSuffix = STRING_c_str(hostSuffixString);
AzureIoTClient	88:248736be106e	978	}
AzureIoTClient	88:248736be106e	979	}
AzureIoTClient	88:248736be106e	980	STRING_TOKENIZER_destroy(tokenizer2);
AzureIoTClient	88:248736be106e	981	}
AzureIoTClient	88:248736be106e	982	}
AzureIoTClient	88:248736be106e	983	else if (strcmp(s_token, DEVICEID_TOKEN) == 0)
AzureIoTClient	88:248736be106e	984	{
AzureIoTClient	88:248736be106e	985	deviceIdString = STRING_clone(valueString);
AzureIoTClient	88:248736be106e	986	if (deviceIdString != NULL)
AzureIoTClient	88:248736be106e	987	{
AzureIoTClient	88:248736be106e	988	config->deviceId = STRING_c_str(deviceIdString);
AzureIoTClient	88:248736be106e	989	}
AzureIoTClient	88:248736be106e	990	else
AzureIoTClient	88:248736be106e	991	{
AzureIoTClient	88:248736be106e	992	LogError("Failure cloning device id string");
AzureIoTClient	88:248736be106e	993	break;
AzureIoTClient	88:248736be106e	994	}
AzureIoTClient	88:248736be106e	995	}
AzureIoTClient	88:248736be106e	996	else if (strcmp(s_token, DEVICEKEY_TOKEN) == 0)
AzureIoTClient	88:248736be106e	997	{
AzureIoTClient	88:248736be106e	998	deviceKeyString = STRING_clone(valueString);
AzureIoTClient	88:248736be106e	999	if (deviceKeyString != NULL)
AzureIoTClient	88:248736be106e	1000	{
AzureIoTClient	88:248736be106e	1001	config->deviceKey = STRING_c_str(deviceKeyString);
AzureIoTClient	88:248736be106e	1002	}
AzureIoTClient	88:248736be106e	1003	else
AzureIoTClient	88:248736be106e	1004	{
AzureIoTClient	88:248736be106e	1005	LogError("Failure cloning device key string");
AzureIoTClient	88:248736be106e	1006	break;
AzureIoTClient	88:248736be106e	1007	}
AzureIoTClient	88:248736be106e	1008	}
AzureIoTClient	88:248736be106e	1009	else if (strcmp(s_token, DEVICESAS_TOKEN) == 0)
AzureIoTClient	88:248736be106e	1010	{
AzureIoTClient	88:248736be106e	1011	deviceSasTokenString = STRING_clone(valueString);
AzureIoTClient	88:248736be106e	1012	if (deviceSasTokenString != NULL)
AzureIoTClient	88:248736be106e	1013	{
AzureIoTClient	88:248736be106e	1014	config->deviceSasToken = STRING_c_str(deviceSasTokenString);
AzureIoTClient	88:248736be106e	1015	}
AzureIoTClient	88:248736be106e	1016	else
AzureIoTClient	88:248736be106e	1017	{
AzureIoTClient	88:248736be106e	1018	LogError("Failure cloning device sasToken string");
AzureIoTClient	88:248736be106e	1019	break;
AzureIoTClient	88:248736be106e	1020	}
AzureIoTClient	88:248736be106e	1021	}
AzureIoTClient	88:248736be106e	1022	else if (strcmp(s_token, X509_TOKEN) == 0)
AzureIoTClient	88:248736be106e	1023	{
AzureIoTClient	88:248736be106e	1024	if (strcmp(STRING_c_str(valueString), X509_TOKEN_ONLY_ACCEPTABLE_VALUE) != 0)
AzureIoTClient	88:248736be106e	1025	{
AzureIoTClient	88:248736be106e	1026	LogError("x509 option has wrong value, the only acceptable one is \"true\"");
AzureIoTClient	88:248736be106e	1027	break;
AzureIoTClient	88:248736be106e	1028	}
AzureIoTClient	88:248736be106e	1029	else
AzureIoTClient	88:248736be106e	1030	{
AzureIoTClient	88:248736be106e	1031	isx509found = 1;
AzureIoTClient	88:248736be106e	1032	}
AzureIoTClient	88:248736be106e	1033	}
AzureIoTClient	88:248736be106e	1034	else if (strcmp(s_token, PROVISIONING_TOKEN) == 0)
AzureIoTClient	88:248736be106e	1035	{
AzureIoTClient	88:248736be106e	1036	if (strcmp(STRING_c_str(valueString), PROVISIONING_ACCEPTABLE_VALUE) != 0)
AzureIoTClient	88:248736be106e	1037	{
AzureIoTClient	88:248736be106e	1038	LogError("provisioning option has wrong value, the only acceptable one is \"true\"");
AzureIoTClient	88:248736be106e	1039	break;
AzureIoTClient	88:248736be106e	1040	}
AzureIoTClient	88:248736be106e	1041	else
AzureIoTClient	88:248736be106e	1042	{
AzureIoTClient	88:248736be106e	1043	use_provisioning = 1;
AzureIoTClient	88:248736be106e	1044	}
AzureIoTClient	88:248736be106e	1045	}
AzureIoTClient	88:248736be106e	1046
AzureIoTClient	88:248736be106e	1047	/* Codes_SRS_IOTHUBCLIENT_LL_04_001: [IoTHubClientCore_LL_CreateFromConnectionString shall verify the existence of key/value pair GatewayHostName. If it does exist it shall pass the value to IoTHubClientCore_LL_Create API.] */
AzureIoTClient	89:a2ed767a532e	1048	else if (strcmp(s_token, PROTOCOL_GATEWAY_HOST_TOKEN) == 0)
AzureIoTClient	88:248736be106e	1049	{
AzureIoTClient	88:248736be106e	1050	protocolGateway = STRING_clone(valueString);
AzureIoTClient	88:248736be106e	1051	if (protocolGateway != NULL)
AzureIoTClient	88:248736be106e	1052	{
AzureIoTClient	88:248736be106e	1053	config->protocolGatewayHostName = STRING_c_str(protocolGateway);
AzureIoTClient	88:248736be106e	1054	}
AzureIoTClient	88:248736be106e	1055	else
AzureIoTClient	88:248736be106e	1056	{
AzureIoTClient	88:248736be106e	1057	LogError("Failure cloning protocol Gateway Name");
AzureIoTClient	88:248736be106e	1058	break;
AzureIoTClient	88:248736be106e	1059	}
AzureIoTClient	88:248736be106e	1060	}
AzureIoTClient	89:a2ed767a532e	1061	/Codes_SRS_IOTHUBCLIENT_LL_31_126: [IoTHubClient_LL_CreateFromConnectionString shall optionally parse ModuleId, if present.] /
AzureIoTClient	89:a2ed767a532e	1062	else if (strcmp(s_token, MODULE_ID_TOKEN) == 0)
AzureIoTClient	89:a2ed767a532e	1063	{
AzureIoTClient	89:a2ed767a532e	1064	moduleId = STRING_clone(valueString);
AzureIoTClient	89:a2ed767a532e	1065	if (moduleId == NULL)
AzureIoTClient	89:a2ed767a532e	1066	{
AzureIoTClient	89:a2ed767a532e	1067	LogError("Failure cloning moduleId string");
AzureIoTClient	89:a2ed767a532e	1068	break;
AzureIoTClient	89:a2ed767a532e	1069	}
AzureIoTClient	89:a2ed767a532e	1070	}
AzureIoTClient	88:248736be106e	1071	}
AzureIoTClient	88:248736be106e	1072	}
AzureIoTClient	88:248736be106e	1073	}
AzureIoTClient	88:248736be106e	1074	/* parsing is done - check the result */
AzureIoTClient	88:248736be106e	1075	if (config->iotHubName == NULL)
AzureIoTClient	88:248736be106e	1076	{
AzureIoTClient	88:248736be106e	1077	LogError("iotHubName is not found");
AzureIoTClient	88:248736be106e	1078	result = NULL;
AzureIoTClient	88:248736be106e	1079	}
AzureIoTClient	88:248736be106e	1080	else if (config->iotHubSuffix == NULL)
AzureIoTClient	88:248736be106e	1081	{
AzureIoTClient	88:248736be106e	1082	LogError("iotHubSuffix is not found");
AzureIoTClient	88:248736be106e	1083	result = NULL;
AzureIoTClient	88:248736be106e	1084	}
AzureIoTClient	88:248736be106e	1085	else if (config->deviceId == NULL)
AzureIoTClient	88:248736be106e	1086	{
AzureIoTClient	88:248736be106e	1087	LogError("deviceId is not found");
AzureIoTClient	88:248736be106e	1088	result = NULL;
AzureIoTClient	88:248736be106e	1089	}
AzureIoTClient	88:248736be106e	1090	else if (!(
AzureIoTClient	88:248736be106e	1091	((!use_provisioning && !isx509found) && (config->deviceSasToken == NULL) ^ (config->deviceKey == NULL)) \|\|
AzureIoTClient	88:248736be106e	1092	((use_provisioning \|\| isx509found) && (config->deviceSasToken == NULL) && (config->deviceKey == NULL))
AzureIoTClient	88:248736be106e	1093	))
AzureIoTClient	88:248736be106e	1094	{
AzureIoTClient	88:248736be106e	1095	LogError("invalid combination of x509, provisioning, deviceSasToken and deviceKey");
AzureIoTClient	88:248736be106e	1096	result = NULL;
AzureIoTClient	88:248736be106e	1097	}
AzureIoTClient	88:248736be106e	1098	else
AzureIoTClient	88:248736be106e	1099	{
AzureIoTClient	88:248736be106e	1100	/* Codes_SRS_IOTHUBCLIENT_LL_12_011: [IoTHubClientCore_LL_CreateFromConnectionString shall call into the IoTHubClientCore_LL_Create API with the current structure and returns with the return value of it] */
AzureIoTClient	89:a2ed767a532e	1101	result = initialize_iothub_client(config, NULL, use_provisioning, STRING_c_str(moduleId));
AzureIoTClient	88:248736be106e	1102	if (result == NULL)
AzureIoTClient	88:248736be106e	1103	{
AzureIoTClient	88:248736be106e	1104	LogError("IoTHubClientCore_LL_Create failed");
AzureIoTClient	88:248736be106e	1105	}
AzureIoTClient	88:248736be106e	1106	else
AzureIoTClient	88:248736be106e	1107	{
AzureIoTClient	88:248736be106e	1108	/return as is/
AzureIoTClient	88:248736be106e	1109	}
AzureIoTClient	88:248736be106e	1110	}
AzureIoTClient	88:248736be106e	1111	}
AzureIoTClient	88:248736be106e	1112	if (deviceSasTokenString != NULL)
AzureIoTClient	88:248736be106e	1113	STRING_delete(deviceSasTokenString);
AzureIoTClient	88:248736be106e	1114	if (deviceKeyString != NULL)
AzureIoTClient	88:248736be106e	1115	STRING_delete(deviceKeyString);
AzureIoTClient	88:248736be106e	1116	if (deviceIdString != NULL)
AzureIoTClient	88:248736be106e	1117	STRING_delete(deviceIdString);
AzureIoTClient	88:248736be106e	1118	if (hostSuffixString != NULL)
AzureIoTClient	88:248736be106e	1119	STRING_delete(hostSuffixString);
AzureIoTClient	88:248736be106e	1120	if (hostNameString != NULL)
AzureIoTClient	88:248736be106e	1121	STRING_delete(hostNameString);
AzureIoTClient	88:248736be106e	1122	if (valueString != NULL)
AzureIoTClient	88:248736be106e	1123	STRING_delete(valueString);
AzureIoTClient	88:248736be106e	1124	if (tokenString != NULL)
AzureIoTClient	88:248736be106e	1125	STRING_delete(tokenString);
AzureIoTClient	88:248736be106e	1126	if (connString != NULL)
AzureIoTClient	88:248736be106e	1127	STRING_delete(connString);
AzureIoTClient	88:248736be106e	1128	if (protocolGateway != NULL)
AzureIoTClient	88:248736be106e	1129	STRING_delete(protocolGateway);
AzureIoTClient	89:a2ed767a532e	1130	if (moduleId != NULL)
AzureIoTClient	89:a2ed767a532e	1131	STRING_delete(moduleId);
AzureIoTClient	88:248736be106e	1132
AzureIoTClient	88:248736be106e	1133	if (tokenizer1 != NULL)
AzureIoTClient	88:248736be106e	1134	STRING_TOKENIZER_destroy(tokenizer1);
AzureIoTClient	88:248736be106e	1135
AzureIoTClient	88:248736be106e	1136	free(config);
AzureIoTClient	88:248736be106e	1137	}
AzureIoTClient	88:248736be106e	1138	}
AzureIoTClient	88:248736be106e	1139	return result;
AzureIoTClient	88:248736be106e	1140	}
AzureIoTClient	88:248736be106e	1141
AzureIoTClient	89:a2ed767a532e	1142	IOTHUB_CLIENT_CORE_LL_HANDLE IoTHubClientCore_LL_CreateImpl(const IOTHUB_CLIENT_CONFIG* config, const char* module_id, bool use_dev_auth)
AzureIoTClient	88:248736be106e	1143	{
AzureIoTClient	88:248736be106e	1144	IOTHUB_CLIENT_CORE_LL_HANDLE result;
AzureIoTClient	88:248736be106e	1145	/Codes_SRS_IOTHUBCLIENT_LL_02_001: [IoTHubClientCore_LL_Create shall return NULL if config parameter is NULL or protocol field is NULL.]/
AzureIoTClient	88:248736be106e	1146	if(
AzureIoTClient	88:248736be106e	1147	(config == NULL) \|\|
AzureIoTClient	88:248736be106e	1148	(config->protocol == NULL)
AzureIoTClient	88:248736be106e	1149	)
AzureIoTClient	88:248736be106e	1150	{
AzureIoTClient	88:248736be106e	1151	result = NULL;
AzureIoTClient	88:248736be106e	1152	LogError("invalid configuration (NULL detected)");
AzureIoTClient	88:248736be106e	1153	}
AzureIoTClient	88:248736be106e	1154	else
AzureIoTClient	88:248736be106e	1155	{
AzureIoTClient	89:a2ed767a532e	1156	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = initialize_iothub_client(config, NULL, use_dev_auth, module_id);
AzureIoTClient	88:248736be106e	1157	if (handleData == NULL)
AzureIoTClient	88:248736be106e	1158	{
AzureIoTClient	88:248736be106e	1159	LogError("initialize iothub client");
AzureIoTClient	88:248736be106e	1160	result = NULL;
AzureIoTClient	88:248736be106e	1161	}
AzureIoTClient	88:248736be106e	1162	else
AzureIoTClient	88:248736be106e	1163	{
AzureIoTClient	88:248736be106e	1164	result = handleData;
AzureIoTClient	88:248736be106e	1165	}
AzureIoTClient	88:248736be106e	1166	}
AzureIoTClient	88:248736be106e	1167
AzureIoTClient	88:248736be106e	1168	return result;
AzureIoTClient	88:248736be106e	1169	}
AzureIoTClient	88:248736be106e	1170
AzureIoTClient	89:a2ed767a532e	1171	IOTHUB_CLIENT_CORE_LL_HANDLE IoTHubClientCore_LL_Create(const IOTHUB_CLIENT_CONFIG* config)
AzureIoTClient	89:a2ed767a532e	1172	{
AzureIoTClient	89:a2ed767a532e	1173	return IoTHubClientCore_LL_CreateImpl(config, NULL, false);
AzureIoTClient	89:a2ed767a532e	1174	}
AzureIoTClient	89:a2ed767a532e	1175
AzureIoTClient	89:a2ed767a532e	1176	#ifdef USE_EDGE_MODULES
AzureIoTClient	91:bbf806070c5f	1177	IOTHUB_CLIENT_CORE_LL_HANDLE IoTHubClientCore_LL_CreateFromEnvironment(IOTHUB_CLIENT_TRANSPORT_PROVIDER protocol)
AzureIoTClient	89:a2ed767a532e	1178	{
AzureIoTClient	91:bbf806070c5f	1179	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* result;
AzureIoTClient	91:bbf806070c5f	1180	EDGE_ENVIRONMENT_VARIABLES edge_environment_variables;
AzureIoTClient	91:bbf806070c5f	1181
AzureIoTClient	91:bbf806070c5f	1182	memset(&edge_environment_variables, 0, sizeof(edge_environment_variables));
AzureIoTClient	89:a2ed767a532e	1183
AzureIoTClient	91:bbf806070c5f	1184	if (retrieve_edge_environment_variabes(&edge_environment_variables) != 0)
AzureIoTClient	89:a2ed767a532e	1185	{
AzureIoTClient	91:bbf806070c5f	1186	LogError("retrieve_edge_environment_variabes failed");
AzureIoTClient	91:bbf806070c5f	1187	result = NULL;
AzureIoTClient	91:bbf806070c5f	1188	}
AzureIoTClient	91:bbf806070c5f	1189	// The presence of a connection string environment variable means we use it, ignoring other settings
AzureIoTClient	91:bbf806070c5f	1190	else if (edge_environment_variables.connection_string != NULL)
AzureIoTClient	91:bbf806070c5f	1191	{
AzureIoTClient	91:bbf806070c5f	1192	result = IoTHubClientCore_LL_CreateFromConnectionString(edge_environment_variables.connection_string, protocol);
AzureIoTClient	91:bbf806070c5f	1193	}
AzureIoTClient	91:bbf806070c5f	1194	else if (iothub_security_init(IOTHUB_SECURITY_TYPE_HTTP_EDGE) != 0)
AzureIoTClient	91:bbf806070c5f	1195	{
AzureIoTClient	91:bbf806070c5f	1196	LogError("iothub_security_init failed");
AzureIoTClient	89:a2ed767a532e	1197	result = NULL;
AzureIoTClient	89:a2ed767a532e	1198	}
AzureIoTClient	91:bbf806070c5f	1199	else
AzureIoTClient	89:a2ed767a532e	1200	{
AzureIoTClient	91:bbf806070c5f	1201	IOTHUB_CLIENT_CONFIG client_config;
AzureIoTClient	89:a2ed767a532e	1202
AzureIoTClient	91:bbf806070c5f	1203	memset(&client_config, 0, sizeof(client_config));
AzureIoTClient	91:bbf806070c5f	1204	client_config.protocol = protocol;
AzureIoTClient	91:bbf806070c5f	1205	client_config.deviceId = edge_environment_variables.device_id;
AzureIoTClient	91:bbf806070c5f	1206	client_config.iotHubName = edge_environment_variables.iothub_name;
AzureIoTClient	91:bbf806070c5f	1207	client_config.iotHubSuffix = edge_environment_variables.iothub_suffix;
AzureIoTClient	91:bbf806070c5f	1208	client_config.protocolGatewayHostName = edge_environment_variables.gatewayhostname;
AzureIoTClient	91:bbf806070c5f	1209
AzureIoTClient	91:bbf806070c5f	1210	if ((result = IoTHubClientCore_LL_CreateImpl(&client_config, edge_environment_variables.module_id, true)) != NULL)
AzureIoTClient	89:a2ed767a532e	1211	{
AzureIoTClient	91:bbf806070c5f	1212	// Because the Edge Hub almost always use self-signed certificates, we need
AzureIoTClient	91:bbf806070c5f	1213	// to query it for the the certificate its using so we can trust it.
AzureIoTClient	91:bbf806070c5f	1214	char* trustedCertificate = IoTHubClient_Auth_Get_TrustBundle(result->authorization_module);
AzureIoTClient	91:bbf806070c5f	1215	IOTHUB_CLIENT_RESULT setTrustResult;
AzureIoTClient	91:bbf806070c5f	1216
AzureIoTClient	91:bbf806070c5f	1217	if (trustedCertificate == NULL)
AzureIoTClient	91:bbf806070c5f	1218	{
AzureIoTClient	91:bbf806070c5f	1219	LogError("IoTHubClient_Auth_Get_TrustBundle failed");
AzureIoTClient	91:bbf806070c5f	1220	IoTHubClientCore_LL_Destroy(result);
AzureIoTClient	91:bbf806070c5f	1221	result = NULL;
AzureIoTClient	91:bbf806070c5f	1222	}
AzureIoTClient	91:bbf806070c5f	1223	else if ((setTrustResult = IoTHubClientCore_LL_SetOption(result, OPTION_TRUSTED_CERT, trustedCertificate)) != IOTHUB_CLIENT_OK)
AzureIoTClient	91:bbf806070c5f	1224	{
AzureIoTClient	91:bbf806070c5f	1225	LogError("IoTHubClientCore_LL_SetOption failed, err = %d", setTrustResult);
AzureIoTClient	91:bbf806070c5f	1226	IoTHubClientCore_LL_Destroy(result);
AzureIoTClient	91:bbf806070c5f	1227	result = NULL;
AzureIoTClient	91:bbf806070c5f	1228	}
AzureIoTClient	91:bbf806070c5f	1229
AzureIoTClient	91:bbf806070c5f	1230	free(trustedCertificate);
AzureIoTClient	89:a2ed767a532e	1231	}
AzureIoTClient	91:bbf806070c5f	1232	}
AzureIoTClient	89:a2ed767a532e	1233
AzureIoTClient	91:bbf806070c5f	1234	free(edge_environment_variables.iothub_buffer);
AzureIoTClient	89:a2ed767a532e	1235	return result;
AzureIoTClient	89:a2ed767a532e	1236	}
AzureIoTClient	89:a2ed767a532e	1237	#endif
AzureIoTClient	89:a2ed767a532e	1238
AzureIoTClient	89:a2ed767a532e	1239
AzureIoTClient	88:248736be106e	1240	IOTHUB_CLIENT_CORE_LL_HANDLE IoTHubClientCore_LL_CreateWithTransport(const IOTHUB_CLIENT_DEVICE_CONFIG * config)
AzureIoTClient	88:248736be106e	1241	{
AzureIoTClient	88:248736be106e	1242	IOTHUB_CLIENT_CORE_LL_HANDLE result;
AzureIoTClient	88:248736be106e	1243	/Codes_SRS_IOTHUBCLIENT_LL_17_001: [IoTHubClientCore_LL_CreateWithTransport shall return NULL if config parameter is NULL, or protocol field is NULL or transportHandle is NULL.]/
AzureIoTClient	88:248736be106e	1244	if (
AzureIoTClient	88:248736be106e	1245	(config == NULL) \|\|
AzureIoTClient	88:248736be106e	1246	(config->protocol == NULL) \|\|
AzureIoTClient	88:248736be106e	1247	(config->transportHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	1248	/Codes_SRS_IOTHUBCLIENT_LL_02_098: [ IoTHubClientCore_LL_CreateWithTransport shall fail and return NULL if both config->deviceKey AND config->deviceSasToken are NULL. ]/
AzureIoTClient	88:248736be106e	1249	((config->deviceKey == NULL) && (config->deviceSasToken == NULL))
AzureIoTClient	88:248736be106e	1250	)
AzureIoTClient	88:248736be106e	1251	{
AzureIoTClient	88:248736be106e	1252	result = NULL;
AzureIoTClient	88:248736be106e	1253	LogError("invalid configuration (NULL detected)");
AzureIoTClient	88:248736be106e	1254	}
AzureIoTClient	88:248736be106e	1255	else
AzureIoTClient	88:248736be106e	1256	{
AzureIoTClient	89:a2ed767a532e	1257	result = initialize_iothub_client(NULL, config, false, NULL);
AzureIoTClient	88:248736be106e	1258	}
AzureIoTClient	88:248736be106e	1259	return result;
AzureIoTClient	88:248736be106e	1260	}
AzureIoTClient	88:248736be106e	1261
AzureIoTClient	88:248736be106e	1262	void IoTHubClientCore_LL_Destroy(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle)
AzureIoTClient	88:248736be106e	1263	{
AzureIoTClient	88:248736be106e	1264	/Codes_SRS_IOTHUBCLIENT_LL_02_009: [IoTHubClientCore_LL_Destroy shall do nothing if parameter iotHubClientHandle is NULL.]/
AzureIoTClient	88:248736be106e	1265	if (iotHubClientHandle != NULL)
AzureIoTClient	88:248736be106e	1266	{
AzureIoTClient	88:248736be106e	1267	PDLIST_ENTRY unsend;
AzureIoTClient	88:248736be106e	1268	/Codes_SRS_IOTHUBCLIENT_LL_17_010: [IoTHubClientCore_LL_Destroy shall call the underlaying layer's _Unregister function] /
AzureIoTClient	88:248736be106e	1269	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1270	handleData->IoTHubTransport_Unregister(handleData->deviceHandle);
AzureIoTClient	88:248736be106e	1271	if (handleData->isSharedTransport == false)
AzureIoTClient	88:248736be106e	1272	{
AzureIoTClient	88:248736be106e	1273	/Codes_SRS_IOTHUBCLIENT_LL_02_010: [If iotHubClientHandle was not created by IoTHubClientCore_LL_CreateWithTransport, IoTHubClientCore_LL_Destroy shall call the underlaying layer's _Destroy function.] /
AzureIoTClient	88:248736be106e	1274	handleData->IoTHubTransport_Destroy(handleData->transportHandle);
AzureIoTClient	88:248736be106e	1275	}
AzureIoTClient	88:248736be106e	1276	/if any, remove the items currently not send/
AzureIoTClient	88:248736be106e	1277	while ((unsend = DList_RemoveHeadList(&(handleData->waitingToSend))) != &(handleData->waitingToSend))
AzureIoTClient	88:248736be106e	1278	{
AzureIoTClient	88:248736be106e	1279	IOTHUB_MESSAGE_LIST* temp = containingRecord(unsend, IOTHUB_MESSAGE_LIST, entry);
AzureIoTClient	88:248736be106e	1280	/Codes_SRS_IOTHUBCLIENT_LL_02_033: [Otherwise, IoTHubClientCore_LL_Destroy shall complete all the event message callbacks that are in the waitingToSend list with the result IOTHUB_CLIENT_CONFIRMATION_BECAUSE_DESTROY.] /
AzureIoTClient	88:248736be106e	1281	if (temp->callback != NULL)
AzureIoTClient	88:248736be106e	1282	{
AzureIoTClient	88:248736be106e	1283	temp->callback(IOTHUB_CLIENT_CONFIRMATION_BECAUSE_DESTROY, temp->context);
AzureIoTClient	88:248736be106e	1284	}
AzureIoTClient	88:248736be106e	1285	IoTHubMessage_Destroy(temp->messageHandle);
AzureIoTClient	88:248736be106e	1286	free(temp);
AzureIoTClient	88:248736be106e	1287	}
AzureIoTClient	88:248736be106e	1288
AzureIoTClient	88:248736be106e	1289	/* Codes_SRS_IOTHUBCLIENT_LL_07_007: [ IoTHubClientCore_LL_Destroy shall iterate the device twin queues and destroy any remaining items. ] */
AzureIoTClient	88:248736be106e	1290	while ((unsend = DList_RemoveHeadList(&(handleData->iot_msg_queue))) != &(handleData->iot_msg_queue))
AzureIoTClient	88:248736be106e	1291	{
AzureIoTClient	88:248736be106e	1292	IOTHUB_DEVICE_TWIN* temp = containingRecord(unsend, IOTHUB_DEVICE_TWIN, entry);
AzureIoTClient	88:248736be106e	1293	device_twin_data_destroy(temp);
AzureIoTClient	88:248736be106e	1294	}
AzureIoTClient	88:248736be106e	1295	while ((unsend = DList_RemoveHeadList(&(handleData->iot_ack_queue))) != &(handleData->iot_ack_queue))
AzureIoTClient	88:248736be106e	1296	{
AzureIoTClient	88:248736be106e	1297	IOTHUB_DEVICE_TWIN* temp = containingRecord(unsend, IOTHUB_DEVICE_TWIN, entry);
AzureIoTClient	88:248736be106e	1298	device_twin_data_destroy(temp);
AzureIoTClient	88:248736be106e	1299	}
AzureIoTClient	88:248736be106e	1300
AzureIoTClient	89:a2ed767a532e	1301	/* Codes_SRS_IOTHUBCLIENT_LL_31_141: [ IoTHubClient_LL_Destroy shall iterate registered callbacks for input queues and destroy any remaining items. ] */
AzureIoTClient	89:a2ed767a532e	1302	delete_event_callback_list(handleData);
AzureIoTClient	89:a2ed767a532e	1303
AzureIoTClient	88:248736be106e	1304	/Codes_SRS_IOTHUBCLIENT_LL_17_011: [IoTHubClientCore_LL_Destroy shall free the resources allocated by IoTHubClient (if any).] /
AzureIoTClient	88:248736be106e	1305	IoTHubClient_Auth_Destroy(handleData->authorization_module);
AzureIoTClient	88:248736be106e	1306	tickcounter_destroy(handleData->tickCounter);
AzureIoTClient	88:248736be106e	1307	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	1308	IoTHubClient_LL_UploadToBlob_Destroy(handleData->uploadToBlobHandle);
AzureIoTClient	88:248736be106e	1309	#endif
AzureIoTClient	91:bbf806070c5f	1310	#ifdef USE_EDGE_MODULES
AzureIoTClient	91:bbf806070c5f	1311	IoTHubClient_EdgeHandle_Destroy(handleData->methodHandle);
AzureIoTClient	91:bbf806070c5f	1312	#endif
AzureIoTClient	88:248736be106e	1313	STRING_delete(handleData->product_info);
AzureIoTClient	88:248736be106e	1314	free(handleData);
AzureIoTClient	88:248736be106e	1315	}
AzureIoTClient	88:248736be106e	1316	}
AzureIoTClient	88:248736be106e	1317
AzureIoTClient	88:248736be106e	1318	/Codes_SRS_IOTHUBCLIENT_LL_02_044: [ Messages already delivered to IoTHubClientCore_LL shall not have their timeouts modified by a new call to IoTHubClientCore_LL_SetOption. ]/
AzureIoTClient	88:248736be106e	1319	/returns 0 on success, any other value is error/
AzureIoTClient	88:248736be106e	1320	static int attach_ms_timesOutAfter(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData, IOTHUB_MESSAGE_LIST *newEntry)
AzureIoTClient	88:248736be106e	1321	{
AzureIoTClient	88:248736be106e	1322	int result;
AzureIoTClient	88:248736be106e	1323	/Codes_SRS_IOTHUBCLIENT_LL_02_043: [ Calling IoTHubClientCore_LL_SetOption with value set to "0" shall disable the timeout mechanism for all new messages. ]/
AzureIoTClient	88:248736be106e	1324	if (handleData->currentMessageTimeout == 0)
AzureIoTClient	88:248736be106e	1325	{
AzureIoTClient	88:248736be106e	1326	newEntry->ms_timesOutAfter = 0; /do not timeout/
AzureIoTClient	88:248736be106e	1327	result = 0;
AzureIoTClient	88:248736be106e	1328	}
AzureIoTClient	88:248736be106e	1329	else
AzureIoTClient	88:248736be106e	1330	{
AzureIoTClient	88:248736be106e	1331	/Codes_SRS_IOTHUBCLIENT_LL_02_039: [ "messageTimeout" - once IoTHubClientCore_LL_SendEventAsync is called the message shall timeout after value miliseconds. Value is a pointer to a tickcounter_ms_t. ]/
AzureIoTClient	88:248736be106e	1332	if (tickcounter_get_current_ms(handleData->tickCounter, &newEntry->ms_timesOutAfter) != 0)
AzureIoTClient	88:248736be106e	1333	{
AzureIoTClient	88:248736be106e	1334	result = __FAILURE__;
AzureIoTClient	88:248736be106e	1335	LogError("unable to get the current relative tickcount");
AzureIoTClient	88:248736be106e	1336	}
AzureIoTClient	88:248736be106e	1337	else
AzureIoTClient	88:248736be106e	1338	{
AzureIoTClient	88:248736be106e	1339	newEntry->ms_timesOutAfter += handleData->currentMessageTimeout;
AzureIoTClient	88:248736be106e	1340	result = 0;
AzureIoTClient	88:248736be106e	1341	}
AzureIoTClient	88:248736be106e	1342	}
AzureIoTClient	88:248736be106e	1343	return result;
AzureIoTClient	88:248736be106e	1344	}
AzureIoTClient	88:248736be106e	1345
AzureIoTClient	88:248736be106e	1346	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SendEventAsync(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_MESSAGE_HANDLE eventMessageHandle, IOTHUB_CLIENT_EVENT_CONFIRMATION_CALLBACK eventConfirmationCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1347	{
AzureIoTClient	88:248736be106e	1348	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1349	/Codes_SRS_IOTHUBCLIENT_LL_02_011: [IoTHubClientCore_LL_SendEventAsync shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter iotHubClientHandle or eventMessageHandle is NULL.]/
AzureIoTClient	88:248736be106e	1350	if (
AzureIoTClient	88:248736be106e	1351	(iotHubClientHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	1352	(eventMessageHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	1353	/Codes_SRS_IOTHUBCLIENT_LL_02_012: [IoTHubClientCore_LL_SendEventAsync shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter eventConfirmationCallback is NULL and userContextCallback is not NULL.] /
AzureIoTClient	88:248736be106e	1354	((eventConfirmationCallback == NULL) && (userContextCallback != NULL))
AzureIoTClient	88:248736be106e	1355	)
AzureIoTClient	88:248736be106e	1356	{
AzureIoTClient	88:248736be106e	1357	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1358	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	1359	}
AzureIoTClient	88:248736be106e	1360	else
AzureIoTClient	88:248736be106e	1361	{
AzureIoTClient	88:248736be106e	1362	IOTHUB_MESSAGE_LIST newEntry = (IOTHUB_MESSAGE_LIST)malloc(sizeof(IOTHUB_MESSAGE_LIST));
AzureIoTClient	88:248736be106e	1363	if (newEntry == NULL)
AzureIoTClient	88:248736be106e	1364	{
AzureIoTClient	88:248736be106e	1365	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1366	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	1367	}
AzureIoTClient	88:248736be106e	1368	else
AzureIoTClient	88:248736be106e	1369	{
AzureIoTClient	88:248736be106e	1370	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1371
AzureIoTClient	88:248736be106e	1372	if (attach_ms_timesOutAfter(handleData, newEntry) != 0)
AzureIoTClient	88:248736be106e	1373	{
AzureIoTClient	88:248736be106e	1374	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1375	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	1376	free(newEntry);
AzureIoTClient	88:248736be106e	1377	}
AzureIoTClient	88:248736be106e	1378	else
AzureIoTClient	88:248736be106e	1379	{
AzureIoTClient	88:248736be106e	1380	/Codes_SRS_IOTHUBCLIENT_LL_02_013: [IoTHubClientCore_LL_SendEventAsync shall add the DLIST waitingToSend a new record cloning the information from eventMessageHandle, eventConfirmationCallback, userContextCallback.]/
AzureIoTClient	88:248736be106e	1381	if ((newEntry->messageHandle = IoTHubMessage_Clone(eventMessageHandle)) == NULL)
AzureIoTClient	88:248736be106e	1382	{
AzureIoTClient	88:248736be106e	1383	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1384	free(newEntry);
AzureIoTClient	88:248736be106e	1385	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	1386	}
AzureIoTClient	88:248736be106e	1387	else if (IoTHubClient_Diagnostic_AddIfNecessary(&handleData->diagnostic_setting, newEntry->messageHandle) != 0)
AzureIoTClient	88:248736be106e	1388	{
AzureIoTClient	88:248736be106e	1389	/Codes_SRS_IOTHUBCLIENT_LL_02_014: [If cloning and/or adding the information/diagnostic fails for any reason, IoTHubClientCore_LL_SendEventAsync shall fail and return IOTHUB_CLIENT_ERROR.] /
AzureIoTClient	88:248736be106e	1390	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1391	IoTHubMessage_Destroy(newEntry->messageHandle);
AzureIoTClient	88:248736be106e	1392	free(newEntry);
AzureIoTClient	88:248736be106e	1393	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	1394	}
AzureIoTClient	88:248736be106e	1395	else
AzureIoTClient	88:248736be106e	1396	{
AzureIoTClient	88:248736be106e	1397	/Codes_SRS_IOTHUBCLIENT_LL_02_013: [IoTHubClientCore_LL_SendEventAsync shall add the DLIST waitingToSend a new record cloning the information from eventMessageHandle, eventConfirmationCallback, userContextCallback.]/
AzureIoTClient	88:248736be106e	1398	newEntry->callback = eventConfirmationCallback;
AzureIoTClient	88:248736be106e	1399	newEntry->context = userContextCallback;
AzureIoTClient	88:248736be106e	1400	DList_InsertTailList(&(iotHubClientHandle->waitingToSend), &(newEntry->entry));
AzureIoTClient	88:248736be106e	1401	/Codes_SRS_IOTHUBCLIENT_LL_02_015: [Otherwise IoTHubClientCore_LL_SendEventAsync shall succeed and return IOTHUB_CLIENT_OK.] /
AzureIoTClient	88:248736be106e	1402	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	1403	}
AzureIoTClient	88:248736be106e	1404	}
AzureIoTClient	88:248736be106e	1405	}
AzureIoTClient	88:248736be106e	1406	}
AzureIoTClient	88:248736be106e	1407	return result;
AzureIoTClient	88:248736be106e	1408	}
AzureIoTClient	88:248736be106e	1409
AzureIoTClient	88:248736be106e	1410	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetMessageCallback(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC messageCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1411	{
AzureIoTClient	88:248736be106e	1412	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1413	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1414	{
AzureIoTClient	88:248736be106e	1415	/Codes_SRS_IOTHUBCLIENT_LL_02_016: [IoTHubClientCore_LL_SetMessageCallback shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter iotHubClientHandle is NULL.] /
AzureIoTClient	88:248736be106e	1416	LogError("Invalid argument - iotHubClientHandle is NULL");
AzureIoTClient	88:248736be106e	1417	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1418	}
AzureIoTClient	88:248736be106e	1419	else
AzureIoTClient	88:248736be106e	1420	{
AzureIoTClient	88:248736be106e	1421	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1422	if (messageCallback == NULL)
AzureIoTClient	88:248736be106e	1423	{
AzureIoTClient	88:248736be106e	1424	if (handleData->messageCallback.type == CALLBACK_TYPE_NONE)
AzureIoTClient	88:248736be106e	1425	{
AzureIoTClient	88:248736be106e	1426	/Codes_SRS_IOTHUBCLIENT_LL_10_010: [If parameter messageCallback is NULL and the _SetMessageCallback had not been called to subscribe for messages, then IoTHubClientCore_LL_SetMessageCallback shall fail and return IOTHUB_CLIENT_ERROR.] /
AzureIoTClient	88:248736be106e	1427	LogError("not currently set to accept or process incoming messages.");
AzureIoTClient	88:248736be106e	1428	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1429	}
AzureIoTClient	88:248736be106e	1430	else if (handleData->messageCallback.type == CALLBACK_TYPE_ASYNC)
AzureIoTClient	88:248736be106e	1431	{
AzureIoTClient	88:248736be106e	1432	/Codes_SRS_IOTHUBCLIENT_LL_10_010: [If parameter messageCallback is NULL and the _SetMessageCallback had not been called to subscribe for messages, then IoTHubClientCore_LL_SetMessageCallback shall fail and return IOTHUB_CLIENT_ERROR.] /
AzureIoTClient	88:248736be106e	1433	LogError("Invalid workflow sequence. Please unsubscribe using the IoTHubClientCore_LL_SetMessageCallback_Ex function.");
AzureIoTClient	88:248736be106e	1434	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1435	}
AzureIoTClient	88:248736be106e	1436	else
AzureIoTClient	88:248736be106e	1437	{
AzureIoTClient	88:248736be106e	1438	/Codes_SRS_IOTHUBCLIENT_LL_02_019: [If parameter messageCallback is NULL then IoTHubClientCore_LL_SetMessageCallback shall call the underlying layer's _Unsubscribe function and return IOTHUB_CLIENT_OK.] /
AzureIoTClient	88:248736be106e	1439	handleData->IoTHubTransport_Unsubscribe(handleData->deviceHandle);
AzureIoTClient	88:248736be106e	1440	handleData->messageCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	1441	handleData->messageCallback.callbackSync = NULL;
AzureIoTClient	88:248736be106e	1442	handleData->messageCallback.callbackAsync = NULL;
AzureIoTClient	88:248736be106e	1443	handleData->messageCallback.userContextCallback = NULL;
AzureIoTClient	88:248736be106e	1444	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	1445	}
AzureIoTClient	88:248736be106e	1446	}
AzureIoTClient	88:248736be106e	1447	else
AzureIoTClient	88:248736be106e	1448	{
AzureIoTClient	88:248736be106e	1449	if (handleData->messageCallback.type == CALLBACK_TYPE_ASYNC)
AzureIoTClient	88:248736be106e	1450	{
AzureIoTClient	88:248736be106e	1451	/* Codes_SRS_IOTHUBCLIENT_LL_10_011: [If parameter messageCallback is non-NULL and the _SetMessageCallback_Ex had been used to susbscribe for messages, then IoTHubClientCore_LL_SetMessageCallback shall fail and return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	1452	LogError("Invalid workflow sequence. Please unsubscribe using the IoTHubClientCore_LL_SetMessageCallback_Ex function before subscribing with MessageCallback.");
AzureIoTClient	88:248736be106e	1453	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1454	}
AzureIoTClient	88:248736be106e	1455	else
AzureIoTClient	88:248736be106e	1456	{
AzureIoTClient	88:248736be106e	1457	if (handleData->IoTHubTransport_Subscribe(handleData->deviceHandle) == 0)
AzureIoTClient	88:248736be106e	1458	{
AzureIoTClient	88:248736be106e	1459	/Codes_SRS_IOTHUBCLIENT_LL_02_017: [If parameter messageCallback is non-NULL then IoTHubClientCore_LL_SetMessageCallback shall call the underlying layer's _Subscribe function.]/
AzureIoTClient	88:248736be106e	1460	handleData->messageCallback.type = CALLBACK_TYPE_SYNC;
AzureIoTClient	88:248736be106e	1461	handleData->messageCallback.callbackSync = messageCallback;
AzureIoTClient	88:248736be106e	1462	handleData->messageCallback.userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1463	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	1464	}
AzureIoTClient	88:248736be106e	1465	else
AzureIoTClient	88:248736be106e	1466	{
AzureIoTClient	88:248736be106e	1467	/Codes_SRS_IOTHUBCLIENT_LL_02_018: [If the underlying layer's _Subscribe function fails, then IoTHubClientCore_LL_SetMessageCallback shall fail and return IOTHUB_CLIENT_ERROR. Otherwise IoTHubClientCore_LL_SetMessageCallback shall succeed and return IOTHUB_CLIENT_OK.]/
AzureIoTClient	88:248736be106e	1468	LogError("IoTHubTransport_Subscribe failed");
AzureIoTClient	88:248736be106e	1469	handleData->messageCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	1470	handleData->messageCallback.callbackSync = NULL;
AzureIoTClient	88:248736be106e	1471	handleData->messageCallback.callbackAsync = NULL;
AzureIoTClient	88:248736be106e	1472	handleData->messageCallback.userContextCallback = NULL;
AzureIoTClient	88:248736be106e	1473	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1474	}
AzureIoTClient	88:248736be106e	1475	}
AzureIoTClient	88:248736be106e	1476	}
AzureIoTClient	88:248736be106e	1477	}
AzureIoTClient	88:248736be106e	1478	return result;
AzureIoTClient	88:248736be106e	1479	}
AzureIoTClient	88:248736be106e	1480
AzureIoTClient	88:248736be106e	1481	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetMessageCallback_Ex(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX messageCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	1482	{
AzureIoTClient	88:248736be106e	1483	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1484	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	1485	{
AzureIoTClient	88:248736be106e	1486	/Codes_SRS_IOTHUBCLIENT_LL_10_021: [IoTHubClientCore_LL_SetMessageCallback_Ex shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter iotHubClientHandle is NULL.]/
AzureIoTClient	88:248736be106e	1487	LogError("Invalid argument - iotHubClientHandle is NULL");
AzureIoTClient	88:248736be106e	1488	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1489	}
AzureIoTClient	88:248736be106e	1490	else
AzureIoTClient	88:248736be106e	1491	{
AzureIoTClient	88:248736be106e	1492	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1493	if (messageCallback == NULL)
AzureIoTClient	88:248736be106e	1494	{
AzureIoTClient	88:248736be106e	1495	if (handleData->messageCallback.type == CALLBACK_TYPE_NONE)
AzureIoTClient	88:248736be106e	1496	{
AzureIoTClient	88:248736be106e	1497	/Codes_SRS_IOTHUBCLIENT_LL_10_018: [If parameter messageCallback is NULL and IoTHubClientCore_LL_SetMessageCallback_Ex had not been used to subscribe for messages, then IoTHubClientCore_LL_SetMessageCallback_Ex shall fail and return IOTHUB_CLIENT_ERROR.] /
AzureIoTClient	88:248736be106e	1498	LogError("not currently set to accept or process incoming messages.");
AzureIoTClient	88:248736be106e	1499	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1500	}
AzureIoTClient	88:248736be106e	1501	else if (handleData->messageCallback.type == CALLBACK_TYPE_SYNC)
AzureIoTClient	88:248736be106e	1502	{
AzureIoTClient	88:248736be106e	1503	/Codes_SRS_IOTHUBCLIENT_LL_10_019: [If parameter messageCallback is NULL and IoTHubClientCore_LL_SetMessageCallback had been used to subscribe for messages, then IoTHubClientCore_LL_SetMessageCallback_Ex shall fail and return IOTHUB_CLIENT_ERROR.] /
AzureIoTClient	88:248736be106e	1504	LogError("Invalid workflow sequence. Please unsubscribe using the IoTHubClientCore_LL_SetMessageCallback function.");
AzureIoTClient	88:248736be106e	1505	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1506	}
AzureIoTClient	88:248736be106e	1507	else
AzureIoTClient	88:248736be106e	1508	{
AzureIoTClient	88:248736be106e	1509	/Codes_SRS_IOTHUBCLIENT_LL_10_023: [If parameter messageCallback is NULL then IoTHubClientCore_LL_SetMessageCallback_Ex shall call the underlying layer's _Unsubscribe function and return IOTHUB_CLIENT_OK.] /
AzureIoTClient	88:248736be106e	1510	handleData->IoTHubTransport_Unsubscribe(handleData->deviceHandle);
AzureIoTClient	88:248736be106e	1511	handleData->messageCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	1512	handleData->messageCallback.callbackSync = NULL;
AzureIoTClient	88:248736be106e	1513	handleData->messageCallback.callbackAsync = NULL;
AzureIoTClient	88:248736be106e	1514	handleData->messageCallback.userContextCallback = NULL;
AzureIoTClient	88:248736be106e	1515	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	1516	}
AzureIoTClient	88:248736be106e	1517	}
AzureIoTClient	88:248736be106e	1518	else
AzureIoTClient	88:248736be106e	1519	{
AzureIoTClient	88:248736be106e	1520	if (handleData->messageCallback.type == CALLBACK_TYPE_SYNC)
AzureIoTClient	88:248736be106e	1521	{
AzureIoTClient	88:248736be106e	1522	/Codes_SRS_IOTHUBCLIENT_LL_10_020: [If parameter messageCallback is non-NULL, and IoTHubClientCore_LL_SetMessageCallback had been used to subscribe for messages, then IoTHubClientCore_LL_SetMessageCallback_Ex shall fail and return IOTHUB_CLIENT_ERROR.] /
AzureIoTClient	88:248736be106e	1523	LogError("Invalid workflow sequence. Please unsubscribe using the IoTHubClientCore_LL_MessageCallbackEx function before subscribing with MessageCallback.");
AzureIoTClient	88:248736be106e	1524	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1525	}
AzureIoTClient	88:248736be106e	1526	else
AzureIoTClient	88:248736be106e	1527	{
AzureIoTClient	88:248736be106e	1528	if (handleData->IoTHubTransport_Subscribe(handleData->deviceHandle) == 0)
AzureIoTClient	88:248736be106e	1529	{
AzureIoTClient	88:248736be106e	1530	/Codes_SRS_IOTHUBCLIENT_LL_10_024: [If parameter messageCallback is non-NULL then IoTHubClientCore_LL_SetMessageCallback_Ex shall call the underlying layer's _Subscribe function.]/
AzureIoTClient	88:248736be106e	1531	handleData->messageCallback.type = CALLBACK_TYPE_ASYNC;
AzureIoTClient	88:248736be106e	1532	handleData->messageCallback.callbackAsync = messageCallback;
AzureIoTClient	88:248736be106e	1533	handleData->messageCallback.userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	1534	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	1535	}
AzureIoTClient	88:248736be106e	1536	else
AzureIoTClient	88:248736be106e	1537	{
AzureIoTClient	88:248736be106e	1538	/Codes_SRS_IOTHUBCLIENT_LL_10_025: [If the underlying layer's _Subscribe function fails, then IoTHubClientCore_LL_SetMessageCallback_Ex shall fail and return IOTHUB_CLIENT_ERROR. Otherwise IoTHubClientCore_LL_SetMessageCallback_Ex shall succeed and return IOTHUB_CLIENT_OK.] /
AzureIoTClient	88:248736be106e	1539	LogError("IoTHubTransport_Subscribe failed");
AzureIoTClient	88:248736be106e	1540	handleData->messageCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	1541	handleData->messageCallback.callbackSync = NULL;
AzureIoTClient	88:248736be106e	1542	handleData->messageCallback.callbackAsync = NULL;
AzureIoTClient	88:248736be106e	1543	handleData->messageCallback.userContextCallback = NULL;
AzureIoTClient	88:248736be106e	1544	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	1545	}
AzureIoTClient	88:248736be106e	1546	}
AzureIoTClient	88:248736be106e	1547	}
AzureIoTClient	88:248736be106e	1548	}
AzureIoTClient	88:248736be106e	1549	return result;
AzureIoTClient	88:248736be106e	1550	}
AzureIoTClient	88:248736be106e	1551
AzureIoTClient	88:248736be106e	1552	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SendMessageDisposition(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, MESSAGE_CALLBACK_INFO* message_data, IOTHUBMESSAGE_DISPOSITION_RESULT disposition)
AzureIoTClient	88:248736be106e	1553	{
AzureIoTClient	88:248736be106e	1554	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1555	if ((iotHubClientHandle == NULL) \|\| (message_data == NULL))
AzureIoTClient	88:248736be106e	1556	{
AzureIoTClient	88:248736be106e	1557	/Codes_SRS_IOTHUBCLIENT_LL_10_026: [IoTHubClientCore_LL_SendMessageDisposition shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter iotHubClientHandle is NULL.]/
AzureIoTClient	88:248736be106e	1558	LogError("Invalid argument handle=%p, message=%p", iotHubClientHandle, message_data);
AzureIoTClient	88:248736be106e	1559	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1560	}
AzureIoTClient	88:248736be106e	1561	else
AzureIoTClient	88:248736be106e	1562	{
AzureIoTClient	88:248736be106e	1563	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1564	/Codes_SRS_IOTHUBCLIENT_LL_10_027: [IoTHubClientCore_LL_SendMessageDisposition shall return the result from calling the underlying layer's _Send_Message_Disposition.]/
AzureIoTClient	88:248736be106e	1565	result = handleData->IoTHubTransport_SendMessageDisposition(message_data, disposition);
AzureIoTClient	88:248736be106e	1566	}
AzureIoTClient	88:248736be106e	1567	return result;
AzureIoTClient	88:248736be106e	1568	}
AzureIoTClient	88:248736be106e	1569
AzureIoTClient	88:248736be106e	1570	static void DoTimeouts(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData)
AzureIoTClient	88:248736be106e	1571	{
AzureIoTClient	88:248736be106e	1572	tickcounter_ms_t nowTick;
AzureIoTClient	88:248736be106e	1573	if (tickcounter_get_current_ms(handleData->tickCounter, &nowTick) != 0)
AzureIoTClient	88:248736be106e	1574	{
AzureIoTClient	88:248736be106e	1575	LogError("unable to get the current ms, timeouts will not be processed");
AzureIoTClient	88:248736be106e	1576	}
AzureIoTClient	88:248736be106e	1577	else
AzureIoTClient	88:248736be106e	1578	{
AzureIoTClient	88:248736be106e	1579	DLIST_ENTRY* currentItemInWaitingToSend = handleData->waitingToSend.Flink;
AzureIoTClient	88:248736be106e	1580	while (currentItemInWaitingToSend != &(handleData->waitingToSend)) /while we are not at the end of the list/
AzureIoTClient	88:248736be106e	1581	{
AzureIoTClient	88:248736be106e	1582	IOTHUB_MESSAGE_LIST* fullEntry = containingRecord(currentItemInWaitingToSend, IOTHUB_MESSAGE_LIST, entry);
AzureIoTClient	88:248736be106e	1583	/Codes_SRS_IOTHUBCLIENT_LL_02_041: [ If more than value miliseconds have passed since the call to IoTHubClientCore_LL_SendEventAsync then the message callback shall be called with a status code of IOTHUB_CLIENT_CONFIRMATION_TIMEOUT. ]/
AzureIoTClient	88:248736be106e	1584	if ((fullEntry->ms_timesOutAfter != 0) && (fullEntry->ms_timesOutAfter < nowTick))
AzureIoTClient	88:248736be106e	1585	{
AzureIoTClient	88:248736be106e	1586	PDLIST_ENTRY theNext = currentItemInWaitingToSend->Flink; /need to save the next item, because the below operations are destructive/
AzureIoTClient	88:248736be106e	1587	DList_RemoveEntryList(currentItemInWaitingToSend);
AzureIoTClient	88:248736be106e	1588	if (fullEntry->callback != NULL)
AzureIoTClient	88:248736be106e	1589	{
AzureIoTClient	88:248736be106e	1590	fullEntry->callback(IOTHUB_CLIENT_CONFIRMATION_MESSAGE_TIMEOUT, fullEntry->context);
AzureIoTClient	88:248736be106e	1591	}
AzureIoTClient	88:248736be106e	1592	IoTHubMessage_Destroy(fullEntry->messageHandle); /because it has been cloned/
AzureIoTClient	88:248736be106e	1593	free(fullEntry);
AzureIoTClient	88:248736be106e	1594	currentItemInWaitingToSend = theNext;
AzureIoTClient	88:248736be106e	1595	}
AzureIoTClient	88:248736be106e	1596	else
AzureIoTClient	88:248736be106e	1597	{
AzureIoTClient	88:248736be106e	1598	currentItemInWaitingToSend = currentItemInWaitingToSend->Flink;
AzureIoTClient	88:248736be106e	1599	}
AzureIoTClient	88:248736be106e	1600	}
AzureIoTClient	88:248736be106e	1601	}
AzureIoTClient	88:248736be106e	1602	}
AzureIoTClient	88:248736be106e	1603
AzureIoTClient	88:248736be106e	1604	void IoTHubClientCore_LL_DoWork(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle)
AzureIoTClient	88:248736be106e	1605	{
AzureIoTClient	88:248736be106e	1606	/Codes_SRS_IOTHUBCLIENT_LL_02_020: [If parameter iotHubClientHandle is NULL then IoTHubClientCore_LL_DoWork shall not perform any action.] /
AzureIoTClient	88:248736be106e	1607	if (iotHubClientHandle != NULL)
AzureIoTClient	88:248736be106e	1608	{
AzureIoTClient	88:248736be106e	1609	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1610	DoTimeouts(handleData);
AzureIoTClient	88:248736be106e	1611
AzureIoTClient	88:248736be106e	1612	/Codes_SRS_IOTHUBCLIENT_LL_07_008: [ IoTHubClientCore_LL_DoWork shall iterate the message queue and execute the underlying transports IoTHubTransport_ProcessItem function for each item. ] /
AzureIoTClient	88:248736be106e	1613	DLIST_ENTRY* client_item = handleData->iot_msg_queue.Flink;
AzureIoTClient	88:248736be106e	1614	while (client_item != &(handleData->iot_msg_queue)) /while we are not at the end of the list/
AzureIoTClient	88:248736be106e	1615	{
AzureIoTClient	88:248736be106e	1616	PDLIST_ENTRY next_item = client_item->Flink;
AzureIoTClient	88:248736be106e	1617
AzureIoTClient	88:248736be106e	1618	IOTHUB_DEVICE_TWIN* queue_data = containingRecord(client_item, IOTHUB_DEVICE_TWIN, entry);
AzureIoTClient	88:248736be106e	1619	IOTHUB_IDENTITY_INFO identity_info;
AzureIoTClient	88:248736be106e	1620	identity_info.device_twin = queue_data;
AzureIoTClient	88:248736be106e	1621	IOTHUB_PROCESS_ITEM_RESULT process_results = handleData->IoTHubTransport_ProcessItem(handleData->transportHandle, IOTHUB_TYPE_DEVICE_TWIN, &identity_info);
AzureIoTClient	88:248736be106e	1622	if (process_results == IOTHUB_PROCESS_CONTINUE \|\| process_results == IOTHUB_PROCESS_NOT_CONNECTED)
AzureIoTClient	88:248736be106e	1623	{
AzureIoTClient	88:248736be106e	1624	/Codes_SRS_IOTHUBCLIENT_LL_07_010: [ If 'IoTHubTransport_ProcessItem' returns IOTHUB_PROCESS_CONTINUE or IOTHUB_PROCESS_NOT_CONNECTED IoTHubClientCore_LL_DoWork shall continue on to call the underlaying layer's _DoWork function. ]/
AzureIoTClient	88:248736be106e	1625	break;
AzureIoTClient	88:248736be106e	1626	}
AzureIoTClient	88:248736be106e	1627	else
AzureIoTClient	88:248736be106e	1628	{
AzureIoTClient	88:248736be106e	1629	DList_RemoveEntryList(client_item);
AzureIoTClient	88:248736be106e	1630	if (process_results == IOTHUB_PROCESS_OK)
AzureIoTClient	88:248736be106e	1631	{
AzureIoTClient	88:248736be106e	1632	/Codes_SRS_IOTHUBCLIENT_LL_07_011: [ If 'IoTHubTransport_ProcessItem' returns IOTHUB_PROCESS_OK IoTHubClientCore_LL_DoWork shall add the IOTHUB_DEVICE_TWIN to the ack queue. ]/
AzureIoTClient	88:248736be106e	1633	DList_InsertTailList(&(iotHubClientHandle->iot_ack_queue), &(queue_data->entry));
AzureIoTClient	88:248736be106e	1634	}
AzureIoTClient	88:248736be106e	1635	else
AzureIoTClient	88:248736be106e	1636	{
AzureIoTClient	88:248736be106e	1637	/Codes_SRS_IOTHUBCLIENT_LL_07_012: [ If 'IoTHubTransport_ProcessItem' returns any other value IoTHubClientCore_LL_DoWork shall destroy the IOTHUB_DEVICE_TWIN item. ]/
AzureIoTClient	88:248736be106e	1638	LogError("Failure queue processing item");
AzureIoTClient	88:248736be106e	1639	device_twin_data_destroy(queue_data);
AzureIoTClient	88:248736be106e	1640	}
AzureIoTClient	88:248736be106e	1641	}
AzureIoTClient	88:248736be106e	1642	// Move along to the next item
AzureIoTClient	88:248736be106e	1643	client_item = next_item;
AzureIoTClient	88:248736be106e	1644	}
AzureIoTClient	88:248736be106e	1645
AzureIoTClient	88:248736be106e	1646	/Codes_SRS_IOTHUBCLIENT_LL_02_021: [Otherwise, IoTHubClientCore_LL_DoWork shall invoke the underlaying layer's _DoWork function.]/
AzureIoTClient	88:248736be106e	1647	handleData->IoTHubTransport_DoWork(handleData->transportHandle, iotHubClientHandle);
AzureIoTClient	88:248736be106e	1648	}
AzureIoTClient	88:248736be106e	1649	}
AzureIoTClient	88:248736be106e	1650
AzureIoTClient	88:248736be106e	1651	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_GetSendStatus(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_STATUS *iotHubClientStatus)
AzureIoTClient	88:248736be106e	1652	{
AzureIoTClient	88:248736be106e	1653	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	1654
AzureIoTClient	88:248736be106e	1655	/* Codes_SRS_IOTHUBCLIENT_09_007: [IoTHubClient_GetSendStatus shall return IOTHUB_CLIENT_INVALID_ARG if called with NULL parameter] */
AzureIoTClient	88:248736be106e	1656	if (iotHubClientHandle == NULL \|\| iotHubClientStatus == NULL)
AzureIoTClient	88:248736be106e	1657	{
AzureIoTClient	88:248736be106e	1658	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	1659	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	1660	}
AzureIoTClient	88:248736be106e	1661	else
AzureIoTClient	88:248736be106e	1662	{
AzureIoTClient	88:248736be106e	1663	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	1664
AzureIoTClient	88:248736be106e	1665	/* Codes_SRS_IOTHUBCLIENT_09_008: [IoTHubClient_GetSendStatus shall return IOTHUB_CLIENT_OK and status IOTHUB_CLIENT_SEND_STATUS_IDLE if there is currently no items to be sent] */
AzureIoTClient	88:248736be106e	1666	/* Codes_SRS_IOTHUBCLIENT_09_009: [IoTHubClient_GetSendStatus shall return IOTHUB_CLIENT_OK and status IOTHUB_CLIENT_SEND_STATUS_BUSY if there are currently items to be sent] */
AzureIoTClient	88:248736be106e	1667	result = handleData->IoTHubTransport_GetSendStatus(handleData->deviceHandle, iotHubClientStatus);
AzureIoTClient	88:248736be106e	1668	}
AzureIoTClient	88:248736be106e	1669
AzureIoTClient	88:248736be106e	1670	return result;
AzureIoTClient	88:248736be106e	1671	}
AzureIoTClient	88:248736be106e	1672
AzureIoTClient	88:248736be106e	1673	void IoTHubClientCore_LL_SendComplete(IOTHUB_CLIENT_CORE_LL_HANDLE handle, PDLIST_ENTRY completed, IOTHUB_CLIENT_CONFIRMATION_RESULT result)
AzureIoTClient	88:248736be106e	1674	{
AzureIoTClient	88:248736be106e	1675	/Codes_SRS_IOTHUBCLIENT_LL_02_022: [If parameter completed is NULL, or parameter handle is NULL then IoTHubClientCore_LL_SendBatch shall return.]/
AzureIoTClient	88:248736be106e	1676	if (
AzureIoTClient	88:248736be106e	1677	(handle == NULL) \|\|
AzureIoTClient	88:248736be106e	1678	(completed == NULL)
AzureIoTClient	88:248736be106e	1679	)
AzureIoTClient	88:248736be106e	1680	{
AzureIoTClient	88:248736be106e	1681	/"shall return"/
AzureIoTClient	88:248736be106e	1682	LogError("invalid arg");
AzureIoTClient	88:248736be106e	1683	}
AzureIoTClient	88:248736be106e	1684	else
AzureIoTClient	88:248736be106e	1685	{
AzureIoTClient	88:248736be106e	1686	/Codes_SRS_IOTHUBCLIENT_LL_02_027: [If parameter result is IOTHUB_CLIENT_CONFIRMATION_ERROR then IoTHubClientCore_LL_SendComplete shall call all the non-NULL callbacks with the result parameter set to IOTHUB_CLIENT_CONFIRMATION_ERROR and the context set to the context passed originally in the SendEventAsync call.] /
AzureIoTClient	88:248736be106e	1687	/Codes_SRS_IOTHUBCLIENT_LL_02_025: [If parameter result is IOTHUB_CLIENT_CONFIRMATION_OK then IoTHubClientCore_LL_SendComplete shall call all the non-NULL callbacks with the result parameter set to IOTHUB_CLIENT_CONFIRMATION_OK and the context set to the context passed originally in the SendEventAsync call.]/
AzureIoTClient	88:248736be106e	1688	PDLIST_ENTRY oldest;
AzureIoTClient	88:248736be106e	1689	while ((oldest = DList_RemoveHeadList(completed)) != completed)
AzureIoTClient	88:248736be106e	1690	{
AzureIoTClient	88:248736be106e	1691	IOTHUB_MESSAGE_LIST* messageList = (IOTHUB_MESSAGE_LIST*)containingRecord(oldest, IOTHUB_MESSAGE_LIST, entry);
AzureIoTClient	88:248736be106e	1692	/Codes_SRS_IOTHUBCLIENT_LL_02_026: [If any callback is NULL then there shall not be a callback call.]/
AzureIoTClient	88:248736be106e	1693	if (messageList->callback != NULL)
AzureIoTClient	88:248736be106e	1694	{
AzureIoTClient	88:248736be106e	1695	messageList->callback(result, messageList->context);
AzureIoTClient	88:248736be106e	1696	}
AzureIoTClient	88:248736be106e	1697	IoTHubMessage_Destroy(messageList->messageHandle);
AzureIoTClient	88:248736be106e	1698	free(messageList);
AzureIoTClient	88:248736be106e	1699	}
AzureIoTClient	88:248736be106e	1700	}
AzureIoTClient	88:248736be106e	1701	}
AzureIoTClient	88:248736be106e	1702
AzureIoTClient	88:248736be106e	1703	int IoTHubClientCore_LL_DeviceMethodComplete(IOTHUB_CLIENT_CORE_LL_HANDLE handle, const char* method_name, const unsigned char* payLoad, size_t size, METHOD_HANDLE response_id)
AzureIoTClient	88:248736be106e	1704	{
AzureIoTClient	88:248736be106e	1705	int result;
AzureIoTClient	88:248736be106e	1706	if (handle == NULL)
AzureIoTClient	88:248736be106e	1707	{
AzureIoTClient	88:248736be106e	1708	/* Codes_SRS_IOTHUBCLIENT_LL_07_017: [ If handle or response is NULL then IoTHubClientCore_LL_DeviceMethodComplete shall return 500. ] */
AzureIoTClient	88:248736be106e	1709	LogError("Invalid argument handle=%p", handle);
AzureIoTClient	88:248736be106e	1710	result = __FAILURE__;
AzureIoTClient	88:248736be106e	1711	}
AzureIoTClient	88:248736be106e	1712	else
AzureIoTClient	88:248736be106e	1713	{
AzureIoTClient	88:248736be106e	1714	/* Codes_SRS_IOTHUBCLIENT_LL_07_018: [ If deviceMethodCallback is not NULL IoTHubClientCore_LL_DeviceMethodComplete shall execute deviceMethodCallback and return the status. ] */
AzureIoTClient	88:248736be106e	1715	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)handle;
AzureIoTClient	88:248736be106e	1716	switch (handleData->methodCallback.type)
AzureIoTClient	88:248736be106e	1717	{
AzureIoTClient	88:248736be106e	1718	case CALLBACK_TYPE_SYNC:
AzureIoTClient	88:248736be106e	1719	{
AzureIoTClient	88:248736be106e	1720	unsigned char* payload_resp = NULL;
AzureIoTClient	88:248736be106e	1721	size_t response_size = 0;
AzureIoTClient	88:248736be106e	1722	result = handleData->methodCallback.callbackSync(method_name, payLoad, size, &payload_resp, &response_size, handleData->methodCallback.userContextCallback);
AzureIoTClient	88:248736be106e	1723	/* Codes_SRS_IOTHUBCLIENT_LL_07_020: [ deviceMethodCallback shall build the BUFFER_HANDLE with the response payload from the IOTHUB_CLIENT_DEVICE_METHOD_CALLBACK_ASYNC callback. ] */
AzureIoTClient	88:248736be106e	1724	if (payload_resp != NULL && response_size > 0)
AzureIoTClient	88:248736be106e	1725	{
AzureIoTClient	88:248736be106e	1726	result = handleData->IoTHubTransport_DeviceMethod_Response(handleData->deviceHandle, response_id, payload_resp, response_size, result);
AzureIoTClient	88:248736be106e	1727	}
AzureIoTClient	88:248736be106e	1728	else
AzureIoTClient	88:248736be106e	1729	{
AzureIoTClient	88:248736be106e	1730	result = __FAILURE__;
AzureIoTClient	88:248736be106e	1731	}
AzureIoTClient	88:248736be106e	1732	if (payload_resp != NULL)
AzureIoTClient	88:248736be106e	1733	{
AzureIoTClient	88:248736be106e	1734	free(payload_resp);
AzureIoTClient	88:248736be106e	1735	}
AzureIoTClient	88:248736be106e	1736	break;
AzureIoTClient	88:248736be106e	1737	}
AzureIoTClient	88:248736be106e	1738	case CALLBACK_TYPE_ASYNC:
AzureIoTClient	88:248736be106e	1739	result = handleData->methodCallback.callbackAsync(method_name, payLoad, size, response_id, handleData->methodCallback.userContextCallback);
AzureIoTClient	88:248736be106e	1740	break;
AzureIoTClient	88:248736be106e	1741	default:
AzureIoTClient	88:248736be106e	1742	/* Codes_SRS_IOTHUBCLIENT_LL_07_019: [ If deviceMethodCallback is NULL IoTHubClientCore_LL_DeviceMethodComplete shall return 404. ] */
AzureIoTClient	88:248736be106e	1743	result = 0;
AzureIoTClient	88:248736be106e	1744	break;
AzureIoTClient	88:248736be106e	1745	}
AzureIoTClient	88:248736be106e	1746	}
AzureIoTClient	88:248736be106e	1747	return result;
AzureIoTClient	88:248736be106e	1748	}
AzureIoTClient	88:248736be106e	1749
AzureIoTClient	88:248736be106e	1750	void IoTHubClientCore_LL_RetrievePropertyComplete(IOTHUB_CLIENT_CORE_LL_HANDLE handle, DEVICE_TWIN_UPDATE_STATE update_state, const unsigned char* payLoad, size_t size)
AzureIoTClient	88:248736be106e	1751	{
AzureIoTClient	88:248736be106e	1752	if (handle == NULL)
AzureIoTClient	88:248736be106e	1753	{
AzureIoTClient	88:248736be106e	1754	/* Codes_SRS_IOTHUBCLIENT_LL_07_013: [ If handle is NULL then IoTHubClientCore_LL_RetrievePropertyComplete shall do nothing.] */
AzureIoTClient	88:248736be106e	1755	LogError("Invalid argument handle=%p", handle);
AzureIoTClient	88:248736be106e	1756	}
AzureIoTClient	88:248736be106e	1757	else
AzureIoTClient	88:248736be106e	1758	{
AzureIoTClient	88:248736be106e	1759	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)handle;
AzureIoTClient	88:248736be106e	1760	/* Codes_SRS_IOTHUBCLIENT_LL_07_014: [ If deviceTwinCallback is NULL then IoTHubClientCore_LL_RetrievePropertyComplete shall do nothing.] */
AzureIoTClient	88:248736be106e	1761	if (handleData->deviceTwinCallback)
AzureIoTClient	88:248736be106e	1762	{
AzureIoTClient	88:248736be106e	1763	/* Codes_SRS_IOTHUBCLIENT_LL_07_015: [ If the the update_state parameter is DEVICE_TWIN_UPDATE_PARTIAL and a DEVICE_TWIN_UPDATE_COMPLETE has not been previously recieved then IoTHubClientCore_LL_RetrievePropertyComplete shall do nothing.] */
AzureIoTClient	88:248736be106e	1764	if (update_state == DEVICE_TWIN_UPDATE_COMPLETE)
AzureIoTClient	88:248736be106e	1765	{
AzureIoTClient	88:248736be106e	1766	handleData->complete_twin_update_encountered = true;
AzureIoTClient	88:248736be106e	1767	}
AzureIoTClient	88:248736be106e	1768	if (handleData->complete_twin_update_encountered)
AzureIoTClient	88:248736be106e	1769	{
AzureIoTClient	88:248736be106e	1770	/* Codes_SRS_IOTHUBCLIENT_LL_07_016: [ If deviceTwinCallback is set and DEVICE_TWIN_UPDATE_COMPLETE has been encountered then IoTHubClientCore_LL_RetrievePropertyComplete shall call deviceTwinCallback.] */
AzureIoTClient	88:248736be106e	1771	handleData->deviceTwinCallback(update_state, payLoad, size, handleData->deviceTwinContextCallback);
AzureIoTClient	88:248736be106e	1772	}
AzureIoTClient	88:248736be106e	1773	}
AzureIoTClient	88:248736be106e	1774	}
AzureIoTClient	88:248736be106e	1775	}
AzureIoTClient	88:248736be106e	1776
AzureIoTClient	88:248736be106e	1777	void IoTHubClientCore_LL_ReportedStateComplete(IOTHUB_CLIENT_CORE_LL_HANDLE handle, uint32_t item_id, int status_code)
AzureIoTClient	88:248736be106e	1778	{
AzureIoTClient	88:248736be106e	1779	/* Codes_SRS_IOTHUBCLIENT_LL_07_002: [ if handle or queue_handle are NULL then IoTHubClientCore_LL_ReportedStateComplete shall do nothing. ] */
AzureIoTClient	88:248736be106e	1780	if (handle == NULL)
AzureIoTClient	88:248736be106e	1781	{
AzureIoTClient	88:248736be106e	1782	/"shall return"/
AzureIoTClient	88:248736be106e	1783	LogError("Invalid argument handle=%p", handle);
AzureIoTClient	88:248736be106e	1784	}
AzureIoTClient	88:248736be106e	1785	else
AzureIoTClient	88:248736be106e	1786	{
AzureIoTClient	88:248736be106e	1787	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)handle;
AzureIoTClient	88:248736be106e	1788
AzureIoTClient	88:248736be106e	1789	/* Codes_SRS_IOTHUBCLIENT_LL_07_003: [ IoTHubClientCore_LL_ReportedStateComplete shall enumerate through the IOTHUB_DEVICE_TWIN structures in queue_handle. ]*/
AzureIoTClient	88:248736be106e	1790	DLIST_ENTRY* client_item = handleData->iot_ack_queue.Flink;
AzureIoTClient	88:248736be106e	1791	while (client_item != &(handleData->iot_ack_queue)) /while we are not at the end of the list/
AzureIoTClient	88:248736be106e	1792	{
AzureIoTClient	88:248736be106e	1793	PDLIST_ENTRY next_item = client_item->Flink;
AzureIoTClient	88:248736be106e	1794	IOTHUB_DEVICE_TWIN* queue_data = containingRecord(client_item, IOTHUB_DEVICE_TWIN, entry);
AzureIoTClient	88:248736be106e	1795	if (queue_data->item_id == item_id)
AzureIoTClient	88:248736be106e	1796	{
AzureIoTClient	88:248736be106e	1797	if (queue_data->reported_state_callback != NULL)
AzureIoTClient	88:248736be106e	1798	{
AzureIoTClient	88:248736be106e	1799	queue_data->reported_state_callback(status_code, queue_data->context);
AzureIoTClient	88:248736be106e	1800	}
AzureIoTClient	88:248736be106e	1801	/Codes_SRS_IOTHUBCLIENT_LL_07_009: [ IoTHubClientCore_LL_ReportedStateComplete shall remove the IOTHUB_DEVICE_TWIN item from the ack queue.]/
AzureIoTClient	88:248736be106e	1802	DList_RemoveEntryList(client_item);
AzureIoTClient	88:248736be106e	1803	device_twin_data_destroy(queue_data);
AzureIoTClient	88:248736be106e	1804	break;
AzureIoTClient	88:248736be106e	1805	}
AzureIoTClient	88:248736be106e	1806	client_item = next_item;
AzureIoTClient	88:248736be106e	1807	}
AzureIoTClient	88:248736be106e	1808	}
AzureIoTClient	88:248736be106e	1809	}
AzureIoTClient	88:248736be106e	1810
AzureIoTClient	89:a2ed767a532e	1811	static bool invoke_message_callback(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData, MESSAGE_CALLBACK_INFO* messageData)
AzureIoTClient	89:a2ed767a532e	1812	{
AzureIoTClient	89:a2ed767a532e	1813	bool result;
AzureIoTClient	89:a2ed767a532e	1814	/* Codes_SRS_IOTHUBCLIENT_LL_09_004: [IoTHubClient_LL_GetLastMessageReceiveTime shall return lastMessageReceiveTime in localtime] */
AzureIoTClient	89:a2ed767a532e	1815	handleData->lastMessageReceiveTime = get_time(NULL);
AzureIoTClient	89:a2ed767a532e	1816
AzureIoTClient	89:a2ed767a532e	1817	switch (handleData->messageCallback.type)
AzureIoTClient	89:a2ed767a532e	1818	{
AzureIoTClient	89:a2ed767a532e	1819	case CALLBACK_TYPE_NONE:
AzureIoTClient	89:a2ed767a532e	1820	{
AzureIoTClient	89:a2ed767a532e	1821	/Codes_SRS_IOTHUBCLIENT_LL_02_032: [If the client is not subscribed to receive messages then IoTHubClient_LL_MessageCallback shall return false.] /
AzureIoTClient	89:a2ed767a532e	1822	LogError("Invalid workflow - not currently set up to accept messages");
AzureIoTClient	89:a2ed767a532e	1823	result = false;
AzureIoTClient	89:a2ed767a532e	1824	break;
AzureIoTClient	89:a2ed767a532e	1825	}
AzureIoTClient	89:a2ed767a532e	1826	case CALLBACK_TYPE_SYNC:
AzureIoTClient	89:a2ed767a532e	1827	{
AzureIoTClient	89:a2ed767a532e	1828	/Codes_SRS_IOTHUBCLIENT_LL_02_030: [If messageCallbackType is LEGACY then IoTHubClient_LL_MessageCallback shall invoke the last callback function (the parameter messageCallback to IoTHubClient_LL_SetMessageCallback) passing the message and the passed userContextCallback.]/
AzureIoTClient	89:a2ed767a532e	1829	IOTHUBMESSAGE_DISPOSITION_RESULT cb_result = handleData->messageCallback.callbackSync(messageData->messageHandle, handleData->messageCallback.userContextCallback);
AzureIoTClient	89:a2ed767a532e	1830
AzureIoTClient	89:a2ed767a532e	1831	/Codes_SRS_IOTHUBCLIENT_LL_10_007: [If messageCallbackType is LEGACY then IoTHubClient_LL_MessageCallback shall send the message disposition as returned by the client to the underlying layer.] /
AzureIoTClient	89:a2ed767a532e	1832	if (handleData->IoTHubTransport_SendMessageDisposition(messageData, cb_result) != IOTHUB_CLIENT_OK)
AzureIoTClient	89:a2ed767a532e	1833	{
AzureIoTClient	89:a2ed767a532e	1834	LogError("IoTHubTransport_SendMessageDisposition failed");
AzureIoTClient	89:a2ed767a532e	1835	}
AzureIoTClient	89:a2ed767a532e	1836	result = true;
AzureIoTClient	89:a2ed767a532e	1837	break;
AzureIoTClient	89:a2ed767a532e	1838	}
AzureIoTClient	89:a2ed767a532e	1839	case CALLBACK_TYPE_ASYNC:
AzureIoTClient	89:a2ed767a532e	1840	{
AzureIoTClient	89:a2ed767a532e	1841	/* Codes_SRS_IOTHUBCLIENT_LL_10_009: [If messageCallbackType is ASYNC then IoTHubClient_LL_MessageCallback shall return what messageCallbacEx returns.] */
AzureIoTClient	89:a2ed767a532e	1842	result = handleData->messageCallback.callbackAsync(messageData, handleData->messageCallback.userContextCallback);
AzureIoTClient	89:a2ed767a532e	1843	if (!result)
AzureIoTClient	89:a2ed767a532e	1844	{
AzureIoTClient	89:a2ed767a532e	1845	LogError("messageCallbackEx failed");
AzureIoTClient	89:a2ed767a532e	1846	}
AzureIoTClient	89:a2ed767a532e	1847	break;
AzureIoTClient	89:a2ed767a532e	1848	}
AzureIoTClient	89:a2ed767a532e	1849	default:
AzureIoTClient	89:a2ed767a532e	1850	{
AzureIoTClient	89:a2ed767a532e	1851	LogError("Invalid state");
AzureIoTClient	89:a2ed767a532e	1852	result = false;
AzureIoTClient	89:a2ed767a532e	1853	break;
AzureIoTClient	89:a2ed767a532e	1854	}
AzureIoTClient	89:a2ed767a532e	1855	}
AzureIoTClient	89:a2ed767a532e	1856
AzureIoTClient	89:a2ed767a532e	1857	return result;
AzureIoTClient	89:a2ed767a532e	1858	}
AzureIoTClient	89:a2ed767a532e	1859
AzureIoTClient	88:248736be106e	1860	bool IoTHubClientCore_LL_MessageCallback(IOTHUB_CLIENT_CORE_LL_HANDLE handle, MESSAGE_CALLBACK_INFO* messageData)
AzureIoTClient	88:248736be106e	1861	{
AzureIoTClient	88:248736be106e	1862	bool result;
AzureIoTClient	88:248736be106e	1863	if ((handle == NULL) \|\| messageData == NULL)
AzureIoTClient	88:248736be106e	1864	{
AzureIoTClient	89:a2ed767a532e	1865	/Codes_SRS_IOTHUBCLIENT_LL_02_029: [If parameter handle is NULL then IoTHubClient_LL_MessageCallback shall return IOTHUBMESSAGE_ABANDONED.] /
AzureIoTClient	88:248736be106e	1866	LogError("invalid argument: handle(%p), messageData(%p)", handle, messageData);
AzureIoTClient	88:248736be106e	1867	result = false;
AzureIoTClient	88:248736be106e	1868	}
AzureIoTClient	88:248736be106e	1869	else if (messageData->messageHandle == NULL)
AzureIoTClient	88:248736be106e	1870	{
AzureIoTClient	89:a2ed767a532e	1871	/Codes_SRS_IOTHUBCLIENT_LL_10_004: [If messageHandle field of paramger messageData is NULL then IoTHubClient_LL_MessageCallback shall return IOTHUBMESSAGE_ABANDONED.] /
AzureIoTClient	88:248736be106e	1872	LogError("invalid argument messageData->messageHandle(NULL)");
AzureIoTClient	88:248736be106e	1873	result = false;
AzureIoTClient	88:248736be106e	1874	}
AzureIoTClient	88:248736be106e	1875	else
AzureIoTClient	88:248736be106e	1876	{
AzureIoTClient	88:248736be106e	1877	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)handle;
AzureIoTClient	89:a2ed767a532e	1878	return invoke_message_callback(handleData, messageData);
AzureIoTClient	89:a2ed767a532e	1879	}
AzureIoTClient	89:a2ed767a532e	1880	return result;
AzureIoTClient	89:a2ed767a532e	1881	}
AzureIoTClient	88:248736be106e	1882
AzureIoTClient	89:a2ed767a532e	1883	static bool is_event_equal(IOTHUB_EVENT_CALLBACK event_callback, const char input_name)
AzureIoTClient	89:a2ed767a532e	1884	{
AzureIoTClient	89:a2ed767a532e	1885	bool result;
AzureIoTClient	89:a2ed767a532e	1886
AzureIoTClient	89:a2ed767a532e	1887	if (event_callback != NULL)
AzureIoTClient	89:a2ed767a532e	1888	{
AzureIoTClient	89:a2ed767a532e	1889	const char* event_input_name = STRING_c_str(event_callback->inputName);
AzureIoTClient	89:a2ed767a532e	1890	if ((event_input_name != NULL) && (input_name != NULL))
AzureIoTClient	89:a2ed767a532e	1891	{
AzureIoTClient	89:a2ed767a532e	1892	// Matched the input queue name of a named handler
AzureIoTClient	89:a2ed767a532e	1893	result = (strcmp(event_input_name, input_name) == 0);
AzureIoTClient	89:a2ed767a532e	1894	}
AzureIoTClient	89:a2ed767a532e	1895	else if ((input_name == NULL) && (event_input_name == NULL))
AzureIoTClient	89:a2ed767a532e	1896	{
AzureIoTClient	89:a2ed767a532e	1897	// Matched the default handler
AzureIoTClient	89:a2ed767a532e	1898	result = true;
AzureIoTClient	89:a2ed767a532e	1899	}
AzureIoTClient	89:a2ed767a532e	1900	else
AzureIoTClient	88:248736be106e	1901	{
AzureIoTClient	89:a2ed767a532e	1902	result = false;
AzureIoTClient	89:a2ed767a532e	1903	}
AzureIoTClient	89:a2ed767a532e	1904	}
AzureIoTClient	89:a2ed767a532e	1905	else
AzureIoTClient	89:a2ed767a532e	1906	{
AzureIoTClient	89:a2ed767a532e	1907	result = false;
AzureIoTClient	89:a2ed767a532e	1908	}
AzureIoTClient	89:a2ed767a532e	1909	return result;
AzureIoTClient	89:a2ed767a532e	1910	}
AzureIoTClient	89:a2ed767a532e	1911
AzureIoTClient	89:a2ed767a532e	1912	static bool is_event_equal_for_match(LIST_ITEM_HANDLE list_item, const void* match_context)
AzureIoTClient	89:a2ed767a532e	1913	{
AzureIoTClient	89:a2ed767a532e	1914	return is_event_equal((IOTHUB_EVENT_CALLBACK)singlylinkedlist_item_get_value(list_item), (const char)match_context);
AzureIoTClient	89:a2ed767a532e	1915	}
AzureIoTClient	89:a2ed767a532e	1916
AzureIoTClient	89:a2ed767a532e	1917	bool IoTHubClientCore_LL_MessageCallbackFromInput(IOTHUB_CLIENT_CORE_LL_HANDLE handle, MESSAGE_CALLBACK_INFO* messageData)
AzureIoTClient	89:a2ed767a532e	1918	{
AzureIoTClient	89:a2ed767a532e	1919	bool result;
AzureIoTClient	89:a2ed767a532e	1920	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)handle;
AzureIoTClient	89:a2ed767a532e	1921
AzureIoTClient	89:a2ed767a532e	1922	if ((handle == NULL) \|\| messageData == NULL)
AzureIoTClient	89:a2ed767a532e	1923	{
AzureIoTClient	89:a2ed767a532e	1924	// Codes_SRS_IOTHUBCLIENT_LL_31_137: [ If either parameter `handle` or `messageData` is `NULL` then `IoTHubClient_LL_MessageCallbackFromInput` shall return `false`.** ]
AzureIoTClient	89:a2ed767a532e	1925	LogError("invalid argument: handle(%p), messageData(%p)", handle, messageData);
AzureIoTClient	89:a2ed767a532e	1926	result = false;
AzureIoTClient	89:a2ed767a532e	1927	}
AzureIoTClient	89:a2ed767a532e	1928	else if (messageData->messageHandle == NULL)
AzureIoTClient	89:a2ed767a532e	1929	{
AzureIoTClient	89:a2ed767a532e	1930	// Codes_SRS_IOTHUBCLIENT_LL_31_137: [ If either parameter `handle` or `messageData` is `NULL` then `IoTHubClient_LL_MessageCallbackFromInput` shall return `false`.** ]
AzureIoTClient	89:a2ed767a532e	1931	LogError("invalid argument messageData->messageHandle(NULL)");
AzureIoTClient	89:a2ed767a532e	1932	result = false;
AzureIoTClient	89:a2ed767a532e	1933	}
AzureIoTClient	89:a2ed767a532e	1934	else if (handleData->event_callbacks == NULL)
AzureIoTClient	89:a2ed767a532e	1935	{
AzureIoTClient	89:a2ed767a532e	1936	LogError("Callback from input called but no input specific callbacks registered");
AzureIoTClient	89:a2ed767a532e	1937	result = false;
AzureIoTClient	89:a2ed767a532e	1938	}
AzureIoTClient	89:a2ed767a532e	1939	else
AzureIoTClient	89:a2ed767a532e	1940	{
AzureIoTClient	89:a2ed767a532e	1941	const char* inputName = IoTHubMessage_GetInputName(messageData->messageHandle);
AzureIoTClient	89:a2ed767a532e	1942
AzureIoTClient	89:a2ed767a532e	1943	LIST_ITEM_HANDLE item_handle = NULL;
AzureIoTClient	89:a2ed767a532e	1944
AzureIoTClient	89:a2ed767a532e	1945	item_handle = singlylinkedlist_find(handleData->event_callbacks, is_event_equal_for_match, (const void*)inputName);
AzureIoTClient	89:a2ed767a532e	1946
AzureIoTClient	89:a2ed767a532e	1947	if (item_handle == NULL)
AzureIoTClient	89:a2ed767a532e	1948	{
AzureIoTClient	89:a2ed767a532e	1949	// Codes_SRS_IOTHUBCLIENT_LL_31_138: [ If there is no registered handler for the inputName from `IoTHubMessage_GetInputName`, then `IoTHubClient_LL_MessageCallbackFromInput` shall attempt invoke the default handler handler.** ]
AzureIoTClient	89:a2ed767a532e	1950	item_handle = singlylinkedlist_find(handleData->event_callbacks, is_event_equal_for_match, NULL);
AzureIoTClient	89:a2ed767a532e	1951	}
AzureIoTClient	89:a2ed767a532e	1952
AzureIoTClient	89:a2ed767a532e	1953	if (item_handle == NULL)
AzureIoTClient	89:a2ed767a532e	1954	{
AzureIoTClient	89:a2ed767a532e	1955	LogError("Could not find callback (explicit or default) for input queue %s", inputName);
AzureIoTClient	89:a2ed767a532e	1956	result = false;
AzureIoTClient	89:a2ed767a532e	1957	}
AzureIoTClient	89:a2ed767a532e	1958	else
AzureIoTClient	89:a2ed767a532e	1959	{
AzureIoTClient	89:a2ed767a532e	1960	IOTHUB_EVENT_CALLBACK* event_callback = (IOTHUB_EVENT_CALLBACK*)singlylinkedlist_item_get_value(item_handle);
AzureIoTClient	89:a2ed767a532e	1961	if (NULL == event_callback)
AzureIoTClient	88:248736be106e	1962	{
AzureIoTClient	89:a2ed767a532e	1963	LogError("singlylinkedlist_item_get_value for event_callback failed");
AzureIoTClient	88:248736be106e	1964	result = false;
AzureIoTClient	88:248736be106e	1965	}
AzureIoTClient	89:a2ed767a532e	1966	else
AzureIoTClient	88:248736be106e	1967	{
AzureIoTClient	89:a2ed767a532e	1968	// Codes_SRS_IOTHUBCLIENT_LL_09_004: [IoTHubClient_LL_GetLastMessageReceiveTime shall return lastMessageReceiveTime in localtime]
AzureIoTClient	89:a2ed767a532e	1969	handleData->lastMessageReceiveTime = get_time(NULL);
AzureIoTClient	88:248736be106e	1970
AzureIoTClient	89:a2ed767a532e	1971	if (event_callback->callbackAsyncEx != NULL)
AzureIoTClient	88:248736be106e	1972	{
AzureIoTClient	89:a2ed767a532e	1973	// Codes_SRS_IOTHUBCLIENT_LL_31_139: [ `IoTHubClient_LL_MessageCallbackFromInput` shall the callback from the given inputName queue if it has been registered.** ]
AzureIoTClient	89:a2ed767a532e	1974	result = event_callback->callbackAsyncEx(messageData, event_callback->userContextCallbackEx);
AzureIoTClient	88:248736be106e	1975	}
AzureIoTClient	89:a2ed767a532e	1976	else
AzureIoTClient	88:248736be106e	1977	{
AzureIoTClient	89:a2ed767a532e	1978	// Codes_SRS_IOTHUBCLIENT_LL_31_139: [ `IoTHubClient_LL_MessageCallbackFromInput` shall the callback from the given inputName queue if it has been registered.** ]
AzureIoTClient	89:a2ed767a532e	1979	IOTHUBMESSAGE_DISPOSITION_RESULT cb_result = event_callback->callbackAsync(messageData->messageHandle, event_callback->userContextCallback);
AzureIoTClient	89:a2ed767a532e	1980
AzureIoTClient	89:a2ed767a532e	1981	// Codes_SRS_IOTHUBCLIENT_LL_31_140: [ `IoTHubClient_LL_MessageCallbackFromInput` shall send the message disposition as returned by the client to the underlying layer and return `true` if an input queue match is found.** ]
AzureIoTClient	89:a2ed767a532e	1982	if (handleData->IoTHubTransport_SendMessageDisposition(messageData, cb_result) != IOTHUB_CLIENT_OK)
AzureIoTClient	89:a2ed767a532e	1983	{
AzureIoTClient	89:a2ed767a532e	1984	LogError("IoTHubTransport_SendMessageDisposition failed");
AzureIoTClient	89:a2ed767a532e	1985	}
AzureIoTClient	89:a2ed767a532e	1986	result = true;
AzureIoTClient	88:248736be106e	1987	}
AzureIoTClient	88:248736be106e	1988	}
AzureIoTClient	88:248736be106e	1989	}
AzureIoTClient	88:248736be106e	1990	}
AzureIoTClient	89:a2ed767a532e	1991
AzureIoTClient	88:248736be106e	1992	return result;
AzureIoTClient	88:248736be106e	1993	}
AzureIoTClient	88:248736be106e	1994
AzureIoTClient	89:a2ed767a532e	1995
AzureIoTClient	88:248736be106e	1996	void IoTHubClientCore_LL_ConnectionStatusCallBack(IOTHUB_CLIENT_CORE_LL_HANDLE handle, IOTHUB_CLIENT_CONNECTION_STATUS status, IOTHUB_CLIENT_CONNECTION_STATUS_REASON reason)
AzureIoTClient	88:248736be106e	1997	{
AzureIoTClient	88:248736be106e	1998	/Codes_SRS_IOTHUBCLIENT_LL_25_113: [If parameter connectionStatus is NULL or parameter handle is NULL then IoTHubClientCore_LL_ConnectionStatusCallBack shall return.]/
AzureIoTClient	88:248736be106e	1999	if (handle == NULL)
AzureIoTClient	88:248736be106e	2000	{
AzureIoTClient	88:248736be106e	2001	/"shall return"/
AzureIoTClient	88:248736be106e	2002	LogError("invalid arg");
AzureIoTClient	88:248736be106e	2003	}
AzureIoTClient	88:248736be106e	2004	else
AzureIoTClient	88:248736be106e	2005	{
AzureIoTClient	88:248736be106e	2006	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)handle;
AzureIoTClient	88:248736be106e	2007
AzureIoTClient	88:248736be106e	2008	/Codes_SRS_IOTHUBCLIENT_LL_25_114: [IoTHubClientCore_LL_ConnectionStatusCallBack shall call non-callback set by the user from IoTHubClientCore_LL_SetConnectionStatusCallback passing the status, reason and the passed userContextCallback.]/
AzureIoTClient	88:248736be106e	2009	if (handleData->conStatusCallback != NULL)
AzureIoTClient	88:248736be106e	2010	{
AzureIoTClient	88:248736be106e	2011	handleData->conStatusCallback(status, reason, handleData->conStatusUserContextCallback);
AzureIoTClient	88:248736be106e	2012	}
AzureIoTClient	88:248736be106e	2013	}
AzureIoTClient	88:248736be106e	2014
AzureIoTClient	88:248736be106e	2015	}
AzureIoTClient	88:248736be106e	2016
AzureIoTClient	88:248736be106e	2017	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetConnectionStatusCallback(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_CONNECTION_STATUS_CALLBACK connectionStatusCallback, void * userContextCallback)
AzureIoTClient	88:248736be106e	2018	{
AzureIoTClient	88:248736be106e	2019	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2020	/Codes_SRS_IOTHUBCLIENT_LL_25_111: [IoTHubClientCore_LL_SetConnectionStatusCallback shall return IOTHUB_CLIENT_INVALID_ARG if called with NULL parameter iotHubClientHandle]* */
AzureIoTClient	88:248736be106e	2021	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	2022	{
AzureIoTClient	88:248736be106e	2023	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2024	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2025	}
AzureIoTClient	88:248736be106e	2026	else
AzureIoTClient	88:248736be106e	2027	{
AzureIoTClient	88:248736be106e	2028	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2029	/Codes_SRS_IOTHUBCLIENT_LL_25_112: [IoTHubClientCore_LL_SetConnectionStatusCallback shall return IOTHUB_CLIENT_OK and save the callback and userContext as a member of the handle.] /
AzureIoTClient	88:248736be106e	2030	handleData->conStatusCallback = connectionStatusCallback;
AzureIoTClient	88:248736be106e	2031	handleData->conStatusUserContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	2032	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2033	}
AzureIoTClient	88:248736be106e	2034
AzureIoTClient	88:248736be106e	2035	return result;
AzureIoTClient	88:248736be106e	2036	}
AzureIoTClient	88:248736be106e	2037
AzureIoTClient	88:248736be106e	2038	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetRetryPolicy(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_RETRY_POLICY retryPolicy, size_t retryTimeoutLimitInSeconds)
AzureIoTClient	88:248736be106e	2039	{
AzureIoTClient	88:248736be106e	2040	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2041	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2042
AzureIoTClient	88:248736be106e	2043	/* Codes_SRS_IOTHUBCLIENT_LL_25_116: [If iotHubClientHandle, retryPolicy or retryTimeoutLimitinSeconds is NULL, IoTHubClientCore_LL_GetRetryPolicy shall return IOTHUB_CLIENT_INVALID_ARG]*/
AzureIoTClient	88:248736be106e	2044	if (handleData == NULL)
AzureIoTClient	88:248736be106e	2045	{
AzureIoTClient	88:248736be106e	2046	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2047	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2048	}
AzureIoTClient	88:248736be106e	2049	else
AzureIoTClient	88:248736be106e	2050	{
AzureIoTClient	88:248736be106e	2051	if (handleData->transportHandle == NULL)
AzureIoTClient	88:248736be106e	2052	{
AzureIoTClient	88:248736be106e	2053	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2054	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2055	}
AzureIoTClient	88:248736be106e	2056	else
AzureIoTClient	88:248736be106e	2057	{
AzureIoTClient	88:248736be106e	2058	if (handleData->IoTHubTransport_SetRetryPolicy(handleData->transportHandle, retryPolicy, retryTimeoutLimitInSeconds) != 0)
AzureIoTClient	88:248736be106e	2059	{
AzureIoTClient	88:248736be106e	2060	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2061	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2062	}
AzureIoTClient	88:248736be106e	2063	else
AzureIoTClient	88:248736be106e	2064	{
AzureIoTClient	88:248736be106e	2065	/* Codes_SRS_IOTHUBCLIENT_LL_25_118: [IoTHubClientCore_LL_SetRetryPolicy shall save connection retry policies specified by the user to retryPolicy in struct IOTHUB_CLIENT_CORE_LL_HANDLE_DATA] */
AzureIoTClient	88:248736be106e	2066	/* Codes_SRS_IOTHUBCLIENT_LL_25_119: [IoTHubClientCore_LL_SetRetryPolicy shall save retryTimeoutLimitInSeconds in seconds to retryTimeout in struct IOTHUB_CLIENT_CORE_LL_HANDLE_DATA] */
AzureIoTClient	88:248736be106e	2067	handleData->retryPolicy = retryPolicy;
AzureIoTClient	88:248736be106e	2068	handleData->retryTimeoutLimitInSeconds = retryTimeoutLimitInSeconds;
AzureIoTClient	88:248736be106e	2069	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2070	}
AzureIoTClient	88:248736be106e	2071	}
AzureIoTClient	88:248736be106e	2072	}
AzureIoTClient	88:248736be106e	2073	return result;
AzureIoTClient	88:248736be106e	2074	}
AzureIoTClient	88:248736be106e	2075
AzureIoTClient	88:248736be106e	2076	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_GetRetryPolicy(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_RETRY_POLICY* retryPolicy, size_t* retryTimeoutLimitInSeconds)
AzureIoTClient	88:248736be106e	2077	{
AzureIoTClient	88:248736be106e	2078	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2079
AzureIoTClient	88:248736be106e	2080	/* Codes_SRS_IOTHUBCLIENT_LL_09_001: [IoTHubClientCore_LL_GetLastMessageReceiveTime shall return IOTHUB_CLIENT_INVALID_ARG if any of the arguments is NULL] */
AzureIoTClient	88:248736be106e	2081	if (iotHubClientHandle == NULL \|\| retryPolicy == NULL \|\| retryTimeoutLimitInSeconds == NULL)
AzureIoTClient	88:248736be106e	2082	{
AzureIoTClient	88:248736be106e	2083	LogError("Invalid parameter IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle = %p, IOTHUB_CLIENT_RETRY_POLICY* retryPolicy = %p, size_t* retryTimeoutLimitInSeconds = %p", iotHubClientHandle, retryPolicy, retryTimeoutLimitInSeconds);
AzureIoTClient	88:248736be106e	2084	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2085	}
AzureIoTClient	88:248736be106e	2086	else
AzureIoTClient	88:248736be106e	2087	{
AzureIoTClient	88:248736be106e	2088	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2089
AzureIoTClient	88:248736be106e	2090	*retryPolicy = handleData->retryPolicy;
AzureIoTClient	88:248736be106e	2091	*retryTimeoutLimitInSeconds = handleData->retryTimeoutLimitInSeconds;
AzureIoTClient	88:248736be106e	2092	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2093	}
AzureIoTClient	88:248736be106e	2094
AzureIoTClient	88:248736be106e	2095	return result;
AzureIoTClient	88:248736be106e	2096	}
AzureIoTClient	88:248736be106e	2097
AzureIoTClient	88:248736be106e	2098	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_GetLastMessageReceiveTime(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, time_t* lastMessageReceiveTime)
AzureIoTClient	88:248736be106e	2099	{
AzureIoTClient	88:248736be106e	2100	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2101	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2102
AzureIoTClient	88:248736be106e	2103	/* Codes_SRS_IOTHUBCLIENT_LL_09_001: [IoTHubClientCore_LL_GetLastMessageReceiveTime shall return IOTHUB_CLIENT_INVALID_ARG if any of the arguments is NULL] */
AzureIoTClient	88:248736be106e	2104	if (handleData == NULL \|\| lastMessageReceiveTime == NULL)
AzureIoTClient	88:248736be106e	2105	{
AzureIoTClient	88:248736be106e	2106	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2107	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2108	}
AzureIoTClient	88:248736be106e	2109	else
AzureIoTClient	88:248736be106e	2110	{
AzureIoTClient	88:248736be106e	2111	/* Codes_SRS_IOTHUBCLIENT_LL_09_002: [IoTHubClientCore_LL_GetLastMessageReceiveTime shall return IOTHUB_CLIENT_INDEFINITE_TIME - and not set 'lastMessageReceiveTime' - if it is unable to provide the time for the last commands] */
AzureIoTClient	88:248736be106e	2112	if (handleData->lastMessageReceiveTime == INDEFINITE_TIME)
AzureIoTClient	88:248736be106e	2113	{
AzureIoTClient	88:248736be106e	2114	result = IOTHUB_CLIENT_INDEFINITE_TIME;
AzureIoTClient	88:248736be106e	2115	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2116	}
AzureIoTClient	88:248736be106e	2117	else
AzureIoTClient	88:248736be106e	2118	{
AzureIoTClient	88:248736be106e	2119	/* Codes_SRS_IOTHUBCLIENT_LL_09_003: [IoTHubClientCore_LL_GetLastMessageReceiveTime shall return IOTHUB_CLIENT_OK if it wrote in the lastMessageReceiveTime the time when the last command was received] */
AzureIoTClient	88:248736be106e	2120	/* Codes_SRS_IOTHUBCLIENT_LL_09_004: [IoTHubClientCore_LL_GetLastMessageReceiveTime shall return lastMessageReceiveTime in localtime] */
AzureIoTClient	88:248736be106e	2121	*lastMessageReceiveTime = handleData->lastMessageReceiveTime;
AzureIoTClient	88:248736be106e	2122	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2123	}
AzureIoTClient	88:248736be106e	2124	}
AzureIoTClient	88:248736be106e	2125
AzureIoTClient	88:248736be106e	2126	return result;
AzureIoTClient	88:248736be106e	2127	}
AzureIoTClient	88:248736be106e	2128
AzureIoTClient	88:248736be106e	2129	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetOption(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* optionName, const void* value)
AzureIoTClient	88:248736be106e	2130	{
AzureIoTClient	88:248736be106e	2131
AzureIoTClient	88:248736be106e	2132	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2133	/Codes_SRS_IOTHUBCLIENT_LL_02_034: [If iotHubClientHandle is NULL then IoTHubClientCore_LL_SetOption shall return IOTHUB_CLIENT_INVALID_ARG.]/
AzureIoTClient	88:248736be106e	2134	/Codes_SRS_IOTHUBCLIENT_LL_02_035: [If optionName is NULL then IoTHubClientCore_LL_SetOption shall return IOTHUB_CLIENT_INVALID_ARG.] /
AzureIoTClient	88:248736be106e	2135	/Codes_SRS_IOTHUBCLIENT_LL_02_036: [If value is NULL then IoTHubClientCore_LL_SetOption shall return IOTHUB_CLIENT_INVALID_ARG.] /
AzureIoTClient	88:248736be106e	2136	if (
AzureIoTClient	88:248736be106e	2137	(iotHubClientHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	2138	(optionName == NULL) \|\|
AzureIoTClient	88:248736be106e	2139	(value == NULL)
AzureIoTClient	88:248736be106e	2140	)
AzureIoTClient	88:248736be106e	2141	{
AzureIoTClient	88:248736be106e	2142	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2143	LogError("invalid argument (NULL)");
AzureIoTClient	88:248736be106e	2144	}
AzureIoTClient	88:248736be106e	2145	else
AzureIoTClient	88:248736be106e	2146	{
AzureIoTClient	88:248736be106e	2147	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2148
AzureIoTClient	88:248736be106e	2149	/Codes_SRS_IOTHUBCLIENT_LL_02_039: [ "messageTimeout" - once IoTHubClientCore_LL_SendEventAsync is called the message shall timeout after value miliseconds. Value is a pointer to a tickcounter_ms_t. ]/
AzureIoTClient	88:248736be106e	2150	if (strcmp(optionName, OPTION_MESSAGE_TIMEOUT) == 0)
AzureIoTClient	88:248736be106e	2151	{
AzureIoTClient	88:248736be106e	2152	/this is an option handled by IoTHubClientCore_LL/
AzureIoTClient	88:248736be106e	2153	/Codes_SRS_IOTHUBCLIENT_LL_02_043: [ Calling IoTHubClientCore_LL_SetOption with value set to "0" shall disable the timeout mechanism for all new messages. ]/
AzureIoTClient	88:248736be106e	2154	handleData->currentMessageTimeout = (const tickcounter_ms_t)value;
AzureIoTClient	88:248736be106e	2155	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2156	}
AzureIoTClient	88:248736be106e	2157	else if (strcmp(optionName, OPTION_PRODUCT_INFO) == 0)
AzureIoTClient	88:248736be106e	2158	{
AzureIoTClient	88:248736be106e	2159	/Codes_SRS_IOTHUBCLIENT_LL_10_033: [repeat calls with "product_info" will erase the previously set product information if applicatble. ]/
AzureIoTClient	88:248736be106e	2160	if (handleData->product_info != NULL)
AzureIoTClient	88:248736be106e	2161	{
AzureIoTClient	88:248736be106e	2162	STRING_delete(handleData->product_info);
AzureIoTClient	88:248736be106e	2163	handleData->product_info = NULL;
AzureIoTClient	88:248736be106e	2164	}
AzureIoTClient	88:248736be106e	2165
AzureIoTClient	88:248736be106e	2166	/Codes_SRS_IOTHUBCLIENT_LL_10_035: [If string concatenation fails, `IoTHubClientCore_LL_SetOption` shall return `IOTHUB_CLIENT_ERRROR`. Otherwise, `IOTHUB_CLIENT_OK` shall be returned. ]/
AzureIoTClient	88:248736be106e	2167	handleData->product_info = make_product_info((const char*)value);
AzureIoTClient	88:248736be106e	2168	if (handleData->product_info == NULL)
AzureIoTClient	88:248736be106e	2169	{
AzureIoTClient	88:248736be106e	2170	LogError("STRING_construct_sprintf failed");
AzureIoTClient	88:248736be106e	2171	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2172	}
AzureIoTClient	88:248736be106e	2173	else
AzureIoTClient	88:248736be106e	2174	{
AzureIoTClient	88:248736be106e	2175	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2176	}
AzureIoTClient	88:248736be106e	2177	}
AzureIoTClient	88:248736be106e	2178	else if (strcmp(optionName, OPTION_DIAGNOSTIC_SAMPLING_PERCENTAGE) == 0)
AzureIoTClient	88:248736be106e	2179	{
AzureIoTClient	88:248736be106e	2180	uint32_t percentage = (uint32_t)value;
AzureIoTClient	88:248736be106e	2181	if (percentage > 100)
AzureIoTClient	88:248736be106e	2182	{
AzureIoTClient	88:248736be106e	2183	/Codes_SRS_IOTHUBCLIENT_LL_10_036: [Calling IoTHubClientCore_LL_SetOption with value > 100 shall return `IOTHUB_CLIENT_ERRROR`. ]/
AzureIoTClient	88:248736be106e	2184	LogError("The value of diag_sampling_percentage is out of range [0, 100]: %u", percentage);
AzureIoTClient	88:248736be106e	2185	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2186	}
AzureIoTClient	88:248736be106e	2187	else
AzureIoTClient	88:248736be106e	2188	{
AzureIoTClient	88:248736be106e	2189	/Codes_SRS_IOTHUBCLIENT_LL_10_037: [Calling IoTHubClientCore_LL_SetOption with value between [0, 100] shall return `IOTHUB_CLIENT_OK`. ]/
AzureIoTClient	88:248736be106e	2190	handleData->diagnostic_setting.diagSamplingPercentage = percentage;
AzureIoTClient	88:248736be106e	2191	handleData->diagnostic_setting.currentMessageNumber = 0;
AzureIoTClient	88:248736be106e	2192	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2193	}
AzureIoTClient	88:248736be106e	2194	}
AzureIoTClient	88:248736be106e	2195	else if (strcmp(optionName, OPTION_BLOB_UPLOAD_TIMEOUT_SECS) == 0)
AzureIoTClient	88:248736be106e	2196	{
AzureIoTClient	88:248736be106e	2197	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	2198	// This option just gets passed down into IoTHubClientCore_LL_UploadToBlob
AzureIoTClient	88:248736be106e	2199	/Codes_SRS_IOTHUBCLIENT_LL_30_010: [ blob_xfr_timeout - IoTHubClientCore_LL_SetOption shall pass this option to IoTHubClient_UploadToBlob_SetOption and return its result. ]/
AzureIoTClient	88:248736be106e	2200	result = IoTHubClient_LL_UploadToBlob_SetOption(handleData->uploadToBlobHandle, optionName, value);
AzureIoTClient	88:248736be106e	2201	if(result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	2202	{
AzureIoTClient	88:248736be106e	2203	LogError("unable to IoTHubClientCore_LL_UploadToBlob_SetOption");
AzureIoTClient	88:248736be106e	2204	}
AzureIoTClient	88:248736be106e	2205	#else
AzureIoTClient	88:248736be106e	2206	LogError("OPTION_BLOB_TRANSFER_TIMEOUT option being set with DONT_USE_UPLOADTOBLOB compiler switch");
AzureIoTClient	88:248736be106e	2207	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2208	#endif /DONT_USE_UPLOADTOBLOB/
AzureIoTClient	88:248736be106e	2209	}
AzureIoTClient	88:248736be106e	2210	else
AzureIoTClient	88:248736be106e	2211	{
AzureIoTClient	88:248736be106e	2212	// This section is unusual for SetOption calls because it attempts to pass unhandled options
AzureIoTClient	88:248736be106e	2213	// to two downstream targets (IoTHubTransport_SetOption and IoTHubClientCore_LL_UploadToBlob_SetOption) instead of one.
AzureIoTClient	88:248736be106e	2214
AzureIoTClient	88:248736be106e	2215	/Codes_SRS_IOTHUBCLIENT_LL_30_011: [ IoTHubClientCore_LL_SetOption shall always pass unhandled options to Transport_SetOption. ]/
AzureIoTClient	88:248736be106e	2216	/Codes_SRS_IOTHUBCLIENT_LL_30_012: [ If Transport_SetOption fails, IoTHubClientCore_LL_SetOption shall return that failure code. ]/
AzureIoTClient	88:248736be106e	2217	result = handleData->IoTHubTransport_SetOption(handleData->transportHandle, optionName, value);
AzureIoTClient	88:248736be106e	2218	if(result != IOTHUB_CLIENT_OK)
AzureIoTClient	88:248736be106e	2219	{
AzureIoTClient	88:248736be106e	2220	LogError("unable to IoTHubTransport_SetOption");
AzureIoTClient	88:248736be106e	2221	}
AzureIoTClient	88:248736be106e	2222	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	2223	else
AzureIoTClient	88:248736be106e	2224	{
AzureIoTClient	88:248736be106e	2225	/Codes_SRS_IOTHUBCLIENT_LL_30_013: [ If the DONT_USE_UPLOADTOBLOB compiler switch is undefined, IoTHubClientCore_LL_SetOption shall pass unhandled options to IoTHubClient_UploadToBlob_SetOption and ignore the result. ]/
AzureIoTClient	88:248736be106e	2226	(void)IoTHubClient_LL_UploadToBlob_SetOption(handleData->uploadToBlobHandle, optionName, value);
AzureIoTClient	88:248736be106e	2227	}
AzureIoTClient	88:248736be106e	2228	#endif /DONT_USE_UPLOADTOBLOB/
AzureIoTClient	88:248736be106e	2229	}
AzureIoTClient	88:248736be106e	2230	}
AzureIoTClient	88:248736be106e	2231	return result;
AzureIoTClient	88:248736be106e	2232	}
AzureIoTClient	88:248736be106e	2233
AzureIoTClient	88:248736be106e	2234	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_GetOption(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* optionName, void** value)
AzureIoTClient	88:248736be106e	2235	{
AzureIoTClient	88:248736be106e	2236	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2237
AzureIoTClient	88:248736be106e	2238	if ((iotHubClientHandle == NULL) \|\| (optionName == NULL) \|\| (value == NULL))
AzureIoTClient	88:248736be106e	2239	{
AzureIoTClient	88:248736be106e	2240	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2241	LogError("invalid argument iotHubClientHandle(%p); optionName(%p); value(%p)", iotHubClientHandle, optionName, value);
AzureIoTClient	88:248736be106e	2242	}
AzureIoTClient	88:248736be106e	2243	else if (strcmp(optionName, OPTION_PRODUCT_INFO) == 0)
AzureIoTClient	88:248736be106e	2244	{
AzureIoTClient	88:248736be106e	2245	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2246	*value = iotHubClientHandle->product_info;
AzureIoTClient	88:248736be106e	2247	}
AzureIoTClient	88:248736be106e	2248	else
AzureIoTClient	88:248736be106e	2249	{
AzureIoTClient	88:248736be106e	2250	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2251	LogError("invalid argument (%s)", optionName);
AzureIoTClient	88:248736be106e	2252	}
AzureIoTClient	88:248736be106e	2253	return result;
AzureIoTClient	88:248736be106e	2254	}
AzureIoTClient	88:248736be106e	2255
AzureIoTClient	88:248736be106e	2256	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetDeviceTwinCallback(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_DEVICE_TWIN_CALLBACK deviceTwinCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	2257	{
AzureIoTClient	88:248736be106e	2258	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2259	/* Codes_SRS_IOTHUBCLIENT_LL_10_001: [ IoTHubClientCore_LL_SetDeviceTwinCallback shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter iotHubClientHandle is NULL.] */
AzureIoTClient	88:248736be106e	2260	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	2261	{
AzureIoTClient	88:248736be106e	2262	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2263	LogError("Invalid argument specified iothubClientHandle=%p", iotHubClientHandle);
AzureIoTClient	88:248736be106e	2264	}
AzureIoTClient	88:248736be106e	2265	else
AzureIoTClient	88:248736be106e	2266	{
AzureIoTClient	88:248736be106e	2267	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2268	if (deviceTwinCallback == NULL)
AzureIoTClient	88:248736be106e	2269	{
AzureIoTClient	88:248736be106e	2270	/* Codes_SRS_IOTHUBCLIENT_LL_10_006: [ If deviceTwinCallback is NULL, then IoTHubClientCore_LL_SetDeviceTwinCallback shall call the underlying layer's _Unsubscribe function and return IOTHUB_CLIENT_OK.] */
AzureIoTClient	88:248736be106e	2271	handleData->IoTHubTransport_Unsubscribe_DeviceTwin(handleData->transportHandle);
AzureIoTClient	88:248736be106e	2272	handleData->deviceTwinCallback = NULL;
AzureIoTClient	88:248736be106e	2273	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2274	}
AzureIoTClient	88:248736be106e	2275	else
AzureIoTClient	88:248736be106e	2276	{
AzureIoTClient	88:248736be106e	2277	/* Codes_SRS_IOTHUBCLIENT_LL_10_002: [ If deviceTwinCallback is not NULL, then IoTHubClientCore_LL_SetDeviceTwinCallback shall call the underlying layer's _Subscribe function.] */
AzureIoTClient	88:248736be106e	2278	if (handleData->IoTHubTransport_Subscribe_DeviceTwin(handleData->transportHandle) == 0)
AzureIoTClient	88:248736be106e	2279	{
AzureIoTClient	88:248736be106e	2280	handleData->deviceTwinCallback = deviceTwinCallback;
AzureIoTClient	88:248736be106e	2281	handleData->deviceTwinContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	2282	/* Codes_SRS_IOTHUBCLIENT_LL_10_005: [ Otherwise IoTHubClientCore_LL_SetDeviceTwinCallback shall succeed and return IOTHUB_CLIENT_OK.] */
AzureIoTClient	88:248736be106e	2283	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2284	}
AzureIoTClient	88:248736be106e	2285	else
AzureIoTClient	88:248736be106e	2286	{
AzureIoTClient	88:248736be106e	2287	/* Codes_SRS_IOTHUBCLIENT_LL_10_003: [ If the underlying layer's _Subscribe function fails, then IoTHubClientCore_LL_SetDeviceTwinCallback shall fail and return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	2288	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2289	}
AzureIoTClient	88:248736be106e	2290	}
AzureIoTClient	88:248736be106e	2291	}
AzureIoTClient	88:248736be106e	2292	return result;
AzureIoTClient	88:248736be106e	2293	}
AzureIoTClient	88:248736be106e	2294
AzureIoTClient	88:248736be106e	2295	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SendReportedState(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const unsigned char* reportedState, size_t size, IOTHUB_CLIENT_REPORTED_STATE_CALLBACK reportedStateCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	2296	{
AzureIoTClient	88:248736be106e	2297	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2298	/* Codes_SRS_IOTHUBCLIENT_LL_10_012: [ IoTHubClientCore_LL_SendReportedState shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter iotHubClientHandle is NULL. ] */
AzureIoTClient	88:248736be106e	2299	/* Codes_SRS_IOTHUBCLIENT_LL_10_013: [ IoTHubClientCore_LL_SendReportedState shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter reportedState is NULL] */
AzureIoTClient	88:248736be106e	2300	/* Codes_SRS_IOTHUBCLIENT_LL_07_005: [ IoTHubClientCore_LL_SendReportedState shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter size is equal to 0. ] */
AzureIoTClient	88:248736be106e	2301	if (iotHubClientHandle == NULL \|\| (reportedState == NULL \|\| size == 0) )
AzureIoTClient	88:248736be106e	2302	{
AzureIoTClient	88:248736be106e	2303	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2304	LogError("Invalid argument specified iothubClientHandle=%p, reportedState=%p, size=%zu", iotHubClientHandle, reportedState, size);
AzureIoTClient	88:248736be106e	2305	}
AzureIoTClient	88:248736be106e	2306	else
AzureIoTClient	88:248736be106e	2307	{
AzureIoTClient	88:248736be106e	2308	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2309	/* Codes_SRS_IOTHUBCLIENT_LL_10_014: [IoTHubClientCore_LL_SendReportedState shall construct and queue the reported a Device_Twin structure for transmition by the underlying transport.] */
AzureIoTClient	88:248736be106e	2310	IOTHUB_DEVICE_TWIN* client_data = dev_twin_data_create(handleData, get_next_item_id(handleData), reportedState, size, reportedStateCallback, userContextCallback);
AzureIoTClient	88:248736be106e	2311	if (client_data == NULL)
AzureIoTClient	88:248736be106e	2312	{
AzureIoTClient	88:248736be106e	2313	/* Codes_SRS_IOTHUBCLIENT_LL_10_015: [If any error is encountered IoTHubClientCore_LL_SendReportedState shall return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	2314	LogError("Failure constructing device twin data");
AzureIoTClient	88:248736be106e	2315	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2316	}
AzureIoTClient	88:248736be106e	2317	else
AzureIoTClient	88:248736be106e	2318	{
AzureIoTClient	88:248736be106e	2319	if (handleData->IoTHubTransport_Subscribe_DeviceTwin(handleData->transportHandle) != 0)
AzureIoTClient	88:248736be106e	2320	{
AzureIoTClient	88:248736be106e	2321	LogError("Failure adding device twin data to queue");
AzureIoTClient	88:248736be106e	2322	device_twin_data_destroy(client_data);
AzureIoTClient	88:248736be106e	2323	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2324	}
AzureIoTClient	88:248736be106e	2325	else
AzureIoTClient	88:248736be106e	2326	{
AzureIoTClient	88:248736be106e	2327	/* Codes_SRS_IOTHUBCLIENT_LL_07_001: [ IoTHubClientCore_LL_SendReportedState shall queue the constructed reportedState data to be consumed by the targeted transport. ] */
AzureIoTClient	88:248736be106e	2328	DList_InsertTailList(&(iotHubClientHandle->iot_msg_queue), &(client_data->entry));
AzureIoTClient	88:248736be106e	2329
AzureIoTClient	88:248736be106e	2330	/* Codes_SRS_IOTHUBCLIENT_LL_10_016: [ Otherwise IoTHubClientCore_LL_SendReportedState shall succeed and return IOTHUB_CLIENT_OK.] */
AzureIoTClient	88:248736be106e	2331	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2332	}
AzureIoTClient	88:248736be106e	2333	}
AzureIoTClient	88:248736be106e	2334	}
AzureIoTClient	88:248736be106e	2335	return result;
AzureIoTClient	88:248736be106e	2336	}
AzureIoTClient	88:248736be106e	2337
AzureIoTClient	88:248736be106e	2338	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetDeviceMethodCallback(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_DEVICE_METHOD_CALLBACK_ASYNC deviceMethodCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	2339	{
AzureIoTClient	88:248736be106e	2340	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2341
AzureIoTClient	88:248736be106e	2342	/Codes_SRS_IOTHUBCLIENT_LL_12_017: [ IoTHubClientCore_LL_SetDeviceMethodCallback shall fail and return IOTHUB_CLIENT_INVALID_ARG if parameter iotHubClientHandle is NULL. ] /
AzureIoTClient	88:248736be106e	2343	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	2344	{
AzureIoTClient	88:248736be106e	2345	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2346	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2347	}
AzureIoTClient	88:248736be106e	2348	else
AzureIoTClient	88:248736be106e	2349	{
AzureIoTClient	88:248736be106e	2350	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2351	if (deviceMethodCallback == NULL)
AzureIoTClient	88:248736be106e	2352	{
AzureIoTClient	88:248736be106e	2353	if (handleData->methodCallback.type == CALLBACK_TYPE_NONE)
AzureIoTClient	88:248736be106e	2354	{
AzureIoTClient	88:248736be106e	2355	/* Codes_SRS_IOTHUBCLIENT_LL_10_029: [ If deviceMethodCallback is NULL and the client is not subscribed to receive method calls, IoTHubClientCore_LL_SetDeviceMethodCallback shall fail and return IOTHUB_CLIENT_ERROR. ] */
AzureIoTClient	88:248736be106e	2356	LogError("not currently set to accept or process incoming messages.");
AzureIoTClient	88:248736be106e	2357	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2358	}
AzureIoTClient	88:248736be106e	2359	else if (handleData->methodCallback.type == CALLBACK_TYPE_ASYNC)
AzureIoTClient	88:248736be106e	2360	{
AzureIoTClient	88:248736be106e	2361	/* Codes_SRS_IOTHUBCLIENT_LL_10_028: [If the user has subscribed using IoTHubClientCore_LL_SetDeviceMethodCallback_Ex, IoTHubClientCore_LL_SetDeviceMethodCallback shall fail and return IOTHUB_CLIENT_ERROR. ] */
AzureIoTClient	88:248736be106e	2362	LogError("Invalid workflow sequence. Please unsubscribe using the IoTHubClientCore_LL_SetDeviceMethodCallback_Ex function.");
AzureIoTClient	88:248736be106e	2363	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2364	}
AzureIoTClient	88:248736be106e	2365	else
AzureIoTClient	88:248736be106e	2366	{
AzureIoTClient	88:248736be106e	2367	/Codes_SRS_IOTHUBCLIENT_LL_02_019: [If parameter messageCallback is NULL then IoTHubClientCore_LL_SetMessageCallback shall call the underlying layer's _Unsubscribe function and return IOTHUB_CLIENT_OK.] /
AzureIoTClient	88:248736be106e	2368	/Codes_SRS_IOTHUBCLIENT_LL_12_018: [If deviceMethodCallback is NULL, then IoTHubClientCore_LL_SetDeviceMethodCallback shall call the underlying layer's IoTHubTransport_Unsubscribe_DeviceMethod function and return IOTHUB_CLIENT_OK. ] /
AzureIoTClient	88:248736be106e	2369	/Codes_SRS_IOTHUBCLIENT_LL_12_022: [ Otherwise IoTHubClientCore_LL_SetDeviceMethodCallback shall succeed and return IOTHUB_CLIENT_OK. ]/
AzureIoTClient	88:248736be106e	2370	handleData->IoTHubTransport_Unsubscribe_DeviceMethod(handleData->transportHandle);
AzureIoTClient	88:248736be106e	2371	handleData->methodCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	2372	handleData->methodCallback.callbackSync = NULL;
AzureIoTClient	88:248736be106e	2373	handleData->methodCallback.userContextCallback = NULL;
AzureIoTClient	88:248736be106e	2374	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2375	}
AzureIoTClient	88:248736be106e	2376	}
AzureIoTClient	88:248736be106e	2377	else
AzureIoTClient	88:248736be106e	2378	{
AzureIoTClient	88:248736be106e	2379	if (handleData->methodCallback.type == CALLBACK_TYPE_ASYNC)
AzureIoTClient	88:248736be106e	2380	{
AzureIoTClient	88:248736be106e	2381	/* Codes_SRS_IOTHUBCLIENT_LL_10_028: [If the user has subscribed using IoTHubClientCore_LL_SetDeviceMethodCallback_Ex, IoTHubClientCore_LL_SetDeviceMethodCallback shall fail and return IOTHUB_CLIENT_ERROR. ] */
AzureIoTClient	88:248736be106e	2382	LogError("Invalid workflow sequence. Please unsubscribe using the IoTHubClientCore_LL_SetDeviceMethodCallback_Ex function before subscribing with IoTHubClientCore_LL_SetDeviceMethodCallback.");
AzureIoTClient	88:248736be106e	2383	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2384	}
AzureIoTClient	88:248736be106e	2385	else
AzureIoTClient	88:248736be106e	2386	{
AzureIoTClient	88:248736be106e	2387	/Codes_SRS_IOTHUBCLIENT_LL_12_019: [ If deviceMethodCallback is not NULL, then IoTHubClientCore_LL_SetDeviceMethodCallback shall call the underlying layer's IoTHubTransport_Subscribe_DeviceMethod function. ]/
AzureIoTClient	88:248736be106e	2388	if (handleData->IoTHubTransport_Subscribe_DeviceMethod(handleData->deviceHandle) == 0)
AzureIoTClient	88:248736be106e	2389	{
AzureIoTClient	88:248736be106e	2390	/Codes_SRS_IOTHUBCLIENT_LL_12_022: [ Otherwise IoTHubClientCore_LL_SetDeviceMethodCallback shall succeed and return IOTHUB_CLIENT_OK. ]/
AzureIoTClient	88:248736be106e	2391	handleData->methodCallback.type = CALLBACK_TYPE_SYNC;
AzureIoTClient	88:248736be106e	2392	handleData->methodCallback.callbackSync = deviceMethodCallback;
AzureIoTClient	88:248736be106e	2393	handleData->methodCallback.callbackAsync = NULL;
AzureIoTClient	88:248736be106e	2394	handleData->methodCallback.userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	2395	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2396	}
AzureIoTClient	88:248736be106e	2397	else
AzureIoTClient	88:248736be106e	2398	{
AzureIoTClient	88:248736be106e	2399	/Codes_SRS_IOTHUBCLIENT_LL_12_020: [ If the underlying layer's IoTHubTransport_Subscribe_DeviceMethod function fails, then IoTHubClientCore_LL_SetDeviceMethodCallback shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2400	/Codes_SRS_IOTHUBCLIENT_LL_12_021: [ If adding the information fails for any reason, IoTHubClientCore_LL_SetDeviceMethodCallback shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	88:248736be106e	2401	LogError("IoTHubTransport_Subscribe_DeviceMethod failed");
AzureIoTClient	88:248736be106e	2402	handleData->methodCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	2403	handleData->methodCallback.callbackAsync = NULL;
AzureIoTClient	88:248736be106e	2404	handleData->methodCallback.callbackSync = NULL;
AzureIoTClient	88:248736be106e	2405	handleData->methodCallback.userContextCallback = NULL;
AzureIoTClient	88:248736be106e	2406	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2407	}
AzureIoTClient	88:248736be106e	2408	}
AzureIoTClient	88:248736be106e	2409	}
AzureIoTClient	88:248736be106e	2410	}
AzureIoTClient	88:248736be106e	2411	return result;
AzureIoTClient	88:248736be106e	2412	}
AzureIoTClient	88:248736be106e	2413
AzureIoTClient	88:248736be106e	2414	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetDeviceMethodCallback_Ex(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_CLIENT_INBOUND_DEVICE_METHOD_CALLBACK inboundDeviceMethodCallback, void* userContextCallback)
AzureIoTClient	88:248736be106e	2415	{
AzureIoTClient	88:248736be106e	2416	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2417	/* Codes_SRS_IOTHUBCLIENT_LL_07_021: [ If handle is NULL then IoTHubClientCore_LL_SetDeviceMethodCallback_Ex shall return IOTHUB_CLIENT_INVALID_ARG.] */
AzureIoTClient	88:248736be106e	2418	if (iotHubClientHandle == NULL)
AzureIoTClient	88:248736be106e	2419	{
AzureIoTClient	88:248736be106e	2420	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2421	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2422	}
AzureIoTClient	88:248736be106e	2423	else
AzureIoTClient	88:248736be106e	2424	{
AzureIoTClient	88:248736be106e	2425	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2426	if (inboundDeviceMethodCallback == NULL)
AzureIoTClient	88:248736be106e	2427	{
AzureIoTClient	88:248736be106e	2428	if (handleData->methodCallback.type == CALLBACK_TYPE_NONE)
AzureIoTClient	88:248736be106e	2429	{
AzureIoTClient	88:248736be106e	2430	/* Codes_SRS_IOTHUBCLIENT_LL_10_030: [ If deviceMethodCallback is NULL and the client is not subscribed to receive method calls, IoTHubClientCore_LL_SetDeviceMethodCallback shall fail and return IOTHUB_CLIENT_ERROR. ] */
AzureIoTClient	88:248736be106e	2431	LogError("not currently set to accept or process incoming messages.");
AzureIoTClient	88:248736be106e	2432	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2433	}
AzureIoTClient	88:248736be106e	2434	else if (handleData->methodCallback.type == CALLBACK_TYPE_SYNC)
AzureIoTClient	88:248736be106e	2435	{
AzureIoTClient	88:248736be106e	2436	/* Codes_SRS_IOTHUBCLIENT_LL_10_031: [If the user has subscribed using IoTHubClientCore_LL_SetDeviceMethodCallback, IoTHubClientCore_LL_SetDeviceMethodCallback_Ex shall fail and return IOTHUB_CLIENT_ERROR. ] */
AzureIoTClient	88:248736be106e	2437	LogError("Invalid workflow sequence. Please unsubscribe using the IoTHubClientCore_LL_SetDeviceMethodCallback function.");
AzureIoTClient	88:248736be106e	2438	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2439	}
AzureIoTClient	88:248736be106e	2440	else
AzureIoTClient	88:248736be106e	2441	{
AzureIoTClient	88:248736be106e	2442	/* Codes_SRS_IOTHUBCLIENT_LL_07_022: [ If inboundDeviceMethodCallback is NULL then IoTHubClientCore_LL_SetDeviceMethodCallback_Ex shall call the underlying layer's IoTHubTransport_Unsubscribe_DeviceMethod function and return IOTHUB_CLIENT_OK.] */
AzureIoTClient	88:248736be106e	2443	handleData->IoTHubTransport_Unsubscribe_DeviceMethod(handleData->transportHandle);
AzureIoTClient	88:248736be106e	2444	handleData->methodCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	2445	handleData->methodCallback.callbackAsync = NULL;
AzureIoTClient	88:248736be106e	2446	handleData->methodCallback.userContextCallback = NULL;
AzureIoTClient	88:248736be106e	2447	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2448	}
AzureIoTClient	88:248736be106e	2449	}
AzureIoTClient	88:248736be106e	2450	else
AzureIoTClient	88:248736be106e	2451	{
AzureIoTClient	88:248736be106e	2452	if (handleData->methodCallback.type == CALLBACK_TYPE_SYNC)
AzureIoTClient	88:248736be106e	2453	{
AzureIoTClient	88:248736be106e	2454	/* Codes_SRS_IOTHUBCLIENT_LL_10_031: [If the user has subscribed using IoTHubClientCore_LL_SetDeviceMethodCallback, IoTHubClientCore_LL_SetDeviceMethodCallback_Ex shall fail and return IOTHUB_CLIENT_ERROR. ] */
AzureIoTClient	88:248736be106e	2455	LogError("Invalid workflow sequence. Please unsubscribe using the IoTHubClientCore_LL_SetDeviceMethodCallback function before subscribing with IoTHubClientCore_LL_SetDeviceMethodCallback_Ex.");
AzureIoTClient	88:248736be106e	2456	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2457	}
AzureIoTClient	88:248736be106e	2458	else
AzureIoTClient	88:248736be106e	2459	{
AzureIoTClient	88:248736be106e	2460	/* Codes_SRS_IOTHUBCLIENT_LL_07_023: [ If inboundDeviceMethodCallback is non-NULL then IoTHubClientCore_LL_SetDeviceMethodCallback_Ex shall call the underlying layer's IoTHubTransport_Subscribe_DeviceMethod function.]*/
AzureIoTClient	88:248736be106e	2461	if (handleData->IoTHubTransport_Subscribe_DeviceMethod(handleData->deviceHandle) == 0)
AzureIoTClient	88:248736be106e	2462	{
AzureIoTClient	88:248736be106e	2463	handleData->methodCallback.type = CALLBACK_TYPE_ASYNC;
AzureIoTClient	88:248736be106e	2464	handleData->methodCallback.callbackAsync = inboundDeviceMethodCallback;
AzureIoTClient	88:248736be106e	2465	handleData->methodCallback.callbackSync = NULL;
AzureIoTClient	88:248736be106e	2466	handleData->methodCallback.userContextCallback = userContextCallback;
AzureIoTClient	88:248736be106e	2467	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2468	}
AzureIoTClient	88:248736be106e	2469	else
AzureIoTClient	88:248736be106e	2470	{
AzureIoTClient	88:248736be106e	2471	/* Codes_SRS_IOTHUBCLIENT_LL_07_025: [ If any error is encountered then IoTHubClientCore_LL_SetDeviceMethodCallback_Ex shall return IOTHUB_CLIENT_ERROR.] */
AzureIoTClient	88:248736be106e	2472	LogError("IoTHubTransport_Subscribe_DeviceMethod failed");
AzureIoTClient	88:248736be106e	2473	handleData->methodCallback.type = CALLBACK_TYPE_NONE;
AzureIoTClient	88:248736be106e	2474	handleData->methodCallback.callbackAsync = NULL;
AzureIoTClient	88:248736be106e	2475	handleData->methodCallback.callbackSync = NULL;
AzureIoTClient	88:248736be106e	2476	handleData->methodCallback.userContextCallback = NULL;
AzureIoTClient	88:248736be106e	2477	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2478	}
AzureIoTClient	88:248736be106e	2479	}
AzureIoTClient	88:248736be106e	2480	}
AzureIoTClient	88:248736be106e	2481	}
AzureIoTClient	88:248736be106e	2482	return result;
AzureIoTClient	88:248736be106e	2483	}
AzureIoTClient	88:248736be106e	2484
AzureIoTClient	88:248736be106e	2485	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_DeviceMethodResponse(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, METHOD_HANDLE methodId, const unsigned char* response, size_t response_size, int status_response)
AzureIoTClient	88:248736be106e	2486	{
AzureIoTClient	88:248736be106e	2487	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2488	/* Codes_SRS_IOTHUBCLIENT_LL_07_026: [ If handle or methodId is NULL then IoTHubClientCore_LL_DeviceMethodResponse shall return IOTHUB_CLIENT_INVALID_ARG.] */
AzureIoTClient	88:248736be106e	2489	if (iotHubClientHandle == NULL \|\| methodId == NULL)
AzureIoTClient	88:248736be106e	2490	{
AzureIoTClient	88:248736be106e	2491	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2492	LOG_ERROR_RESULT;
AzureIoTClient	88:248736be106e	2493	}
AzureIoTClient	88:248736be106e	2494	else
AzureIoTClient	88:248736be106e	2495	{
AzureIoTClient	88:248736be106e	2496	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	88:248736be106e	2497	/* Codes_SRS_IOTHUBCLIENT_LL_07_027: [ IoTHubClientCore_LL_DeviceMethodResponse shall call the IoTHubTransport_DeviceMethod_Response transport function.] */
AzureIoTClient	88:248736be106e	2498	if (handleData->IoTHubTransport_DeviceMethod_Response(handleData->deviceHandle, methodId, response, response_size, status_response) != 0)
AzureIoTClient	88:248736be106e	2499	{
AzureIoTClient	88:248736be106e	2500	LogError("IoTHubTransport_DeviceMethod_Response failed");
AzureIoTClient	88:248736be106e	2501	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	88:248736be106e	2502	}
AzureIoTClient	88:248736be106e	2503	else
AzureIoTClient	88:248736be106e	2504	{
AzureIoTClient	88:248736be106e	2505	result = IOTHUB_CLIENT_OK;
AzureIoTClient	88:248736be106e	2506	}
AzureIoTClient	88:248736be106e	2507	}
AzureIoTClient	88:248736be106e	2508	return result;
AzureIoTClient	88:248736be106e	2509	}
AzureIoTClient	88:248736be106e	2510
AzureIoTClient	88:248736be106e	2511	#ifndef DONT_USE_UPLOADTOBLOB
AzureIoTClient	88:248736be106e	2512	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_UploadToBlob(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* destinationFileName, const unsigned char* source, size_t size)
AzureIoTClient	88:248736be106e	2513	{
AzureIoTClient	88:248736be106e	2514	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2515	/Codes_SRS_IOTHUBCLIENT_LL_02_061: [ If iotHubClientHandle is NULL then IoTHubClientCore_LL_UploadToBlob shall fail and return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	2516	/Codes_SRS_IOTHUBCLIENT_LL_02_062: [ If destinationFileName is NULL then IoTHubClientCore_LL_UploadToBlob shall fail and return IOTHUB_CLIENT_INVALID_ARG. ]/
AzureIoTClient	88:248736be106e	2517	/Codes_SRS_IOTHUBCLIENT_LL_02_063: [ If `source` is `NULL` and size is greater than 0 then `IoTHubClientCore_LL_UploadToBlob` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2518	if (
AzureIoTClient	88:248736be106e	2519	(iotHubClientHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	2520	(destinationFileName == NULL) \|\|
AzureIoTClient	88:248736be106e	2521	((source == NULL) && (size >0))
AzureIoTClient	88:248736be106e	2522	)
AzureIoTClient	88:248736be106e	2523	{
AzureIoTClient	88:248736be106e	2524	LogError("invalid parameters IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle=%p, const char* destinationFileName=%s, const unsigned char* source=%p, size_t size=%zu", iotHubClientHandle, destinationFileName, source, size);
AzureIoTClient	88:248736be106e	2525	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2526	}
AzureIoTClient	88:248736be106e	2527	else
AzureIoTClient	88:248736be106e	2528	{
AzureIoTClient	88:248736be106e	2529	result = IoTHubClient_LL_UploadToBlob_Impl(iotHubClientHandle->uploadToBlobHandle, destinationFileName, source, size);
AzureIoTClient	88:248736be106e	2530	}
AzureIoTClient	88:248736be106e	2531	return result;
AzureIoTClient	88:248736be106e	2532	}
AzureIoTClient	88:248736be106e	2533
AzureIoTClient	88:248736be106e	2534	typedef struct UPLOAD_MULTIPLE_BLOCKS_WRAPPER_CONTEXT_TAG
AzureIoTClient	88:248736be106e	2535	{
AzureIoTClient	88:248736be106e	2536	IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_CALLBACK getDataCallback;
AzureIoTClient	88:248736be106e	2537	void* context;
AzureIoTClient	88:248736be106e	2538	} UPLOAD_MULTIPLE_BLOCKS_WRAPPER_CONTEXT;
AzureIoTClient	88:248736be106e	2539
AzureIoTClient	88:248736be106e	2540
AzureIoTClient	88:248736be106e	2541	static IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_RESULT uploadMultipleBlocksCallbackWrapper(IOTHUB_CLIENT_FILE_UPLOAD_RESULT result, unsigned char const ** data, size_t* size, void* context)
AzureIoTClient	88:248736be106e	2542	{
AzureIoTClient	88:248736be106e	2543	UPLOAD_MULTIPLE_BLOCKS_WRAPPER_CONTEXT* wrapperContext = (UPLOAD_MULTIPLE_BLOCKS_WRAPPER_CONTEXT*)context;
AzureIoTClient	88:248736be106e	2544	wrapperContext->getDataCallback(result, data, size, wrapperContext->context);
AzureIoTClient	88:248736be106e	2545	return IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_OK;
AzureIoTClient	88:248736be106e	2546	}
AzureIoTClient	88:248736be106e	2547
AzureIoTClient	88:248736be106e	2548	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_UploadMultipleBlocksToBlob(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* destinationFileName, IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_CALLBACK getDataCallback, void* context)
AzureIoTClient	88:248736be106e	2549	{
AzureIoTClient	88:248736be106e	2550	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2551	/Codes_SRS_IOTHUBCLIENT_LL_99_005: [ If `iotHubClientHandle` is `NULL` then `IoTHubClientCore_LL_UploadMultipleBlocksToBlob(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2552	/Codes_SRS_IOTHUBCLIENT_LL_99_006: [ If `destinationFileName` is `NULL` then `IoTHubClientCore_LL_UploadMultipleBlocksToBlob(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2553	/Codes_SRS_IOTHUBCLIENT_LL_99_007: [ If `getDataCallback` is `NULL` then `IoTHubClientCore_LL_UploadMultipleBlocksToBlob(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2554	if (
AzureIoTClient	88:248736be106e	2555	(iotHubClientHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	2556	(destinationFileName == NULL) \|\|
AzureIoTClient	88:248736be106e	2557	(getDataCallback == NULL)
AzureIoTClient	88:248736be106e	2558	)
AzureIoTClient	88:248736be106e	2559	{
AzureIoTClient	88:248736be106e	2560	LogError("invalid parameters IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle=%p, const char* destinationFileName=%p, getDataCallback=%p", iotHubClientHandle, destinationFileName, getDataCallback);
AzureIoTClient	88:248736be106e	2561	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2562	}
AzureIoTClient	88:248736be106e	2563	else
AzureIoTClient	88:248736be106e	2564	{
AzureIoTClient	88:248736be106e	2565	UPLOAD_MULTIPLE_BLOCKS_WRAPPER_CONTEXT uploadMultipleBlocksWrapperContext;
AzureIoTClient	88:248736be106e	2566	uploadMultipleBlocksWrapperContext.getDataCallback = getDataCallback;
AzureIoTClient	88:248736be106e	2567	uploadMultipleBlocksWrapperContext.context = context;
AzureIoTClient	88:248736be106e	2568
AzureIoTClient	88:248736be106e	2569	result = IoTHubClient_LL_UploadMultipleBlocksToBlob_Impl(iotHubClientHandle->uploadToBlobHandle, destinationFileName, uploadMultipleBlocksCallbackWrapper, &uploadMultipleBlocksWrapperContext);
AzureIoTClient	88:248736be106e	2570	}
AzureIoTClient	88:248736be106e	2571	return result;
AzureIoTClient	88:248736be106e	2572	}
AzureIoTClient	88:248736be106e	2573
AzureIoTClient	88:248736be106e	2574	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_UploadMultipleBlocksToBlobEx(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* destinationFileName, IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_CALLBACK_EX getDataCallbackEx, void* context)
AzureIoTClient	88:248736be106e	2575	{
AzureIoTClient	88:248736be106e	2576	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	88:248736be106e	2577	/Codes_SRS_IOTHUBCLIENT_LL_99_005: [ If `iotHubClientHandle` is `NULL` then `IoTHubClientCore_LL_UploadMultipleBlocksToBlob(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2578	/Codes_SRS_IOTHUBCLIENT_LL_99_006: [ If `destinationFileName` is `NULL` then `IoTHubClientCore_LL_UploadMultipleBlocksToBlob(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2579	/Codes_SRS_IOTHUBCLIENT_LL_99_007: [ If `getDataCallback` is `NULL` then `IoTHubClientCore_LL_UploadMultipleBlocksToBlob(Ex)` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]/
AzureIoTClient	88:248736be106e	2580	if (
AzureIoTClient	88:248736be106e	2581	(iotHubClientHandle == NULL) \|\|
AzureIoTClient	88:248736be106e	2582	(destinationFileName == NULL) \|\|
AzureIoTClient	88:248736be106e	2583	(getDataCallbackEx == NULL)
AzureIoTClient	88:248736be106e	2584	)
AzureIoTClient	88:248736be106e	2585	{
AzureIoTClient	88:248736be106e	2586	LogError("invalid parameters IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle=%p, destinationFileName=%p, getDataCallbackEx=%p", iotHubClientHandle, destinationFileName, getDataCallbackEx);
AzureIoTClient	88:248736be106e	2587	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	88:248736be106e	2588	}
AzureIoTClient	88:248736be106e	2589	else
AzureIoTClient	88:248736be106e	2590	{
AzureIoTClient	88:248736be106e	2591	result = IoTHubClient_LL_UploadMultipleBlocksToBlob_Impl(iotHubClientHandle->uploadToBlobHandle, destinationFileName, getDataCallbackEx, context);
AzureIoTClient	88:248736be106e	2592	}
AzureIoTClient	88:248736be106e	2593	return result;
AzureIoTClient	88:248736be106e	2594	}
AzureIoTClient	88:248736be106e	2595
AzureIoTClient	89:a2ed767a532e	2596	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SendEventToOutputAsync(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, IOTHUB_MESSAGE_HANDLE eventMessageHandle, const char* outputName, IOTHUB_CLIENT_EVENT_CONFIRMATION_CALLBACK eventConfirmationCallback, void* userContextCallback)
AzureIoTClient	89:a2ed767a532e	2597	{
AzureIoTClient	89:a2ed767a532e	2598	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	89:a2ed767a532e	2599
AzureIoTClient	89:a2ed767a532e	2600	if ((iotHubClientHandle == NULL) \|\| (outputName == NULL) \|\| (eventMessageHandle == NULL) \|\| ((eventConfirmationCallback == NULL) && (userContextCallback != NULL)))
AzureIoTClient	89:a2ed767a532e	2601	{
AzureIoTClient	89:a2ed767a532e	2602	// Codes_SRS_IOTHUBCLIENT_LL_31_127: [ If `iotHubClientHandle`, `outputName`, or `eventConfirmationCallback` is `NULL`, `IoTHubClient_LL_SendEventToOutputAsync` shall return `IOTHUB_CLIENT_INVALID_ARG`. ]
AzureIoTClient	89:a2ed767a532e	2603	LogError("Invalid argument (iotHubClientHandle=%p, outputName=%p, eventMessageHandle=%p)", iotHubClientHandle, outputName, eventMessageHandle);
AzureIoTClient	89:a2ed767a532e	2604	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	89:a2ed767a532e	2605	}
AzureIoTClient	89:a2ed767a532e	2606	else
AzureIoTClient	89:a2ed767a532e	2607	{
AzureIoTClient	89:a2ed767a532e	2608	// Codes_SRS_IOTHUBCLIENT_LL_31_128: [ `IoTHubClient_LL_SendEventToOutputAsync` shall set the outputName of the message to send. ]
AzureIoTClient	89:a2ed767a532e	2609	if (IoTHubMessage_SetOutputName(eventMessageHandle, outputName) != IOTHUB_MESSAGE_OK)
AzureIoTClient	89:a2ed767a532e	2610	{
AzureIoTClient	89:a2ed767a532e	2611	LogError("IoTHubMessage_SetOutputName failed");
AzureIoTClient	89:a2ed767a532e	2612	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2613	}
AzureIoTClient	89:a2ed767a532e	2614	// Codes_SRS_IOTHUBCLIENT_LL_31_129: [ `IoTHubClient_LL_SendEventToOutputAsync` shall invoke `IoTHubClient_LL_SendEventAsync` to send the message. ]
AzureIoTClient	89:a2ed767a532e	2615	else if ((result = IoTHubClientCore_LL_SendEventAsync(iotHubClientHandle, eventMessageHandle, eventConfirmationCallback, userContextCallback)) != IOTHUB_CLIENT_OK)
AzureIoTClient	89:a2ed767a532e	2616	{
AzureIoTClient	89:a2ed767a532e	2617	LogError("Call into IoTHubClient_LL_SendEventAsync failed, result=%d", result);
AzureIoTClient	89:a2ed767a532e	2618	}
AzureIoTClient	89:a2ed767a532e	2619	}
AzureIoTClient	89:a2ed767a532e	2620
AzureIoTClient	89:a2ed767a532e	2621	return result;
AzureIoTClient	89:a2ed767a532e	2622	}
AzureIoTClient	89:a2ed767a532e	2623
AzureIoTClient	89:a2ed767a532e	2624
AzureIoTClient	89:a2ed767a532e	2625	static IOTHUB_CLIENT_RESULT create_event_handler_callback(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData, const char* inputName, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC callbackSync, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX callbackSyncEx, void* userContextCallback, void* userContextCallbackEx, size_t userContextCallbackExLength)
AzureIoTClient	89:a2ed767a532e	2626	{
AzureIoTClient	89:a2ed767a532e	2627	IOTHUB_CLIENT_RESULT result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2628	bool add_to_list = false;
AzureIoTClient	89:a2ed767a532e	2629
AzureIoTClient	89:a2ed767a532e	2630	if ((handleData->event_callbacks == NULL) && ((handleData->event_callbacks = singlylinkedlist_create()) == NULL))
AzureIoTClient	89:a2ed767a532e	2631	{
AzureIoTClient	89:a2ed767a532e	2632	LogError("Could not allocate linked list for callbacks");
AzureIoTClient	89:a2ed767a532e	2633	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2634	}
AzureIoTClient	89:a2ed767a532e	2635	else
AzureIoTClient	89:a2ed767a532e	2636	{
AzureIoTClient	89:a2ed767a532e	2637	IOTHUB_EVENT_CALLBACK* event_callback = NULL;
AzureIoTClient	89:a2ed767a532e	2638	LIST_ITEM_HANDLE item_handle = singlylinkedlist_find(handleData->event_callbacks, is_event_equal_for_match, (const void*)inputName);
AzureIoTClient	89:a2ed767a532e	2639	if (item_handle == NULL)
AzureIoTClient	89:a2ed767a532e	2640	{
AzureIoTClient	89:a2ed767a532e	2641	// Codes_SRS_IOTHUBCLIENT_LL_31_134: [ `IoTHubClient_LL_SetInputMessageCallback` shall allocate a callback handle to associate callbacks from the transport => client if `inputName` isn't already present in the callback list. ]
AzureIoTClient	89:a2ed767a532e	2642	event_callback = (IOTHUB_EVENT_CALLBACK*)malloc(sizeof(IOTHUB_EVENT_CALLBACK));
AzureIoTClient	89:a2ed767a532e	2643	if (event_callback == NULL)
AzureIoTClient	89:a2ed767a532e	2644	{
AzureIoTClient	89:a2ed767a532e	2645	LogError("Could not allocate IOTHUB_EVENT_CALLBACK");
AzureIoTClient	89:a2ed767a532e	2646	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2647	}
AzureIoTClient	89:a2ed767a532e	2648	else
AzureIoTClient	89:a2ed767a532e	2649	{
AzureIoTClient	89:a2ed767a532e	2650	memset(event_callback, 0, sizeof(*event_callback));
AzureIoTClient	89:a2ed767a532e	2651	add_to_list = true;
AzureIoTClient	89:a2ed767a532e	2652	}
AzureIoTClient	89:a2ed767a532e	2653	}
AzureIoTClient	89:a2ed767a532e	2654	else
AzureIoTClient	89:a2ed767a532e	2655	{
AzureIoTClient	89:a2ed767a532e	2656	// Codes_SRS_IOTHUBCLIENT_LL_31_135: [ `IoTHubClient_LL_SetInputMessageCallback` shall reuse the existing callback handle if `inputName` is already present in the callback list. ]
AzureIoTClient	89:a2ed767a532e	2657	event_callback = (IOTHUB_EVENT_CALLBACK*)singlylinkedlist_item_get_value(item_handle);
AzureIoTClient	89:a2ed767a532e	2658	if (event_callback == NULL)
AzureIoTClient	89:a2ed767a532e	2659	{
AzureIoTClient	89:a2ed767a532e	2660	LogError("singlylinkedlist_item_get_value failed looking up event callback");
AzureIoTClient	89:a2ed767a532e	2661	}
AzureIoTClient	89:a2ed767a532e	2662	}
AzureIoTClient	89:a2ed767a532e	2663
AzureIoTClient	89:a2ed767a532e	2664	if (event_callback != NULL)
AzureIoTClient	89:a2ed767a532e	2665	{
AzureIoTClient	89:a2ed767a532e	2666	if ((inputName != NULL) && (event_callback->inputName == NULL))
AzureIoTClient	89:a2ed767a532e	2667	{
AzureIoTClient	89:a2ed767a532e	2668	event_callback->inputName = STRING_construct(inputName);
AzureIoTClient	89:a2ed767a532e	2669	}
AzureIoTClient	89:a2ed767a532e	2670
AzureIoTClient	89:a2ed767a532e	2671	if ((inputName == NULL) \|\| (event_callback->inputName != NULL))
AzureIoTClient	89:a2ed767a532e	2672	{
AzureIoTClient	89:a2ed767a532e	2673	event_callback->callbackAsync = callbackSync;
AzureIoTClient	89:a2ed767a532e	2674	event_callback->callbackAsyncEx = callbackSyncEx;
AzureIoTClient	89:a2ed767a532e	2675
AzureIoTClient	89:a2ed767a532e	2676	free(event_callback->userContextCallbackEx);
AzureIoTClient	89:a2ed767a532e	2677	event_callback->userContextCallbackEx = NULL;
AzureIoTClient	89:a2ed767a532e	2678
AzureIoTClient	89:a2ed767a532e	2679	if (userContextCallbackEx == NULL)
AzureIoTClient	89:a2ed767a532e	2680	{
AzureIoTClient	89:a2ed767a532e	2681	event_callback->userContextCallback = userContextCallback;
AzureIoTClient	89:a2ed767a532e	2682	}
AzureIoTClient	89:a2ed767a532e	2683
AzureIoTClient	89:a2ed767a532e	2684	if ((userContextCallbackEx != NULL) &&
AzureIoTClient	89:a2ed767a532e	2685	(NULL == (event_callback->userContextCallbackEx = malloc(userContextCallbackExLength))))
AzureIoTClient	89:a2ed767a532e	2686	{
AzureIoTClient	89:a2ed767a532e	2687	LogError("Unable to allocate userContextCallback");
AzureIoTClient	89:a2ed767a532e	2688	delete_event(event_callback);
AzureIoTClient	89:a2ed767a532e	2689	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2690	}
AzureIoTClient	89:a2ed767a532e	2691	else if ((add_to_list == true) && (NULL == singlylinkedlist_add(handleData->event_callbacks, event_callback)))
AzureIoTClient	89:a2ed767a532e	2692	{
AzureIoTClient	89:a2ed767a532e	2693	LogError("Unable to add eventCallback to list");
AzureIoTClient	89:a2ed767a532e	2694	delete_event(event_callback);
AzureIoTClient	89:a2ed767a532e	2695	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2696	}
AzureIoTClient	89:a2ed767a532e	2697	else
AzureIoTClient	89:a2ed767a532e	2698	{
AzureIoTClient	89:a2ed767a532e	2699	if (userContextCallbackEx != NULL)
AzureIoTClient	89:a2ed767a532e	2700	{
AzureIoTClient	89:a2ed767a532e	2701	// Codes_SRS_IOTHUBCLIENT_LL_31_141: [`IoTHubClient_LL_SetInputMessageCallbackEx` shall copy the data passed in extended context. ]
AzureIoTClient	89:a2ed767a532e	2702	memcpy(event_callback->userContextCallbackEx, userContextCallbackEx, userContextCallbackExLength);
AzureIoTClient	89:a2ed767a532e	2703	}
AzureIoTClient	89:a2ed767a532e	2704	result = IOTHUB_CLIENT_OK;
AzureIoTClient	89:a2ed767a532e	2705	}
AzureIoTClient	89:a2ed767a532e	2706	}
AzureIoTClient	89:a2ed767a532e	2707	else
AzureIoTClient	89:a2ed767a532e	2708	{
AzureIoTClient	89:a2ed767a532e	2709	delete_event(event_callback);
AzureIoTClient	89:a2ed767a532e	2710	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2711	}
AzureIoTClient	89:a2ed767a532e	2712	}
AzureIoTClient	89:a2ed767a532e	2713	}
AzureIoTClient	89:a2ed767a532e	2714
AzureIoTClient	89:a2ed767a532e	2715	return result;
AzureIoTClient	89:a2ed767a532e	2716	}
AzureIoTClient	89:a2ed767a532e	2717
AzureIoTClient	89:a2ed767a532e	2718	static IOTHUB_CLIENT_RESULT remove_event_unsubscribe_if_needed(IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData, const char* inputName)
AzureIoTClient	89:a2ed767a532e	2719	{
AzureIoTClient	89:a2ed767a532e	2720	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	89:a2ed767a532e	2721
AzureIoTClient	89:a2ed767a532e	2722	LIST_ITEM_HANDLE item_handle = singlylinkedlist_find(handleData->event_callbacks, is_event_equal_for_match, (const void*)inputName);
AzureIoTClient	89:a2ed767a532e	2723	if (item_handle == NULL)
AzureIoTClient	89:a2ed767a532e	2724	{
AzureIoTClient	89:a2ed767a532e	2725	// Codes_SRS_IOTHUBCLIENT_LL_31_132: [ If `eventHandlerCallback` is NULL, `IoTHubClient_LL_SetInputMessageCallback` shall return `IOTHUB_CLIENT_ERROR` if the `inputName` is not present. ]
AzureIoTClient	89:a2ed767a532e	2726	LogError("Input name %s was not present", inputName);
AzureIoTClient	89:a2ed767a532e	2727	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2728	}
AzureIoTClient	89:a2ed767a532e	2729	else
AzureIoTClient	89:a2ed767a532e	2730	{
AzureIoTClient	89:a2ed767a532e	2731	IOTHUB_EVENT_CALLBACK* event_callback = (IOTHUB_EVENT_CALLBACK*)singlylinkedlist_item_get_value(item_handle);
AzureIoTClient	89:a2ed767a532e	2732	if (event_callback == NULL)
AzureIoTClient	89:a2ed767a532e	2733	{
AzureIoTClient	89:a2ed767a532e	2734	LogError("singlylinkedlist_item_get_value failed");
AzureIoTClient	89:a2ed767a532e	2735	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2736	}
AzureIoTClient	89:a2ed767a532e	2737	else
AzureIoTClient	89:a2ed767a532e	2738	{
AzureIoTClient	89:a2ed767a532e	2739	delete_event(event_callback);
AzureIoTClient	89:a2ed767a532e	2740	// Codes_SRS_IOTHUBCLIENT_LL_31_131: [ If `eventHandlerCallback` is NULL, `IoTHubClient_LL_SetInputMessageCallback` shall remove the `inputName` from its callback list if present. ]
AzureIoTClient	89:a2ed767a532e	2741	if (singlylinkedlist_remove(handleData->event_callbacks, item_handle) != 0)
AzureIoTClient	89:a2ed767a532e	2742	{
AzureIoTClient	89:a2ed767a532e	2743	LogError("singlylinkedlist_remove failed");
AzureIoTClient	89:a2ed767a532e	2744	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2745	}
AzureIoTClient	89:a2ed767a532e	2746	else
AzureIoTClient	89:a2ed767a532e	2747	{
AzureIoTClient	89:a2ed767a532e	2748	if (singlylinkedlist_get_head_item(handleData->event_callbacks) == NULL)
AzureIoTClient	89:a2ed767a532e	2749	{
AzureIoTClient	89:a2ed767a532e	2750	// Codes_SRS_IOTHUBCLIENT_LL_31_133: [ If `eventHandlerCallback` is NULL, `IoTHubClient_LL_SetInputMessageCallback` shall invoke `IoTHubTransport_Unsubscribe_InputQueue` if this was the last input callback. ]
AzureIoTClient	89:a2ed767a532e	2751	handleData->IoTHubTransport_Unsubscribe_InputQueue(handleData);
AzureIoTClient	89:a2ed767a532e	2752	}
AzureIoTClient	89:a2ed767a532e	2753	result = IOTHUB_CLIENT_OK;
AzureIoTClient	89:a2ed767a532e	2754	}
AzureIoTClient	89:a2ed767a532e	2755	}
AzureIoTClient	89:a2ed767a532e	2756	}
AzureIoTClient	89:a2ed767a532e	2757
AzureIoTClient	89:a2ed767a532e	2758	return result;
AzureIoTClient	89:a2ed767a532e	2759	}
AzureIoTClient	89:a2ed767a532e	2760
AzureIoTClient	89:a2ed767a532e	2761
AzureIoTClient	89:a2ed767a532e	2762	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetInputMessageCallbackImpl(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* inputName, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC eventHandlerCallback, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX eventHandlerCallbackEx, void userContextCallback, void userContextCallbackEx, size_t userContextCallbackExLength)
AzureIoTClient	89:a2ed767a532e	2763	{
AzureIoTClient	89:a2ed767a532e	2764	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	89:a2ed767a532e	2765
AzureIoTClient	89:a2ed767a532e	2766	if (iotHubClientHandle == NULL)
AzureIoTClient	89:a2ed767a532e	2767	{
AzureIoTClient	89:a2ed767a532e	2768	// Codes_SRS_IOTHUBCLIENT_LL_31_130: [ If `iotHubClientHandle` or `inputName` is NULL, `IoTHubClient_LL_SetInputMessageCallback` shall return IOTHUB_CLIENT_INVALID_ARG. ]
AzureIoTClient	89:a2ed767a532e	2769	LogError("Invalid argument - iotHubClientHandle=%p, inputName=%p", iotHubClientHandle, inputName);
AzureIoTClient	89:a2ed767a532e	2770	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	89:a2ed767a532e	2771	}
AzureIoTClient	89:a2ed767a532e	2772	else
AzureIoTClient	89:a2ed767a532e	2773	{
AzureIoTClient	89:a2ed767a532e	2774	IOTHUB_CLIENT_CORE_LL_HANDLE_DATA* handleData = (IOTHUB_CLIENT_CORE_LL_HANDLE_DATA*)iotHubClientHandle;
AzureIoTClient	89:a2ed767a532e	2775	if ((eventHandlerCallback == NULL) && (eventHandlerCallbackEx == NULL))
AzureIoTClient	89:a2ed767a532e	2776	{
AzureIoTClient	89:a2ed767a532e	2777	result = (IOTHUB_CLIENT_RESULT)remove_event_unsubscribe_if_needed(handleData, inputName);
AzureIoTClient	89:a2ed767a532e	2778	}
AzureIoTClient	89:a2ed767a532e	2779	else
AzureIoTClient	89:a2ed767a532e	2780	{
AzureIoTClient	89:a2ed767a532e	2781	bool registered_with_transport_handler = (handleData->event_callbacks != NULL) && (singlylinkedlist_get_head_item(handleData->event_callbacks) != NULL);
AzureIoTClient	89:a2ed767a532e	2782	if ((result = (IOTHUB_CLIENT_RESULT)create_event_handler_callback(handleData, inputName, eventHandlerCallback, eventHandlerCallbackEx, userContextCallback, userContextCallbackEx, userContextCallbackExLength)) != IOTHUB_CLIENT_OK)
AzureIoTClient	89:a2ed767a532e	2783	{
AzureIoTClient	89:a2ed767a532e	2784	LogError("create_event_handler_callback call failed, error = %d", result);
AzureIoTClient	89:a2ed767a532e	2785	}
AzureIoTClient	89:a2ed767a532e	2786	// Codes_SRS_IOTHUBCLIENT_LL_31_136: [ `IoTHubClient_LL_SetInputMessageCallback` shall invoke `IoTHubTransport_Subscribe_InputQueue` if this is the first callback being registered. ]
AzureIoTClient	89:a2ed767a532e	2787	else if (!registered_with_transport_handler && (handleData->IoTHubTransport_Subscribe_InputQueue(handleData->deviceHandle) != 0))
AzureIoTClient	89:a2ed767a532e	2788	{
AzureIoTClient	89:a2ed767a532e	2789	LogError("IoTHubTransport_Subscribe_InputQueue failed");
AzureIoTClient	89:a2ed767a532e	2790	delete_event_callback_list(handleData);
AzureIoTClient	89:a2ed767a532e	2791	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	89:a2ed767a532e	2792	}
AzureIoTClient	89:a2ed767a532e	2793	else
AzureIoTClient	89:a2ed767a532e	2794	{
AzureIoTClient	89:a2ed767a532e	2795	result = IOTHUB_CLIENT_OK;
AzureIoTClient	89:a2ed767a532e	2796	}
AzureIoTClient	89:a2ed767a532e	2797	}
AzureIoTClient	89:a2ed767a532e	2798	}
AzureIoTClient	89:a2ed767a532e	2799	return result;
AzureIoTClient	89:a2ed767a532e	2800
AzureIoTClient	89:a2ed767a532e	2801	}
AzureIoTClient	89:a2ed767a532e	2802
AzureIoTClient	89:a2ed767a532e	2803	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetInputMessageCallbackEx(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* inputName, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX eventHandlerCallbackEx, void *userContextCallbackEx, size_t userContextCallbackExLength)
AzureIoTClient	89:a2ed767a532e	2804	{
AzureIoTClient	89:a2ed767a532e	2805	return IoTHubClientCore_LL_SetInputMessageCallbackImpl(iotHubClientHandle, inputName, NULL, eventHandlerCallbackEx, NULL, userContextCallbackEx, userContextCallbackExLength);
AzureIoTClient	89:a2ed767a532e	2806	}
AzureIoTClient	89:a2ed767a532e	2807
AzureIoTClient	89:a2ed767a532e	2808	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_SetInputMessageCallback(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* inputName, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC eventHandlerCallback, void* userContextCallback)
AzureIoTClient	89:a2ed767a532e	2809	{
AzureIoTClient	89:a2ed767a532e	2810	return IoTHubClientCore_LL_SetInputMessageCallbackImpl(iotHubClientHandle, inputName, eventHandlerCallback, NULL, userContextCallback, NULL, 0);
AzureIoTClient	89:a2ed767a532e	2811	}
AzureIoTClient	89:a2ed767a532e	2812
AzureIoTClient	91:bbf806070c5f	2813	#ifdef USE_EDGE_MODULES
AzureIoTClient	91:bbf806070c5f	2814	/* These should be replaced during iothub_client refactor */
AzureIoTClient	91:bbf806070c5f	2815	IOTHUB_CLIENT_RESULT IoTHubClientCore_LL_GenericMethodInvoke(IOTHUB_CLIENT_CORE_LL_HANDLE iotHubClientHandle, const char* deviceId, const char* moduleId, const char* methodName, const char* methodPayload, unsigned int timeout, int* responseStatus, unsigned char** responsePayload, size_t* responsePayloadSize)
AzureIoTClient	91:bbf806070c5f	2816	{
AzureIoTClient	91:bbf806070c5f	2817	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	91:bbf806070c5f	2818	if (iotHubClientHandle != NULL)
AzureIoTClient	91:bbf806070c5f	2819	{
AzureIoTClient	91:bbf806070c5f	2820	if (moduleId != NULL)
AzureIoTClient	91:bbf806070c5f	2821	{
AzureIoTClient	91:bbf806070c5f	2822	result = IoTHubClient_Edge_ModuleMethodInvoke(iotHubClientHandle->methodHandle, deviceId, moduleId, methodName, methodPayload, timeout, responseStatus, responsePayload, responsePayloadSize);
AzureIoTClient	91:bbf806070c5f	2823	}
AzureIoTClient	91:bbf806070c5f	2824	else
AzureIoTClient	91:bbf806070c5f	2825	{
AzureIoTClient	91:bbf806070c5f	2826	result = IoTHubClient_Edge_DeviceMethodInvoke(iotHubClientHandle->methodHandle, deviceId, methodName, methodPayload, timeout, responseStatus, responsePayload, responsePayloadSize);
AzureIoTClient	88:248736be106e	2827
AzureIoTClient	91:bbf806070c5f	2828	}
AzureIoTClient	91:bbf806070c5f	2829	}
AzureIoTClient	91:bbf806070c5f	2830	else
AzureIoTClient	91:bbf806070c5f	2831	{
AzureIoTClient	91:bbf806070c5f	2832	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	91:bbf806070c5f	2833	}
AzureIoTClient	91:bbf806070c5f	2834	return result;
AzureIoTClient	91:bbf806070c5f	2835	}
AzureIoTClient	91:bbf806070c5f	2836	#endif
AzureIoTClient	91:bbf806070c5f	2837
AzureIoTClient	91:bbf806070c5f	2838	/end/
AzureIoTClient	88:248736be106e	2839
AzureIoTClient	88:248736be106e	2840	#endif /* DONT_USE_UPLOADTOBLOB */

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_ll.c@91:bbf806070c5f, 2018-07-12 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Developers

Important Information for this Arm website

Access Warning