GitHub/paho.mqtt-sn.embedded-c
1
0
Fork 0
mirror of https://github.com/eclipse/paho.mqtt-sn.embedded-c.git synced 2025-12-13 23:46:51 +01:00
Code Issues Projects Releases Wiki Activity

BugFix BugFix of Issues #41

Browse Source
This commit is contained in:
tomoaki
2016-12-09 13:20:23 +09:00
parent 64f7bbac1b
commit d386541c1a
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
MQTTSNGateway/src/MQTTSNGWBrokerRecvTask.cpp
View File

@@ -119,7 +119,6 @@ void BrokerRecvTask::run(void)
if ( rc > 0 ) if ( rc > 0 )
{ {
if ( log(client, packet) == -1 ) if ( log(client, packet) == -1 )
{ {
delete packet; delete packet;
goto nextClient; goto nextClient;
@@ -132,7 +131,13 @@ void BrokerRecvTask::run(void)
} }
else else
{ {
if (rc == -1) if ( rc == 0 )
{
client->getNetwork()->close();
delete packet;
goto nextClient;
}
else if (rc == -1)
{ {
WRITELOG("%s BrokerRecvTask can't receive a packet from the broker errno=%d %s%s\n", ERRMSG_HEADER, errno, client->getClientId(), ERRMSG_FOOTER); WRITELOG("%s BrokerRecvTask can't receive a packet from the broker errno=%d %s%s\n", ERRMSG_HEADER, errno, client->getClientId(), ERRMSG_FOOTER);
} }