Duy tran / Mbed OS Water_Monitor_clone_v1

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   MQTT NDefLib

Fork of Cloud_IBM_MbedOS by ST

MQTTNetwork.h@3:e1f6c5af437e, 2017-12-05 (annotated)

Committer:
DuyLionTran
Date:
Tue Dec 05 17:12:57 2017 +0000
Revision:
3:e1f6c5af437e
Parent:
0:e477c0f8b2e4 
IBM_Mbed_OS_Duy_Clone

Who changed what in which revision?

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