#ifndef CONTENT_RENDERER_RENDER_THREAD_IMPL_H_
#define CONTENT_RENDERER_RENDER_THREAD_IMPL_H_
#include <stddef.h>
#include <stdint.h>
#include <deque>
#include <map>
#include <memory>
#include <optional>
#include <set>
#include <string>
#include <utility>
#include <vector>
#include "base/cancelable_callback.h"
#include "base/clang_profiling_buildflags.h"
#include "base/containers/unique_ptr_adapters.h"
#include "base/gtest_prod_util.h"
#include "base/memory/discardable_memory_allocator.h"
#include "base/memory/memory_pressure_listener.h"
#include "base/memory/scoped_refptr.h"
#include "base/memory/structured_shared_memory.h"
#include "base/metrics/user_metrics_action.h"
#include "base/observer_list.h"
#include "base/process/process.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "base/trace_event/trace_log.h"
#include "base/trace_event/typed_macros.h"
#include "base/types/pass_key.h"
#include "build/build_config.h"
#include "content/child/child_thread_impl.h"
#include "content/common/agent_scheduling_group.mojom.h"
#include "content/common/content_export.h"
#include "content/common/render_message_filter.mojom.h"
#include "content/common/renderer.mojom.h"
#include "content/common/renderer_host.mojom.h"
#include "content/public/renderer/render_thread.h"
#include "content/renderer/blink_isolates_pressure_listener.h"
#include "content/renderer/discardable_memory_utils.h"
#include "content/renderer/memory_reclaimer_pressure_listener.h"
#include "content/renderer/skia_graphics_pressure_listener.h"
#include "gpu/ipc/client/gpu_channel_host.h"
#include "ipc/ipc_sync_channel.h"
#include "media/media_buildflags.h"
#include "media/mojo/clients/mojo_codec_factory.h"
#include "mojo/public/cpp/bindings/associated_receiver.h"
#include "mojo/public/cpp/bindings/associated_remote.h"
#include "mojo/public/cpp/bindings/pending_associated_receiver.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "mojo/public/cpp/bindings/receiver.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "net/base/network_change_notifier.h"
#include "net/nqe/effective_connection_type.h"
#include "services/viz/public/mojom/compositing/compositing_mode_watcher.mojom.h"
#include "third_party/blink/public/common/associated_interfaces/associated_interface_registry.h"
#include "third_party/blink/public/common/user_agent/user_agent_metadata.h"
#include "third_party/blink/public/mojom/origin_trials/origin_trials_settings.mojom-forward.h"
#include "third_party/blink/public/mojom/shared_storage/shared_storage_worklet_service.mojom.h"
#include "third_party/blink/public/platform/scheduler/web_thread_scheduler.h"
#include "third_party/blink/public/platform/url_loader_throttle_provider.h"
#include "third_party/blink/public/platform/web_connection_type.h"
#include "ui/gfx/native_ui_types.h"
#ifdef IS_ARKWEB
#include "arkweb/build/features/features.h"
#endif
#if BUILDFLAG(ARKWEB_READER_MODE)
#include "arkweb/chromium_ext/third_party/blink/public/mojom/dom_distiller/reader_mode_config.mojom-forward.h"
#include "arkweb/chromium_ext/third_party/blink/public/mojom/dom_distiller/reader_mode_config.mojom.h"
#endif
namespace blink {
class WebVideoCaptureImplManager;
}
namespace base {
class SingleThreadTaskRunner;
class Thread;
class WaitableEvent;
}
namespace cc {
class RasterDarkModeFilter;
}
namespace gpu {
class GpuChannelHost;
class SharedImageInterface;
}
namespace media {
class MojoGpuVideoAcceleratorFactories;
}
namespace mojo {
class BinderMap;
}
namespace viz {
class ContextProviderCommandBuffer;
class Gpu;
class RasterContextProvider;
}
namespace content {
class AgentSchedulingGroup;
class RenderFrameImpl;
class RenderThreadObserver;
class RendererBlinkPlatformImpl;
class VariationsRenderThreadObserver;
#if BUILDFLAG(IS_WIN)
class DCOMPTextureFactory;
class OverlayStateServiceProvider;
class OverlayStateServiceProviderImpl;
#endif
#if BUILDFLAG(ARKWEB_SAME_LAYER)
class NativeTextureFactory;
#endif
class CONTENT_EXPORT RenderThreadImpl
: public RenderThread,
public ChildThreadImpl,
public mojom::Renderer,
public viz::mojom::CompositingModeWatcher,
public base::trace_event::TraceLog::AsyncEnabledStateObserver,
public base::MemoryPressureListener {
public:
static RenderThreadImpl* current();
static scoped_refptr<base::SingleThreadTaskRunner>
DeprecatedGetMainTaskRunner();
RenderThreadImpl(
base::RepeatingClosure quit_closure,
std::unique_ptr<blink::scheduler::WebThreadScheduler> scheduler);
RenderThreadImpl(
const InProcessChildThreadParams& params,
int32_t client_id,
std::unique_ptr<blink::scheduler::WebThreadScheduler> scheduler);
RenderThreadImpl(const RenderThreadImpl&) = delete;
RenderThreadImpl& operator=(const RenderThreadImpl&) = delete;
~RenderThreadImpl() override;
void Shutdown() override;
bool ShouldBeDestroyed() override;
static void RegisterSchemes();
IPC::SyncChannel* GetChannel() override;
std::string GetLocale() override;
void OnTraceLogEnabled() override;
void OnTraceLogDisabled() override;
bool GenerateFrameRoutingID(int32_t& routing_id,
blink::LocalFrameToken& frame_token,
base::UnguessableToken& devtools_frame_token,
blink::DocumentToken& document_token) override;
void AddObserver(RenderThreadObserver* observer) override;
void RemoveObserver(RenderThreadObserver* observer) override;
int PostTaskToAllWebWorkers(base::RepeatingClosure closure) override;
base::WaitableEvent* GetShutdownEvent() override;
int32_t GetClientId() override;
blink::WebString GetUserAgent() override;
const blink::UserAgentMetadata& GetUserAgentMetadata() override;
void WriteIntoTrace(
perfetto::TracedProto<perfetto::protos::pbzero::RenderProcessHost> proto)
override;
blink::mojom::PerformanceTier GetCpuPerformanceTier() override;
void OnAssociatedInterfaceRequest(
const std::string& name,
mojo::ScopedInterfaceEndpointHandle handle) override;
blink::scheduler::WebThreadScheduler* GetWebMainThreadScheduler();
bool IsLcdTextEnabled();
bool IsElasticOverscrollEnabled();
bool IsScrollAnimatorEnabled();
void SetScrollAnimatorEnabled(bool enable_scroll_animator,
base::PassKey<AgentSchedulingGroup>);
bool IsThreadedAnimationEnabled();
void CompositingModeFallbackToSoftware() override;
bool IsGpuCompositingDisabled() const { return is_gpu_compositing_disabled_; }
bool IsGpuRemoteDisconnected();
scoped_refptr<gpu::GpuChannelHost> EstablishGpuChannelSync();
using EstablishGpuChannelCallback =
base::OnceCallback<void(scoped_refptr<gpu::GpuChannelHost>)>;
void EstablishGpuChannel(EstablishGpuChannelCallback callback);
blink::AssociatedInterfaceRegistry* GetAssociatedInterfaceRegistry();
base::DiscardableMemoryAllocator* GetDiscardableMemoryAllocatorForTest()
const {
return discardable_memory_allocator_.get();
}
RendererBlinkPlatformImpl* blink_platform_impl() const {
DCHECK(blink_platform_impl_);
return blink_platform_impl_.get();
}
scoped_refptr<base::SingleThreadTaskRunner> compositor_task_runner() const {
return compositor_task_runner_;
}
const std::vector<std::string> cors_exempt_header_list() const {
return cors_exempt_header_list_;
}
blink::URLLoaderThrottleProvider* url_loader_throttle_provider() const {
return url_loader_throttle_provider_.get();
}
#if BUILDFLAG(IS_WIN)
scoped_refptr<DCOMPTextureFactory> GetDCOMPTextureFactory();
scoped_refptr<OverlayStateServiceProvider> GetOverlayStateServiceProvider();
#endif
#if BUILDFLAG(ARKWEB_SAME_LAYER)
scoped_refptr<NativeTextureFactory> GetNativeTexureFactory();
#endif
blink::WebVideoCaptureImplManager* video_capture_impl_manager() const {
return vc_manager_.get();
}
gpu::GpuChannelHost* GetGpuChannel();
scoped_refptr<base::SequencedTaskRunner> GetMediaSequencedTaskRunner();
scoped_refptr<viz::RasterContextProvider>
GetVideoFrameCompositorContextProvider(
scoped_refptr<viz::RasterContextProvider>);
scoped_refptr<gpu::SharedImageInterface>
GetRenderThreadSharedImageInterface();
scoped_refptr<viz::RasterContextProvider>
SharedCompositorWorkerContextProvider(
cc::RasterDarkModeFilter* dark_mode_filter);
media::GpuVideoAcceleratorFactories* GetGpuFactories();
scoped_refptr<viz::ContextProviderCommandBuffer>
SharedMainThreadContextProvider();
class CONTENT_EXPORT HistogramCustomizer {
public:
HistogramCustomizer();
HistogramCustomizer(const HistogramCustomizer&) = delete;
HistogramCustomizer& operator=(const HistogramCustomizer&) = delete;
~HistogramCustomizer();
void RenderViewNavigatedToHost(const std::string& host, size_t view_count);
std::string ConvertToCustomHistogramName(const char* histogram_name) const;
private:
FRIEND_TEST_ALL_PREFIXES(RenderThreadImplUnittest,
IdentifyAlexaTop10NonGoogleSite);
friend class RenderThreadImplUnittest;
std::string HostToCustomHistogramSuffix(const std::string& host);
bool IsAlexaTop10NonGoogleSite(const std::string& host);
void SetCommonHost(const std::string& host);
std::string common_host_;
std::string common_host_histogram_suffix_;
std::set<std::string> custom_histograms_;
};
HistogramCustomizer* histogram_customizer() {
return &histogram_customizer_;
}
mojom::RendererHost* GetRendererHost();
void SetRenderingColorSpace(const gfx::ColorSpace& color_space);
gfx::ColorSpace GetRenderingColorSpace();
base::TimeTicks run_loop_start_time() const { return run_loop_start_time_; }
void set_run_loop_start_time(base::TimeTicks run_loop_start_time) {
run_loop_start_time_ = run_loop_start_time;
}
#if BUILDFLAG(IS_ANDROID)
void SetPrivateMemoryFootprint(uint64_t private_memory_footprint_bytes);
#endif
#if BUILDFLAG(ARKWEB_BLANK_OPTIMIZE)
void SetBlanklessDumpInfo(uint32_t nweb_id,
uint64_t blankless_key,
uint64_t frame_sink_id,
int32_t lcp_time,
int64_t pref_hash);
#endif
#if BUILDFLAG(ARKWEB_READER_MODE)
void UpdateReaderModeConfig(
blink::mojom::ReaderModeConfigPtr config) override;
const blink::mojom::ReaderModeConfig* GetReaderModeConfig() override;
#endif
#if BUILDFLAG(ARKWEB_EXT_VIDEO_LOAD_OPTIMIZATION)
void UpdateVideoLoadOptimizationConfigData(const bool enable,
const int preload_video_time,
const int min_cache_time,
const int max_cache_time,
const int moov_size,
const int bit_rate,
const std::vector<std::string>& support_domains) override;
bool IsVideoLoadOptimizationEnabled(const std::string& url) const;
bool IsVideoLoadOptSupportDomainMatch(const std::string& url) const;
int GetVideoPreloadTimeDefault() const;
int GetVideoMinCacheTimeDefault() const;
int GetVideoMaxCacheTimeDefault() const;
int GetVideoMoovSizeDefault() const;
int GetVideoBitrateDefault() const;
#endif
private:
FRIEND_TEST_ALL_PREFIXES(RenderThreadImplBrowserTest,
TransferSharedLastForegroundTime);
friend class RenderThreadImplBrowserTest;
friend class AgentSchedulingGroup;
#if BUILDFLAG(ARKWEB_TEST)
friend class RenderThreadImplExtUnittest;
#endif
void OnProcessFinalRelease() override;
void OnChannelError() override;
void RecordAction(const base::UserMetricsAction& action) override;
void RecordComputedAction(const std::string& action) override;
#if BUILDFLAG(ARKWEB_I18N)
void NotifyLocaleChanged(const std::string& update_locale) override;
#endif
#if BUILDFLAG(ARKWEB_LOGGER_REPORT)
void OnChannelConnected(int32_t peer_pid) override;
#endif
#if BUILDFLAG(IS_ANDROID)
void OnMemoryPressureFromBrowserReceived(
base::MemoryPressureLevel level) override;
#endif
void SetBatterySaverMode(bool battery_saver_mode_enabled) override;
bool IsMainThread();
void Init();
void InitializeCompositorThread();
void InitializeWebKit(mojo::BinderMap* binders);
void CreateAgentSchedulingGroup(
mojo::PendingReceiver<IPC::mojom::ChannelBootstrap> bootstrap) override;
void CreateAssociatedAgentSchedulingGroup(
mojo::PendingAssociatedReceiver<mojom::AgentSchedulingGroup>
agent_scheduling_group) override;
void TransferSharedLastForegroundTime(
base::ReadOnlySharedMemoryRegion last_foreground_time_region) override;
void OnNetworkConnectionChanged(
net::NetworkChangeNotifier::ConnectionType type,
double max_bandwidth_mbps) override;
void OnNetworkQualityChanged(net::EffectiveConnectionType type,
base::TimeDelta http_rtt,
base::TimeDelta transport_rtt,
double bandwidth_kbps) override;
void SetWebKitSharedTimersSuspended(bool suspend) override;
void InitializeRenderer(
const std::string& user_agent,
const blink::UserAgentMetadata& user_agent_metadata,
const std::vector<std::string>& cors_exempt_header_list,
blink::mojom::OriginTrialsSettingsPtr origin_trial_settings,
blink::mojom::PerformanceTier cpu_performance_tier,
uint64_t trace_id) override;
void UpdateScrollbarTheme(
mojom::UpdateScrollbarThemeParamsPtr params) override;
void OnSystemColorsChanged(int32_t aqua_color_variant) override;
void UpdateSystemColorInfo(
mojom::UpdateSystemColorInfoParamsPtr params) override;
void PurgePluginListCache() override;
void PurgeResourceCache(PurgeResourceCacheCallback callback) override;
void SetProcessState(base::Process::Priority priority,
mojom::RenderProcessVisibleState visible_state) override;
void SetIsLockedToSite() override;
#if BUILDFLAG(CLANG_PROFILING_INSIDE_SANDBOX)
void WriteClangProfilingProfile(
WriteClangProfilingProfileCallback callback) override;
#endif
void SetIsCrossOriginIsolated(bool value) override;
void SetIsWebSecurityDisabled(bool value) override;
void SetIsIsolatedContext(bool value) override;
#if BUILDFLAG(ARKWEB_SYNC_RENDER)
void SetDrawMode(int mode, base::PassKey<AgentSchedulingGroup>);
#endif
#if BUILDFLAG(ARKWEB_THEME_FONT)
void UpdateThemeFontFile(const std::vector<base::File> theme_fonts) override;
#endif
void SetWebUIResourceUrlToCodeCacheMap(
const base::flat_map<GURL, int>& resource_map) override;
void OnMemoryPressure(
base::MemoryPressureLevel memory_pressure_level) override;
bool RendererIsHidden() const;
void OnRendererHidden();
void OnRendererVisible();
bool RendererIsBackgrounded() const;
void OnRendererBackgrounded();
void OnRendererForegrounded();
void OnRendererInterfaceReceiver(
mojo::PendingAssociatedReceiver<mojom::Renderer> receiver);
std::unique_ptr<media::MojoCodecFactory> CreateMediaMojoCodecFactory(
scoped_refptr<viz::ContextProviderCommandBuffer> context_provider,
bool enable_video_decode_accelerator,
bool enable_video_encode_accelerator);
mojom::RenderMessageFilter* render_message_filter();
void RequestNewItemsForFrameRoutingCache();
void PopulateFrameRoutingCacheWithItems(
std::vector<mojom::FrameRoutingInfoPtr> infos);
scoped_refptr<discardable_memory::ClientDiscardableSharedMemoryManager>
discardable_memory_allocator_;
std::unique_ptr<blink::scheduler::WebThreadScheduler> main_thread_scheduler_;
std::unique_ptr<RendererBlinkPlatformImpl> blink_platform_impl_;
std::unique_ptr<blink::URLLoaderThrottleProvider>
url_loader_throttle_provider_;
std::vector<std::string> cors_exempt_header_list_;
std::unique_ptr<blink::WebVideoCaptureImplManager> vc_manager_;
std::optional<base::Process::Priority> process_priority_;
perfetto::NamedTrack process_priority_track_{"Renderer priority"};
std::optional<mojom::RenderProcessVisibleState> visible_state_;
perfetto::NamedTrack process_visibility_track_{"Renderer visibility"};
std::optional<base::AtomicSharedMemory<base::TimeTicks>::ReadOnlyMapping>
last_foreground_time_mapping_;
blink::WebString user_agent_;
blink::UserAgentMetadata user_agent_metadata_;
bool is_gpu_compositing_disabled_ = false;
std::vector<std::unique_ptr<media::MojoGpuVideoAcceleratorFactories>>
gpu_factories_;
std::unique_ptr<base::Thread> media_thread_;
scoped_refptr<base::SequencedTaskRunner> media_task_runner_;
scoped_refptr<base::SingleThreadTaskRunner> compositor_task_runner_;
std::unique_ptr<base::Thread> video_frame_compositor_thread_;
#if BUILDFLAG(IS_WIN)
scoped_refptr<DCOMPTextureFactory> dcomp_texture_factory_;
scoped_refptr<OverlayStateServiceProviderImpl>
overlay_state_service_provider_;
#endif
#if BUILDFLAG(ARKWEB_SAME_LAYER)
scoped_refptr<NativeTextureFactory> native_texture_factory_;
#endif
#if BUILDFLAG(ARKWEB_READER_MODE)
blink::mojom::ReaderModeConfigPtr reader_mode_config_;
#endif
#if BUILDFLAG(ARKWEB_EXT_VIDEO_LOAD_OPTIMIZATION)
std::atomic<bool> video_load_opt_enable_{false};
std::atomic<int> preload_video_time_{4};
std::atomic<int> min_cache_time_{2};
std::atomic<int> max_cache_time_{6};
std::atomic<int> moov_size_{512};
std::atomic<int> bit_rate_{2000};
std::vector<std::string> support_domains_;
mutable std::mutex cloud_control_config_mutex;
#endif
scoped_refptr<viz::ContextProviderCommandBuffer> shared_main_thread_contexts_;
base::ObserverList<RenderThreadObserver>::Unchecked observers_;
scoped_refptr<viz::RasterContextProvider>
video_frame_compositor_context_provider_;
scoped_refptr<viz::RasterContextProvider> shared_worker_context_provider_;
scoped_refptr<gpu::SharedImageInterface> shared_image_interface_;
HistogramCustomizer histogram_customizer_;
std::unique_ptr<base::SyncMemoryPressureListenerRegistration>
memory_pressure_listener_registration_;
MemoryReclaimerPressureListener memory_reclaimer_pressure_listener_;
SkiaGraphicsPressureListener skia_graphics_pressure_listener_;
BlinkIsolatesPressureListener blink_isolates_pressure_listener_;
std::unique_ptr<viz::Gpu> gpu_;
std::unique_ptr<VariationsRenderThreadObserver> variations_observer_;
bool is_lcd_text_enabled_;
bool is_partial_raster_enabled_;
bool is_elastic_overscroll_enabled_;
bool is_threaded_animation_enabled_;
bool is_scroll_animator_enabled_;
gfx::ColorSpace rendering_color_space_;
mojo::AssociatedRemote<mojom::RendererHost> renderer_host_;
blink::AssociatedInterfaceRegistry associated_interfaces_;
mojo::AssociatedReceiver<mojom::Renderer> renderer_receiver_{this};
mojo::Remote<mojom::RenderMessageFilter> render_message_filter_;
std::set<std::unique_ptr<AgentSchedulingGroup>, base::UniquePtrComparator>
agent_scheduling_groups_;
int process_foregrounded_count_;
int32_t client_id_;
bool is_context_result_fatal_ = false;
mojo::Remote<viz::mojom::CompositingModeReporter> compositing_mode_reporter_;
mojo::Receiver<viz::mojom::CompositingModeWatcher>
compositing_mode_watcher_receiver_{this};
base::TimeTicks run_loop_start_time_;
std::deque<mojom::FrameRoutingInfoPtr> cached_frame_routing_;
bool cached_items_requested_ = false;
bool use_cached_routing_table_ = false;
blink::mojom::PerformanceTier cpu_performance_tier_ =
blink::mojom::PerformanceTier::kUnknown;
std::optional<base::ThreadPoolInstance::ScopedRestrictedTasks>
restrict_thread_pool_;
base::WeakPtrFactory<RenderThreadImpl> weak_factory_{this};
};
}
#endif