mirror of
https://bitbucket.org/chromiumembedded/cef
synced 2024-12-12 17:46:04 +01:00
128 lines
3.5 KiB
C++
128 lines
3.5 KiB
C++
// Copyright (c) 2012 The Chromium Embedded Framework 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 "libcef/browser/browser_message_loop.h"
|
|
#include "libcef/browser/context.h"
|
|
#include "libcef/common/content_client.h"
|
|
|
|
#include "base/memory/ptr_util.h"
|
|
#include "base/run_loop.h"
|
|
|
|
#if defined(OS_MACOSX)
|
|
#include "base/mac/scoped_nsautorelease_pool.h"
|
|
#endif
|
|
|
|
namespace {
|
|
|
|
// MessagePump implementation that delegates to OnScheduleMessagePumpWork() for
|
|
// scheduling.
|
|
class MessagePumpExternal : public base::MessagePump {
|
|
public:
|
|
MessagePumpExternal(float max_time_slice,
|
|
CefRefPtr<CefBrowserProcessHandler> handler)
|
|
: max_time_slice_(max_time_slice),
|
|
handler_(handler) {
|
|
}
|
|
|
|
void Run(Delegate* delegate) override {
|
|
base::TimeTicks start = base::TimeTicks::Now();
|
|
while (true) {
|
|
#if defined(OS_MACOSX)
|
|
base::mac::ScopedNSAutoreleasePool autorelease_pool;
|
|
#endif
|
|
|
|
const bool has_more_work = DirectRunWork(delegate);
|
|
if (!has_more_work)
|
|
break;
|
|
|
|
const base::TimeDelta& delta = base::TimeTicks::Now() - start;
|
|
if (delta.InSecondsF() > max_time_slice_)
|
|
break;
|
|
}
|
|
}
|
|
|
|
void Quit() override {
|
|
}
|
|
|
|
void ScheduleWork() override {
|
|
handler_->OnScheduleMessagePumpWork(0);
|
|
}
|
|
|
|
void ScheduleDelayedWork(const base::TimeTicks& delayed_work_time) override {
|
|
const base::TimeDelta& delta = delayed_work_time - base::TimeTicks::Now();
|
|
handler_->OnScheduleMessagePumpWork(delta.InMilliseconds());
|
|
}
|
|
|
|
private:
|
|
bool DirectRunWork(Delegate* delegate) {
|
|
bool did_work = false;
|
|
bool did_delayed_work = false;
|
|
bool did_idle_work = false;
|
|
|
|
// Perform work & delayed work.
|
|
// If no work was found, then perform idle work.
|
|
|
|
did_work = delegate->DoWork();
|
|
|
|
// We are using an external timer, so we don't have any action based on the
|
|
// returned next delayed work time.
|
|
base::TimeTicks next_time;
|
|
did_delayed_work = delegate->DoDelayedWork(&next_time);
|
|
|
|
if (!did_work && !did_delayed_work) {
|
|
did_idle_work = delegate->DoIdleWork();
|
|
}
|
|
|
|
return did_work || did_delayed_work || did_idle_work;
|
|
}
|
|
|
|
const float max_time_slice_;
|
|
CefRefPtr<CefBrowserProcessHandler> handler_;
|
|
};
|
|
|
|
CefRefPtr<CefBrowserProcessHandler> GetBrowserProcessHandler() {
|
|
CefRefPtr<CefApp> app = CefContentClient::Get()->application();
|
|
if (app)
|
|
return app->GetBrowserProcessHandler();
|
|
return nullptr;
|
|
}
|
|
|
|
std::unique_ptr<base::MessagePump> CreatePump() {
|
|
const CefSettings& settings = CefContext::Get()->settings();
|
|
if (settings.external_message_pump) {
|
|
CefRefPtr<CefBrowserProcessHandler> handler = GetBrowserProcessHandler();
|
|
if (handler)
|
|
return base::WrapUnique(new MessagePumpExternal(0.01f, handler));
|
|
}
|
|
|
|
return base::MessageLoop::CreateMessagePumpForType(
|
|
base::MessageLoop::TYPE_UI);
|
|
}
|
|
|
|
} // namespace
|
|
|
|
CefBrowserMessageLoop::CefBrowserMessageLoop()
|
|
: base::MessageLoopForUI(CreatePump()) {
|
|
BindToCurrentThread();
|
|
}
|
|
|
|
CefBrowserMessageLoop::~CefBrowserMessageLoop() {
|
|
}
|
|
|
|
// static
|
|
CefBrowserMessageLoop* CefBrowserMessageLoop::current() {
|
|
base::MessageLoop* loop = base::MessageLoop::current();
|
|
DCHECK(loop->IsType(base::MessageLoop::TYPE_UI));
|
|
return static_cast<CefBrowserMessageLoop*>(loop);
|
|
}
|
|
|
|
void CefBrowserMessageLoop::DoMessageLoopIteration() {
|
|
base::RunLoop run_loop;
|
|
run_loop.RunUntilIdle();
|
|
}
|
|
|
|
void CefBrowserMessageLoop::RunMessageLoop() {
|
|
Run();
|
|
}
|