COM replaced with RPC for firing events in broker.

ceee/ie/broker/broker_module.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.
 //
 // Declaration of ATL module object for EXE module.
 
 #include <atlbase.h>
 #include <atlhost.h>
 
 #include "base/at_exit.h"
 #include "base/command_line.h"
 #include "base/debug/trace_event.h"
 #include "base/logging.h"
 #include "base/logging_win.h"
 #include "ceee/ie/broker/broker.h"
+#include "ceee/ie/broker/broker_rpc_server.h"
 #include "ceee/ie/broker/chrome_postman.h"
 #include "ceee/ie/broker/executors_manager.h"
 #include "ceee/ie/broker/resource.h"
 #include "ceee/ie/broker/window_events_funnel.h"
 #include "ceee/ie/common/crash_reporter.h"
 #include "ceee/common/com_utils.h"
 #include "chrome/common/url_constants.h"
 
 namespace {
 
@@ skipping 46 matching lines @@
   }
 
   HRESULT PostMessageLoop();
   HRESULT PreMessageLoop(int show);
  private:
   // We maintain a postman COM object on the stack so that we can
   // properly initialize and terminate it at the right time.
   CComObjectStackEx<ChromePostman> chrome_postman_;
   CrashReporter crash_reporter_;
   base::AtExitManager at_exit_;
+  BrokerRpcServer rpc_server_;
 };
 
 CeeeBrokerModule module;
 
 extern "C" int WINAPI _tWinMain(HINSTANCE, HINSTANCE, LPTSTR, int nShowCmd) {
   return module.WinMain(nShowCmd);
 }
 
 CeeeBrokerModule::CeeeBrokerModule()
     : crash_reporter_(L"ceee_broker") {
@@ skipping 59 matching lines @@
   // The above is best-effort, don't bail on error.
   return S_OK;
 }
 
 HRESULT CeeeBrokerModule::PreMessageLoop(int show) {
   // It's important to initialize the postman BEFORE we make the Broker
   // and the event funnel available, since we may get requests to execute
   // API invocation or Fire events before the postman is ready to handle them.
   chrome_postman_.Init();
   WindowEventsFunnel::Initialize();
+
+  rpc_server_.Start();

[Sigurður Ásgeirsson, 2010/11/12 14:40:24]

Return error from the function on failure, as the broker's no use without the
RPC server. 

[Vitaly Buka corp, 2010/11/12 20:58:48]

Done.

+  DCHECK(rpc_server_.is_started());
+
   return CAtlExeModuleT<CeeeBrokerModule>::PreMessageLoop(show);
 }
 
 HRESULT CeeeBrokerModule::PostMessageLoop() {
   HRESULT hr = CAtlExeModuleT<CeeeBrokerModule>::PostMessageLoop();
   Singleton<ExecutorsManager,
             ExecutorsManager::SingletonTraits>()->Terminate();
   WindowEventsFunnel::Terminate();
   chrome_postman_.Term();
   return hr;
@@ skipping 14 matching lines @@
 
 LONG LockModule() {
   return module.LockModule();
 }
 
 LONG UnlockModule() {
   return module.UnlockModule();
 }
 
 }  // namespace