123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- /*
- * Copyright (c) 2018-2020, Andreas Kling <kling@serenityos.org>
- *
- * SPDX-License-Identifier: BSD-2-Clause
- */
- #include <LibAudio/Buffer.h>
- #include <LibAudio/ConnectionFromClient.h>
- #include <time.h>
- namespace Audio {
- // FIXME: We don't know what is a good value for this.
- // Real-time audio may be improved with a lower value.
- static timespec g_enqueue_wait_time { 0, 10'000'000 };
- ConnectionFromClient::ConnectionFromClient(NonnullOwnPtr<Core::Stream::LocalSocket> socket)
- : IPC::ConnectionToServer<AudioClientEndpoint, AudioServerEndpoint>(*this, move(socket))
- {
- }
- void ConnectionFromClient::enqueue(LegacyBuffer const& buffer)
- {
- for (;;) {
- auto success = enqueue_buffer(buffer.anonymous_buffer(), buffer.id(), buffer.sample_count());
- if (success)
- break;
- nanosleep(&g_enqueue_wait_time, nullptr);
- }
- }
- void ConnectionFromClient::async_enqueue(LegacyBuffer const& buffer)
- {
- async_enqueue_buffer(buffer.anonymous_buffer(), buffer.id(), buffer.sample_count());
- }
- bool ConnectionFromClient::try_enqueue(LegacyBuffer const& buffer)
- {
- return enqueue_buffer(buffer.anonymous_buffer(), buffer.id(), buffer.sample_count());
- }
- void ConnectionFromClient::finished_playing_buffer(i32 buffer_id)
- {
- if (on_finish_playing_buffer)
- on_finish_playing_buffer(buffer_id);
- }
- void ConnectionFromClient::main_mix_muted_state_changed(bool muted)
- {
- if (on_main_mix_muted_state_change)
- on_main_mix_muted_state_change(muted);
- }
- void ConnectionFromClient::main_mix_volume_changed(double volume)
- {
- if (on_main_mix_volume_change)
- on_main_mix_volume_change(volume);
- }
- void ConnectionFromClient::client_volume_changed(double volume)
- {
- if (on_client_volume_change)
- on_client_volume_change(volume);
- }
- }
|