diff options
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/server.c | 6 |
1 files changed, 5 insertions, 1 deletions
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); |