AudioServer: Broadcast muted state changes to all clients

Libraries/LibAudio/AClientConnection.cpp

@@ -77,6 +77,14 @@ int AClientConnection::get_playing_buffer()
     return send_sync<AudioServer::GetPlayingBuffer>()->buffer_id();
 }
 
-void AClientConnection::handle(const AudioClient::FinishedPlayingBuffer&)
+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());
 }

Libraries/LibAudio/AClientConnection.h

@@ -29,6 +29,10 @@ public:
     void set_paused(bool paused);
     void clear_buffer(bool paused = false);
 
+    Function<void(i32 buffer_id)> on_finish_playing_buffer;
+    Function<void(bool muted)> on_muted_state_change;
+
 private:
     virtual void handle(const AudioClient::FinishedPlayingBuffer&) override;
+    virtual void handle(const AudioClient::MutedStateChanged&) override;
 };

Servers/AudioServer/ASClientConnection.cpp

@@ -13,6 +13,15 @@
 
 static HashMap<int, RefPtr<ASClientConnection>> s_connections;
 
+void ASClientConnection::for_each(Function<void(ASClientConnection&)> callback)
+{
+    NonnullRefPtrVector<ASClientConnection> connections;
+    for (auto& it : s_connections)
+        connections.append(*it.value);
+    for (auto& connection : connections)
+        callback(connection);
+}
+
 ASClientConnection::ASClientConnection(CLocalSocket& client_socket, int client_id, ASMixer& mixer)
     : ConnectionNG(*this, client_socket, client_id)
     , m_mixer(mixer)
@@ -34,6 +43,11 @@ void ASClientConnection::did_finish_playing_buffer(Badge<ASBufferQueue>, int buf
     post_message(AudioClient::FinishedPlayingBuffer(buffer_id));
 }
 
+void ASClientConnection::did_change_muted_state(Badge<ASMixer>, bool muted)
+{
+    post_message(AudioClient::MutedStateChanged(muted));
+}
+
 OwnPtr<AudioServer::GreetResponse> ASClientConnection::handle(const AudioServer::Greet& message)
 {
     set_client_pid(message.client_pid());

Servers/AudioServer/ASClientConnection.h

@@ -13,10 +13,14 @@ class ASClientConnection final : public IPC::Server::ConnectionNG<AudioServerEnd
 public:
     explicit ASClientConnection(CLocalSocket&, int client_id, ASMixer& mixer);
     ~ASClientConnection() override;
+
     void did_finish_playing_buffer(Badge<ASBufferQueue>, int buffer_id);
+    void did_change_muted_state(Badge<ASMixer>, bool muted);
 
     virtual void die() override;
 
+    static void for_each(Function<void(ASClientConnection&)>);
+
 private:
     virtual OwnPtr<AudioServer::GreetResponse> handle(const AudioServer::Greet&) override;
     virtual OwnPtr<AudioServer::GetMainMixVolumeResponse> handle(const AudioServer::GetMainMixVolume&) override;

Servers/AudioServer/ASMixer.cpp

@@ -101,7 +101,12 @@ void ASMixer::mix()
 
 void ASMixer::set_muted(bool muted)
 {
+    if (m_muted == muted)
+        return;
     m_muted = muted;
+    ASClientConnection::for_each([muted](ASClientConnection& client) {
+        client.did_change_muted_state({}, muted);
+    });
 }
 
 ASBufferQueue::ASBufferQueue(ASClientConnection& client)

Servers/AudioServer/AudioClient.ipc

@@ -1,4 +1,5 @@
 endpoint AudioClient = 82
 {
     FinishedPlayingBuffer(i32 buffer_id) =|
+    MutedStateChanged(bool muted) =|
 }