diff options
| author | Oskari Timperi <oskari.timperi@iki.fi> | 2017-02-14 23:06:59 +0200 |
|---|---|---|
| committer | Oskari Timperi <oskari.timperi@iki.fi> | 2017-02-14 23:06:59 +0200 |
| commit | b2cfc193e287a2ab4461a1da37ddcc499f1cac68 (patch) | |
| tree | 8b43168818dded3d3eb11f0b88cbf17a32c169bc /src | |
| parent | 26c4816e77692f51dfbb19fe3e73f082d1ace1a7 (diff) | |
| download | mqtt-b2cfc193e287a2ab4461a1da37ddcc499f1cac68.tar.gz mqtt-b2cfc193e287a2ab4461a1da37ddcc499f1cac68.zip | |
Fixes to make valgrind happy
Diffstat (limited to 'src')
| -rw-r--r-- | src/client.c | 17 |
1 files changed, 2 insertions, 15 deletions
diff --git a/src/client.c b/src/client.c index 12c65a6..e7739ad 100644 --- a/src/client.c +++ b/src/client.c @@ -657,8 +657,6 @@ static void MqttClientHandleSubAck(MqttClient *client, MqttPacketSubAck *packet) packet->returnCode); } } - - MqttPacketFree((MqttPacket *) packet); } static void MqttClientHandlePublish(MqttClient *client, MqttPacketPublish *packet) @@ -684,7 +682,6 @@ static void MqttClientHandlePublish(MqttClient *client, MqttPacketPublish *packe { LOG_DEBUG("resending PUBREC id:%d", MqttPacketId(packet)); MqttClientQueuePacket(client, pubRec); - MqttPacketFree((MqttPacket *) packet); return; } } @@ -713,8 +710,6 @@ static void MqttClientHandlePublish(MqttClient *client, MqttPacketPublish *packe MqttClientQueuePacket(client, resp); } - - MqttPacketFree((MqttPacket *) packet); } static void MqttClientHandlePubAck(MqttClient *client, MqttPacket *packet) @@ -745,8 +740,6 @@ static void MqttClientHandlePubAck(MqttClient *client, MqttPacket *packet) client->onPublish(client, MqttPacketId(packet)); } } - - MqttPacketFree(packet); } static void MqttClientHandlePubRec(MqttClient *client, MqttPacket *packet) @@ -782,8 +775,6 @@ static void MqttClientHandlePubRec(MqttClient *client, MqttPacket *packet) TAILQ_INSERT_TAIL(&client->outMessages, pubRel, messages); } - - MqttPacketFree(packet); } static void MqttClientHandlePubRel(MqttClient *client, MqttPacket *packet) @@ -839,8 +830,6 @@ static void MqttClientHandlePubRel(MqttClient *client, MqttPacket *packet) MqttClientQueuePacket(client, pubComp); } - - MqttPacketFree(packet); } static void MqttClientHandlePubComp(MqttClient *client, MqttPacket *packet) @@ -872,8 +861,6 @@ static void MqttClientHandlePubComp(MqttClient *client, MqttPacket *packet) client->onPublish(client, MqttPacketId(packet)); } } - - MqttPacketFree(packet); } static void MqttClientHandleUnsubAck(MqttClient *client, MqttPacket *packet) @@ -908,8 +895,6 @@ static void MqttClientHandleUnsubAck(MqttClient *client, MqttPacket *packet) client->onUnsubscribe(client, MqttPacketId(packet)); } } - - MqttPacketFree(packet); } static int MqttClientRecvPacket(MqttClient *client) @@ -964,6 +949,8 @@ static int MqttClientRecvPacket(MqttClient *client) break; } + MqttPacketFree(packet); + return 0; } |