A small footprint MQTT library
Dependents: STM32F746_iothub_client_sample_mqtt FXOS8700CQ_To_Azure_IoT f767zi_mqtt FXOS8700CQ_To_Azure_IoT ... more
Diff: azure_umqtt_c/mqtt_codec.h
- Revision:
- 2:f3140ae5c35c
- Parent:
- 0:ef4901974abc
- Child:
- 8:83bb166aba73
--- a/azure_umqtt_c/mqtt_codec.h Sun Apr 24 16:40:45 2016 -0700 +++ b/azure_umqtt_c/mqtt_codec.h Mon May 09 14:37:25 2016 -0700 @@ -7,35 +7,38 @@ #ifdef __cplusplus #include <cstdint> #include <cstdbool> +#include <cstddef> extern "C" { #else #include <stdint.h> #include <stdbool.h> +#include <stddef.h> #endif // __cplusplus #include "azure_c_shared_utility/xio.h" #include "azure_c_shared_utility/buffer_.h" +#include "azure_c_shared_utility/umock_c_prod.h" #include "azure_umqtt_c/mqttconst.h" typedef struct MQTTCODEC_INSTANCE_TAG* MQTTCODEC_HANDLE; typedef void(*ON_PACKET_COMPLETE_CALLBACK)(void* context, CONTROL_PACKET_TYPE packet, int flags, BUFFER_HANDLE headerData); -extern MQTTCODEC_HANDLE mqtt_codec_create(ON_PACKET_COMPLETE_CALLBACK packetComplete, void* callbackCtx); -extern void mqtt_codec_destroy(MQTTCODEC_HANDLE handle); +MOCKABLE_FUNCTION(, MQTTCODEC_HANDLE, mqtt_codec_create, ON_PACKET_COMPLETE_CALLBACK, packetComplete, void*, callbackCtx); +MOCKABLE_FUNCTION(, void, mqtt_codec_destroy, MQTTCODEC_HANDLE, handle); -extern BUFFER_HANDLE mqtt_codec_connect(const MQTT_CLIENT_OPTIONS* mqttOptions); -extern BUFFER_HANDLE mqtt_codec_disconnect(); -extern BUFFER_HANDLE mqtt_codec_publish(QOS_VALUE qosValue, bool duplicateMsg, bool serverRetain, uint16_t packetId, const char* topicName, const uint8_t* msgBuffer, size_t buffLen); -extern BUFFER_HANDLE mqtt_codec_publishAck(uint16_t packetId); -extern BUFFER_HANDLE mqtt_codec_publishReceived(uint16_t packetId); -extern BUFFER_HANDLE mqtt_codec_publishRelease(uint16_t packetId); -extern BUFFER_HANDLE mqtt_codec_publishComplete(uint16_t packetId); -extern BUFFER_HANDLE mqtt_codec_ping(); -extern BUFFER_HANDLE mqtt_codec_subscribe(uint16_t packetId, SUBSCRIBE_PAYLOAD* subscribeList, size_t count); -extern BUFFER_HANDLE mqtt_codec_unsubscribe(uint16_t packetId, const char** unsubscribeList, size_t count); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_connect, const MQTT_CLIENT_OPTIONS*, mqttOptions); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_disconnect); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_publish, QOS_VALUE, qosValue, bool, duplicateMsg, bool, serverRetain, uint16_t, packetId, const char*, topicName, const uint8_t*, msgBuffer, size_t, buffLen); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_publishAck, uint16_t, packetId); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_publishReceived, uint16_t, packetId); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_publishRelease, uint16_t, packetId); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_publishComplete, uint16_t, packetId); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_ping); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_subscribe, uint16_t, packetId, SUBSCRIBE_PAYLOAD*, subscribeList, size_t, count); +MOCKABLE_FUNCTION(, BUFFER_HANDLE, mqtt_codec_unsubscribe, uint16_t, packetId, const char**, unsubscribeList, size_t, count); -extern int mqtt_codec_bytesReceived(MQTTCODEC_HANDLE handle, const unsigned char* buffer, size_t size); +MOCKABLE_FUNCTION(, int, mqtt_codec_bytesReceived, MQTTCODEC_HANDLE, handle, const unsigned char*, buffer, size_t, size); #ifdef __cplusplus }