mirror of
https://github.com/eclipse/paho.mqtt-sn.embedded-c.git
synced 2025-12-15 16:36:52 +01:00
@@ -161,7 +161,7 @@ void BrokerRecvTask::run(void)
|
|||||||
|
|
||||||
delete packet;
|
delete packet;
|
||||||
|
|
||||||
if ( (rc == -1 || rc == -2) && client->isActive() )
|
if ( (rc == -1 || rc == -2) && ( client->isActive() || client->isSleep() || client->isAwake() ))
|
||||||
{
|
{
|
||||||
/* disconnect the client */
|
/* disconnect the client */
|
||||||
packet = new MQTTGWPacket();
|
packet = new MQTTGWPacket();
|
||||||
|
|||||||
@@ -359,6 +359,9 @@ void PacketHandleTask::transparentPacketHandler(Client*client, MQTTGWPacket* pac
|
|||||||
case UNSUBACK:
|
case UNSUBACK:
|
||||||
_mqttSubscribe->handleUnsuback(client, packet);
|
_mqttSubscribe->handleUnsuback(client, packet);
|
||||||
break;
|
break;
|
||||||
|
case DISCONNECT:
|
||||||
|
client->disconnected(); // Just change Client's status to "Disconnected"
|
||||||
|
break;
|
||||||
default:
|
default:
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user