Index: content/browser/renderer_host/render_message_filter.cc |
diff --git a/content/browser/renderer_host/render_message_filter.cc b/content/browser/renderer_host/render_message_filter.cc |
index 9e2aa1c63738e4396a14e26bb2b503987dfa7b76..8c96f8504fcaa89e6a44369129fc0c97b9d21a98 100644 |
--- a/content/browser/renderer_host/render_message_filter.cc |
+++ b/content/browser/renderer_host/render_message_filter.cc |
@@ -204,6 +204,8 @@ bool RenderMessageFilter::OnMessageReceived(const IPC::Message& message) { |
OnAllocateLockedDiscardableSharedMemory) |
IPC_MESSAGE_HANDLER(ChildProcessHostMsg_DeletedDiscardableSharedMemory, |
OnDeletedDiscardableSharedMemory) |
+ IPC_MESSAGE_HANDLER(ChildProcessHostMsg_SetThreadAffinity, |
+ OnSetThreadAffinity) |
IPC_MESSAGE_HANDLER_DELAY_REPLY(RenderProcessHostMsg_Keygen, OnKeygen) |
IPC_MESSAGE_HANDLER(RenderProcessHostMsg_DidGenerateCacheableMetadata, |
OnCacheableMetadataAvailable) |
@@ -414,6 +416,24 @@ void RenderMessageFilter::OnDeletedDiscardableSharedMemory( |
this, id)); |
} |
+void RenderMessageFilter::SetThreadAffinityOnFileThread( |
+ base::PlatformThreadId id, |
+ base::ThreadPriority priority) { |
+#if defined(OS_LINUX) |
+ base::PlatformThread::SetThreadAffinity( |
+ peer_pid() + id + 1, // Magic conversion to global Thread ID. |
+ priority); |
+#endif |
+} |
+ |
+void RenderMessageFilter::OnSetThreadAffinity(base::PlatformThreadId id, |
+ base::ThreadPriority priority) { |
+ BrowserThread::PostTask( |
+ BrowserThread::FILE_USER_BLOCKING, FROM_HERE, |
+ base::Bind(&RenderMessageFilter::SetThreadAffinityOnFileThread, this, id, |
+ priority)); |
+} |
+ |
void RenderMessageFilter::OnCacheableMetadataAvailable( |
const GURL& url, |
base::Time expected_response_time, |