Piping for audio decoding.

remoting/client/audio_decode_scheduler.h

Index: remoting/client/audio_decode_scheduler.h
diff --git a/remoting/client/audio_decode_scheduler.h b/remoting/client/audio_decode_scheduler.h
new file mode 100644
index 0000000000000000000000000000000000000000..be5cfcfae2d1635ff9f1605eef475d31c1d52f31
--- /dev/null
+++ b/remoting/client/audio_decode_scheduler.h
@@ -0,0 +1,59 @@
+// Copyright (c) 2012 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#ifndef REMOTING_CLIENT_AUDIO_DECODE_SCHEDULER_H_
+#define REMOTING_CLIENT_AUDIO_DECODE_SCHEDULER_H_
+
+#include "base/memory/ref_counted.h"
+#include "base/memory/scoped_ptr.h"
+#include "remoting/protocol/audio_stub.h"
+
+namespace base {
+class SingleThreadTaskRunner;
+}  // namespace base
+
+namespace remoting {
+
+namespace protocol {
+class SessionConfig;
+}  // namespace protocol
+
+class AudioDecoder;
+class AudioPacket;
+class AudioPlayer;
+
+class AudioDecodeScheduler : public protocol::AudioStub {
+ public:
+  AudioDecodeScheduler(
+      scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,

[Wez, 2012/08/07 18:29:05]

nit: It's not clear what it means for this to be the "main" TaskRunner; it's the
TaskRunner we expect our AudioStub API to be called on, and the one that we
dispatch to the AudioPlayer on, so you might call it the "playback" TaskRunner,
or simply add a comment to clarify how the two TaskRunners will be used.

+      scoped_refptr<base::SingleThreadTaskRunner> audio_decode_task_runner,
+      scoped_ptr<AudioPlayer> audio_player);
+  virtual ~AudioDecodeScheduler();
+
+  // Initializes decoder with the information from the protocol config.
+  void Initialize(const protocol::SessionConfig& config);
+
+  // AudioStub implementation.
+  virtual void ProcessAudioPacket(scoped_ptr<AudioPacket> packet,
+                                  const base::Closure& done) OVERRIDE;
+
+ private:
+  // Called on the audio decoder thread.
+  void DecodePacket(scoped_ptr<AudioPacket> packet, const base::Closure& done);
+
+  // Called on the main thread.
+  void ProcessDecodedPacket(scoped_ptr<AudioPacket> packet,
+                            const base::Closure& done);
+
+  scoped_refptr<base::SingleThreadTaskRunner> main_task_runner_;
+  scoped_refptr<base::SingleThreadTaskRunner> audio_decode_task_runner_;
+  scoped_ptr<AudioDecoder> decoder_;
+  scoped_ptr<AudioPlayer> audio_player_;
+
+  DISALLOW_COPY_AND_ASSIGN(AudioDecodeScheduler);
+};
+
+}  // namespace remoting
+
+#endif  // REMOTING_CLIENT_AUDIO_DECODE_SCHEDULER_H_