[update] fix issues bug

RT-Thread-packages · Mar 11, 2022 · 0e4c9af · 0e4c9af
1 parent 92c2fae
commit 0e4c9af
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/MQTTClient-RT/paho_mqtt.h b/MQTTClient-RT/paho_mqtt.h
@@ -91,7 +91,7 @@ struct MQTTClient
 
     /* publish interface */
     rt_mutex_t pub_mutex;             /* publish data mutex for blocking */
-#if defined(RT_USING_POSIX) && (defined(RT_USING_DFS_NET) || defined(SAL_USING_POSIX))
+#if defined(RT_USING_POSIX_FS) && (defined(RT_USING_DFS_NET) || defined(SAL_USING_POSIX))
     struct rt_pipe_device* pipe_device;
     int pub_pipe[2];
 #else

diff --git a/MQTTClient-RT/paho_mqtt_pipe.c b/MQTTClient-RT/paho_mqtt_pipe.c
@@ -3,13 +3,15 @@
 
 #include <rtthread.h>
 #include <rtdevice.h>
-#include <dfs_posix.h>
 #include <sys/time.h>
 
 #include <netdb.h>
 #include <sys/socket.h>
 #include <sys/select.h>
 
+#include <fcntl.h>
+#include <sys/errno.h>
+
 #include "MQTTPacket.h"
 #include "paho_mqtt.h"
 
@@ -41,6 +43,12 @@
 #endif
 #endif
 
+#ifndef RT_PIPE_BUFSZ
+#define PIPE_BUFSZ    512
+#else
+#define PIPE_BUFSZ    RT_PIPE_BUFSZ
+#endif
+
 /*
  * resolve server address
  * @param server the server sockaddress