Move core pieces of browser\renderer_host to src\content.

chrome/browser/renderer_host/database_message_filter.cc

Index: chrome/browser/renderer_host/database_message_filter.cc
===================================================================
--- chrome/browser/renderer_host/database_message_filter.cc	(revision 75488)
+++ chrome/browser/renderer_host/database_message_filter.cc	(working copy)
@@ -1,323 +0,0 @@
-// Copyright (c) 2010 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 "chrome/browser/renderer_host/database_message_filter.h"
-
-#include <string>
-
-#include "base/string_util.h"
-#include "base/threading/thread.h"
-#include "chrome/browser/content_settings/host_content_settings_map.h"
-#include "chrome/browser/metrics/user_metrics.h"
-#include "chrome/browser/net/chrome_url_request_context.h"
-#include "chrome/common/database_messages.h"
-#include "chrome/common/result_codes.h"
-#include "googleurl/src/gurl.h"
-#include "third_party/sqlite/sqlite3.h"
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebSecurityOrigin.h"
-#include "webkit/database/database_util.h"
-#include "webkit/database/vfs_backend.h"
-
-#if defined(OS_POSIX)
-#include "base/file_descriptor_posix.h"
-#endif
-
-using WebKit::WebSecurityOrigin;
-using webkit_database::DatabaseTracker;
-using webkit_database::DatabaseUtil;
-using webkit_database::VfsBackend;
-
-const int kNumDeleteRetries = 2;
-const int kDelayDeleteRetryMs = 100;
-
-DatabaseMessageFilter::DatabaseMessageFilter(
-    webkit_database::DatabaseTracker* db_tracker,
-    HostContentSettingsMap *host_content_settings_map)
-    : db_tracker_(db_tracker),
-      observer_added_(false),
-      host_content_settings_map_(host_content_settings_map) {
-  DCHECK(db_tracker_);
-}
-
-void DatabaseMessageFilter::OnChannelClosing() {
-  BrowserMessageFilter::OnChannelClosing();
-  if (observer_added_) {
-    observer_added_ = false;
-    BrowserThread::PostTask(
-        BrowserThread::FILE, FROM_HERE,
-        NewRunnableMethod(this, &DatabaseMessageFilter::RemoveObserver));
-  }
-}
-
-void DatabaseMessageFilter::AddObserver() {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  db_tracker_->AddObserver(this);
-}
-
-void DatabaseMessageFilter::RemoveObserver() {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-
-  // If the renderer process died without closing all databases,
-  // then we need to manually close those connections
-  db_tracker_->CloseDatabases(database_connections_);
-  database_connections_.RemoveAllConnections();
-
-  db_tracker_->RemoveObserver(this);
-}
-
-void DatabaseMessageFilter::OverrideThreadForMessage(
-    const IPC::Message& message,
-    BrowserThread::ID* thread) {
-  if (IPC_MESSAGE_CLASS(message) == DatabaseMsgStart &&
-      message.type() != DatabaseHostMsg_Allow::ID) {
-    *thread = BrowserThread::FILE;
-  }
-
-  if (message.type() == DatabaseHostMsg_OpenFile::ID && !observer_added_) {
-    observer_added_ = true;
-    BrowserThread::PostTask(
-        BrowserThread::FILE, FROM_HERE,
-        NewRunnableMethod(this, &DatabaseMessageFilter::AddObserver));
-  }
-}
-
-bool DatabaseMessageFilter::OnMessageReceived(
-    const IPC::Message& message,
-    bool* message_was_ok) {
-  bool handled = true;
-  IPC_BEGIN_MESSAGE_MAP_EX(DatabaseMessageFilter, message, *message_was_ok)
-    IPC_MESSAGE_HANDLER_DELAY_REPLY(DatabaseHostMsg_OpenFile,
-                                    OnDatabaseOpenFile)
-    IPC_MESSAGE_HANDLER_DELAY_REPLY(DatabaseHostMsg_DeleteFile,
-                                    OnDatabaseDeleteFile)
-    IPC_MESSAGE_HANDLER_DELAY_REPLY(DatabaseHostMsg_GetFileAttributes,
-                                    OnDatabaseGetFileAttributes)
-    IPC_MESSAGE_HANDLER_DELAY_REPLY(DatabaseHostMsg_GetFileSize,
-                                    OnDatabaseGetFileSize)
-    IPC_MESSAGE_HANDLER(DatabaseHostMsg_Opened, OnDatabaseOpened)
-    IPC_MESSAGE_HANDLER(DatabaseHostMsg_Modified, OnDatabaseModified)
-    IPC_MESSAGE_HANDLER(DatabaseHostMsg_Closed, OnDatabaseClosed)
-    IPC_MESSAGE_HANDLER_DELAY_REPLY(DatabaseHostMsg_Allow, OnAllowDatabase)
-    IPC_MESSAGE_UNHANDLED(handled = false)
-  IPC_END_MESSAGE_MAP_EX()
-  return handled;
-}
-
-DatabaseMessageFilter::~DatabaseMessageFilter() {
-}
-
-void DatabaseMessageFilter::OnDatabaseOpenFile(const string16& vfs_file_name,
-                                               int desired_flags,
-                                               IPC::Message* reply_msg) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  base::PlatformFile file_handle = base::kInvalidPlatformFileValue;
-  base::PlatformFile target_handle = base::kInvalidPlatformFileValue;
-  string16 origin_identifier;
-  string16 database_name;
-
-  // When in incognito mode, we want to make sure that all DB files are
-  // removed when the incognito profile goes away, so we add the
-  // SQLITE_OPEN_DELETEONCLOSE flag when opening all files, and keep
-  // open handles to them in the database tracker to make sure they're
-  // around for as long as needed.
-  if (vfs_file_name.empty()) {
-    VfsBackend::OpenTempFileInDirectory(db_tracker_->DatabaseDirectory(),
-                                        desired_flags, &file_handle);
-  } else if (DatabaseUtil::CrackVfsFileName(vfs_file_name, &origin_identifier,
-                                            &database_name, NULL) &&
-             !db_tracker_->IsDatabaseScheduledForDeletion(origin_identifier,
-                                                          database_name)) {
-      FilePath db_file =
-          DatabaseUtil::GetFullFilePathForVfsFile(db_tracker_, vfs_file_name);
-      if (!db_file.empty()) {
-        if (db_tracker_->IsIncognitoProfile()) {
-          db_tracker_->GetIncognitoFileHandle(vfs_file_name, &file_handle);
-          if (file_handle == base::kInvalidPlatformFileValue) {
-            VfsBackend::OpenFile(db_file,
-                                 desired_flags | SQLITE_OPEN_DELETEONCLOSE,
-                                 &file_handle);
-            if (VfsBackend::FileTypeIsMainDB(desired_flags) ||
-                VfsBackend::FileTypeIsJournal(desired_flags))
-              db_tracker_->SaveIncognitoFileHandle(vfs_file_name, file_handle);
-          }
-        } else {
-          VfsBackend::OpenFile(db_file, desired_flags, &file_handle);
-        }
-      }
-  }
-
-  // Then we duplicate the file handle to make it useable in the renderer
-  // process. The original handle is closed, unless we saved it in the
-  // database tracker.
-  bool auto_close = !db_tracker_->HasSavedIncognitoFileHandle(vfs_file_name);
-  VfsBackend::GetFileHandleForProcess(peer_handle(), file_handle,
-                                      &target_handle, auto_close);
-
-  DatabaseHostMsg_OpenFile::WriteReplyParams(
-      reply_msg,
-#if defined(OS_WIN)
-      target_handle
-#elif defined(OS_POSIX)
-      base::FileDescriptor(target_handle, auto_close)
-#endif
-      );
-  Send(reply_msg);
-}
-
-void DatabaseMessageFilter::OnDatabaseDeleteFile(const string16& vfs_file_name,
-                                                 const bool& sync_dir,
-                                                 IPC::Message* reply_msg) {
-  DatabaseDeleteFile(vfs_file_name, sync_dir, reply_msg, kNumDeleteRetries);
-}
-
-void DatabaseMessageFilter::DatabaseDeleteFile(const string16& vfs_file_name,
-                                               bool sync_dir,
-                                               IPC::Message* reply_msg,
-                                               int reschedule_count) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-
-  // Return an error if the file name is invalid or if the file could not
-  // be deleted after kNumDeleteRetries attempts.
-  int error_code = SQLITE_IOERR_DELETE;
-  FilePath db_file =
-      DatabaseUtil::GetFullFilePathForVfsFile(db_tracker_, vfs_file_name);
-  if (!db_file.empty()) {
-    // In order to delete a journal file in incognito mode, we only need to
-    // close the open handle to it that's stored in the database tracker.
-    if (db_tracker_->IsIncognitoProfile()) {
-      if (db_tracker_->CloseIncognitoFileHandle(vfs_file_name))
-        error_code = SQLITE_OK;
-    } else {
-      error_code = VfsBackend::DeleteFile(db_file, sync_dir);
-    }
-
-    if ((error_code == SQLITE_IOERR_DELETE) && reschedule_count) {
-      // If the file could not be deleted, try again.
-      BrowserThread::PostDelayedTask(
-          BrowserThread::FILE, FROM_HERE,
-          NewRunnableMethod(this,
-                            &DatabaseMessageFilter::DatabaseDeleteFile,
-                            vfs_file_name,
-                            sync_dir,
-                            reply_msg,
-                            reschedule_count - 1),
-          kDelayDeleteRetryMs);
-      return;
-    }
-  }
-
-  DatabaseHostMsg_DeleteFile::WriteReplyParams(reply_msg, error_code);
-  Send(reply_msg);
-}
-
-void DatabaseMessageFilter::OnDatabaseGetFileAttributes(
-    const string16& vfs_file_name,
-    IPC::Message* reply_msg) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  int32 attributes = -1;
-  FilePath db_file =
-      DatabaseUtil::GetFullFilePathForVfsFile(db_tracker_, vfs_file_name);
-  if (!db_file.empty())
-    attributes = VfsBackend::GetFileAttributes(db_file);
-
-  DatabaseHostMsg_GetFileAttributes::WriteReplyParams(
-      reply_msg, attributes);
-  Send(reply_msg);
-}
-
-void DatabaseMessageFilter::OnDatabaseGetFileSize(
-  const string16& vfs_file_name, IPC::Message* reply_msg) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  int64 size = 0;
-  FilePath db_file =
-      DatabaseUtil::GetFullFilePathForVfsFile(db_tracker_, vfs_file_name);
-  if (!db_file.empty())
-    size = VfsBackend::GetFileSize(db_file);
-
-  DatabaseHostMsg_GetFileSize::WriteReplyParams(reply_msg, size);
-  Send(reply_msg);
-}
-
-void DatabaseMessageFilter::OnDatabaseOpened(const string16& origin_identifier,
-                                             const string16& database_name,
-                                             const string16& description,
-                                             int64 estimated_size) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  int64 database_size = 0;
-  int64 space_available = 0;
-  database_connections_.AddConnection(origin_identifier, database_name);
-  db_tracker_->DatabaseOpened(origin_identifier, database_name, description,
-                              estimated_size, &database_size, &space_available);
-  Send(new DatabaseMsg_UpdateSize(origin_identifier, database_name,
-                                  database_size, space_available));
-}
-
-void DatabaseMessageFilter::OnDatabaseModified(
-    const string16& origin_identifier,
-    const string16& database_name) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  if (!database_connections_.IsDatabaseOpened(
-          origin_identifier, database_name)) {
-    UserMetrics::RecordAction(UserMetricsAction("BadMessageTerminate_DBMF"));
-    BadMessageReceived();
-    return;
-  }
-
-  db_tracker_->DatabaseModified(origin_identifier, database_name);
-}
-
-void DatabaseMessageFilter::OnDatabaseClosed(const string16& origin_identifier,
-                                             const string16& database_name) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  if (!database_connections_.IsDatabaseOpened(
-          origin_identifier, database_name)) {
-    UserMetrics::RecordAction(UserMetricsAction("BadMessageTerminate_DBMF"));
-    BadMessageReceived();
-    return;
-  }
-
-  db_tracker_->DatabaseClosed(origin_identifier, database_name);
-  database_connections_.RemoveConnection(origin_identifier, database_name);
-}
-
-void DatabaseMessageFilter::OnAllowDatabase(const std::string& origin_url,
-                                            const string16& name,
-                                            const string16& display_name,
-                                            unsigned long estimated_size,
-                                            IPC::Message* reply_msg) {
-  GURL url = GURL(origin_url);
-  ContentSetting content_setting =
-      host_content_settings_map_->GetContentSetting(
-          url, CONTENT_SETTINGS_TYPE_COOKIES, "");
-  AllowDatabaseResponse(reply_msg, content_setting);
-}
-
-void DatabaseMessageFilter::AllowDatabaseResponse(
-    IPC::Message* reply_msg, ContentSetting content_setting) {
-  DCHECK((content_setting == CONTENT_SETTING_ALLOW) ||
-         (content_setting == CONTENT_SETTING_BLOCK) ||
-         (content_setting == CONTENT_SETTING_SESSION_ONLY));
-  DatabaseHostMsg_Allow::WriteReplyParams(
-      reply_msg, content_setting != CONTENT_SETTING_BLOCK);
-  Send(reply_msg);
-}
-
-void DatabaseMessageFilter::OnDatabaseSizeChanged(
-    const string16& origin_identifier,
-    const string16& database_name,
-    int64 database_size,
-    int64 space_available) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  if (database_connections_.IsOriginUsed(origin_identifier)) {
-    Send(new DatabaseMsg_UpdateSize(origin_identifier, database_name,
-                                    database_size, space_available));
-  }
-}
-
-void DatabaseMessageFilter::OnDatabaseScheduledForDeletion(
-    const string16& origin_identifier,
-    const string16& database_name) {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-  Send(new DatabaseMsg_CloseImmediately(origin_identifier, database_name));
-}