MQTT client internal API definitions.
More...
|
|
#define | MAX_NO_OF_REMAINING_LENGTH_BYTES 4 |
| |
|
| size_t | aws_iot_mqtt_internal_write_len_to_buffer (unsigned char *buf, uint32_t length) |
| |
| IoT_Error_t | aws_iot_mqtt_internal_decode_remaining_length_from_buffer (unsigned char *buf, uint32_t *decodedLen, uint32_t *readBytesLen) |
| |
|
uint32_t | aws_iot_mqtt_internal_get_final_packet_length_from_remaining_length (uint32_t rem_len) |
| |
| uint16_t | aws_iot_mqtt_internal_read_uint16_t (unsigned char **pptr) |
| |
| void | aws_iot_mqtt_internal_write_uint_16 (unsigned char **pptr, uint16_t anInt) |
| |
| unsigned char | aws_iot_mqtt_internal_read_char (unsigned char **pptr) |
| |
| void | aws_iot_mqtt_internal_write_char (unsigned char **pptr, unsigned char c) |
| |
|
void | aws_iot_mqtt_internal_write_utf8_string (unsigned char **pptr, const char *string, uint16_t stringLen) |
| |
| IoT_Error_t | aws_iot_mqtt_internal_init_header (MQTTHeader *pHeader, MessageTypes message_type, QoS qos, uint8_t dup, uint8_t retained) |
| |
|
IoT_Error_t | aws_iot_mqtt_internal_send_packet (AWS_IoT_Client *pClient, size_t length, Timer *pTimer) |
| |
|
IoT_Error_t | aws_iot_mqtt_internal_cycle_read (AWS_IoT_Client *pClient, Timer *pTimer, uint8_t *pPacketType) |
| |
|
IoT_Error_t | aws_iot_mqtt_internal_wait_for_read (AWS_IoT_Client *pClient, uint8_t packetType, Timer *pTimer) |
| |
| IoT_Error_t | aws_iot_mqtt_internal_serialize_zero (unsigned char *pTxBuf, size_t txBufLen, MessageTypes packetType, size_t *pSerializedLength) |
| |
| IoT_Error_t aws_iot_mqtt_internal_decode_remaining_length_from_buffer |
( |
unsigned char * |
buf, |
|
|
uint32_t * |
decodedLen, |
|
|
uint32_t * |
readBytesLen |
|
) |
| |
Decodes the message length according to the MQTT algorithm
- Parameters
-
| the | buffer containing the message |
| value | the decoded length returned |
- Returns
- the number of bytes read from the socket
| IoT_Error_t aws_iot_mqtt_internal_init_header |
( |
MQTTHeader * |
pHeader, |
|
|
MessageTypes |
message_type, |
|
|
QoS |
qos, |
|
|
uint8_t |
dup, |
|
|
uint8_t |
retained |
|
) |
| |
Initialize the MQTTHeader structure. Used to ensure that Header bits are always initialized using the proper mappings. No Endianness issues here since the individual fields are all less than a byte. Also generates no warnings since all fields are initialized using hex constants
| unsigned char aws_iot_mqtt_internal_read_char |
( |
unsigned char ** |
pptr | ) |
|
Reads one character from the input buffer.
- Parameters
-
| pptr | pointer to the input buffer - incremented by the number of bytes used & returned |
- Returns
- the character read
| uint16_t aws_iot_mqtt_internal_read_uint16_t |
( |
unsigned char ** |
pptr | ) |
|
Calculates uint16 packet id from two bytes read from the input buffer Checks Endianness at runtime
- Parameters
-
| pptr | pointer to the input buffer - incremented by the number of bytes used & returned |
- Returns
- the value calculated
| IoT_Error_t aws_iot_mqtt_internal_serialize_zero |
( |
unsigned char * |
pTxBuf, |
|
|
size_t |
txBufLen, |
|
|
MessageTypes |
packetType, |
|
|
size_t * |
pSerializedLength |
|
) |
| |
Serializes a 0-length packet into the supplied buffer, ready for writing to a socket
- Parameters
-
| buf | the buffer into which the packet will be serialized |
| buflen | the length in bytes of the supplied buffer, to avoid overruns |
| packettype | the message type |
| serialized | length |
- Returns
- IoT_Error_t indicating function execution status
| void aws_iot_mqtt_internal_write_char |
( |
unsigned char ** |
pptr, |
|
|
unsigned char |
c |
|
) |
| |
Writes one character to an output buffer.
- Parameters
-
| pptr | pointer to the output buffer - incremented by the number of bytes used & returned |
| c | the character to write |
| size_t aws_iot_mqtt_internal_write_len_to_buffer |
( |
unsigned char * |
buf, |
|
|
uint32_t |
length |
|
) |
| |
Encodes the message length according to the MQTT algorithm
- Parameters
-
| buf | the buffer into which the encoded data is written |
| length | the length to be encoded |
- Returns
- the number of bytes written to buffer
| void aws_iot_mqtt_internal_write_uint_16 |
( |
unsigned char ** |
pptr, |
|
|
uint16_t |
anInt |
|
) |
| |
Writes an integer as 2 bytes to an output buffer.
- Parameters
-
| pptr | pointer to the output buffer - incremented by the number of bytes used & returned |
| anInt | the integer to write |