#ifndef _DYNREG_INTERNAL_H_
#define _DYNREG_INTERNAL_H_

#include "linkkit/wrappers/wrappers.h"

#ifdef INFRA_LOG
#include "linkkit/infra/infra_log.h"
#define dynreg_info(...) log_info("dynreg", __VA_ARGS__)
#define dynreg_err(...)  log_err("dynreg", __VA_ARGS__)
#define dynreg_dbg(...)  log_debug("dynreg", __VA_ARGS__)
#else
#define dynreg_info(...)         \
    do {                         \
        HAL_Printf(__VA_ARGS__); \
        HAL_Printf("\r\n");      \
    } while (0)
#define dynreg_err(...)          \
    do {                         \
        HAL_Printf(__VA_ARGS__); \
        HAL_Printf("\r\n");      \
    } while (0)
#define dynreg_dbg(...)          \
    do {                         \
        HAL_Printf(__VA_ARGS__); \
        HAL_Printf("\r\n");      \
    } while (0)
#endif

#ifdef INFRA_MEM_STATS
#include "linkkit/infra/infra_mem_stats.h"
#define dynreg_malloc(size) LITE_malloc(size, MEM_MAGIC, "dynreg")
#define dynreg_free(ptr)    LITE_free(ptr)
#else
#define dynreg_malloc(size) HAL_Malloc(size)
#define dynreg_free(ptr)       \
    {                          \
        HAL_Free((void *)ptr); \
        ptr = NULL;            \
    }
#endif

#endif

#ifdef MQTT_DYNAMIC_REGISTER
#include "linkkit/mqtt_api.h"
void *wrapper_mqtt_init(iotx_mqtt_param_t *mqtt_params);
int wrapper_mqtt_connect(void *client);
int wrapper_mqtt_yield(void *client, int timeout_ms);
int wrapper_mqtt_subscribe(void *client, const char *topicFilter,
                           iotx_mqtt_qos_t qos,
                           iotx_mqtt_event_handle_func_fpt topic_handle_func,
                           void *pcontext);
int wrapper_mqtt_release(void **pclient);
#endif