Xin Zhang / azure-iot-c-sdk-f767zi

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependents:   samplemqtt

iothub_client/inc/internal/iothub_client_private.h@0:f7f1f0d76dd6, 2018-08-23 (annotated)

Committer:
XinZhangMS
Date:
Thu Aug 23 06:52:14 2018 +0000
Revision:
0:f7f1f0d76dd6
azure-c-sdk for mbed os supporting NUCLEO_F767ZI

Who changed what in which revision?

UserRevisionLine numberNew contents of line
XinZhangMS 0:f7f1f0d76dd6 1 // Copyright (c) Microsoft. All rights reserved.
XinZhangMS 0:f7f1f0d76dd6 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
XinZhangMS 0:f7f1f0d76dd6 3
XinZhangMS 0:f7f1f0d76dd6 4 #ifndef IOTHUB_CLIENT_PRIVATE_H
XinZhangMS 0:f7f1f0d76dd6 5 #define IOTHUB_CLIENT_PRIVATE_H
XinZhangMS 0:f7f1f0d76dd6 6
XinZhangMS 0:f7f1f0d76dd6 7 #include <stdbool.h>
XinZhangMS 0:f7f1f0d76dd6 8 #include <signal.h>
XinZhangMS 0:f7f1f0d76dd6 9
XinZhangMS 0:f7f1f0d76dd6 10 #include "azure_c_shared_utility/constbuffer.h"
XinZhangMS 0:f7f1f0d76dd6 11 #include "azure_c_shared_utility/crt_abstractions.h"
XinZhangMS 0:f7f1f0d76dd6 12 #include "azure_c_shared_utility/doublylinkedlist.h"
XinZhangMS 0:f7f1f0d76dd6 13 #include "azure_c_shared_utility/macro_utils.h"
XinZhangMS 0:f7f1f0d76dd6 14 #include "azure_c_shared_utility/tickcounter.h"
XinZhangMS 0:f7f1f0d76dd6 15 #include "azure_c_shared_utility/umock_c_prod.h"
XinZhangMS 0:f7f1f0d76dd6 16
XinZhangMS 0:f7f1f0d76dd6 17 #include "iothub_message.h"
XinZhangMS 0:f7f1f0d76dd6 18 #include "iothub_client_core_ll.h"
XinZhangMS 0:f7f1f0d76dd6 19 #include "internal/iothub_transport_ll_private.h"
XinZhangMS 0:f7f1f0d76dd6 20 #include "internal/iothubtransport.h"
XinZhangMS 0:f7f1f0d76dd6 21
XinZhangMS 0:f7f1f0d76dd6 22 #ifdef USE_EDGE_MODULES
XinZhangMS 0:f7f1f0d76dd6 23 #include "internal/iothub_client_edge.h"
XinZhangMS 0:f7f1f0d76dd6 24 #endif
XinZhangMS 0:f7f1f0d76dd6 25
XinZhangMS 0:f7f1f0d76dd6 26 #ifdef __cplusplus
XinZhangMS 0:f7f1f0d76dd6 27 extern "C"
XinZhangMS 0:f7f1f0d76dd6 28 {
XinZhangMS 0:f7f1f0d76dd6 29 #endif
XinZhangMS 0:f7f1f0d76dd6 30
XinZhangMS 0:f7f1f0d76dd6 31 #define EVENT_ENDPOINT "/messages/events"
XinZhangMS 0:f7f1f0d76dd6 32 #define MESSAGE_ENDPOINT "/messages/devicebound"
XinZhangMS 0:f7f1f0d76dd6 33 #define MESSAGE_ENDPOINT_HTTP "/messages/devicebound"
XinZhangMS 0:f7f1f0d76dd6 34 #define MESSAGE_ENDPOINT_HTTP_ETAG "/messages/devicebound/"
XinZhangMS 0:f7f1f0d76dd6 35 #define CLIENT_DEVICE_TYPE_PREFIX "iothubclient"
XinZhangMS 0:f7f1f0d76dd6 36 #define CLIENT_DEVICE_BACKSLASH "/"
XinZhangMS 0:f7f1f0d76dd6 37 #define CBS_REPLY_TO "cbs"
XinZhangMS 0:f7f1f0d76dd6 38 #define CBS_ENDPOINT "/$" CBS_REPLY_TO
XinZhangMS 0:f7f1f0d76dd6 39 #define API_VERSION "?api-version=2016-11-14"
XinZhangMS 0:f7f1f0d76dd6 40 #define REJECT_QUERY_PARAMETER "&reject"
XinZhangMS 0:f7f1f0d76dd6 41
XinZhangMS 0:f7f1f0d76dd6 42 typedef bool(*IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX)(MESSAGE_CALLBACK_INFO* messageData, void* userContextCallback);
XinZhangMS 0:f7f1f0d76dd6 43
XinZhangMS 0:f7f1f0d76dd6 44 MOCKABLE_FUNCTION(, void, IoTHubClientCore_LL_SendComplete, IOTHUB_CLIENT_CORE_LL_HANDLE, handle, PDLIST_ENTRY, completed, IOTHUB_CLIENT_CONFIRMATION_RESULT, result);
XinZhangMS 0:f7f1f0d76dd6 45 MOCKABLE_FUNCTION(, void, IoTHubClientCore_LL_ReportedStateComplete, IOTHUB_CLIENT_CORE_LL_HANDLE, handle, uint32_t, item_id, int, status_code);
XinZhangMS 0:f7f1f0d76dd6 46 MOCKABLE_FUNCTION(, bool, IoTHubClientCore_LL_MessageCallback, IOTHUB_CLIENT_CORE_LL_HANDLE, handle, MESSAGE_CALLBACK_INFO*, message_data);
XinZhangMS 0:f7f1f0d76dd6 47 MOCKABLE_FUNCTION(, void, IoTHubClientCore_LL_RetrievePropertyComplete, IOTHUB_CLIENT_CORE_LL_HANDLE, handle, DEVICE_TWIN_UPDATE_STATE, update_state, const unsigned char*, payLoad, size_t, size);
XinZhangMS 0:f7f1f0d76dd6 48 MOCKABLE_FUNCTION(, 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);
XinZhangMS 0:f7f1f0d76dd6 49 MOCKABLE_FUNCTION(, void, IoTHubClientCore_LL_ConnectionStatusCallBack, IOTHUB_CLIENT_CORE_LL_HANDLE, handle, IOTHUB_CLIENT_CONNECTION_STATUS, status, IOTHUB_CLIENT_CONNECTION_STATUS_REASON, reason);
XinZhangMS 0:f7f1f0d76dd6 50 MOCKABLE_FUNCTION(, IOTHUB_CLIENT_RESULT, IoTHubClientCore_LL_SetMessageCallback_Ex, IOTHUB_CLIENT_CORE_LL_HANDLE, iotHubClientHandle, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX, messageCallback, void*, userContextCallback);
XinZhangMS 0:f7f1f0d76dd6 51 MOCKABLE_FUNCTION(, IOTHUB_CLIENT_RESULT, IoTHubClientCore_LL_SendMessageDisposition, IOTHUB_CLIENT_CORE_LL_HANDLE, iotHubClientHandle, MESSAGE_CALLBACK_INFO*, messageData, IOTHUBMESSAGE_DISPOSITION_RESULT, disposition);
XinZhangMS 0:f7f1f0d76dd6 52 MOCKABLE_FUNCTION(, IOTHUB_CLIENT_RESULT, IoTHubClientCore_LL_GetOption, IOTHUB_CLIENT_CORE_LL_HANDLE, iotHubClientHandle, const char*, optionName, void**, value);
XinZhangMS 0:f7f1f0d76dd6 53 MOCKABLE_FUNCTION(, bool, IoTHubClientCore_LL_MessageCallbackFromInput, IOTHUB_CLIENT_CORE_LL_HANDLE, handle, MESSAGE_CALLBACK_INFO*, message_data);
XinZhangMS 0:f7f1f0d76dd6 54 MOCKABLE_FUNCTION(, IOTHUB_CLIENT_RESULT, IoTHubClientCore_LL_SetInputMessageCallbackEx, IOTHUB_CLIENT_CORE_LL_HANDLE, iotHubClientHandle, const char*, inputName, IOTHUB_CLIENT_MESSAGE_CALLBACK_ASYNC_EX, eventHandlerCallbackEx, void *, userContextCallback, size_t, userContextCallbackLength);
XinZhangMS 0:f7f1f0d76dd6 55
XinZhangMS 0:f7f1f0d76dd6 56 #ifdef USE_EDGE_MODULES
XinZhangMS 0:f7f1f0d76dd6 57 /* (Should be replaced after iothub_client refactor)*/
XinZhangMS 0:f7f1f0d76dd6 58 MOCKABLE_FUNCTION(, IOTHUB_CLIENT_EDGE_HANDLE, IoTHubClientCore_LL_GetEdgeHandle, IOTHUB_CLIENT_CORE_LL_HANDLE, iotHubClientHandle);
XinZhangMS 0:f7f1f0d76dd6 59 MOCKABLE_FUNCTION(, 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);
XinZhangMS 0:f7f1f0d76dd6 60 #endif
XinZhangMS 0:f7f1f0d76dd6 61
XinZhangMS 0:f7f1f0d76dd6 62 typedef struct IOTHUB_MESSAGE_LIST_TAG
XinZhangMS 0:f7f1f0d76dd6 63 {
XinZhangMS 0:f7f1f0d76dd6 64 IOTHUB_MESSAGE_HANDLE messageHandle;
XinZhangMS 0:f7f1f0d76dd6 65 IOTHUB_CLIENT_EVENT_CONFIRMATION_CALLBACK callback;
XinZhangMS 0:f7f1f0d76dd6 66 void* context;
XinZhangMS 0:f7f1f0d76dd6 67 DLIST_ENTRY entry;
XinZhangMS 0:f7f1f0d76dd6 68 tickcounter_ms_t ms_timesOutAfter; /* a value of "0" means "no timeout", if the IOTHUBCLIENT_LL's handle tickcounter > msTimesOutAfer then the message shall timeout*/
XinZhangMS 0:f7f1f0d76dd6 69 }IOTHUB_MESSAGE_LIST;
XinZhangMS 0:f7f1f0d76dd6 70
XinZhangMS 0:f7f1f0d76dd6 71 typedef struct IOTHUB_DEVICE_TWIN_TAG
XinZhangMS 0:f7f1f0d76dd6 72 {
XinZhangMS 0:f7f1f0d76dd6 73 uint32_t item_id;
XinZhangMS 0:f7f1f0d76dd6 74 tickcounter_ms_t ms_timesOutAfter; /* a value of "0" means "no timeout", if the IOTHUBCLIENT_LL's handle tickcounter > msTimesOutAfer then the message shall timeout*/
XinZhangMS 0:f7f1f0d76dd6 75 IOTHUB_CLIENT_REPORTED_STATE_CALLBACK reported_state_callback;
XinZhangMS 0:f7f1f0d76dd6 76 CONSTBUFFER_HANDLE report_data_handle;
XinZhangMS 0:f7f1f0d76dd6 77 void* context;
XinZhangMS 0:f7f1f0d76dd6 78 DLIST_ENTRY entry;
XinZhangMS 0:f7f1f0d76dd6 79 IOTHUB_CLIENT_CORE_LL_HANDLE client_handle;
XinZhangMS 0:f7f1f0d76dd6 80 IOTHUB_DEVICE_HANDLE device_handle;
XinZhangMS 0:f7f1f0d76dd6 81 } IOTHUB_DEVICE_TWIN;
XinZhangMS 0:f7f1f0d76dd6 82
XinZhangMS 0:f7f1f0d76dd6 83 union IOTHUB_IDENTITY_INFO_TAG
XinZhangMS 0:f7f1f0d76dd6 84 {
XinZhangMS 0:f7f1f0d76dd6 85 IOTHUB_DEVICE_TWIN* device_twin;
XinZhangMS 0:f7f1f0d76dd6 86 IOTHUB_MESSAGE_LIST* iothub_message;
XinZhangMS 0:f7f1f0d76dd6 87 };
XinZhangMS 0:f7f1f0d76dd6 88
XinZhangMS 0:f7f1f0d76dd6 89 #ifdef __cplusplus
XinZhangMS 0:f7f1f0d76dd6 90 }
XinZhangMS 0:f7f1f0d76dd6 91 #endif
XinZhangMS 0:f7f1f0d76dd6 92
XinZhangMS 0:f7f1f0d76dd6 93 #endif /* IOTHUB_CLIENT_PRIVATE_H */