Astrid Vanneste / Mbed OS PGO6_VoteController

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

Fork of PGO6_VoteController_template by Jens de hoog

MQTTNetwork.h@4:08da93eb6014, 2018-10-08 (annotated)

Committer:
AstridVanneste
Date:
Mon Oct 08 13:37:19 2018 +0000
Revision:
4:08da93eb6014
Parent:
0:fd29cd85e75e 
LED

Who changed what in which revision?

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