From 692785bc9da6904cf17e986fb034730ed3d78231 Mon Sep 17 00:00:00 2001 From: Andrew Opalach Date: Sat, 14 Dec 2024 11:13:38 -0500 Subject: Work on pause and seek Signed-off-by: Andrew Opalach --- src/server/server.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'src/server') diff --git a/src/server/server.c b/src/server/server.c index f53eb52..109be14 100644 --- a/src/server/server.c +++ b/src/server/server.c @@ -144,9 +144,11 @@ static void list_sink_callback(void *userdata, u8 op, struct lia_list_entry *ent aki_packet_write_u8(packet, op); aki_packet_write_str(packet, &sink->server->addr); aki_packet_write_u16(packet, CAMU_PORT); - aki_packet_write_u16(packet, resource->node->id); + aki_packet_write_u32(packet, resource->node->id); + aki_packet_write_u32(packet, entry->id); aki_packet_write_s32(packet, sequence); aki_packet_write_u64(packet, timing->at); + al_assert(timing->seek_pos <= INT64_MAX); aki_packet_write_u64(packet, timing->seek_pos); aki_packet_write_u8(packet, timing->pause); aki_packet_write_bool(packet, timing->previous_ended); @@ -162,6 +164,7 @@ static void list_sink_callback(void *userdata, u8 op, struct lia_list_entry *ent } case LIANA_SINK_PAUSE: { struct aki_packet *packet = aki_rpc_get_packet(sink->conn->rpc, CAMU_SINK_PAUSE); + aki_packet_write_u32(packet, entry->id); aki_packet_write_s32(packet, sequence); aki_packet_write_u64(packet, timing->at); aki_packet_write_u8(packet, timing->pause); @@ -170,6 +173,7 @@ static void list_sink_callback(void *userdata, u8 op, struct lia_list_entry *ent } case LIANA_SINK_SEEK: { struct aki_packet *packet = aki_rpc_get_packet(sink->conn->rpc, CAMU_SINK_SEEK); + aki_packet_write_u32(packet, entry->id); aki_packet_write_s32(packet, sequence); aki_packet_write_u64(packet, timing->at); aki_packet_write_u64(packet, timing->seek_pos); -- cgit v1.2.3-101-g0448