2 files changed, 5 insertions, 4 deletions
diff --git a/src/server/server.c b/src/server/server.c
index 7781c05..513e22e 100644
--- a/src/server/server.c
+++ b/src/server/server.c
@@ -225,7 +225,7 @@ void handle_toggle_sink(struct camu_server *server, str *name, struct camu_serve
 
 // One list_pump() call at a single point should be equivalent to any amount in succession.
 // There are two things to consider while within list_pump().
-//  1. An entry that was pending may be freed, making entry->list an invalid statement.
+//  1. An entry that was pending may be freed, making entry->list invalid.
 //  2. resource->pending may be edited (added to).
 // So, we create an array of every list that needs to be pumped and operate on that.
 static void process_pending(struct camu_resource *resource)
@@ -922,6 +922,7 @@ bool camu_server_listen(struct camu_server *server, u8 type, str *addr, u16 port
 
 void camu_server_bind_direct(struct camu_server *server)
 {
+    al_str_from(&server->addr, "[direct]");
     nn_multiplex_direct_init(multiplex_callback, server);
 }
 
@@ -1025,7 +1026,7 @@ void camu_server_local_add(struct camu_server *server, struct nn_packet *packet)
     handle_add_command(server, al_array_last(server->lists), packet);
 }
 
-void camu_server_local_set_index(struct camu_server *server, u32 index)
+void camu_server_local_start_at(struct camu_server *server, s32 index)
 {
-    lia_list_skipto(al_array_last(server->lists), LIANA_SEQUENCE_ANY, index);
+    lia_list_start_at(al_array_last(server->lists), index);
 }
diff --git a/src/server/server.h b/src/server/server.h
index 6552413..3112679 100644
--- a/src/server/server.h
+++ b/src/server/server.h
@@ -57,4 +57,4 @@ void camu_server_free(struct camu_server *server);
 
 // Local compat.
 void camu_server_local_add(struct camu_server *server, struct nn_packet *packet);
-void camu_server_local_set_index(struct camu_server *server, u32 index);
+void camu_server_local_start_at(struct camu_server *server, s32 index);