Add AutoThread types for Windows that initialize COM.

remoting/base/auto_thread.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.
 
 #include "remoting/base/auto_thread.h"
 
 #include "base/bind.h"
 #include "base/lazy_instance.h"
 #include "base/third_party/dynamic_annotations/dynamic_annotations.h"
 #include "base/threading/thread_local.h"
 #include "base/threading/thread_restrictions.h"
 #include "base/synchronization/waitable_event.h"
 #include "remoting/base/auto_thread_task_runner.h"
 
+#if defined(OS_WIN)
+#include "base/win/scoped_com_initializer.h"
+#endif
+
 namespace remoting {
 
+namespace {
+
+MessageLoop::Type AutoThreadToMessageLoopType(AutoThread::Type type) {
+  switch (type) {
+  case AutoThread::TYPE_DEFAULT: return MessageLoop::TYPE_DEFAULT;
+  case AutoThread::TYPE_IO: return MessageLoop::TYPE_IO;
+  case AutoThread::TYPE_UI: return MessageLoop::TYPE_UI;
+#if defined(OS_WIN)
+  case AutoThread::TYPE_UI_COM_STA: return MessageLoop::TYPE_UI;
+  case AutoThread::TYPE_UI_COM_MTA: return MessageLoop::TYPE_UI;
+#endif
+  }
+  NOTREACHED();
+  return MessageLoop::TYPE_DEFAULT;
+}
+
+#if defined(OS_WIN)
+scoped_ptr<base::win::ScopedCOMInitializer> CreateComInitializerForType(
+    AutoThread::Type type) {
+  scoped_ptr<base::win::ScopedCOMInitializer> initializer;
+  if (type == AutoThread::TYPE_UI_COM_STA) {
+    initializer.reset(new base::win::ScopedCOMInitializer());
+  } else if (type == AutoThread::TYPE_UI_COM_MTA) {
+    initializer.reset(new base::win::ScopedCOMInitializer(
+                          base::win::ScopedCOMInitializer::kMTA));
+  }
+  return initializer.Pass();
+}
+#endif
+
+}
+
 // Used to pass data to ThreadMain.  This structure is allocated on the stack
 // from within StartWithType.
 struct AutoThread::StartupData {
-  MessageLoop::Type loop_type;
+  Type loop_type;
 
   // Used to receive the AutoThreadTaskRunner for the thread.
   scoped_refptr<AutoThreadTaskRunner> task_runner;
 
   // Used to synchronize thread startup.
   base::WaitableEvent event;
 
-  explicit StartupData(MessageLoop::Type type)
+  explicit StartupData(Type type)
     : loop_type(type),
       event(false, false) {}
 };
 
 // static
 scoped_refptr<AutoThreadTaskRunner> AutoThread::CreateWithType(
     const char* name,
     scoped_refptr<AutoThreadTaskRunner> joiner,
-    MessageLoop::Type type) {
+    Type type) {
   AutoThread* thread = new AutoThread(name, joiner);
   scoped_refptr<AutoThreadTaskRunner> task_runner = thread->StartWithType(type);
   if (task_runner.get()) {
     return task_runner;
   } else {
     delete thread;
     return NULL;
   }
 }
 
 // static
 scoped_refptr<AutoThreadTaskRunner> AutoThread::Create(
     const char* name, scoped_refptr<AutoThreadTaskRunner> joiner) {
-  return CreateWithType(name, joiner, MessageLoop::TYPE_DEFAULT);
+  return CreateWithType(name, joiner, TYPE_DEFAULT);
 }
 
 AutoThread::AutoThread(const char* name)
   : startup_data_(NULL),
     thread_(0),
     name_(name),
     was_quit_properly_(false) {
 }
 
 AutoThread::AutoThread(const char* name, AutoThreadTaskRunner* joiner)
   : startup_data_(NULL),
     thread_(0),
     name_(name),
     was_quit_properly_(false),
     joiner_(joiner) {
 }
 
 AutoThread::~AutoThread() {
   DCHECK(!startup_data_);
 
   // Wait for the thread to exit.
   if (thread_) {
     base::PlatformThread::Join(thread_);
   }
 }
 
 scoped_refptr<AutoThreadTaskRunner>
-AutoThread::StartWithType(MessageLoop::Type type) {
+AutoThread::StartWithType(Type type) {
   DCHECK(!thread_);
 
   StartupData startup_data(type);
   startup_data_ = &startup_data;
 
   if (!base::PlatformThread::Create(0, this, &thread_)) {
     DLOG(ERROR) << "failed to create thread";
     startup_data_ = NULL;
     return NULL;
   }
 
   // Wait for the thread to start and initialize message_loop_
   // TODO(wez): Since at this point we know the MessageLoop _will_ run, and
   // the thread lifetime is controlled by the AutoThreadTaskRunner, we would
   // ideally return the AutoThreadTaskRunner to the caller without waiting for
   // the thread to signal us.
   base::ThreadRestrictions::ScopedAllowWait allow_wait;
   startup_data.event.Wait();
 
   // set it to NULL so we don't keep a pointer to some object on the stack.
   startup_data_ = NULL;
 
   DCHECK(startup_data.task_runner.get());
   return startup_data.task_runner;
 }
 
 scoped_refptr<AutoThreadTaskRunner> AutoThread::Start() {
-  return StartWithType(MessageLoop::TYPE_DEFAULT);
+  return StartWithType(TYPE_DEFAULT);
 }
 
 void AutoThread::QuitThread(
     scoped_refptr<base::SingleThreadTaskRunner> task_runner) {
   if (!task_runner->BelongsToCurrentThread()) {
     task_runner->PostTask(FROM_HERE, base::Bind(&AutoThread::QuitThread,
                                                 base::Unretained(this),
                                                 task_runner));
     return;
   }
 
   MessageLoop::current()->Quit();
   was_quit_properly_ = true;
 
   if (joiner_) {
     joiner_->PostTask(FROM_HERE, base::Bind(&AutoThread::JoinAndDeleteThread,
                                             base::Unretained(this)));
   }
 }
 
 void AutoThread::JoinAndDeleteThread() {
   delete this;
 }
 
 void AutoThread::ThreadMain() {
   // The message loop for this thread.
-  MessageLoop message_loop(startup_data_->loop_type);
+  MessageLoop message_loop(
+      AutoThreadToMessageLoopType(startup_data_->loop_type));
 
   // Complete the initialization of our AutoThread object.
   base::PlatformThread::SetName(name_.c_str());
   ANNOTATE_THREAD_NAME(name_.c_str());  // Tell the name to race detector.
   message_loop.set_thread_name(name_);
 
   // Return an AutoThreadTaskRunner that will cleanly quit this thread when
   // no more references to it remain.
   startup_data_->task_runner =
       new AutoThreadTaskRunner(message_loop.message_loop_proxy(),
           base::Bind(&AutoThread::QuitThread,
                      base::Unretained(this),
                      message_loop.message_loop_proxy()));
 
   startup_data_->event.Signal();
   // startup_data_ can't be touched anymore since the starting thread is now
   // unlocked.
 
+#if defined(OS_WIN)
+  // Initialize COM on the thread, if requested.
+  scoped_ptr<base::win::ScopedCOMInitializer> com_initializer(
+      CreateComInitializerForType(startup_data_->loop_type));
+#endif
+
   message_loop.Run();
 
   // Assert that MessageLoop::Quit was called by AutoThread::QuitThread.
   DCHECK(was_quit_properly_);
 }
 
 }  // namespace base