diff options
| author | Oskari Timperi <oskari.timperi@iki.fi> | 2017-02-12 23:50:54 +0200 |
|---|---|---|
| committer | Oskari Timperi <oskari.timperi@iki.fi> | 2017-02-12 23:50:54 +0200 |
| commit | b8ab5e2d6b3f34f4c56b906130ba63173df8f2d0 (patch) | |
| tree | 24e1c88bb75c2e439ce95c312bb54c9867ac531a /src/client.c | |
| parent | c742eeb2a4192f05b5e594830fafea116243b431 (diff) | |
| download | mqtt-b8ab5e2d6b3f34f4c56b906130ba63173df8f2d0.tar.gz mqtt-b8ab5e2d6b3f34f4c56b906130ba63173df8f2d0.zip | |
Fixes to make code to almost compile on -std=c89 setting
Diffstat (limited to 'src/client.c')
| -rw-r--r-- | src/client.c | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/client.c b/src/client.c index aaebad3..09d8455 100644 --- a/src/client.c +++ b/src/client.c @@ -342,8 +342,8 @@ int MqttClientRunOnce(MqttClient *client) FD_SET(client->stream.sock, &wfd); } - // TODO: break select when queuing packets (need to protect queue with mutex - // to allow queuing packets from another thread) + /* TODO: break select when queuing packets (need to protect queue with + mutex to allow queuing packets from another thread) */ memset(&tv, 0, sizeof(tv)); tv.tv_sec = client->keepAlive; @@ -749,7 +749,6 @@ static void MqttClientHandlePublish(MqttClient *client, MqttPacketPublish *packe if (pubRec) { LOG_DEBUG("resending PUBREC id:%d", MqttPacketId(packet)); - // MqttPacketWithId *pubRec = (MqttPacketWithId *) pubRecNode->packet; MqttClientQueuePacket(client, pubRec); MqttPacketFree((MqttPacket *) packet); return; |