mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2024-09-20 17:58:18 +03:00
f93c0dc489
Instead of passing the PIDs back and forth in a handshake "Greet" message, just use getsockopt(SO_PEERCRED) on both sides to get the same information from the kernel. This is a nice little simplification of the IPC protocol, although it does not get rid of the handshake since we still have to pass the "client ID" from the server to each client so they know how to refer to themselves. This might not be necessary and we might be able to get rid of this later on.
90 lines
2.2 KiB
C++
90 lines
2.2 KiB
C++
#include <LibAudio/ABuffer.h>
|
|
#include <LibAudio/AClientConnection.h>
|
|
#include <SharedBuffer.h>
|
|
|
|
AClientConnection::AClientConnection()
|
|
: IServerConnection(*this, "/tmp/portal/audio")
|
|
{
|
|
}
|
|
|
|
void AClientConnection::handshake()
|
|
{
|
|
auto response = send_sync<AudioServer::Greet>();
|
|
set_my_client_id(response->client_id());
|
|
}
|
|
|
|
void AClientConnection::enqueue(const ABuffer& buffer)
|
|
{
|
|
for (;;) {
|
|
const_cast<ABuffer&>(buffer).shared_buffer().share_with(server_pid());
|
|
auto response = send_sync<AudioServer::EnqueueBuffer>(buffer.shared_buffer_id(), buffer.sample_count());
|
|
if (response->success())
|
|
break;
|
|
sleep(1);
|
|
}
|
|
}
|
|
|
|
bool AClientConnection::try_enqueue(const ABuffer& buffer)
|
|
{
|
|
const_cast<ABuffer&>(buffer).shared_buffer().share_with(server_pid());
|
|
auto response = send_sync<AudioServer::EnqueueBuffer>(buffer.shared_buffer_id(), buffer.sample_count());
|
|
return response->success();
|
|
}
|
|
|
|
bool AClientConnection::get_muted()
|
|
{
|
|
return send_sync<AudioServer::GetMuted>()->muted();
|
|
}
|
|
|
|
void AClientConnection::set_muted(bool muted)
|
|
{
|
|
send_sync<AudioServer::SetMuted>(muted);
|
|
}
|
|
|
|
int AClientConnection::get_main_mix_volume()
|
|
{
|
|
return send_sync<AudioServer::GetMainMixVolume>()->volume();
|
|
}
|
|
|
|
void AClientConnection::set_main_mix_volume(int volume)
|
|
{
|
|
send_sync<AudioServer::SetMainMixVolume>(volume);
|
|
}
|
|
|
|
int AClientConnection::get_remaining_samples()
|
|
{
|
|
return send_sync<AudioServer::GetRemainingSamples>()->remaining_samples();
|
|
}
|
|
|
|
int AClientConnection::get_played_samples()
|
|
{
|
|
return send_sync<AudioServer::GetPlayedSamples>()->played_samples();
|
|
}
|
|
|
|
void AClientConnection::set_paused(bool paused)
|
|
{
|
|
send_sync<AudioServer::SetPaused>(paused);
|
|
}
|
|
|
|
void AClientConnection::clear_buffer(bool paused)
|
|
{
|
|
send_sync<AudioServer::ClearBuffer>(paused);
|
|
}
|
|
|
|
int AClientConnection::get_playing_buffer()
|
|
{
|
|
return send_sync<AudioServer::GetPlayingBuffer>()->buffer_id();
|
|
}
|
|
|
|
void AClientConnection::handle(const AudioClient::FinishedPlayingBuffer& message)
|
|
{
|
|
if (on_finish_playing_buffer)
|
|
on_finish_playing_buffer(message.buffer_id());
|
|
}
|
|
|
|
void AClientConnection::handle(const AudioClient::MutedStateChanged& message)
|
|
{
|
|
if (on_muted_state_change)
|
|
on_muted_state_change(message.muted());
|
|
}
|