mirror of
https://github.com/emsesp/EMS-ESP32.git
synced 2025-12-07 00:09:51 +03:00
59 lines
1.3 KiB
C++
59 lines
1.3 KiB
C++
/*
|
|
Copyright (c) 2022 Bert Melis. All rights reserved.
|
|
|
|
This work is licensed under the terms of the MIT license.
|
|
For a copy, see <https://opensource.org/licenses/MIT> or
|
|
the LICENSE file.
|
|
*/
|
|
|
|
#if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)
|
|
|
|
#include "ClientAsync.h"
|
|
|
|
namespace espMqttClientInternals {
|
|
|
|
ClientAsync::ClientAsync()
|
|
: client()
|
|
, availableData(0)
|
|
, bufData(nullptr) {
|
|
// empty
|
|
}
|
|
|
|
bool ClientAsync::connect(IPAddress ip, uint16_t port) {
|
|
return client.connect(ip, port);
|
|
}
|
|
|
|
bool ClientAsync::connect(const char* host, uint16_t port) {
|
|
return client.connect(host, port);
|
|
}
|
|
|
|
size_t ClientAsync::write(const uint8_t* buf, size_t size) {
|
|
return client.write(reinterpret_cast<const char*>(buf), size);
|
|
}
|
|
|
|
int ClientAsync::read(uint8_t* buf, size_t size) {
|
|
size_t willRead = std::min(size, availableData);
|
|
memcpy(buf, bufData, std::min(size, availableData));
|
|
if (availableData > size) {
|
|
emc_log_w("Buffer is smaller than available data: %zu - %zu", size, availableData);
|
|
}
|
|
availableData = 0;
|
|
return willRead;
|
|
}
|
|
|
|
void ClientAsync::stop() {
|
|
client.close(false);
|
|
}
|
|
|
|
bool ClientAsync::connected() {
|
|
return client.connected();
|
|
}
|
|
|
|
bool ClientAsync::disconnected() {
|
|
return client.disconnected();
|
|
}
|
|
|
|
} // namespace espMqttClientInternals
|
|
|
|
#endif
|