Files
kunlun/app/grapp/lwmqtt/include/lwmqtt_lwip.h
2024-09-28 14:24:04 +08:00

36 lines
1.2 KiB
C

#ifndef LWMQTT_LWIP_H
#define LWMQTT_LWIP_H
//#include <time.h>
#include <lwmqtt.h>
#include "iot_io_api.h"
#define LWMQTT_LWIP_MAX_SOCKETS 1
//typedef struct { struct timeval end; } lwmqtt_unix_timer_t;
typedef struct lwmqtt_lwip_timer{
int timeval;
} lwmqtt_lwip_timer_t;
typedef struct lwmqtt_lwip_network{
int socket;
} lwmqtt_lwip_network_t;
void lwmqtt_lwip_timer_set(lwmqtt_client_t *client, void *ref, unsigned int timeout);
unsigned int lwmqtt_lwip_timer_get(lwmqtt_client_t *client, void *ref);
lwmqtt_lwip_timer_t *lwmqtt_lwip_timer_create(void);
lwmqtt_err_t lwmqtt_lwip_network_connect(lwmqtt_lwip_network_t *network, char *host, int port);
void lwmqtt_lwip_network_disconnect(lwmqtt_lwip_network_t *network);
lwmqtt_err_t lwmqtt_lwip_network_peek(lwmqtt_client_t *client, lwmqtt_lwip_network_t *network, int *available);
lwmqtt_err_t lwmqtt_lwip_network_read(lwmqtt_client_t *client, void *ref, unsigned char *buf, int len, int *read,
unsigned int timeout);
lwmqtt_err_t lwmqtt_lwip_network_write(lwmqtt_client_t *client, void *ref, unsigned char *buf, int len, int *sent,
unsigned int timeout);
#endif // LWMQTT_LWIP_H