Support for parsing encrypted WebM streams by src.

media/tools/demuxer_bench/demuxer_bench.cc

 // 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.
 //
 // demuxer_bench is a standalone benchmarking tool for FFmpegDemuxer. It
 // simulates the reading requirements for playback by reading from the stream
 // that has the earliest timestamp.
 
 #include <iostream>
 
@@ skipping 25 matching lines @@
  private:
   DISALLOW_COPY_AND_ASSIGN(DemuxerHostImpl);
 };
 
 void QuitLoopWithStatus(MessageLoop* message_loop,
                         media::PipelineStatus status) {
   CHECK_EQ(status, media::PIPELINE_OK);
   message_loop->PostTask(FROM_HERE, MessageLoop::QuitWhenIdleClosure());
 }
 
+static void NeedKey(const std::string& type, scoped_array<uint8> init_data,
+             int init_data_size) {
+  LOG(INFO) << "File is encrypted.";
+}
+
 typedef std::vector<scoped_refptr<media::DemuxerStream> > Streams;
 
 // Simulates playback reading requirements by reading from each stream
 // present in |demuxer| in as-close-to-monotonically-increasing timestamp order.
 class StreamReader {
  public:
   explicit StreamReader(const scoped_refptr<media::Demuxer>& demuxer);
   ~StreamReader();
 
   // Performs a single step read.
@@ skipping 114 matching lines @@
 
   MessageLoop message_loop;
   DemuxerHostImpl demuxer_host;
   base::FilePath file_path(cmd_line->GetArgs()[0]);
 
   // Setup.
   scoped_refptr<media::FileDataSource> data_source =
       new media::FileDataSource();
   CHECK(data_source->Initialize(file_path));
 
+  media::FFmpegNeedKeyCB need_key_cb = base::Bind(&NeedKey);
   scoped_refptr<media::FFmpegDemuxer> demuxer =
-      new media::FFmpegDemuxer(message_loop.message_loop_proxy(), data_source);
+      new media::FFmpegDemuxer(message_loop.message_loop_proxy(), data_source,
+                               need_key_cb);
 
   demuxer->Initialize(&demuxer_host, base::Bind(
       &QuitLoopWithStatus, &message_loop));
   message_loop.Run();
 
   StreamReader stream_reader(demuxer);
 
   // Benchmark.
   base::TimeTicks start = base::TimeTicks::HighResNow();
   while (!stream_reader.IsDone()) {
@@ skipping 18 matching lines @@
     std::cout << ", " << stream_reader.counts()[i] << " packets" << std::endl;
   }
 
   // Teardown.
   demuxer->Stop(base::Bind(
       &QuitLoopWithStatus, &message_loop, media::PIPELINE_OK));
   message_loop.Run();
 
   return 0;
 }