Free packet with no command/callback

Signed-off-by: Andrew Opalach <andrew@akon.city>

3 files changed, 5 insertions, 3 deletions

diff --git a/src/packet_stream.c b/src/packet_stream.c
index 6d90fa7..9064a1f 100644
--- a/src/packet_stream.c
+++ b/src/packet_stream.c
@@ -167,6 +167,7 @@ void aki_packet_stream_listen(struct aki_packet_stream *stream,
     aki_socket_listen(&stream->s, addr, port);
 }
 
+/*
 static void timeout_callback(struct ev_loop *loop, ev_timer *w, s32 revents)
 {
     (void)loop;
@@ -174,6 +175,7 @@ static void timeout_callback(struct ev_loop *loop, ev_timer *w, s32 revents)
     (void)revents;
     if (!stream->connected) stop_internal(stream);
 }
+*/
 
 static void start_write_internal(struct aki_packet_stream *stream)
 {
diff --git a/src/rpc.c b/src/rpc.c
index 90790e2..e385951 100644
--- a/src/rpc.c
+++ b/src/rpc.c
@@ -18,7 +18,7 @@ static void packet_callback(void *userdata, struct aki_packet_stream *s, struct
             if (callback->id == id) {
                 callback->callback(callback->userdata, packet);
                 al_array_remove_at_iter(conn->callbacks, i);
-                break;
+                return;
             }
         }
     } else { // Command
@@ -33,10 +33,11 @@ static void packet_callback(void *userdata, struct aki_packet_stream *s, struct
                 } else {
                     aki_packet_free(rpacket);
                 }
-                break;
+                return;
             }
         }
     }
+    aki_packet_free(packet);
 }
 
 static void packet_sent_callback(void *userdata, struct aki_packet *packet)
diff --git a/src/util/thread/thread_linux.c b/src/util/thread/thread_linux.c
index 0214ed8..e1d694c 100644
--- a/src/util/thread/thread_linux.c
+++ b/src/util/thread/thread_linux.c
@@ -1,5 +1,4 @@
 #include <al/types.h>
-#include <time.h>
 
 #include "../error.h"