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 | |
| parent | 26c4816e77692f51dfbb19fe3e73f082d1ace1a7 (diff) | |
| download | mqtt-b2cfc193e287a2ab4461a1da37ddcc499f1cac68.tar.gz mqtt-b2cfc193e287a2ab4461a1da37ddcc499f1cac68.zip | |
Fixes to make valgrind happy
| -rw-r--r-- | src/client.c | 17 | ||||
| -rw-r--r-- | tools/pub.c | 2 |
2 files changed, 4 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; } diff --git a/tools/pub.c b/tools/pub.c index 9b5af82..781509c 100644 --- a/tools/pub.c +++ b/tools/pub.c @@ -92,5 +92,7 @@ int main(int argc, char **argv) MqttClientRun(client); + MqttClientFree(client); + return 0; } |