Cast Streaming API end-to-end browser_test.

media/cast/test/utility/standalone_cast_environment.cc

Index: media/cast/test/utility/standalone_cast_environment.cc
diff --git a/media/cast/test/utility/standalone_cast_environment.cc b/media/cast/test/utility/standalone_cast_environment.cc
new file mode 100644
index 0000000000000000000000000000000000000000..7e826209870e9d5b3221494abcccc368d6f4f5b9
--- /dev/null
+++ b/media/cast/test/utility/standalone_cast_environment.cc
@@ -0,0 +1,59 @@
+// 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 "media/cast/test/utility/standalone_cast_environment.h"
+
+#include "base/time/default_tick_clock.h"
+
+namespace media {
+namespace cast {
+
+StandaloneCastEnvironment::StandaloneCastEnvironment(
+    const CastLoggingConfig& logging_config)
+    : CastEnvironment(
+          make_scoped_ptr<base::TickClock>(new base::DefaultTickClock()),
+          NULL,

[hubbe, 2014/03/07 22:48:50]

That's not what I meant...
Why not just pass in the task runners here?

[miu, 2014/03/08 02:20:49]

The base class must be constructed before the derived one.  The
SingleThreadTaskRunner instances are not available until the threads are created
and started below.

+          NULL,
+          NULL,
+          NULL,
+          NULL,
+          NULL,
+          logging_config),
+      main_thread_("StandaloneCastEnvironment Main"),
+      audio_encode_thread_("StandaloneCastEnvironment Audio Encode"),
+      audio_decode_thread_("StandaloneCastEnvironment Audio Decode"),
+      video_encode_thread_("StandaloneCastEnvironment Video Encode"),
+      video_decode_thread_("StandaloneCastEnvironment Video Decode"),
+      transport_thread_("StandaloneCastEnvironment Transport") {
+#define CREATE_TASK_RUNNER(name, options)   \
+  name##_thread_.StartWithOptions(options); \
+  CastEnvironment::name##_thread_proxy_ = name##_thread_.message_loop_proxy()
+
+  CREATE_TASK_RUNNER(main,
+                     base::Thread::Options(base::MessageLoop::TYPE_IO, 0));
+  CREATE_TASK_RUNNER(audio_encode, base::Thread::Options());
+  CREATE_TASK_RUNNER(audio_decode, base::Thread::Options());
+  CREATE_TASK_RUNNER(video_encode, base::Thread::Options());
+  CREATE_TASK_RUNNER(video_decode, base::Thread::Options());
+  CREATE_TASK_RUNNER(transport, base::Thread::Options());
+
+#undef CREATE_TASK_RUNNER
+}
+
+StandaloneCastEnvironment::~StandaloneCastEnvironment() {
+  DCHECK(CalledOnValidThread());
+}
+
+void StandaloneCastEnvironment::Shutdown() {
+  DCHECK(CalledOnValidThread());
+  main_thread_.Stop();
+  audio_encode_thread_.Stop();
+  audio_decode_thread_.Stop();
+  video_encode_thread_.Stop();
+  video_decode_thread_.Stop();
+  transport_thread_.Stop();
+}
+
+}  // namespace cast
+}  // namespace media