From f17ece33769e34d6f4d461fd984ed7f2781df2f5 Mon Sep 17 00:00:00 2001 From: Francois BIOT Date: Thu, 29 Dec 2022 12:52:29 +0100 Subject: [PATCH] MqttClient::client renamed to tcp_client --- src/TinyMqtt.cpp | 55 ++++++++++++++++++++++++------------------------ src/TinyMqtt.h | 13 ++++++------ 2 files changed, 34 insertions(+), 34 deletions(-) diff --git a/src/TinyMqtt.cpp b/src/TinyMqtt.cpp index 5624f76..fc774cf 100644 --- a/src/TinyMqtt.cpp +++ b/src/TinyMqtt.cpp @@ -38,12 +38,12 @@ MqttClient::MqttClient(MqttBroker* local_broker, TcpClient* new_client) { debug("MqttClient private with broker"); #ifdef TINY_MQTT_ASYNC - client = new_client; - client->onData(onData, this); + tcp_client = new_client; + tcp_client->onData(onData, this); // client->onConnect() TODO // client->onDisconnect() TODO #else - client = new WiFiClient(*new_client); + tcp_client = new WiFiClient(*new_client); #endif #ifdef EPOXY_DUINO alive = millis()+500000; @@ -55,30 +55,29 @@ MqttClient::MqttClient(MqttBroker* local_broker, TcpClient* new_client) MqttClient::MqttClient(MqttBroker* local_broker, const std::string& id) : local_broker(local_broker), clientId(id) { - client = nullptr; - if (local_broker) local_broker->addClient(this); } MqttClient::~MqttClient() { close(); - delete client; + delete tcp_client; + debug("*** MqttClient delete()"); } void MqttClient::close(bool bSendDisconnect) { debug("close " << id().c_str()); mqtt_connected = false; - if (client) // connected to a remote broker + if (tcp_client) // connected to a remote broker { - if (bSendDisconnect and client->connected()) + if (bSendDisconnect and tcp_client->connected()) { message.create(MqttMessage::Type::Disconnect); message.hexdump("close"); message.sendTo(this); } - client->stop(); + tcp_client->stop(); } if (local_broker) @@ -100,18 +99,18 @@ void MqttClient::connect(std::string broker, uint16_t port, uint16_t ka) debug("MqttClient::connect_to_host " << broker << ':' << port); keep_alive = ka; close(); - if (client) delete client; - client = new TcpClient; + if (tcp_client) delete tcp_client; + tcp_client = new TcpClient; #ifdef TINY_MQTT_ASYNC - client->onData(onData, this); - client->onConnect(onConnect, this); - client->connect(broker.c_str(), port, ka); + tcp_client->onData(onData, this); + tcp_client->onConnect(onConnect, this); + tcp_client->connect(broker.c_str(), port, ka); #else - if (client->connect(broker.c_str(), port)) + if (tcp_client->connect(broker.c_str(), port)) { debug("link established"); - onConnect(this, client); + onConnect(this, tcp_client); } else { @@ -184,7 +183,7 @@ void MqttBroker::loop() for(size_t i=0; iconnected()) { client->loop(); @@ -290,11 +289,11 @@ void MqttClient::loop() close(); debug(red << "closed"); } - else if (client && client->connected()) + else if (tcp_client && tcp_client->connected()) { debug("pingreq"); uint16_t pingreq = MqttMessage::Type::PingReq; - client->write((const char*)(&pingreq), 2); + tcp_client->write((const char*)(&pingreq), 2); clientAlive(0); // TODO when many MqttClient passes through a local broker @@ -302,9 +301,9 @@ void MqttClient::loop() } } #ifndef TINY_MQTT_ASYNC - while(client && client->available()>0) + while(tcp_client && tcp_client->available()>0) { - message.incoming(client->read()); + message.incoming(tcp_client->read()); if (message.type()) { processMessage(&message); @@ -517,11 +516,11 @@ void MqttClient::processMessage(MqttMessage* mesg) case MqttMessage::Type::PingReq: if (!mqtt_connected) break; - if (client) + if (tcp_client) { uint16_t pingreq = MqttMessage::Type::PingResp; debug(cyan << "Ping response to client "); - client->write((const char*)(&pingreq), 2); + tcp_client->write((const char*)(&pingreq), 2); bclose = false; } else @@ -583,9 +582,9 @@ void MqttClient::processMessage(MqttMessage* mesg) case MqttMessage::Type::Publish: #if TINY_MQTT_DEBUG - Console << "publish " << mqtt_connected << '/' << (long) client << endl; + Console << "publish " << mqtt_connected << '/' << (long) tcp_client << endl; #endif - if (mqtt_connected or client == nullptr) + if (mqtt_connected or tcp_client == nullptr) { uint8_t qos = mesg->flags(); payload = header; @@ -601,7 +600,7 @@ void MqttClient::processMessage(MqttMessage* mesg) // TODO reset DUP // TODO reset RETAIN - if (local_broker==nullptr or client==nullptr) // internal MqttClient receives publish + if (local_broker==nullptr or tcp_client==nullptr) // internal MqttClient receives publish { #if TINY_MQTT_DEBUG if (TinyMqtt::debug >= 2) @@ -727,7 +726,7 @@ MqttError MqttClient::publish(const Topic& topic, const char* payload, size_t pa { return local_broker->publish(this, topic, msg); } - else if (client) + else if (tcp_client) return msg.sendTo(this); else return MqttNowhereToSend; @@ -741,7 +740,7 @@ MqttError MqttClient::publishIfSubscribed(const Topic& topic, MqttMessage& msg) debug("mqttclient publishIfSubscribed " << topic.c_str() << ' ' << subscriptions.size()); if (isSubscribedTo(topic)) { - if (client) + if (tcp_client) retval = msg.sendTo(this); else { diff --git a/src/TinyMqtt.h b/src/TinyMqtt.h index 8980d9b..a035990 100644 --- a/src/TinyMqtt.h +++ b/src/TinyMqtt.h @@ -193,12 +193,13 @@ class MqttClient // no negociation occurred bool connected() { - return (local_broker!=nullptr and client==nullptr) or (client and client->connected()); + return (local_broker!=nullptr and tcp_client==nullptr) + or (tcp_client and tcp_client->connected()); } void write(const char* buf, size_t length) { - if (client) client->write(buf, length); + if (tcp_client) tcp_client->write(buf, length); } const std::string& id() const { return clientId; } @@ -229,7 +230,7 @@ class MqttClient // connected to local broker // TODO seems to be useless - bool isLocal() const { return client == nullptr; } + bool isLocal() const { return tcp_client == nullptr; } void dump(std::string indent="") { @@ -238,9 +239,9 @@ class MqttClient uint32_t ms=millis(); Console << indent << "+-- " << '\'' << clientId.c_str() << "' " << (connected() ? " ON " : " OFF"); Console << ", alive=" << alive << '/' << ms << ", ka=" << keep_alive << ' '; - if (client) + if (tcp_client) { - if (client->connected()) + if (tcp_client->connected()) Console << TinyConsole::green << "connected"; else Console << TinyConsole::red << "disconnected"; @@ -295,7 +296,7 @@ class MqttClient // when MqttBroker uses MqttClient for each external connexion MqttBroker* local_broker=nullptr; - TcpClient* client=nullptr; // connection to remote broker + TcpClient* tcp_client=nullptr; // connection to remote broker std::set subscriptions; std::string clientId; CallBack callback = nullptr;