123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492 |
- // Copyright 2014 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 "gin/public/v8_platform.h"
- #include <algorithm>
- #include "base/bind.h"
- #include "base/bit_cast.h"
- #include "base/check_op.h"
- #include "base/debug/stack_trace.h"
- #include "base/location.h"
- #include "base/memory/nonscannable_memory.h"
- #include "base/memory/raw_ptr.h"
- #include "base/rand_util.h"
- #include "base/system/sys_info.h"
- #include "base/task/post_job.h"
- #include "base/task/task_traits.h"
- #include "base/task/thread_pool.h"
- #include "base/task/thread_pool/thread_pool_instance.h"
- #include "base/trace_event/trace_event.h"
- #include "base/tracing_buildflags.h"
- #include "build/build_config.h"
- #include "gin/per_isolate_data.h"
- #include "v8_platform_page_allocator.h"
- namespace gin {
- namespace {
- base::LazyInstance<V8Platform>::Leaky g_v8_platform = LAZY_INSTANCE_INITIALIZER;
- constexpr base::TaskTraits kLowPriorityTaskTraits = {
- base::TaskPriority::BEST_EFFORT};
- constexpr base::TaskTraits kDefaultTaskTraits = {
- base::TaskPriority::USER_VISIBLE};
- constexpr base::TaskTraits kBlockingTaskTraits = {
- base::TaskPriority::USER_BLOCKING};
- void PrintStackTrace() {
- base::debug::StackTrace trace;
- trace.Print();
- }
- class ConvertableToTraceFormatWrapper final
- : public base::trace_event::ConvertableToTraceFormat {
- public:
- explicit ConvertableToTraceFormatWrapper(
- std::unique_ptr<v8::ConvertableToTraceFormat> inner)
- : inner_(std::move(inner)) {}
- ConvertableToTraceFormatWrapper(const ConvertableToTraceFormatWrapper&) =
- delete;
- ConvertableToTraceFormatWrapper& operator=(
- const ConvertableToTraceFormatWrapper&) = delete;
- ~ConvertableToTraceFormatWrapper() override = default;
- void AppendAsTraceFormat(std::string* out) const final {
- inner_->AppendAsTraceFormat(out);
- }
- private:
- std::unique_ptr<v8::ConvertableToTraceFormat> inner_;
- };
- class EnabledStateObserverImpl final
- : public base::trace_event::TraceLog::EnabledStateObserver {
- public:
- EnabledStateObserverImpl() {
- base::trace_event::TraceLog::GetInstance()->AddEnabledStateObserver(this);
- }
- EnabledStateObserverImpl(const EnabledStateObserverImpl&) = delete;
- EnabledStateObserverImpl& operator=(const EnabledStateObserverImpl&) = delete;
- ~EnabledStateObserverImpl() override {
- base::trace_event::TraceLog::GetInstance()->RemoveEnabledStateObserver(
- this);
- }
- void OnTraceLogEnabled() final {
- base::AutoLock lock(mutex_);
- for (auto* o : observers_) {
- o->OnTraceEnabled();
- }
- }
- void OnTraceLogDisabled() final {
- base::AutoLock lock(mutex_);
- for (auto* o : observers_) {
- o->OnTraceDisabled();
- }
- }
- void AddObserver(v8::TracingController::TraceStateObserver* observer) {
- {
- base::AutoLock lock(mutex_);
- DCHECK(!observers_.count(observer));
- observers_.insert(observer);
- }
- // Fire the observer if recording is already in progress.
- if (base::trace_event::TraceLog::GetInstance()->IsEnabled())
- observer->OnTraceEnabled();
- }
- void RemoveObserver(v8::TracingController::TraceStateObserver* observer) {
- base::AutoLock lock(mutex_);
- DCHECK(observers_.count(observer) == 1);
- observers_.erase(observer);
- }
- private:
- base::Lock mutex_;
- std::unordered_set<v8::TracingController::TraceStateObserver*> observers_;
- };
- base::LazyInstance<EnabledStateObserverImpl>::Leaky g_trace_state_dispatcher =
- LAZY_INSTANCE_INITIALIZER;
- // TODO(skyostil): Deduplicate this with the clamper in Blink.
- class TimeClamper {
- public:
- // As site isolation is enabled on desktop platforms, we can safely provide
- // more timing resolution. Jittering is still enabled everywhere.
- #if BUILDFLAG(IS_ANDROID)
- static constexpr double kResolutionSeconds = 100e-6;
- #else
- static constexpr double kResolutionSeconds = 5e-6;
- #endif
- TimeClamper() : secret_(base::RandUint64()) {}
- TimeClamper(const TimeClamper&) = delete;
- TimeClamper& operator=(const TimeClamper&) = delete;
- double ClampTimeResolution(double time_seconds) const {
- bool was_negative = false;
- if (time_seconds < 0) {
- was_negative = true;
- time_seconds = -time_seconds;
- }
- // For each clamped time interval, compute a pseudorandom transition
- // threshold. The reported time will either be the start of that interval or
- // the next one depending on which side of the threshold |time_seconds| is.
- double interval = floor(time_seconds / kResolutionSeconds);
- double clamped_time = interval * kResolutionSeconds;
- double tick_threshold = ThresholdFor(clamped_time);
- if (time_seconds >= tick_threshold)
- clamped_time = (interval + 1) * kResolutionSeconds;
- if (was_negative)
- clamped_time = -clamped_time;
- return clamped_time;
- }
- private:
- inline double ThresholdFor(double clamped_time) const {
- uint64_t time_hash =
- MurmurHash3(base::bit_cast<int64_t>(clamped_time) ^ secret_);
- return clamped_time + kResolutionSeconds * ToDouble(time_hash);
- }
- static inline double ToDouble(uint64_t value) {
- // Exponent for double values for [1.0 .. 2.0]
- static const uint64_t kExponentBits = uint64_t{0x3FF0000000000000};
- static const uint64_t kMantissaMask = uint64_t{0x000FFFFFFFFFFFFF};
- uint64_t random = (value & kMantissaMask) | kExponentBits;
- return base::bit_cast<double>(random) - 1;
- }
- static inline uint64_t MurmurHash3(uint64_t value) {
- value ^= value >> 33;
- value *= uint64_t{0xFF51AFD7ED558CCD};
- value ^= value >> 33;
- value *= uint64_t{0xC4CEB9FE1A85EC53};
- value ^= value >> 33;
- return value;
- }
- const uint64_t secret_;
- };
- base::LazyInstance<TimeClamper>::Leaky g_time_clamper =
- LAZY_INSTANCE_INITIALIZER;
- #if BUILDFLAG(USE_PARTITION_ALLOC)
- base::LazyInstance<gin::PageAllocator>::Leaky g_page_allocator =
- LAZY_INSTANCE_INITIALIZER;
- #endif // BUILDFLAG(USE_PARTITION_ALLOC)
- class JobDelegateImpl : public v8::JobDelegate {
- public:
- explicit JobDelegateImpl(base::JobDelegate* delegate) : delegate_(delegate) {}
- JobDelegateImpl() = default;
- JobDelegateImpl(const JobDelegateImpl&) = delete;
- JobDelegateImpl& operator=(const JobDelegateImpl&) = delete;
- // v8::JobDelegate:
- bool ShouldYield() override { return delegate_->ShouldYield(); }
- void NotifyConcurrencyIncrease() override {
- delegate_->NotifyConcurrencyIncrease();
- }
- uint8_t GetTaskId() override { return delegate_->GetTaskId(); }
- bool IsJoiningThread() const override { return delegate_->IsJoiningThread(); }
- private:
- raw_ptr<base::JobDelegate> delegate_;
- };
- class JobHandleImpl : public v8::JobHandle {
- public:
- explicit JobHandleImpl(base::JobHandle handle) : handle_(std::move(handle)) {}
- ~JobHandleImpl() override = default;
- JobHandleImpl(const JobHandleImpl&) = delete;
- JobHandleImpl& operator=(const JobHandleImpl&) = delete;
- // v8::JobHandle:
- void NotifyConcurrencyIncrease() override {
- handle_.NotifyConcurrencyIncrease();
- }
- bool UpdatePriorityEnabled() const override { return true; }
- void UpdatePriority(v8::TaskPriority new_priority) override {
- handle_.UpdatePriority(ToBaseTaskPriority(new_priority));
- }
- void Join() override { handle_.Join(); }
- void Cancel() override { handle_.Cancel(); }
- void CancelAndDetach() override { handle_.CancelAndDetach(); }
- bool IsActive() override { return handle_.IsActive(); }
- bool IsValid() override { return !!handle_; }
- private:
- static base::TaskPriority ToBaseTaskPriority(v8::TaskPriority priority) {
- switch (priority) {
- case v8::TaskPriority::kBestEffort:
- return base::TaskPriority::BEST_EFFORT;
- case v8::TaskPriority::kUserVisible:
- return base::TaskPriority::USER_VISIBLE;
- case v8::TaskPriority::kUserBlocking:
- return base::TaskPriority::USER_BLOCKING;
- }
- }
- base::JobHandle handle_;
- };
- } // namespace
- } // namespace gin
- // Allow std::unique_ptr<v8::ConvertableToTraceFormat> to be a valid
- // initialization value for trace macros.
- template <>
- struct base::trace_event::TraceValue::Helper<
- std::unique_ptr<v8::ConvertableToTraceFormat>> {
- static constexpr unsigned char kType = TRACE_VALUE_TYPE_CONVERTABLE;
- static inline void SetValue(
- TraceValue* v,
- std::unique_ptr<v8::ConvertableToTraceFormat> value) {
- // NOTE: |as_convertable| is an owning pointer, so using new here
- // is acceptable.
- v->as_convertable =
- new gin::ConvertableToTraceFormatWrapper(std::move(value));
- }
- };
- namespace gin {
- class V8Platform::TracingControllerImpl : public v8::TracingController {
- public:
- TracingControllerImpl() = default;
- TracingControllerImpl(const TracingControllerImpl&) = delete;
- TracingControllerImpl& operator=(const TracingControllerImpl&) = delete;
- ~TracingControllerImpl() override = default;
- // TracingController implementation.
- #if !BUILDFLAG(USE_PERFETTO_CLIENT_LIBRARY)
- const uint8_t* GetCategoryGroupEnabled(const char* name) override {
- return TRACE_EVENT_API_GET_CATEGORY_GROUP_ENABLED(name);
- }
- uint64_t AddTraceEvent(
- char phase,
- const uint8_t* category_enabled_flag,
- const char* name,
- const char* scope,
- uint64_t id,
- uint64_t bind_id,
- int32_t num_args,
- const char** arg_names,
- const uint8_t* arg_types,
- const uint64_t* arg_values,
- std::unique_ptr<v8::ConvertableToTraceFormat>* arg_convertables,
- unsigned int flags) override {
- base::trace_event::TraceArguments args(
- num_args, arg_names, arg_types,
- reinterpret_cast<const unsigned long long*>(arg_values),
- arg_convertables);
- DCHECK_LE(num_args, 2);
- base::trace_event::TraceEventHandle handle =
- TRACE_EVENT_API_ADD_TRACE_EVENT_WITH_BIND_ID(
- phase, category_enabled_flag, name, scope, id, bind_id, &args,
- flags);
- uint64_t result;
- memcpy(&result, &handle, sizeof(result));
- return result;
- }
- uint64_t AddTraceEventWithTimestamp(
- char phase,
- const uint8_t* category_enabled_flag,
- const char* name,
- const char* scope,
- uint64_t id,
- uint64_t bind_id,
- int32_t num_args,
- const char** arg_names,
- const uint8_t* arg_types,
- const uint64_t* arg_values,
- std::unique_ptr<v8::ConvertableToTraceFormat>* arg_convertables,
- unsigned int flags,
- int64_t timestampMicroseconds) override {
- base::trace_event::TraceArguments args(
- num_args, arg_names, arg_types,
- reinterpret_cast<const unsigned long long*>(arg_values),
- arg_convertables);
- DCHECK_LE(num_args, 2);
- base::TimeTicks timestamp =
- base::TimeTicks() + base::Microseconds(timestampMicroseconds);
- base::trace_event::TraceEventHandle handle =
- TRACE_EVENT_API_ADD_TRACE_EVENT_WITH_THREAD_ID_AND_TIMESTAMP(
- phase, category_enabled_flag, name, scope, id, bind_id,
- TRACE_EVENT_API_CURRENT_THREAD_ID, timestamp, &args, flags);
- uint64_t result;
- memcpy(&result, &handle, sizeof(result));
- return result;
- }
- void UpdateTraceEventDuration(const uint8_t* category_enabled_flag,
- const char* name,
- uint64_t handle) override {
- base::trace_event::TraceEventHandle traceEventHandle;
- memcpy(&traceEventHandle, &handle, sizeof(handle));
- TRACE_EVENT_API_UPDATE_TRACE_EVENT_DURATION(category_enabled_flag, name,
- traceEventHandle);
- }
- #endif // !BUILDFLAG(USE_PERFETTO_CLIENT_LIBRARY)
- void AddTraceStateObserver(TraceStateObserver* observer) override {
- g_trace_state_dispatcher.Get().AddObserver(observer);
- }
- void RemoveTraceStateObserver(TraceStateObserver* observer) override {
- g_trace_state_dispatcher.Get().RemoveObserver(observer);
- }
- };
- // static
- V8Platform* V8Platform::Get() { return g_v8_platform.Pointer(); }
- V8Platform::V8Platform() : tracing_controller_(new TracingControllerImpl) {}
- V8Platform::~V8Platform() = default;
- #if BUILDFLAG(USE_PARTITION_ALLOC)
- PageAllocator* V8Platform::GetPageAllocator() {
- return g_page_allocator.Pointer();
- }
- void V8Platform::OnCriticalMemoryPressure() {
- // We only have a reservation on 32-bit Windows systems.
- // TODO(bbudge) Make the #if's in BlinkInitializer match.
- #if BUILDFLAG(IS_WIN) && defined(ARCH_CPU_32_BITS)
- partition_alloc::ReleaseReservation();
- #endif
- }
- v8::ZoneBackingAllocator* V8Platform::GetZoneBackingAllocator() {
- static struct Allocator final : v8::ZoneBackingAllocator {
- MallocFn GetMallocFn() const override {
- return &base::AllocNonQuarantinable;
- }
- FreeFn GetFreeFn() const override { return &base::FreeNonQuarantinable; }
- } allocator;
- return &allocator;
- }
- #endif // BUILDFLAG(USE_PARTITION_ALLOC)
- std::shared_ptr<v8::TaskRunner> V8Platform::GetForegroundTaskRunner(
- v8::Isolate* isolate) {
- PerIsolateData* data = PerIsolateData::From(isolate);
- return data->task_runner();
- }
- int V8Platform::NumberOfWorkerThreads() {
- // V8Platform assumes the scheduler uses the same set of workers for default
- // and user blocking tasks.
- const size_t num_foreground_workers =
- base::ThreadPoolInstance::Get()
- ->GetMaxConcurrentNonBlockedTasksWithTraitsDeprecated(
- kDefaultTaskTraits);
- DCHECK_EQ(num_foreground_workers,
- base::ThreadPoolInstance::Get()
- ->GetMaxConcurrentNonBlockedTasksWithTraitsDeprecated(
- kBlockingTaskTraits));
- return std::max(1, static_cast<int>(num_foreground_workers));
- }
- void V8Platform::CallOnWorkerThread(std::unique_ptr<v8::Task> task) {
- base::ThreadPool::PostTask(FROM_HERE, kDefaultTaskTraits,
- base::BindOnce(&v8::Task::Run, std::move(task)));
- }
- void V8Platform::CallBlockingTaskOnWorkerThread(
- std::unique_ptr<v8::Task> task) {
- base::ThreadPool::PostTask(FROM_HERE, kBlockingTaskTraits,
- base::BindOnce(&v8::Task::Run, std::move(task)));
- }
- void V8Platform::CallLowPriorityTaskOnWorkerThread(
- std::unique_ptr<v8::Task> task) {
- base::ThreadPool::PostTask(FROM_HERE, kLowPriorityTaskTraits,
- base::BindOnce(&v8::Task::Run, std::move(task)));
- }
- void V8Platform::CallDelayedOnWorkerThread(std::unique_ptr<v8::Task> task,
- double delay_in_seconds) {
- base::ThreadPool::PostDelayedTask(
- FROM_HERE, kDefaultTaskTraits,
- base::BindOnce(&v8::Task::Run, std::move(task)),
- base::Seconds(delay_in_seconds));
- }
- std::unique_ptr<v8::JobHandle> V8Platform::CreateJob(
- v8::TaskPriority priority,
- std::unique_ptr<v8::JobTask> job_task) {
- base::TaskTraits task_traits;
- switch (priority) {
- case v8::TaskPriority::kBestEffort:
- task_traits = kLowPriorityTaskTraits;
- break;
- case v8::TaskPriority::kUserVisible:
- task_traits = kDefaultTaskTraits;
- break;
- case v8::TaskPriority::kUserBlocking:
- task_traits = kBlockingTaskTraits;
- break;
- }
- // Ownership of |job_task| is assumed by |worker_task|, while
- // |max_concurrency_callback| uses an unretained pointer.
- auto* job_task_ptr = job_task.get();
- auto handle =
- base::CreateJob(FROM_HERE, task_traits,
- base::BindRepeating(
- [](const std::unique_ptr<v8::JobTask>& job_task,
- base::JobDelegate* delegate) {
- JobDelegateImpl delegate_impl(delegate);
- job_task->Run(&delegate_impl);
- },
- std::move(job_task)),
- base::BindRepeating(
- [](v8::JobTask* job_task, size_t worker_count) {
- return job_task->GetMaxConcurrency(worker_count);
- },
- base::Unretained(job_task_ptr)));
- return std::make_unique<JobHandleImpl>(std::move(handle));
- }
- bool V8Platform::IdleTasksEnabled(v8::Isolate* isolate) {
- return PerIsolateData::From(isolate)->task_runner()->IdleTasksEnabled();
- }
- double V8Platform::MonotonicallyIncreasingTime() {
- return base::TimeTicks::Now().ToInternalValue() /
- static_cast<double>(base::Time::kMicrosecondsPerSecond);
- }
- double V8Platform::CurrentClockTimeMillis() {
- double now_seconds = base::Time::Now().ToJsTime() / 1000;
- return g_time_clamper.Get().ClampTimeResolution(now_seconds) * 1000;
- }
- v8::TracingController* V8Platform::GetTracingController() {
- return tracing_controller_.get();
- }
- v8::Platform::StackTracePrinter V8Platform::GetStackTracePrinter() {
- return PrintStackTrace;
- }
- } // namespace gin
|