summaryrefslogtreecommitdiff
path: root/Userland/Libraries/LibAudio/ConnectionFromClient.h
diff options
context:
space:
mode:
authorkleines Filmröllchen <filmroellchen@serenityos.org>2022-07-17 11:31:01 +0200
committerLinus Groh <mail@linusgroh.de>2022-07-19 11:17:45 +0100
commit3f59356c79a044e7f2c49a7e456f8309d47508fd (patch)
tree86a7b701f55a40c97be5d7b02a545aa91c67d076 /Userland/Libraries/LibAudio/ConnectionFromClient.h
parent70846d701cc117176eca150c54649639ec5e8337 (diff)
downloadserenity-3f59356c79a044e7f2c49a7e456f8309d47508fd.zip
LibAudio: Rename ConnectionFromClient to ConnectionToServer
The automatic nomenclature change for IPC sockets got this one wrong.
Diffstat (limited to 'Userland/Libraries/LibAudio/ConnectionFromClient.h')
-rw-r--r--Userland/Libraries/LibAudio/ConnectionFromClient.h93
1 files changed, 0 insertions, 93 deletions
diff --git a/Userland/Libraries/LibAudio/ConnectionFromClient.h b/Userland/Libraries/LibAudio/ConnectionFromClient.h
deleted file mode 100644
index b74e553bc8..0000000000
--- a/Userland/Libraries/LibAudio/ConnectionFromClient.h
+++ /dev/null
@@ -1,93 +0,0 @@
-/*
- * Copyright (c) 2018-2020, Andreas Kling <kling@serenityos.org>
- * Copyright (c) 2022, kleines Filmröllchen <filmroellchen@serenityos.org>
- *
- * SPDX-License-Identifier: BSD-2-Clause
- */
-
-#pragma once
-
-#include <AK/Concepts.h>
-#include <AK/FixedArray.h>
-#include <AK/NonnullOwnPtr.h>
-#include <AK/OwnPtr.h>
-#include <LibAudio/Queue.h>
-#include <LibAudio/UserSampleQueue.h>
-#include <LibCore/EventLoop.h>
-#include <LibCore/Object.h>
-#include <LibIPC/ConnectionToServer.h>
-#include <LibThreading/Mutex.h>
-#include <LibThreading/Thread.h>
-#include <Userland/Services/AudioServer/AudioClientEndpoint.h>
-#include <Userland/Services/AudioServer/AudioServerEndpoint.h>
-
-namespace Audio {
-
-class ConnectionFromClient final
- : public IPC::ConnectionToServer<AudioClientEndpoint, AudioServerEndpoint>
- , public AudioClientEndpoint {
- IPC_CLIENT_CONNECTION(ConnectionFromClient, "/tmp/portal/audio")
-public:
- virtual ~ConnectionFromClient() override;
-
- // Both of these APIs are for convenience and when you don't care about real-time behavior.
- // They will not work properly in conjunction with realtime_enqueue.
- // If you don't refill the buffer in time with this API, the last shared buffer write is zero-padded to play all of the samples.
- template<ArrayLike<Sample> Samples>
- ErrorOr<void> async_enqueue(Samples&& samples)
- {
- return async_enqueue(TRY(FixedArray<Sample>::try_create(samples.span())));
- }
-
- ErrorOr<void> async_enqueue(FixedArray<Sample>&& samples);
-
- void clear_client_buffer();
-
- // Returns immediately with the appropriate status if the buffer is full; use in conjunction with remaining_buffers to get low latency.
- ErrorOr<void, AudioQueue::QueueStatus> realtime_enqueue(Array<Sample, AUDIO_BUFFER_SIZE> samples);
-
- // This information can be deducted from the shared audio buffer.
- unsigned total_played_samples() const;
- // How many samples remain in m_enqueued_samples.
- unsigned remaining_samples();
- // How many buffers (i.e. short sample arrays) the server hasn't played yet.
- // Non-realtime code needn't worry about this.
- size_t remaining_buffers() const;
-
- virtual void die() override;
-
- Function<void(bool muted)> on_main_mix_muted_state_change;
- Function<void(double volume)> on_main_mix_volume_change;
- Function<void(double volume)> on_client_volume_change;
-
-private:
- ConnectionFromClient(NonnullOwnPtr<Core::Stream::LocalSocket>);
-
- virtual void main_mix_muted_state_changed(bool) override;
- virtual void main_mix_volume_changed(double) override;
- virtual void client_volume_changed(double) override;
-
- // We use this to perform the audio enqueuing on the background thread's event loop
- virtual void custom_event(Core::CustomEvent&) override;
-
- // FIXME: This should be called every time the sample rate changes, but we just cautiously call it on every non-realtime enqueue.
- void update_good_sleep_time();
-
- // Shared audio buffer: both server and client constantly read and write to/from this.
- // This needn't be mutex protected: it's internally multi-threading aware.
- OwnPtr<AudioQueue> m_buffer;
-
- // The queue of non-realtime audio provided by the user.
- NonnullOwnPtr<UserSampleQueue> m_user_queue;
-
- NonnullRefPtr<Threading::Thread> m_background_audio_enqueuer;
- Core::EventLoop* m_enqueuer_loop;
- Threading::Mutex m_enqueuer_loop_destruction;
- Atomic<bool> m_audio_enqueuer_active { false };
-
- // A good amount of time to sleep when the queue is full.
- // (Only used for non-realtime enqueues)
- timespec m_good_sleep_time {};
-};
-
-}