Index: remoting/protocol/protobuf_video_writer.cc |
diff --git a/remoting/protocol/protobuf_video_writer.cc b/remoting/protocol/protobuf_video_writer.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..96b4e34503d89ff0014fb844ae8dbf3bf01006d9 |
--- /dev/null |
+++ b/remoting/protocol/protobuf_video_writer.cc |
@@ -0,0 +1,36 @@ |
+// Copyright (c) 2010 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. |
+ |
+#include "remoting/protocol/protobuf_video_writer.h" |
+ |
+#include "remoting/protocol/chromotocol_connection.h" |
+#include "remoting/protocol/rtp_writer.h" |
+#include "remoting/protocol/util.h" |
+ |
+namespace remoting { |
+ |
+ProtobufVideoWriter::ProtobufVideoWriter() { } |
+ |
+ProtobufVideoWriter::~ProtobufVideoWriter() { } |
+ |
+void ProtobufVideoWriter::Init(ChromotocolConnection* connection) { |
+ buffered_writer_ = new BufferedSocketWriter(); |
+ // TODO(sergeyu): Provide WriteFailedCallback for the buffered writer. |
+ buffered_writer_->Init(connection->video_channel(), NULL); |
+} |
+ |
+void ProtobufVideoWriter::SendPacket(const VideoPacket& packet) { |
+ buffered_writer_->Write(SerializeAndFrameMessage(packet)); |
+} |
+ |
+int ProtobufVideoWriter::GetPendingPackets() { |
+ return buffered_writer_->GetBufferChunks(); |
+} |
+ |
+ |
+void ProtobufVideoWriter::Close() { |
+ buffered_writer_->Close(); |
+} |
+ |
+} // namespace remoting |