diff options
| author |   Andrew Opalach <andrew@akon.city>
| 2024-12-14 11:13:38 -0500 |
|---|---|---|
| committer | Andrew Opalach <andrew@akon.city>
| 2024-12-14 11:13:38 -0500 |
| commit | 692785bc9da6904cf17e986fb034730ed3d78231 (patch) | |
| tree | 2f3359db61821adb06412b319600baf02ef1c2ee /src/server | |
| parent | b91a978fcba8d0e938549172c68a07172d63b697 (diff) | |
| download | camu-692785bc9da6904cf17e986fb034730ed3d78231.tar.gz camu-692785bc9da6904cf17e986fb034730ed3d78231.tar.bz2 camu-692785bc9da6904cf17e986fb034730ed3d78231.zip | |
Work on pause and seek
Signed-off-by: Andrew Opalach <andrew@akon.city>
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); |