Handle EnableBitstreamConverter RPC message

media/remoting/remote_demuxer_stream_adapter.cc

 // Copyright 2016 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 "media/remoting/remote_demuxer_stream_adapter.h"
 
 #include "base/base64.h"
 #include "base/bind.h"
 #include "media/base/bind_to_current_loop.h"
 #include "media/base/decoder_buffer.h"
@@ skipping 98 matching lines @@
 void RemoteDemuxerStreamAdapter::OnReceivedRpc(
     std::unique_ptr<remoting::pb::RpcMessage> message) {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
   DCHECK(message);
   DCHECK(rpc_handle_ == message->handle());
 
   switch (message->proc()) {
     case remoting::pb::RpcMessage::RPC_DS_INITIALIZE:
       Initialize(message->integer_value());
       break;
+    case remoting::pb::RpcMessage::RPC_DS_ENABLEBITSTREAMCONVERTER:
+      EnableBitstreamConverter();
+      break;
     case remoting::pb::RpcMessage::RPC_DS_READUNTIL:
       ReadUntil(std::move(message));
       break;
     default:
       VLOG(2) << "Unknown RPC: " << message->proc();
   }
 }
 
 void RemoteDemuxerStreamAdapter::Initialize(int remote_callback_handle) {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
@@ skipping 39 matching lines @@
       break;
     }
     default:
       NOTREACHED();
   }
   main_task_runner_->PostTask(
       FROM_HERE, base::Bind(&remoting::RpcBroker::SendMessageToRemote,
                             rpc_broker_, base::Passed(&rpc)));
 }
 
+void RemoteDemuxerStreamAdapter::EnableBitstreamConverter() {
+  DCHECK(media_task_runner_->BelongsToCurrentThread());
+  demuxer_stream_->EnableBitstreamConverter();
+}
+
 void RemoteDemuxerStreamAdapter::ReadUntil(
     std::unique_ptr<remoting::pb::RpcMessage> message) {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
   DCHECK(message);
   if (pending_flush_) {
     VLOG(2) << "Skip actions since it's in the flushing state";
     return;
   }
 
   if (processing_read_rpc_) {
@@ skipping 195 matching lines @@
   }
 
   if (write_watcher_.IsWatching()) {
     VLOG(2) << "Cancel mojo data pipe watcher";
     write_watcher_.Cancel();
   }
 }
 
 }  // namespace remoting
 }  // namespace media