in-chrome viewer for metro

win8/metro_driver/chrome_app_view.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 "win8/metro_driver/stdafx.h"
 #include "win8/metro_driver/chrome_app_view.h"
+#include "win8/metro_driver/direct3d_helper.h"
 
 #include <algorithm>
 #include <windows.applicationModel.datatransfer.h>
 #include <windows.foundation.h>
 
 #include "base/bind.h"
 #include "base/message_loop.h"
 #include "base/win/metro.h"
 
+#include "base/threading/thread.h"
+#include "ipc/ipc_channel.h"
+#include "ipc/ipc_channel_proxy.h"
+#include "ipc/ipc_sender.h"
+
 // This include allows to send WM_SYSCOMMANDs to chrome.
 #include "chrome/app/chrome_command_ids.h"
 #include "win8/metro_driver/winrt_utils.h"
 #include "ui/base/ui_base_switches.h"
 
+//=============================================================================
+

[cpu_(ooo_6.6-7.5), 2012/09/28 21:37:37]

remove this 29 - 60 block.

[scottmg, 2012/09/28 22:14:28]

moved to metro_viewer_messages.cc

+// Get basic type definitions.
+#define IPC_MESSAGE_IMPL
+#include "chrome/common/viewer_messages.h"
+
+// Generate constructors.
+#include "ipc/struct_constructor_macros.h"
+#include "chrome/common/viewer_messages.h"
+
+// Generate destructors.
+#include "ipc/struct_destructor_macros.h"
+#include "chrome/common/viewer_messages.h"
+
+// Generate param traits write methods.
+#include "ipc/param_traits_write_macros.h"
+namespace IPC {
+#include "chrome/common/viewer_messages.h"
+}  // namespace IPC
+
+// Generate param traits read methods.
+#include "ipc/param_traits_read_macros.h"
+namespace IPC {
+#include "chrome/common/viewer_messages.h"
+}  // namespace IPC
+
+// Generate param traits log methods.
+#include "ipc/param_traits_log_macros.h"
+namespace IPC {
+#include "chrome/common/viewer_messages.h"
+}  // namespace IPC
+
+//=============================================================================
+
 typedef winfoundtn::ITypedEventHandler<
     winapp::Core::CoreApplicationView*,
     winapp::Activation::IActivatedEventArgs*> ActivatedHandler;
 
 typedef winfoundtn::ITypedEventHandler<
     winui::Core::CoreWindow*,
     winui::Core::WindowSizeChangedEventArgs*> SizeChangedHandler;
 
 typedef winfoundtn::ITypedEventHandler<
     winui::Input::EdgeGesture*,
@@ skipping 232 matching lines @@
 
     DVLOG(1) << "Hiding current top window:"
             << reinterpret_cast<int>(current_top_window.first);
     AnimateWindow(current_top_window.first, kAnimateWindowTimeoutMs,
                   AW_HIDE | AW_HOR_POSITIVE | AW_SLIDE);
 
     globals.host_windows.push_back(current_top_window);
   }
 }
 
+class ChromeChannelListener : public IPC::Listener {
+ public:
+  virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE {
+    DVLOG(1) << "Received ipc message " << message.type();
+    return true;
+  }
+
+  virtual void OnChannelError() OVERRIDE {
+    DVLOG(1) << "Channel error";
+    MessageLoop::current()->Quit();
+  }
+
+  void Init(IPC::Sender* s) {
+    sender_ = s;
+  }
+
+ private:
+  IPC::Sender* sender_;
+};
+
 }  // namespace
 
 HRESULT ChromeAppView::TileRequestCreateDone(
     winfoundtn::IAsyncOperation<bool>* async,
     AsyncStatus status) {
   if (status == Completed) {
     unsigned char result;
     CheckHR(async->GetResults(&result));
     DVLOG(1) << __FUNCTION__ << " result " << static_cast<int>(result);
   } else {
@@ skipping 413 matching lines @@
   // chrome. Uncomment this once we figure out why they don't fire.
   // RegisterInputPaneNotifications();
 
   hr = winrt_utils::CreateActivationFactory(
       RuntimeClass_Windows_UI_ViewManagement_ApplicationView,
       app_view_.GetAddressOf());
   CheckHR(hr);
 
   DVLOG(1) << "Created appview instance.";
 
+  direct3d_helper_.Initialize(window);
+
+  DVLOG(1) << "Initialized Direct3D.";
+
   hr = devices_handler_.Initialize(window);
   // Don't check or return the failure here, we need to let the app
   // initialization succeed. Even if we won't be able to access devices
   // we still want to allow the app to start.
   LOG_IF(ERROR, FAILED(hr)) << "Failed to initialize devices handler.";
   return S_OK;
 }
 
 IFACEMETHODIMP
 ChromeAppView::Load(HSTRING entryPoint) {
@@ skipping 49 matching lines @@
       }
     }
   }
   MessageLoop::current()->PostDelayedTask(
       FROM_HERE,
       base::Bind(&ChromeAppView::CheckForOSKActivation,
                  base::Unretained(this)),
       base::TimeDelta::FromMilliseconds(kCheckOSKDelayMs));
 }
 
+void SendHwnd(base::Thread* thread, HWND hwnd) {
+  ChromeChannelListener channel_listener;
+  IPC::ChannelProxy chan("viewer", IPC::Channel::MODE_NAMED_CLIENT,

[cpu_(ooo_6.6-7.5), 2012/09/28 21:37:37]

this is the reason the pipe closes, methinks.

[scottmg, 2012/09/28 22:14:28]

Done.

+                         &channel_listener, thread->message_loop_proxy());
+  channel_listener.Init(&chan);
+  chan.Send(new ViewerHostMsg_SetTargetSurface(uint32(hwnd)));
+
+  DVLOG(1) << "ICoreWindow sent " << hwnd;
+}
+
 IFACEMETHODIMP
 ChromeAppView::Run() {
   DVLOG(1) << __FUNCTION__ << ", hwnd=" << LONG_PTR(window_.Get());
   mswr::ComPtr<winui::Core::ICoreDispatcher> dispatcher;
   HRESULT hr = window_->get_Dispatcher(&dispatcher);
   CheckHR(hr, "Dispatcher failed.");
 
   hr = window_->Activate();
   if (SUCCEEDED(hr)) {
     // TODO(cpu): Draw something here.
   } else {
     DVLOG(1) << "Activate failed, hr=" << hr;
   }
 
+  // The thread needs to out-live the ChannelProxy.
+  base::Thread thread("metro_IO_thread");
+  base::Thread::Options options;
+  options.message_loop_type = MessageLoop::TYPE_IO;
+  thread.StartWithOptions(options);
+

[cpu_(ooo_6.6-7.5), 2012/09/28 21:37:37]

if we go back to my code with async message I think it would work.

[scottmg, 2012/09/28 22:14:28]

Done.

+  thread.message_loop_proxy()->PostTask(
+      FROM_HERE,
+      base::Bind(&SendHwnd, &thread, globals.core_window));
+
   // Create a message loop to allow message passing into this thread.
   MessageLoop msg_loop(MessageLoop::TYPE_UI);
 
   // Announce our message loop to the world.
   globals.appview_msg_loop = msg_loop.message_loop_proxy();
 
   // And post the task that'll do the inner Metro message pumping to it.
   msg_loop.PostTask(FROM_HERE, base::Bind(&RunMessageLoop, dispatcher.Get()));
 
   // Post the recurring task which checks for OSK activation in metro chrome.
@@ skipping 94 matching lines @@
     return S_OK;
   }
 
   do {
     ::Sleep(10);
     ::EnumThreadWindows(globals.main_thread_id, &CoreWindowFinder, 0);
   } while (globals.core_window == NULL);
 
   DVLOG(1) << "CoreWindow found: " << std::hex << globals.core_window;
 
-  if (!globals.host_thread) {
-    DWORD chrome_ui_thread_id = 0;
-    globals.host_thread =
-        ::CreateThread(NULL, 0, HostMainThreadProc, NULL, 0,
-                       &chrome_ui_thread_id);
 
+  if (GetAsyncKeyState(VK_SHIFT) && GetAsyncKeyState(VK_F11)) {

[scottmg, 2012/09/28 22:14:28]

Made it #if !defined(USE_AURA) instead

+    DVLOG(1) << "Using Shift-F11 debug hook, connecting to browser";
+  } else {
     if (!globals.host_thread) {
-      NOTREACHED() << "thread creation failed.";
-      return E_UNEXPECTED;
+      DWORD chrome_ui_thread_id = 0;
+      globals.host_thread =
+          ::CreateThread(NULL, 0, HostMainThreadProc, NULL, 0,
+                        &chrome_ui_thread_id);
+
+      if (!globals.host_thread) {
+        NOTREACHED() << "thread creation failed.";
+        return E_UNEXPECTED;
+      }
     }
   }
 
   if (RegisterHotKey(globals.core_window, kFlipWindowsHotKeyId,
                      MOD_CONTROL, VK_F12)) {
     DVLOG(1) << "Registered flip window hotkey.";
   } else {
     VPLOG(1) << "Failed to register flip window hotkey.";
   }
   HRESULT hr = settings_handler_.Initialize();
@@ skipping 260 matching lines @@
   CheckHR(core_app.As(&app_exit));
   globals.app_exit = app_exit.Detach();
 }
 
 IFACEMETHODIMP
 ChromeAppViewFactory::CreateView(winapp::Core::IFrameworkView** view) {
   globals.view = mswr::Make<ChromeAppView>().Detach();
   *view = globals.view;
   return (*view) ? S_OK :  E_OUTOFMEMORY;
 }