diff options
| -rw-r--r-- | src/packet_stream.c | 2 | ||||
| -rw-r--r-- | src/rpc.c | 5 | ||||
| -rw-r--r-- | src/util/thread/thread_linux.c | 1 |
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) { @@ -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" |