ping jin / Mbed OS DISCO_L475VG_IOT01-Sensors-BSP

MQTT-STM32

Dependencies:   MbedJSONValue wifi-ism43362 LSM6DSL HTS221 MQTT

MQTTNetwork.h@0:775536f6b40b, 2020-09-23 (annotated)

Committer:
jingege
Date:
Wed Sep 23 09:12:20 2020 +0000
Revision:
0:775536f6b40b
stm32-MQTT

Who changed what in which revision?

UserRevisionLine numberNew contents of line
jingege 0:775536f6b40b 1 #ifndef _MQTTNETWORK_H_
jingege 0:775536f6b40b 2 #define _MQTTNETWORK_H_
jingege 0:775536f6b40b 3
jingege 0:775536f6b40b 4 #include "NetworkInterface.h"
jingege 0:775536f6b40b 5
jingege 0:775536f6b40b 6 class MQTTNetwork {
jingege 0:775536f6b40b 7 public:
jingege 0:775536f6b40b 8 MQTTNetwork(NetworkStack* aNetwork) : network(aNetwork) {
jingege 0:775536f6b40b 9 socket = new TCPSocket();
jingege 0:775536f6b40b 10 }
jingege 0:775536f6b40b 11
jingege 0:775536f6b40b 12 ~MQTTNetwork()
jingege 0:775536f6b40b 13 {
jingege 0:775536f6b40b 14 delete socket;
jingege 0:775536f6b40b 15 }
jingege 0:775536f6b40b 16
jingege 0:775536f6b40b 17 int read(unsigned char* buffer, int len, int timeout) {
jingege 0:775536f6b40b 18 return socket->recv(buffer, len);
jingege 0:775536f6b40b 19 }
jingege 0:775536f6b40b 20
jingege 0:775536f6b40b 21 int write(unsigned char* buffer, int len, int timeout) {
jingege 0:775536f6b40b 22 return socket->send(buffer, len);
jingege 0:775536f6b40b 23 }
jingege 0:775536f6b40b 24
jingege 0:775536f6b40b 25 int connect(const char* hostname, int port) {
jingege 0:775536f6b40b 26 int ret = socket->open(network);
jingege 0:775536f6b40b 27 printf("ret ===%d\n\n\n",ret);
jingege 0:775536f6b40b 28 ret = socket->connect(hostname, port);
jingege 0:775536f6b40b 29 printf("ret ======== %d\n\n\n", ret);
jingege 0:775536f6b40b 30 return ret;
jingege 0:775536f6b40b 31 }
jingege 0:775536f6b40b 32
jingege 0:775536f6b40b 33 int disconnect() {
jingege 0:775536f6b40b 34 return socket->close();
jingege 0:775536f6b40b 35 }
jingege 0:775536f6b40b 36
jingege 0:775536f6b40b 37 private:
jingege 0:775536f6b40b 38 NetworkStack* network;
jingege 0:775536f6b40b 39 TCPSocket* socket;
jingege 0:775536f6b40b 40 };
jingege 0:775536f6b40b 41
jingege 0:775536f6b40b 42 #endif // _MQTTNETWORK_H_