Added files for audio readers.

remoting/protocol/audio_reader.h

+// 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_PROTOCOL_AUDIO_READER_H_
+#define REMOTING_PROTOCOL_AUDIO_READER_H_
+
+#include "base/callback.h"
+#include "base/compiler_specific.h"
+#include "remoting/proto/audio.pb.h"
+#include "remoting/protocol/audio_stub.h"
+#include "remoting/protocol/message_reader.h"
+
+namespace net {
+class StreamSocket;
+}  // namespace net
+
+namespace remoting {
+namespace protocol {
+
+class Session;
+class SessionConfig;
+
+class AudioReader {
+ public:
+  static AudioReader* Create(const SessionConfig& config);

[Sergey Ulanov, 2012/06/15 19:35:23]

this should be defined after InitializedCallback.
http://google-styleguide.googlecode.com/svn/trunk/cppguide.xml#Declaration_Order

[kxing, 2012/06/15 19:46:41]

Done.

+
+  // The callback is called when initialization is finished. The
+  // parameter is set to true on success.
+  typedef base::Callback<void(bool)> InitializedCallback;
+
+  AudioReader(AudioPacket::Encoding encoding);

[Sergey Ulanov, 2012/06/15 19:35:23]

Constructors with a single argument must be marked as explicit:
http://google-styleguide.googlecode.com/svn/trunk/cppguide.xml#Explicit_Const...

[kxing, 2012/06/15 19:46:41]

Done.

+
+  virtual ~AudioReader();
+
+  // Initializies the reader. Doesn't take ownership of either |connection|

[Sergey Ulanov, 2012/06/15 19:35:23]

nit: remove the second sentence: we now use scoped_ptr<> to pass ownership, so
the comment is redundant.

[kxing, 2012/06/15 19:46:41]

Done.

+  // or |audio_stub|.
+  void Init(Session* session,
+                    AudioStub* audio_stub,

[Sergey Ulanov, 2012/06/15 19:35:23]

incorrect indentation

[kxing, 2012/06/15 19:46:41]

Done.

+                    const InitializedCallback& callback);
+  bool is_connected();
+
+ private:
+  void OnChannelReady(scoped_ptr<net::StreamSocket> socket);
+  void OnNewData(scoped_ptr<AudioPacket> packet,
+                 const base::Closure& done_task);
+
+  Session* session_;
+
+  InitializedCallback initialized_callback_;
+
+  AudioPacket::Encoding encoding_;
+
+  // TODO(sergeyu): Remove |channel_| and let |reader_| own it.
+  scoped_ptr<net::StreamSocket> channel_;
+
+  ProtobufMessageReader<AudioPacket> reader_;
+
+  // The stub that processes all received packets.
+  AudioStub* audio_stub_;
+
+  DISALLOW_COPY_AND_ASSIGN(AudioReader);
+};
+
+}  // namespace protocol
+}  // namespace remoting
+
+#endif  // REMOTING_PROTOCOL_AUDIO_READER_H_