GitHub/zTC1
1
0
Fork 0
mirror of https://github.com/oopuuu/zTC1.git synced 2025-12-12 13:08:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

能编译

Browse Source
This commit is contained in:
zogodo
2020-02-11 00:40:17 +08:00
parent 2828f40d10
commit cf1c1904b7
5 changed files with 24 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
TC1/mqtt_server/user_mqtt_client.c
View File

@@ -31,14 +31,8 @@
#include "user_mqtt_client.h"
#include "c_json/c_json.h"
//#define MQTT_CLIENT_SSL_ENABLE // ssl
#define MAX_MQTT_TOPIC_SIZE (256)
#define MAX_MQTT_DATA_SIZE (1024)
#define MAX_MQTT_SEND_QUEUE_SIZE (10)
char MQTT_SERVER[64] = "192.168.33.219";
int MQTT_SERVER_PORT = 1883;
//char MQTT_SERVER[64] = "192.168.33.219";
//int MQTT_SERVER_PORT = 1883;
#ifdef MQTT_CLIENT_SSL_ENABLE
char* mqtt_server_ssl_cert_str =
@@ -78,10 +72,6 @@ static OSStatus mqtt_msg_publish(Client *c, const char* topic, char qos, char re
OSStatus user_recv_handler(void *arg);
OSStatus user_mqtt_send_socket_state(char socket_id);
void user_mqtt_hass_auto(char socket_id);
void user_mqtt_hass_auto_power(void);
bool isconnect = false;
mico_queue_t mqtt_msg_send_queue = NULL;
@@ -379,7 +369,7 @@ void mqtt_client_thread(mico_thread_arg_t arg)
require_noerr_string(err, MQTT_reconnect, "ERROR: MQTT publish data err");
mqtt_log("MQTT publish data success! send_topic=[%s], msg=[%ld].\r\n", p_send_msg->topic, p_send_msg->datalen);
mqtt_log("MQTT publish data success! send_topic=[%s], msg=[%ld].", p_send_msg->topic, p_send_msg->datalen);
no_mqtt_msg_exchange = false;
free(p_send_msg);
p_send_msg = NULL;

9
TC1/mqtt_server/user_mqtt_client.h
View File

@@ -10,8 +10,13 @@
#define MQTT_CMD_TIMEOUT 5000 // 5s
#define MQTT_YIELD_TMIE 5000 // 5s
extern char MQTT_SERVER[64];
extern int MQTT_SERVER_PORT;
//#define MQTT_CLIENT_SSL_ENABLE // ssl
#define MAX_MQTT_TOPIC_SIZE (256)
#define MAX_MQTT_DATA_SIZE (1024)
#define MAX_MQTT_SEND_QUEUE_SIZE (10)
#define MQTT_SERVER user_config->mqtt_ip
#define MQTT_SERVER_PORT user_config->mqtt_port
extern OSStatus user_mqtt_init(void);
extern OSStatus user_mqtt_send(char *arg);