DevTools: Parallelize trace messages serialization.

content/browser/media/webrtc_getusermedia_browsertest.cc

 // Copyright 2014 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 "base/command_line.h"
 #include "base/debug/trace_event_impl.h"
 #include "base/json/json_reader.h"
 #include "base/strings/stringprintf.h"
 #include "base/test/trace_event_analyzer.h"
 #include "base/values.h"
@@ skipping 78 matching lines @@
                            base::debug::TraceLog::RECORDING_MODE,
                            trace_options);
     // Check that we are indeed recording.
     EXPECT_EQ(trace_log_->GetNumTracesRecorded(), 1);
   }
 
   void StopTracing() {
     CHECK(message_loop_runner_.get() == NULL)
         << "Calling StopTracing more than once";
     trace_log_->SetDisabled();
+    message_loop_proxy_ = base::MessageLoopProxy::current();
     message_loop_runner_ = new MessageLoopRunner;
     trace_log_->Flush(base::Bind(
         &WebRtcGetUserMediaBrowserTest::OnTraceDataCollected,
         base::Unretained(this)));
     message_loop_runner_->Run();
   }
 
   void OnTraceDataCollected(
       const scoped_refptr<base::RefCountedString>& events_str_ptr,
       bool has_more_events) {
     CHECK(!has_more_events);
+    if (!message_loop_proxy_->BelongsToCurrentThread()) {
+      message_loop_proxy_->PostTask(
+          FROM_HERE,
+          Bind(&WebRtcGetUserMediaBrowserTest::OnTraceDataCollected,
+               base::Unretained(this), events_str_ptr, has_more_events));
+      return;
+    }
     recorded_trace_data_ = events_str_ptr;
     message_loop_runner_->Quit();
   }
 
   TraceAnalyzer* CreateTraceAnalyzer() {
     return TraceAnalyzer::Create("[" + recorded_trace_data_->data() + "]");
   }
 
   void RunGetUserMediaAndCollectMeasures(const int time_to_sample_secs,
                                          const std::string& measure_filter,
@@ skipping 107 matching lines @@
       }
     }
     ASSERT_FALSE(audio_ids->empty());
     ASSERT_FALSE(video_ids->empty());
   }
 
  private:
   base::debug::TraceLog* trace_log_;
   scoped_refptr<base::RefCountedString> recorded_trace_data_;
   scoped_refptr<MessageLoopRunner> message_loop_runner_;
+  scoped_refptr<base::MessageLoopProxy> message_loop_proxy_;
 };
 
 // These tests will all make a getUserMedia call with different constraints and
 // see that the success callback is called. If the error callback is called or
 // none of the callbacks are called the tests will simply time out and fail.
 IN_PROC_BROWSER_TEST_F(WebRtcGetUserMediaBrowserTest, GetVideoStreamAndStop) {
   ASSERT_TRUE(embedded_test_server()->InitializeAndWaitUntilReady());
 
   GURL url(embedded_test_server()->GetURL("/media/getusermedia.html"));
   NavigateToURL(shell(), url);
@@ skipping 403 matching lines @@
     {640, 640, 360, 360, 10, 30},
     {640, 640, 480, 480, 10, 30},
     {960, 960, 720, 720, 10, 30},
     {1280, 1280, 720, 720, 10, 30}};
 
 INSTANTIATE_TEST_CASE_P(UserMedia,
                         WebRtcConstraintsBrowserTest,
                         testing::ValuesIn(kAllUserMediaSizes));
 
 }  // namespace content