base: Move renderer threads to the appropriate cpuset.

content/browser/renderer_host/render_message_filter.cc

 // Copyright (c) 2012 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 "content/browser/renderer_host/render_message_filter.h"
 
 #include <errno.h>
 #include <string.h>
 #include <map>
 #include <utility>
@@ skipping 71 matching lines @@
 #endif
 
 #if defined(OS_ANDROID)
 #include "content/browser/media/android/media_throttler.h"
 #endif
 
 #if defined(OS_MACOSX)
 #include "ui/accelerated_widget_mac/window_resize_helper_mac.h"
 #endif
 
+#if defined(OS_LINUX)
+#include "base/linux_util.h"
+#include "base/threading/platform_thread.h"
+#endif
+
 namespace content {
 namespace {
 
 const uint32_t kFilteredMessageClasses[] = {
     ChildProcessMsgStart, RenderProcessMsgStart, ViewMsgStart,
 };
 
 #if defined(OS_MACOSX)
 void ResizeHelperHandleMsgOnUIThread(int render_process_id,
                                      const IPC::Message& message) {
@@ skipping 95 matching lines @@
                         OnDeletedGpuMemoryBuffer)
     IPC_MESSAGE_HANDLER(ChildProcessHostMsg_AllocatedSharedBitmap,
                         OnAllocatedSharedBitmap)
     IPC_MESSAGE_HANDLER(ChildProcessHostMsg_DeletedSharedBitmap,
                         OnDeletedSharedBitmap)
     IPC_MESSAGE_HANDLER_DELAY_REPLY(
         ChildProcessHostMsg_SyncAllocateLockedDiscardableSharedMemory,
         OnAllocateLockedDiscardableSharedMemory)
     IPC_MESSAGE_HANDLER(ChildProcessHostMsg_DeletedDiscardableSharedMemory,
                         OnDeletedDiscardableSharedMemory)
+#if defined(OS_LINUX)
+    IPC_MESSAGE_HANDLER(ChildProcessHostMsg_SetThreadPriority,
+                        OnSetThreadPriority)
+#endif
     IPC_MESSAGE_HANDLER_DELAY_REPLY(RenderProcessHostMsg_Keygen, OnKeygen)
     IPC_MESSAGE_HANDLER(RenderProcessHostMsg_DidGenerateCacheableMetadata,
                         OnCacheableMetadataAvailable)
     IPC_MESSAGE_HANDLER(
         RenderProcessHostMsg_DidGenerateCacheableMetadataInCacheStorage,
         OnCacheableMetadataAvailableForCacheStorage)
 #if defined(OS_MACOSX)
     IPC_MESSAGE_HANDLER_DELAY_REPLY(RenderProcessHostMsg_LoadFont, OnLoadFont)
 #endif
     IPC_MESSAGE_HANDLER(ViewHostMsg_MediaLogEvents, OnMediaLogEvents)
@@ skipping 190 matching lines @@
 
 void RenderMessageFilter::OnDeletedDiscardableSharedMemory(
     DiscardableSharedMemoryId id) {
   BrowserThread::PostTask(
       BrowserThread::FILE_USER_BLOCKING, FROM_HERE,
       base::Bind(
           &RenderMessageFilter::DeletedDiscardableSharedMemoryOnFileThread,
           this, id));
 }
 
+#if defined(OS_LINUX)
+void RenderMessageFilter::SetThreadPriorityOnFileThread(
+    base::PlatformThreadId ns_tid,
+    base::ThreadPriority priority) {
+  bool ns_pid_supported = false;
+  pid_t peer_tid = base::FindThreadID(peer_pid(), ns_tid, &ns_pid_supported);
+  if (peer_tid == -1) {
+    if (ns_pid_supported)
+      DLOG(WARNING) << "Could not find tid";
+    return;
+  }
+
+  if (peer_tid == peer_pid()) {
+    DLOG(WARNING) << "Changing priority of main thread is not allowed";

[Nico, 2016/09/19 20:49:30]

remove (?)

[reveman, 2016/09/19 21:43:39]

Remove the warning log for this case? I'd like to keep it in case we
accidentally write some code in the renderer that tries to do this and this
would at least give some warning to the developer that it's not working as
expected. It's a DLOG to prevent a malicious renderer from flooding the log.

+    return;
+  }
+
+  base::PlatformThread::SetThreadPriority(peer_tid, priority);
+}
+
+void RenderMessageFilter::OnSetThreadPriority(base::PlatformThreadId ns_tid,
+                                              base::ThreadPriority priority) {
+  BrowserThread::PostTask(
+      BrowserThread::FILE_USER_BLOCKING, FROM_HERE,
+      base::Bind(&RenderMessageFilter::SetThreadPriorityOnFileThread, this,
+                 ns_tid, priority));
+}
+#endif
+
 void RenderMessageFilter::OnCacheableMetadataAvailable(
     const GURL& url,
     base::Time expected_response_time,
     const std::vector<char>& data) {
   net::HttpCache* cache = request_context_->GetURLRequestContext()->
       http_transaction_factory()->GetCache();
   if (!cache)
     return;
 
   // Use the same priority for the metadata write as for script
@@ skipping 213 matching lines @@
 void RenderMessageFilter::OnDeletedGpuMemoryBuffer(
     gfx::GpuMemoryBufferId id,
     const gpu::SyncToken& sync_token) {
   DCHECK(BrowserGpuMemoryBufferManager::current());
 
   BrowserGpuMemoryBufferManager::current()->ChildProcessDeletedGpuMemoryBuffer(
       id, PeerHandle(), render_process_id_, sync_token);
 }
 
 }  // namespace content