summaryrefslogtreecommitdiff
path: root/FreeRTOS-Labs/Source/FreeRTOS-IoT-Libraries/c_sdk/aws/shadow/src/private/aws_iot_shadow_internal.h
diff options
context:
space:
mode:
Diffstat (limited to 'FreeRTOS-Labs/Source/FreeRTOS-IoT-Libraries/c_sdk/aws/shadow/src/private/aws_iot_shadow_internal.h')
-rw-r--r--FreeRTOS-Labs/Source/FreeRTOS-IoT-Libraries/c_sdk/aws/shadow/src/private/aws_iot_shadow_internal.h565
1 files changed, 565 insertions, 0 deletions
diff --git a/FreeRTOS-Labs/Source/FreeRTOS-IoT-Libraries/c_sdk/aws/shadow/src/private/aws_iot_shadow_internal.h b/FreeRTOS-Labs/Source/FreeRTOS-IoT-Libraries/c_sdk/aws/shadow/src/private/aws_iot_shadow_internal.h
new file mode 100644
index 000000000..f3795f371
--- /dev/null
+++ b/FreeRTOS-Labs/Source/FreeRTOS-IoT-Libraries/c_sdk/aws/shadow/src/private/aws_iot_shadow_internal.h
@@ -0,0 +1,565 @@
+/*
+ * AWS IoT Shadow V2.1.0
+ * Copyright (C) 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to
+ * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
+ * the Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
+ * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+ * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+
+/**
+ * @file aws_iot_shadow_internal.h
+ * @brief Internal header of Shadow library. This header should not be included in
+ * typical application code.
+ */
+
+#ifndef AWS_IOT_SHADOW_INTERNAL_H_
+#define AWS_IOT_SHADOW_INTERNAL_H_
+
+/* The config header is always included first. */
+#include "iot_config.h"
+
+/* Linear containers (lists and queues) include. */
+#include "iot_linear_containers.h"
+
+/* Platform layer types include. */
+#include "types/iot_platform_types.h"
+
+/* Shadow include. */
+#include "aws_iot_shadow.h"
+
+/* AWS IoT include. */
+#include "aws_iot.h"
+
+/**
+ * @def AwsIotShadow_Assert( expression )
+ * @brief Assertion macro for the Shadow library.
+ *
+ * Set @ref AWS_IOT_SHADOW_ENABLE_ASSERTS to `1` to enable assertions in the Shadow
+ * library.
+ *
+ * @param[in] expression Expression to be evaluated.
+ */
+#if AWS_IOT_SHADOW_ENABLE_ASSERTS == 1
+ #ifndef AwsIotShadow_Assert
+ #ifdef Iot_DefaultAssert
+ #define AwsIotShadow_Assert( expression ) Iot_DefaultAssert( expression )
+ #else
+ #error "Asserts are enabled for Shadow, but AwsIotShadow_Assert is not defined"
+ #endif
+ #endif
+#else /* if AWS_IOT_SHADOW_ENABLE_ASSERTS == 1 */
+ #define AwsIotShadow_Assert( expression )
+#endif /* if AWS_IOT_SHADOW_ENABLE_ASSERTS == 1 */
+
+/* Configure logs for Shadow functions. */
+#ifdef AWS_IOT_LOG_LEVEL_SHADOW
+ #define LIBRARY_LOG_LEVEL AWS_IOT_LOG_LEVEL_SHADOW
+#else
+ #ifdef IOT_LOG_LEVEL_GLOBAL
+ #define LIBRARY_LOG_LEVEL IOT_LOG_LEVEL_GLOBAL
+ #else
+ #define LIBRARY_LOG_LEVEL IOT_LOG_NONE
+ #endif
+#endif
+
+#define LIBRARY_LOG_NAME ( "Shadow" )
+#include "iot_logging_setup.h"
+
+/*
+ * Provide default values for undefined memory allocation functions based on
+ * the usage of dynamic memory allocation.
+ */
+#if IOT_STATIC_MEMORY_ONLY == 1
+ #include "iot_static_memory.h"
+
+/**
+ * @brief Allocate a #_shadowOperation_t. This function should have the same
+ * signature as [malloc]
+ * (http://pubs.opengroup.org/onlinepubs/9699919799/functions/malloc.html).
+ */
+ void * AwsIotShadow_MallocOperation( size_t size );
+
+/**
+ * @brief Free a #_shadowOperation_t. This function should have the same
+ * signature as [free]
+ * (http://pubs.opengroup.org/onlinepubs/9699919799/functions/free.html).
+ */
+ void AwsIotShadow_FreeOperation( void * ptr );
+
+/**
+ * @brief Allocate a buffer for a short string, used for topic names or client
+ * tokens. This function should have the same signature as [malloc]
+ * (http://pubs.opengroup.org/onlinepubs/9699919799/functions/malloc.html).
+ */
+ #define AwsIotShadow_MallocString Iot_MallocMessageBuffer
+
+/**
+ * @brief Free a string. This function should have the same signature as
+ * [free]
+ * (http://pubs.opengroup.org/onlinepubs/9699919799/functions/free.html).
+ */
+ #define AwsIotShadow_FreeString Iot_FreeMessageBuffer
+
+/**
+ * @brief Allocate a #_shadowSubscription_t. This function should have the
+ * same signature as [malloc]
+ * (http://pubs.opengroup.org/onlinepubs/9699919799/functions/malloc.html).
+ */
+ void * AwsIotShadow_MallocSubscription( size_t size );
+
+/**
+ * @brief Free a #_shadowSubscription_t. This function should have the same
+ * signature as [free]
+ * (http://pubs.opengroup.org/onlinepubs/9699919799/functions/free.html).
+ */
+ void AwsIotShadow_FreeSubscription( void * ptr );
+#else /* if IOT_STATIC_MEMORY_ONLY == 1 */
+ #ifndef AwsIotShadow_MallocOperation
+ #ifdef Iot_DefaultMalloc
+ #define AwsIotShadow_MallocOperation Iot_DefaultMalloc
+ #else
+ #error "No malloc function defined for AwsIotShadow_MallocOperation"
+ #endif
+ #endif
+
+ #ifndef AwsIotShadow_FreeOperation
+ #ifdef Iot_DefaultFree
+ #define AwsIotShadow_FreeOperation Iot_DefaultFree
+ #else
+ #error "No free function defined for AwsIotShadow_FreeOperation"
+ #endif
+ #endif
+
+ #ifndef AwsIotShadow_MallocString
+ #ifdef Iot_DefaultMalloc
+ #define AwsIotShadow_MallocString Iot_DefaultMalloc
+ #else
+ #error "No malloc function defined for AwsIotShadow_MallocString"
+ #endif
+ #endif
+
+ #ifndef AwsIotShadow_FreeString
+ #ifdef Iot_DefaultFree
+ #define AwsIotShadow_FreeString Iot_DefaultFree
+ #else
+ #error "No free function defined for AwsIotShadow_FreeString"
+ #endif
+ #endif
+
+ #ifndef AwsIotShadow_MallocSubscription
+ #ifdef Iot_DefaultMalloc
+ #define AwsIotShadow_MallocSubscription Iot_DefaultMalloc
+ #else
+ #error "No malloc function defined for AwsIotShadow_MallocSubscription"
+ #endif
+ #endif
+
+ #ifndef AwsIotShadow_FreeSubscription
+ #ifdef Iot_DefaultFree
+ #define AwsIotShadow_FreeSubscription Iot_DefaultFree
+ #else
+ #error "No free function defined for AwsIotShadow_FreeSubscription"
+ #endif
+ #endif
+#endif /* if IOT_STATIC_MEMORY_ONLY == 1 */
+
+/**
+ * @cond DOXYGEN_IGNORE
+ * Doxygen should ignore this section.
+ *
+ * Provide default values for undefined configuration constants.
+ */
+#ifndef AWS_IOT_SHADOW_DEFAULT_MQTT_TIMEOUT_MS
+ #define AWS_IOT_SHADOW_DEFAULT_MQTT_TIMEOUT_MS ( 5000 )
+#endif
+/** @endcond */
+
+/**
+ * @brief The number of currently available Shadow operations.
+ *
+ * The 3 Shadow operations are DELETE, GET, and UPDATE.
+ */
+#define SHADOW_OPERATION_COUNT ( 3 )
+
+/**
+ * @brief The number of currently available Shadow callbacks.
+ *
+ * The 2 Shadow callbacks are `update/delta` (AKA "Delta") and `/update/documents`
+ * (AKA "Updated").
+ */
+#define SHADOW_CALLBACK_COUNT ( 2 )
+
+/**
+ * @brief The string representing a Shadow DELETE operation in a Shadow MQTT topic.
+ */
+#define SHADOW_DELETE_OPERATION_STRING "/shadow/delete"
+
+/**
+ * @brief The length of #SHADOW_DELETE_OPERATION_STRING.
+ */
+#define SHADOW_DELETE_OPERATION_STRING_LENGTH ( ( uint16_t ) ( sizeof( SHADOW_DELETE_OPERATION_STRING ) - 1 ) )
+
+/**
+ * @brief The string representing a Shadow GET operation in a Shadow MQTT topic.
+ */
+#define SHADOW_GET_OPERATION_STRING "/shadow/get"
+
+/**
+ * @brief The length of #SHADOW_GET_OPERATION_STRING.
+ */
+#define SHADOW_GET_OPERATION_STRING_LENGTH ( ( uint16_t ) ( sizeof( SHADOW_GET_OPERATION_STRING ) - 1 ) )
+
+/**
+ * @brief The string representing a Shadow UPDATE operation in a Shadow MQTT topic.
+ */
+#define SHADOW_UPDATE_OPERATION_STRING "/shadow/update"
+
+/**
+ * @brief The length of #SHADOW_UPDATE_OPERATION_STRING.
+ */
+#define SHADOW_UPDATE_OPERATION_STRING_LENGTH ( ( uint16_t ) ( sizeof( SHADOW_UPDATE_OPERATION_STRING ) - 1 ) )
+
+/**
+ * @brief The suffix for a Shadow delta topic.
+ */
+#define SHADOW_DELTA_SUFFIX "/delta"
+
+/**
+ * @brief The length of #SHADOW_DELTA_SUFFIX.
+ */
+#define SHADOW_DELTA_SUFFIX_LENGTH ( ( uint16_t ) ( sizeof( SHADOW_DELTA_SUFFIX ) - 1 ) )
+
+/**
+ * @brief The suffix for a Shadow updated topic.
+ */
+#define SHADOW_UPDATED_SUFFIX "/documents"
+
+/**
+ * @brief The length of #SHADOW_UPDATED_SUFFIX.
+ */
+#define SHADOW_UPDATED_SUFFIX_LENGTH ( ( uint16_t ) ( sizeof( SHADOW_UPDATED_SUFFIX ) - 1 ) )
+
+/**
+ * @brief The length of the longest Shadow suffix.
+ */
+#define SHADOW_LONGEST_SUFFIX_LENGTH SHADOW_UPDATED_SUFFIX_LENGTH
+
+/**
+ * @brief The macro to convert MQTT error codes to Shadow error codes.
+ * Below are the conversions happening.
+ * IOT_MQTT_SUCCESS to AWS_IOT_SHADOW_SUCCESS
+ * IOT_MQTT_NO_MEMORY to AWS_IOT_SHADOW_NO_MEMORY
+ * all other error codes to AWS_IOT_SHADOW_MQTT_ERROR
+ */
+#define SHADOW_CONVERT_STATUS_CODE_MQTT_TO_SHADOW( X ) \
+ ( ( X ) == IOT_MQTT_SUCCESS ) ? AWS_IOT_SHADOW_SUCCESS : \
+ ( ( X ) == IOT_MQTT_NO_MEMORY ) ? AWS_IOT_SHADOW_NO_MEMORY : \
+ AWS_IOT_SHADOW_MQTT_ERROR
+
+/*----------------------- Shadow internal data types ------------------------*/
+
+/**
+ * @brief Enumerations representing each of the Shadow library's API functions.
+ */
+typedef enum _shadowOperationType
+{
+ /* Shadow operations. */
+ SHADOW_DELETE = 0, /**< @ref shadow_function_deleteasync */
+ SHADOW_GET = 1, /**< @ref shadow_function_getasync */
+ SHADOW_UPDATE = 2, /**< @ref shadow_function_updateasync */
+
+ /* Shadow callbacks. */
+ SET_DELTA_CALLBACK = 3, /**< @ref shadow_function_setdeltacallback */
+ SET_UPDATED_CALLBACK = 4 /**< @ref shadow_function_setupdatedcallback */
+} _shadowOperationType_t;
+
+/**
+ * @brief Enumerations representing each of the Shadow callback functions.
+ */
+typedef enum _shadowCallbackType
+{
+ DELTA_CALLBACK = 0, /**< Delta callback. */
+ UPDATED_CALLBACK = 1 /**< Updated callback. */
+} _shadowCallbackType_t;
+
+/**
+ * @brief Represents a Shadow subscriptions object.
+ *
+ * These structures are stored in a list.
+ */
+typedef struct _shadowSubscription
+{
+ IotLink_t link; /**< @brief List link member. */
+
+ int32_t references[ SHADOW_OPERATION_COUNT ]; /**< @brief Reference counter for Shadow operation topics. */
+ AwsIotShadowCallbackInfo_t callbacks[ SHADOW_CALLBACK_COUNT ]; /**< @brief Shadow callbacks for this Thing. */
+
+ /**
+ * @brief Buffer allocated for removing Shadow topics.
+ *
+ * This buffer is pre-allocated to ensure that memory is available when
+ * unsubscribing.
+ */
+ char * pTopicBuffer;
+
+ size_t thingNameLength; /**< @brief Length of Thing Name. */
+ char pThingName[]; /**< @brief Thing Name associated with this subscriptions object. */
+} _shadowSubscription_t;
+
+/**
+ * @brief Internal structure representing a single Shadow operation (DELETE,
+ * GET, or UPDATE).
+ *
+ * A list of these structures keeps track of all in-progress Shadow operations.
+ */
+typedef struct _shadowOperation
+{
+ IotLink_t link; /**< @brief List link member. */
+
+ /* Basic operation information. */
+ _shadowOperationType_t type; /**< @brief Operation type. */
+ uint32_t flags; /**< @brief Flags passed to operation API function. */
+ AwsIotShadowError_t status; /**< @brief Status of operation. */
+
+ IotMqttConnection_t mqttConnection; /**< @brief MQTT connection associated with this operation. */
+ _shadowSubscription_t * pSubscription; /**< @brief Shadow subscriptions object associated with this operation. */
+
+ union
+ {
+ /* Members valid only for a GET operation. */
+ struct
+ {
+ /**
+ * @brief Function to allocate memory for an incoming Shadow document.
+ *
+ * Only used when the flag #AWS_IOT_SHADOW_FLAG_WAITABLE is set.
+ */
+ void *( *mallocDocument )( size_t );
+
+ const char * pDocument; /**< @brief Retrieved Shadow document. */
+ size_t documentLength; /**< @brief Length of retrieved Shadow document. */
+ } get;
+
+ /* Members valid only for an UPDATE operation. */
+ struct
+ {
+ const char * pClientToken; /**< @brief Client token in update document. */
+ size_t clientTokenLength; /**< @brief Length of client token. */
+ } update;
+ } u; /**< @brief Valid member depends on _shadowOperation_t.type. */
+
+ /* How to notify of an operation's completion. */
+ union
+ {
+ IotSemaphore_t waitSemaphore; /**< @brief Semaphore to be used with @ref shadow_function_wait. */
+ AwsIotShadowCallbackInfo_t callback; /**< @brief User-provided callback function and parameter. */
+ } notify; /**< @brief How to notify of an operation's completion. */
+} _shadowOperation_t;
+
+/* Declarations of names printed in logs. */
+#if LIBRARY_LOG_LEVEL > IOT_LOG_NONE
+ extern const char * const _pAwsIotShadowOperationNames[];
+ extern const char * const _pAwsIotShadowCallbackNames[];
+#endif
+
+/* Declarations of variables for internal Shadow files. */
+extern uint32_t _AwsIotShadowMqttTimeoutMs;
+extern IotListDouble_t _AwsIotShadowPendingOperations;
+extern IotListDouble_t _AwsIotShadowSubscriptions;
+extern IotMutex_t _AwsIotShadowPendingOperationsMutex;
+extern IotMutex_t _AwsIotShadowSubscriptionsMutex;
+
+/*----------------------- Shadow operation functions ------------------------*/
+
+/**
+ * @brief Create a record for a new in-progress Shadow operation.
+ *
+ * @param[out] pNewOperation Set to point to the new operation on success.
+ * @param[in] operation The type of Shadow operation.
+ * @param[in] flags Flags variables passed to a user-facing Shadow function.
+ * @param[in] pCallbackInfo User-provided callback function and parameter.
+ *
+ * @return #AWS_IOT_SHADOW_SUCCESS or #AWS_IOT_SHADOW_NO_MEMORY
+ */
+AwsIotShadowError_t _AwsIotShadow_CreateOperation( _shadowOperation_t ** pNewOperation,
+ _shadowOperationType_t operation,
+ uint32_t flags,
+ const AwsIotShadowCallbackInfo_t * pCallbackInfo );
+
+/**
+ * @brief Free resources used to record a Shadow operation. This is called when
+ * the operation completes.
+ *
+ * @param[in] pData The operation which completed. This parameter is of type
+ * `void*` to match the signature of [free]
+ * (http://pubs.opengroup.org/onlinepubs/9699919799/functions/free.html).
+ */
+void _AwsIotShadow_DestroyOperation( void * pData );
+
+/**
+ * @brief Fill a buffer with a Shadow topic.
+ *
+ * @param[in] type One of: DELETE, GET, UPDATE.
+ * @param[in] pThingName Thing Name to place in the topic.
+ * @param[in] thingNameLength Length of `pThingName`.
+ * @param[out] pTopicBuffer Address of the buffer for the Shadow topic. If the
+ * pointer at this address is `NULL`, this function will allocate a new buffer;
+ * otherwise, it will use the provided buffer.
+ * @param[out] pOperationTopicLength Length of the Shadow operation topic (excluding
+ * any suffix) placed in `pTopicBuffer`.
+ *
+ * @warning This function does not check the length of `pTopicBuffer`! Any provided
+ * buffer must be large enough to accommodate the full Shadow topic, plus
+ * #SHADOW_LONGEST_SUFFIX_LENGTH.
+ *
+ * @return #AWS_IOT_SHADOW_SUCCESS or #AWS_IOT_SHADOW_NO_MEMORY. This function
+ * will not return #AWS_IOT_SHADOW_NO_MEMORY when a buffer is provided.
+ */
+AwsIotShadowError_t _AwsIotShadow_GenerateShadowTopic( _shadowOperationType_t type,
+ const char * pThingName,
+ size_t thingNameLength,
+ char ** pTopicBuffer,
+ uint16_t * pOperationTopicLength );
+
+/**
+ * @brief Process a Shadow operation by sending the necessary MQTT packets.
+ *
+ * @param[in] mqttConnection The MQTT connection to use.
+ * @param[in] pThingName Thing Name for the Shadow operation.
+ * @param[in] thingNameLength Length of `pThingName`.
+ * @param[in] pOperation Operation data to process.
+ * @param[in] pDocumentInfo Information on the Shadow document for GET or UPDATE
+ * operations.
+ *
+ * @return #AWS_IOT_SHADOW_STATUS_PENDING on success. On error, one of
+ * #AWS_IOT_SHADOW_NO_MEMORY or #AWS_IOT_SHADOW_MQTT_ERROR.
+ */
+AwsIotShadowError_t _AwsIotShadow_ProcessOperation( IotMqttConnection_t mqttConnection,
+ const char * pThingName,
+ size_t thingNameLength,
+ _shadowOperation_t * pOperation,
+ const AwsIotShadowDocumentInfo_t * pDocumentInfo );
+
+/*---------------------- Shadow subscription functions ----------------------*/
+
+/**
+ * @brief Find a Shadow subscription object. May create a new subscription object
+ * and adds it to the subscription list if not found.
+ *
+ * @param[in] pThingName Thing Name in the subscription object.
+ * @param[in] thingNameLength Length of `pThingName`.
+ * @param[in] createIfNotFound If `true`, attempt to create a new subscription
+ * object if no match is found.
+ *
+ * @return Pointer to a Shadow subscription object, either found or newly
+ * allocated. Returns `NULL` if no subscription object is found and a new
+ * subscription object could not be allocated.
+ *
+ * @note This function should be called with the subscription list mutex locked.
+ */
+_shadowSubscription_t * _AwsIotShadow_FindSubscription( const char * pThingName,
+ size_t thingNameLength,
+ bool createIfNotFound );
+
+/**
+ * @brief Remove a Shadow subscription object from the subscription list if
+ * unreferenced.
+ *
+ * @param[in] pSubscription Subscription object to check. If this object has no
+ * active references, it is removed from the subscription list.
+ * @param[out] pRemovedSubscription Removed subscription object, if any. Optional;
+ * pass `NULL` to ignore. If not `NULL`, this parameter will be set to the removed
+ * subscription and that subscription will not be destroyed.
+ *
+ * @note This function should be called with the subscription list mutex locked.
+ */
+void _AwsIotShadow_RemoveSubscription( _shadowSubscription_t * pSubscription,
+ _shadowSubscription_t ** pRemovedSubscription );
+
+/**
+ * @brief Free resources used for a Shadow subscription object.
+ *
+ * @param[in] pData The subscription object to destroy. This parameter is of type
+ * `void*` to match the signature of [free]
+ * (http://pubs.opengroup.org/onlinepubs/9699919799/functions/free.html).
+ */
+void _AwsIotShadow_DestroySubscription( void * pData );
+
+/**
+ * @brief Increment the reference count of a Shadow subscriptions object.
+ *
+ * Also adds MQTT subscriptions if necessary.
+ *
+ * @param[in] pOperation The operation for which the reference count should be
+ * incremented.
+ * @param[in] pTopicBuffer Topic buffer containing the operation topic, used if
+ * subscriptions need to be added.
+ * @param[in] operationTopicLength The length of the operation topic in `pTopicBuffer`.
+ * @param[in] callback MQTT callback function for when this operation completes.
+ *
+ * @warning This function does not check the length of `pTopicBuffer`! Any provided
+ * buffer must already contain the Shadow operation topic, plus enough space for the
+ * status suffix.
+ *
+ * @return #AWS_IOT_SHADOW_SUCCESS on success. On error, one of
+ * #AWS_IOT_SHADOW_NO_MEMORY or #AWS_IOT_SHADOW_MQTT_ERROR.
+ *
+ * @note This function should be called with the subscription list mutex locked.
+ */
+AwsIotShadowError_t _AwsIotShadow_IncrementReferences( _shadowOperation_t * pOperation,
+ char * pTopicBuffer,
+ uint16_t operationTopicLength,
+ AwsIotMqttCallbackFunction_t callback );
+
+/**
+ * @brief Decrement the reference count of a Shadow subscriptions object.
+ *
+ * Also removed MQTT subscriptions and deletes the subscription object if necessary.
+ *
+ * @param[in] pOperation The operation for which the reference count should be
+ * decremented.
+ * @param[in] pTopicBuffer Topic buffer containing the operation topic, used if
+ * subscriptions need to be removed.
+ * @param[out] pRemovedSubscription Set to point to a removed subscription.
+ * Optional; pass `NULL` to ignore. If not `NULL`, this function will not destroy
+ * a removed subscription.
+ *
+ * @warning This function does not check the length of `pTopicBuffer`! Any provided
+ * buffer must be large enough to accommodate the full Shadow topic, plus
+ * #SHADOW_LONGEST_SUFFIX_LENGTH.
+ *
+ * @note This function should be called with the subscription list mutex locked.
+ */
+void _AwsIotShadow_DecrementReferences( _shadowOperation_t * pOperation,
+ char * pTopicBuffer,
+ _shadowSubscription_t ** pRemovedSubscription );
+
+/*------------------------- Shadow parser functions -------------------------*/
+
+/**
+ * @brief Parse a Shadow error document.
+ *
+ * @param[in] pErrorDocument The error document to parse.
+ * @param[in] errorDocumentLength The length of `pErrorDocument`.
+ *
+ * @return One of the #AwsIotShadowError_t ranging from 400 to 500 on success.
+ * #AWS_IOT_SHADOW_BAD_RESPONSE on error.
+ */
+AwsIotShadowError_t _AwsIotShadow_ParseErrorDocument( const char * pErrorDocument,
+ size_t errorDocumentLength );
+
+#endif /* ifndef AWS_IOT_SHADOW_INTERNAL_H_ */