test/acl
1
0
Fork 0
mirror of https://gitee.com/acl-dev/acl.git synced 2024-12-02 20:08:21 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fixed one bug that the socket shouldn't be closed in mqtt_client.cpp when some IO errors happen.

Browse Source
This commit is contained in:
zhengshuxin 2023-03-30 16:29:42 +08:00
parent 331e4826dc
commit 49212d2210
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib_acl_cpp/src/mqtt/mqtt_client.cpp
View File

@ -59,8 +59,8 @@ bool mqtt_client::send(mqtt_message& message) {
}
if (conn_->write(buff) == -1) {
conn_->close();
logger_error("send message error=%s", last_serror());
//conn_->close();
//logger_error("send message error=%s", last_serror());
return false;
}
@ -71,8 +71,8 @@ mqtt_message* mqtt_client::get_message(void) {
mqtt_header header(MQTT_RESERVED_MIN);
if (!read_header(header)) {
conn_->close();
logger_error("get header error");
//conn_->close();
//logger_error("get header error");
return NULL;
}
@ -92,7 +92,7 @@ mqtt_message* mqtt_client::get_message(void) {
bool mqtt_client::read_header(mqtt_header& header) {
char ch;
if (!conn_->read(ch)) {
logger_error("read header type error: %s", last_serror());
//logger_error("read header type error: %s", last_serror());
return false;
}