COM replaced with RPC for firing events in broker.

ceee/ie/broker/executors_manager.cc

 // Copyright (c) 2010 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.
 //
 // ExecutorsManager implementation.
 
 #include "ceee/ie/broker/executors_manager.h"
 
 #include "base/logging.h"
 #include "ceee/ie/broker/broker_module_util.h"
@@ skipping 69 matching lines @@
     CHandle thread_handle(::OpenThread(SYNCHRONIZE, FALSE, thread_id));
     if (thread_handle == NULL) {
       DCHECK(false) << "Can't Open thread: " << thread_id;
       return E_UNEXPECTED;
     }
     ExecutorInfo& new_executor_info = executors_[thread_id];
     new_executor_info.executor = executor;
     new_executor_info.thread_handle = thread_handle;
   }  // End of lock.
 
-  if (map_was_empty) {
-    // We go from empty to not empty,
-    // so lock the module to make sure we stay alive.
-    ceee_module_util::LockModule();
-  }
   return S_OK;
 }
 
 HRESULT ExecutorsManager::RegisterWindowExecutor(ThreadId thread_id,
                                                  IUnknown* executor) {
   // We need to fetch the event handle associated to this thread ID from
   // our map in a thread safe way...
   CHandle executor_registration_gate;
   {
     AutoLock lock(lock_);
@@ skipping 35 matching lines @@
   {
     AutoLock lock(lock_);
     map_was_empty = executors_.empty();
     // We should not get here if we already have an executor for that thread.
     DCHECK(executors_.find(thread_id) == executors_.end());
     ExecutorInfo& new_executor_info = executors_[thread_id];
     new_executor_info.executor = executor;
     new_executor_info.thread_handle = thread_handle;
   }  // End of lock.
 
-  if (map_was_empty) {
-    // We go from empty to not empty,
-    // so lock the module to make sure we stay alive.
-    ceee_module_util::LockModule();
-  }
-
-  // Update the list of handles that our thread is waiting on.
   BOOL success = ::SetEvent(update_threads_list_gate_);
   DCHECK(success);
   return S_OK;
 }
 
 HRESULT ExecutorsManager::GetExecutor(ThreadId thread_id, HWND window,
                                       REFIID riid, void** executor) {
   DCHECK(executor != NULL);
   // We may need to wait for either a currently pending
   // or own newly created registration of a new executor.
@@ skipping 92 matching lines @@
     ExecutorsMap::iterator iter = executors_.find(thread_id);
     if (iter == executors_.end()) {
       return S_FALSE;
     }
 
     dead_executor.Attach(iter->second.executor.Detach());
     executors_.erase(iter);
     map_is_empty = executors_.empty();
   }  // End of lock.
 
-  if (map_is_empty) {
-    // We go from not empty to empty,
-    // so unlock the module it can leave in peace.
-    ceee_module_util::UnlockModule();
-  }
   return S_OK;
 }
 
 HRESULT ExecutorsManager::Terminate() {
   if (thread_ != NULL) {
     // Ask our thread to quit and wait for it to be done.
     DWORD result = ::SignalObjectAndWait(termination_gate_, thread_, kTimeOut,
                                          FALSE);
     DCHECK(result == WAIT_OBJECT_0);
     thread_.Close();
   }
   if (!executors_.empty()) {
     // TODO(mad@chromium.org): Can this happen???
     NOTREACHED();
-    ceee_module_util::UnlockModule();
   }
 
   executors_.clear();
   update_threads_list_gate_.Close();
   termination_gate_.Close();
 
   return S_OK;
 }
 
 void ExecutorsManager::SetTabIdForHandle(long tab_id, HWND handle) {
@@ skipping 145 matching lines @@
     } else {
       DCHECK(result == WAIT_FAILED);
       LOG(ERROR) << "ExecutorsManager::ThreadProc " << com::LogWe();
       break;
     }
   }
   // Merci... Bonsoir...
   ::CoUninitialize();
   return 1;
 }