aws_iot_shadow_records.h File Reference

#include <stdbool.h>
#include "aws_iot_shadow_interface.h"
#include "aws_iot_config.h"

Functions
void	addToAckWaitList (uint8_t indexAckWaitList, const char *pThingName, ShadowActions_t action, const char *pExtractedClientToken, fpActionCallback_t callback, void *pCallbackContext, uint32_t timeout_seconds)
bool	getNextFreeIndexOfAckWaitList (uint8_t *pIndex)
void	HandleExpiredResponseCallbacks (void)
void	incrementSubscriptionCnt (const char *pThingName, ShadowActions_t action, bool isSticky)
void	initDeltaTokens (void)
void	initializeRecords (MQTTClient_t *pClient)
bool	isSubscriptionPresent (const char *pThingName, ShadowActions_t action)
IoT_Error_t	publishToShadowAction (const char *pThingName, ShadowActions_t action, const char *pJsonDocumentToBeSent)
IoT_Error_t	registerJsonTokenOnDelta (jsonStruct_t *pStruct)
IoT_Error_t	subscribeToShadowActionAcks (const char *pThingName, ShadowActions_t action, bool isSticky)

Variables
char	mqttClientID [MAX_SIZE_OF_UNIQUE_CLIENT_ID_BYTES]
char	myThingName [MAX_SIZE_OF_THING_NAME]
bool	shadowDiscardOldDeltaFlag
uint32_t	shadowJsonVersionNum

void addToAckWaitList	(	uint8_t	indexAckWaitList,
		const char *	pThingName,
		ShadowActions_t	action,
		const char *	pExtractedClientToken,
		fpActionCallback_t	callback,
		void *	pCallbackContext,
		uint32_t	timeout_seconds
	)

References ToBeReceivedAckRecord_t::action, ToBeReceivedAckRecord_t::callback, callback, countdown(), InitTimer(), ToBeReceivedAckRecord_t::isFree, ToBeReceivedAckRecord_t::pCallbackContext, and strncpy().

Referenced by iot_shadow_action().

bool getNextFreeIndexOfAckWaitList

(

uint8_t *

pIndex

)

References i, and NULL.

Referenced by iot_shadow_action().

void HandleExpiredResponseCallbacks

(

void

)

References ToBeReceivedAckRecord_t::callback, callback, expired(), i, ToBeReceivedAckRecord_t::isFree, NULL, SHADOW_ACK_TIMEOUT, shadowRxBuf, and unsubscribeFromAcceptedAndRejected().

Referenced by aws_iot_shadow_yield().

void incrementSubscriptionCnt	(	const char *	pThingName,
		ShadowActions_t	action,
		bool	isSticky
	)

References SubscriptionRecord_t::count, i, SubscriptionRecord_t::isSticky, MAX_TOPICS_AT_ANY_GIVEN_TIME, SHADOW_ACCEPTED, SHADOW_REJECTED, and topicNameFromThingAndAction().

Referenced by iot_shadow_action().

void initDeltaTokens

(

void

)

References deltaTopicSubscribedFlag, i, JsonTokenTable_t::isFree, and tokenTableIndex.

Referenced by aws_iot_shadow_init().

void initializeRecords

(

MQTTClient_t *

pClient

)

References SubscriptionRecord_t::count, i, ToBeReceivedAckRecord_t::isFree, SubscriptionRecord_t::isFree, SubscriptionRecord_t::isSticky, and MAX_TOPICS_AT_ANY_GIVEN_TIME.

Referenced by aws_iot_shadow_connect().

bool isSubscriptionPresent	(	const char *	pThingName,
		ShadowActions_t	action
	)

References i, MAX_TOPICS_AT_ANY_GIVEN_TIME, SHADOW_ACCEPTED, SHADOW_REJECTED, and topicNameFromThingAndAction().

Referenced by iot_shadow_action().

IoT_Error_t publishToShadowAction	(	const char *	pThingName,
		ShadowActions_t	action,
		const char *	pJsonDocumentToBeSent
	)

References MQTTPublishParams::MessageParams, MQTTMessageParamsDefault, MQTTPublishParamsDefault, NONE_ERROR, MQTTMessageParams::PayloadLen, MQTTMessageParams::pPayload, MQTTPublishParams::pTopic, MQTTClient_t::publish, MQTTMessageParams::qos, QOS_0, SHADOW_ACTION, and topicNameFromThingAndAction().

Referenced by iot_shadow_action().

IoT_Error_t registerJsonTokenOnDelta

(

jsonStruct_t *

pStruct

)

References JsonTokenTable_t::callback, jsonStruct::cb, DEBUG, deltaTopicSubscribedFlag, GENERIC_ERROR, JsonTokenTable_t::isFree, MQTTSubscribeParams::mHandler, myThingName, NONE_ERROR, JsonTokenTable_t::pKey, jsonStruct::pKey, JsonTokenTable_t::pStruct, MQTTSubscribeParams::pTopic, MQTTSubscribeParams::qos, QOS_0, shadow_delta_callback(), shadowDeltaTopic, MQTTClient_t::subscribe, and tokenTableIndex.

Referenced by aws_iot_shadow_register_delta().

IoT_Error_t subscribeToShadowActionAcks	(	const char *	pThingName,
		ShadowActions_t	action,
		bool	isSticky
	)

References AckStatusCallback(), count, SubscriptionRecord_t::count, countdown(), expired(), getNextFreeIndexOfSubscriptionList(), InitTimer(), SubscriptionRecord_t::isFree, SubscriptionRecord_t::isSticky, MQTTSubscribeParams::mHandler, MQTTSubscribeParamsDefault, NONE_ERROR, MQTTSubscribeParams::pTopic, MQTTSubscribeParams::qos, QOS_0, SHADOW_ACCEPTED, SHADOW_REJECTED, MQTTClient_t::subscribe, SUBSCRIBE_SETTLING_TIME, SubscriptionRecord_t::Topic, topicNameFromThingAndAction(), and MQTTClient_t::unsubscribe.

Referenced by iot_shadow_action().

char mqttClientID[MAX_SIZE_OF_UNIQUE_CLIENT_ID_BYTES]

Referenced by aws_iot_shadow_connect(), FillWithClientToken(), and FillWithClientTokenSize().

char myThingName[MAX_SIZE_OF_THING_NAME]

Referenced by aws_iot_shadow_connect(), isAckForMyThingName(), and registerJsonTokenOnDelta().

bool shadowDiscardOldDeltaFlag

Referenced by aws_iot_shadow_disable_discard_old_delta_msgs(), aws_iot_shadow_enable_discard_old_delta_msgs(), and shadow_delta_callback().

uint32_t shadowJsonVersionNum

Referenced by AckStatusCallback(), aws_iot_shadow_get_last_received_version(), aws_iot_shadow_reset_last_received_version(), and shadow_delta_callback().