Index: mojo/edk/embedder/embedder.cc |
diff --git a/mojo/edk/embedder/embedder.cc b/mojo/edk/embedder/embedder.cc |
index 4353f9b3ce51e507a0ced57ac383f01bab976aa5..eff59418f260ad42311b84aa06365f731044470d 100644 |
--- a/mojo/edk/embedder/embedder.cc |
+++ b/mojo/edk/embedder/embedder.cc |
@@ -8,7 +8,6 @@ |
#include <stdint.h> |
#include <utility> |
- |
#include "base/atomicops.h" |
#include "base/bind.h" |
#include "base/bind_helpers.h" |
@@ -43,10 +42,6 @@ Core* g_core = nullptr; |
ProcessDelegate* g_process_delegate; |
base::TaskRunner* g_io_thread_task_runner = nullptr; |
-Core* GetCore() { |
- return g_core; |
-} |
- |
} // namespace internal |
void SetMaxMessageSize(size_t bytes) { |
@@ -77,9 +72,7 @@ void SetParentPipeHandle(ScopedPlatformHandle pipe) { |
} |
void Init() { |
- const base::CommandLine& command_line = |
- *base::CommandLine::ForCurrentProcess(); |
- if (command_line.HasSwitch("use-new-edk") && !internal::g_broker) |
+ if (!internal::g_broker) |
BrokerState::GetInstance(); |
DCHECK(!internal::g_platform_support); |
@@ -89,6 +82,12 @@ void Init() { |
internal::g_core = new Core(internal::g_platform_support); |
} |
+void Init(scoped_refptr<base::TaskRunner> io_thread_task_runner) { |
+ Init(); |
+ DCHECK(!internal::g_io_thread_task_runner); |
+ internal::g_io_thread_task_runner = io_thread_task_runner.get(); |
+} |
+ |
MojoResult AsyncWait(MojoHandle handle, |
MojoHandleSignals signals, |
const base::Callback<void(MojoResult)>& callback) { |