| /* |
| * Copyright (C) 2009 Google Inc. All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions are |
| * met: |
| * |
| * * Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * * Redistributions in binary form must reproduce the above |
| * copyright notice, this list of conditions and the following disclaimer |
| * in the documentation and/or other materials provided with the |
| * distribution. |
| * * Neither the name of Google Inc. nor the names of its |
| * contributors may be used to endorse or promote products derived from |
| * this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
| * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
| * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
| * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
| * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
| * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
| * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| |
| #include "sky/engine/public/web/Sky.h" |
| |
| #include "base/message_loop/message_loop.h" |
| #include "base/rand_util.h" |
| #include "gen/sky/platform/RuntimeEnabledFeatures.h" |
| #include "mojo/message_pump/message_pump_mojo.h" |
| #include "sky/engine/core/dom/Microtask.h" |
| #include "sky/engine/core/frame/Settings.h" |
| #include "sky/engine/core/Init.h" |
| #include "sky/engine/core/page/Page.h" |
| #include "sky/engine/core/script/dart_init.h" |
| #include "sky/engine/platform/LayoutTestSupport.h" |
| #include "sky/engine/platform/Logging.h" |
| #include "sky/engine/public/platform/Platform.h" |
| #include "sky/engine/wtf/Assertions.h" |
| #include "sky/engine/wtf/CryptographicallyRandomNumber.h" |
| #include "sky/engine/wtf/MainThread.h" |
| #include "sky/engine/wtf/text/AtomicString.h" |
| #include "sky/engine/wtf/text/TextEncoding.h" |
| #include "sky/engine/wtf/WTF.h" |
| |
| namespace blink { |
| |
| namespace { |
| |
| void willProcessTask() |
| { |
| } |
| |
| void didProcessTask() |
| { |
| Microtask::performCheckpoint(); |
| // FIXME: Report memory usage to dart? |
| } |
| |
| class TaskObserver : public base::MessageLoop::TaskObserver { |
| public: |
| void WillProcessTask(const base::PendingTask& pending_task) override { willProcessTask(); } |
| void DidProcessTask(const base::PendingTask& pending_task) override { didProcessTask(); } |
| }; |
| |
| class SignalObserver : public mojo::common::MessagePumpMojo::Observer { |
| public: |
| void WillSignalHandler() override { willProcessTask(); } |
| void DidSignalHandler() override { didProcessTask(); } |
| }; |
| |
| static TaskObserver* s_taskObserver = 0; |
| static SignalObserver* s_signalObserver = 0; |
| |
| void addMessageLoopObservers() |
| { |
| ASSERT(!s_taskObserver); |
| s_taskObserver = new TaskObserver; |
| |
| ASSERT(!s_signalObserver); |
| s_signalObserver = new SignalObserver; |
| |
| base::MessageLoop::current()->AddTaskObserver(s_taskObserver); |
| mojo::common::MessagePumpMojo::current()->AddObserver(s_signalObserver); |
| } |
| |
| void removeMessageLoopObservers() |
| { |
| base::MessageLoop::current()->RemoveTaskObserver(s_taskObserver); |
| mojo::common::MessagePumpMojo::current()->RemoveObserver(s_signalObserver); |
| |
| ASSERT(s_taskObserver); |
| delete s_taskObserver; |
| s_taskObserver = 0; |
| |
| ASSERT(s_signalObserver); |
| delete s_signalObserver; |
| s_signalObserver = 0; |
| } |
| |
| } // namespace |
| |
| // Make sure we are not re-initialized in the same address space. |
| // Doing so may cause hard to reproduce crashes. |
| static bool s_webKitInitialized = false; |
| |
| static void cryptographicallyRandomValues(unsigned char* buffer, size_t length) |
| { |
| base::RandBytes(buffer, length); |
| } |
| |
| void initialize(Platform* platform) |
| { |
| ASSERT(!s_webKitInitialized); |
| s_webKitInitialized = true; |
| |
| ASSERT(platform); |
| Platform::initialize(platform); |
| |
| WTF::setRandomSource(cryptographicallyRandomValues); |
| WTF::initialize(); |
| WTF::initializeMainThread(); |
| |
| DEFINE_STATIC_LOCAL(CoreInitializer, initializer, ()); |
| initializer.init(); |
| |
| // There are some code paths (for example, running WebKit in the browser |
| // process and calling into LocalStorage before anything else) where the |
| // UTF8 string encoding tables are used on a background thread before |
| // they're set up. This is a problem because their set up routines assert |
| // they're running on the main WebKitThread. It might be possible to make |
| // the initialization thread-safe, but given that so many code paths use |
| // this, initializing this lazily probably doesn't buy us much. |
| WTF::UTF8Encoding(); |
| |
| InitDartVM(); |
| |
| addMessageLoopObservers(); |
| } |
| |
| void shutdown() |
| { |
| removeMessageLoopObservers(); |
| |
| // FIXME: Shutdown dart? |
| |
| CoreInitializer::shutdown(); |
| WTF::shutdown(); |
| Platform::shutdown(); |
| } |
| |
| void setLayoutTestMode(bool value) |
| { |
| LayoutTestSupport::setIsRunningLayoutTest(value); |
| } |
| |
| bool layoutTestMode() |
| { |
| return LayoutTestSupport::isRunningLayoutTest(); |
| } |
| |
| void setFontAntialiasingEnabledForTest(bool value) |
| { |
| LayoutTestSupport::setFontAntialiasingEnabledForTest(value); |
| } |
| |
| bool fontAntialiasingEnabledForTest() |
| { |
| return LayoutTestSupport::isFontAntialiasingEnabledForTest(); |
| } |
| |
| void enableLogChannel(const char* name) |
| { |
| #if !LOG_DISABLED |
| WTFLogChannel* channel = getChannelFromName(name); |
| if (channel) |
| channel->state = WTFLogChannelOn; |
| #endif // !LOG_DISABLED |
| } |
| |
| } // namespace blink |