Finish server reuse connection, move loop to list

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

1 files changed, 4 insertions, 1 deletions

diff --git a/src/server/server.c b/src/server/server.c
index b7276eb..8373296 100644
--- a/src/server/server.c
+++ b/src/server/server.c
@@ -141,6 +141,7 @@ static void list_sink_callback(void *userdata, u8 op, struct lia_list_entry *ent
         nn_packet_write_u64(packet, timing->seek_pos);
         nn_packet_write_u8(packet, timing->pause);
         nn_packet_write_bool(packet, timing->ended);
+        nn_packet_write_u32(packet, entry->reset_id);
         nn_rpc_connection_command(sink->conn, packet, NULL, NULL);
         break;
     }
@@ -165,6 +166,7 @@ static void list_sink_callback(void *userdata, u8 op, struct lia_list_entry *ent
         nn_packet_write_s32(packet, sequence);
         nn_packet_write_u64(packet, timing->at);
         nn_packet_write_u64(packet, timing->seek_pos);
+        nn_packet_write_u32(packet, entry->reset_id);
         nn_rpc_connection_command(sink->conn, packet, NULL, NULL);
         break;
     }
@@ -553,7 +555,8 @@ static bool list_action_callback(void *userdata, struct nn_rpc_connection *conn,
     }
     case CAMU_LIST_END: {
         u32 id = nn_packet_read_u32(packet);
-        lia_list_end(list, id);
+        u32 reset_id = nn_packet_read_u32(packet);
+        lia_list_end(list, id, reset_id);
         break;
     }
     }