diff options
Diffstat (limited to 'WebCore/platform/sql')
-rw-r--r-- | WebCore/platform/sql/SQLValue.cpp | 8 | ||||
-rw-r--r-- | WebCore/platform/sql/SQLValue.h | 4 | ||||
-rw-r--r-- | WebCore/platform/sql/SQLiteTransaction.cpp | 15 | ||||
-rw-r--r-- | WebCore/platform/sql/SQLiteTransaction.h | 5 | ||||
-rw-r--r-- | WebCore/platform/sql/chromium/SQLiteFileSystemChromium.cpp | 10 | ||||
-rw-r--r-- | WebCore/platform/sql/chromium/SQLiteFileSystemChromiumLinux.cpp | 42 | ||||
-rw-r--r-- | WebCore/platform/sql/chromium/SQLiteFileSystemChromiumMac.cpp | 42 | ||||
-rw-r--r-- | WebCore/platform/sql/chromium/SQLiteFileSystemChromiumPosix.cpp | 190 | ||||
-rw-r--r-- | WebCore/platform/sql/chromium/SQLiteFileSystemChromiumWin.cpp | 13 |
9 files changed, 221 insertions, 108 deletions
diff --git a/WebCore/platform/sql/SQLValue.cpp b/WebCore/platform/sql/SQLValue.cpp index 7e178f9..0ad643e 100644 --- a/WebCore/platform/sql/SQLValue.cpp +++ b/WebCore/platform/sql/SQLValue.cpp @@ -32,10 +32,10 @@ namespace WebCore { SQLValue::SQLValue(const SQLValue& val) + : m_type(val.m_type) + , m_number(val.m_number) + , m_string(val.m_string.threadsafeCopy()) { - m_number = val.m_number; - m_string = val.m_string.copy(); - m_type = val.m_type; } String SQLValue::string() const @@ -43,7 +43,7 @@ String SQLValue::string() const ASSERT(m_type == StringValue); // Must return a copy since ref-shared Strings are not thread safe - return m_string.copy(); + return m_string.threadsafeCopy(); } double SQLValue::number() const diff --git a/WebCore/platform/sql/SQLValue.h b/WebCore/platform/sql/SQLValue.h index 7d85051..0f854fc 100644 --- a/WebCore/platform/sql/SQLValue.h +++ b/WebCore/platform/sql/SQLValue.h @@ -38,9 +38,9 @@ namespace WebCore { public: enum Type { NullValue, NumberValue, StringValue }; - SQLValue() : m_type(NullValue) { } + SQLValue() : m_type(NullValue), m_number(0.0) { } SQLValue(double number) : m_type(NumberValue), m_number(number) { } - SQLValue(const String& s) : m_type(StringValue), m_string(s) { } + SQLValue(const String& s) : m_type(StringValue), m_number(0.0), m_string(s) { } SQLValue(const SQLValue&); Type type() const { return m_type; } diff --git a/WebCore/platform/sql/SQLiteTransaction.cpp b/WebCore/platform/sql/SQLiteTransaction.cpp index 0a236be..a4b2ac8 100644 --- a/WebCore/platform/sql/SQLiteTransaction.cpp +++ b/WebCore/platform/sql/SQLiteTransaction.cpp @@ -30,9 +30,10 @@ namespace WebCore { -SQLiteTransaction::SQLiteTransaction(SQLiteDatabase& db) +SQLiteTransaction::SQLiteTransaction(SQLiteDatabase& db, bool readOnly) : m_db(db) , m_inProgress(false) + , m_readOnly(readOnly) { } @@ -46,7 +47,17 @@ void SQLiteTransaction::begin() { if (!m_inProgress) { ASSERT(!m_db.m_transactionInProgress); - m_inProgress = m_db.executeCommand("BEGIN;"); + // Call BEGIN IMMEDIATE for a write transaction to acquire + // a RESERVED lock on the DB file. Otherwise, another write + // transaction (on another connection) could make changes + // to the same DB file before this transaction gets to execute + // any statements. If that happens, this transaction will fail. + // http://www.sqlite.org/lang_transaction.html + // http://www.sqlite.org/lockingv3.html#locking + if (m_readOnly) + m_inProgress = m_db.executeCommand("BEGIN;"); + else + m_inProgress = m_db.executeCommand("BEGIN IMMEDIATE;"); m_db.m_transactionInProgress = m_inProgress; } } diff --git a/WebCore/platform/sql/SQLiteTransaction.h b/WebCore/platform/sql/SQLiteTransaction.h index cf5a180..557d81c 100644 --- a/WebCore/platform/sql/SQLiteTransaction.h +++ b/WebCore/platform/sql/SQLiteTransaction.h @@ -35,7 +35,7 @@ class SQLiteDatabase; class SQLiteTransaction : public Noncopyable { public: - SQLiteTransaction(SQLiteDatabase& db); + SQLiteTransaction(SQLiteDatabase& db, bool readOnly = false); ~SQLiteTransaction(); void begin(); @@ -47,10 +47,9 @@ public: private: SQLiteDatabase& m_db; bool m_inProgress; - + bool m_readOnly; }; } // namespace WebCore #endif // SQLiteTransation_H - diff --git a/WebCore/platform/sql/chromium/SQLiteFileSystemChromium.cpp b/WebCore/platform/sql/chromium/SQLiteFileSystemChromium.cpp index dc79fd0..3cf961f 100644 --- a/WebCore/platform/sql/chromium/SQLiteFileSystemChromium.cpp +++ b/WebCore/platform/sql/chromium/SQLiteFileSystemChromium.cpp @@ -55,10 +55,10 @@ int SQLiteFileSystem::openDatabase(const String& fileName, sqlite3** database) return sqlite3_open16(path.charactersWithNullTermination(), database); } - // open databases using Chromium's VFS + // open databases using the default VFS + // in renderers, it should be Chromium's VFS; in the browser process it should be SQLite's default VFS return sqlite3_open_v2(fileName.utf8().data(), database, - SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_FULLMUTEX, - "chromium_vfs"); + SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_FULLMUTEX, 0); } String SQLiteFileSystem::getFileNameForNewDatabase( @@ -99,9 +99,7 @@ bool SQLiteFileSystem::deleteEmptyDatabaseDirectory(const String&) bool SQLiteFileSystem::deleteDatabaseFile(const String& fileName) { - // return true if and only if the error code returned by - // ChromiumBridge::deleteDatabase() is 0 - return (!ChromiumBridge::databaseDeleteFile(fileName)); + return (ChromiumBridge::databaseDeleteFile(fileName) == SQLITE_OK); } long long SQLiteFileSystem::getDatabaseFileSize(const String& fileName) diff --git a/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumLinux.cpp b/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumLinux.cpp deleted file mode 100644 index 3582448..0000000 --- a/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumLinux.cpp +++ /dev/null @@ -1,42 +0,0 @@ -/* - * Copyright (C) 2009 Google Inc. All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions are - * met: - * - * * Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * * Redistributions in binary form must reproduce the above - * copyright notice, this list of conditions and the following disclaimer - * in the documentation and/or other materials provided with the - * distribution. - * * Neither the name of Google Inc. nor the names of its - * contributors may be used to endorse or promote products derived from - * this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS - * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT - * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR - * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT - * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, - * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT - * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE - * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -#include "config.h" -#include "SQLiteFileSystem.h" - -namespace WebCore { - -void SQLiteFileSystem::registerSQLiteVFS() -{ - // stub for registering Chromium's SQLite VFS for Linux - ASSERT_NOT_REACHED(); -} - -} // namespace WebCore diff --git a/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumMac.cpp b/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumMac.cpp deleted file mode 100644 index 35a40f5..0000000 --- a/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumMac.cpp +++ /dev/null @@ -1,42 +0,0 @@ -/* - * Copyright (C) 2009 Google Inc. All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions are - * met: - * - * * Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * * Redistributions in binary form must reproduce the above - * copyright notice, this list of conditions and the following disclaimer - * in the documentation and/or other materials provided with the - * distribution. - * * Neither the name of Google Inc. nor the names of its - * contributors may be used to endorse or promote products derived from - * this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS - * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT - * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR - * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT - * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, - * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT - * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE - * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -#include "config.h" -#include "SQLiteFileSystem.h" - -namespace WebCore { - -void SQLiteFileSystem::registerSQLiteVFS() -{ - // stub for registering Chromium's SQLite VFS for Mac - ASSERT_NOT_REACHED(); -} - -} // namespace WebCore diff --git a/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumPosix.cpp b/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumPosix.cpp new file mode 100644 index 0000000..2960a5f --- /dev/null +++ b/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumPosix.cpp @@ -0,0 +1,190 @@ +/* + * Copyright (C) 2009 Google Inc. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are + * met: + * + * * Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * * Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the following disclaimer + * in the documentation and/or other materials provided with the + * distribution. + * * Neither the name of Google Inc. nor the names of its + * contributors may be used to endorse or promote products derived from + * this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS + * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT + * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR + * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT + * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT + * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include "config.h" +#include "SQLiteFileSystem.h" + +#include "ChromiumBridge.h" +#include <sqlite3.h> + +#include <fcntl.h> +#include <string.h> +#include <unistd.h> + +using namespace WebCore; + +// Defined in Chromium's codebase in third_party/sqlite/src/os_unix.c +extern "C" { +void initUnixFile(sqlite3_file* file); +int fillInUnixFile(sqlite3_vfs* vfs, int fd, int dirfd, sqlite3_file* file, const char* fileName, int noLock); +} + +// Chromium's Posix implementation of SQLite VFS +namespace { + +// Opens a file. +// +// vfs - pointer to the sqlite3_vfs object. +// fileName - the name of the file. +// id - the structure that will manipulate the newly opened file. +// desiredFlags - the desired open mode flags. +// usedFlags - the actual open mode flags that were used. +int chromiumOpen(sqlite3_vfs* vfs, const char* fileName, + sqlite3_file* id, int desiredFlags, int* usedFlags) +{ + initUnixFile(id); + int dirfd = -1; + int fd = ChromiumBridge::databaseOpenFile(fileName, desiredFlags, &dirfd); + if (fd < 0) { + if (desiredFlags & SQLITE_OPEN_READWRITE) { + int newFlags = (desiredFlags & ~(SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE)) | SQLITE_OPEN_READONLY; + return chromiumOpen(vfs, fileName, id, newFlags, usedFlags); + } else + return SQLITE_CANTOPEN; + } + if (usedFlags) + *usedFlags = desiredFlags; + + fcntl(fd, F_SETFD, fcntl(fd, F_GETFD) | FD_CLOEXEC); + if (dirfd >= 0) + fcntl(dirfd, F_SETFD, fcntl(fd, F_GETFD) | FD_CLOEXEC); + + // The mask 0x00007F00 gives us the 7 bits that determine the type of the file SQLite is trying to open. + int fileType = desiredFlags & 0x00007F00; + int noLock = (fileType != SQLITE_OPEN_MAIN_DB); + return fillInUnixFile(vfs, fd, dirfd, id, fileName, noLock); +} + +// Deletes the given file. +// +// vfs - pointer to the sqlite3_vfs object. +// fileName - the name of the file. +// syncDir - determines if the directory to which this file belongs +// should be synched after the file is deleted. +int chromiumDelete(sqlite3_vfs*, const char* fileName, int syncDir) +{ + return ChromiumBridge::databaseDeleteFile(fileName, syncDir); +} + +// Check the existance and status of the given file. +// +// vfs - pointer to the sqlite3_vfs object. +// fileName - the name of the file. +// flag - the type of test to make on this file. +// res - the result. +int chromiumAccess(sqlite3_vfs*, const char* fileName, int flag, int* res) +{ + int attr = static_cast<int>(ChromiumBridge::databaseGetFileAttributes(fileName)); + if (attr < 0) { + *res = 0; + return SQLITE_OK; + } + + switch (flag) { + case SQLITE_ACCESS_EXISTS: + *res = 1; // if the file doesn't exist, attr < 0 + break; + case SQLITE_ACCESS_READWRITE: + *res = (attr & W_OK) && (attr & R_OK); + break; + case SQLITE_ACCESS_READ: + *res = (attr & R_OK); + break; + default: + return SQLITE_ERROR; + } + + return SQLITE_OK; +} + +// Turns a relative pathname into a full pathname. +// +// vfs - pointer to the sqlite3_vfs object. +// relativePath - the relative path. +// bufSize - the size of the output buffer in bytes. +// absolutePath - the output buffer where the absolute path will be stored. +int chromiumFullPathname(sqlite3_vfs* vfs, const char* relativePath, + int, char* absolutePath) +{ + // The renderer process doesn't need to know the absolute path of the file + sqlite3_snprintf(vfs->mxPathname, absolutePath, "%s", relativePath); + return SQLITE_OK; +} + +#ifndef SQLITE_OMIT_LOAD_EXTENSION +// Returns NULL, thus disallowing loading libraries in the renderer process. +// +// vfs - pointer to the sqlite3_vfs object. +// fileName - the name of the shared library file. +void* chromiumDlOpen(sqlite3_vfs*, const char*) +{ + return 0; +} +#else +#define chromiumDlOpen 0 +#endif // SQLITE_OMIT_LOAD_EXTENSION + +} // namespace + +namespace WebCore { + +void SQLiteFileSystem::registerSQLiteVFS() +{ + // FIXME: Make sure there aren't any unintended consequences when VFS code is called in the browser process. + if (!ChromiumBridge::sandboxEnabled()) { + ASSERT_NOT_REACHED(); + return; + } + + sqlite3_vfs* unix_vfs = sqlite3_vfs_find("unix"); + static sqlite3_vfs chromium_vfs = { + 1, + unix_vfs->szOsFile, + unix_vfs->mxPathname, + 0, + "chromium_vfs", + unix_vfs->pAppData, + chromiumOpen, + chromiumDelete, + chromiumAccess, + chromiumFullPathname, + chromiumDlOpen, + unix_vfs->xDlError, + unix_vfs->xDlSym, + unix_vfs->xDlClose, + unix_vfs->xRandomness, + unix_vfs->xSleep, + unix_vfs->xCurrentTime, + unix_vfs->xGetLastError + }; + sqlite3_vfs_register(&chromium_vfs, 1); +} + +} // namespace WebCore diff --git a/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumWin.cpp b/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumWin.cpp index b357d4a..153793b 100644 --- a/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumWin.cpp +++ b/WebCore/platform/sql/chromium/SQLiteFileSystemChromiumWin.cpp @@ -35,6 +35,8 @@ #include <sqlite3.h> #include <windows.h> +using namespace WebCore; + // Defined in Chromium's codebase in third_party/sqlite/src/os_win.c extern "C" { int chromium_sqlite3_initialize_win_sqlite3_file(sqlite3_file* file, HANDLE handle); @@ -53,7 +55,7 @@ namespace { int chromiumOpen(sqlite3_vfs*, const char* fileName, sqlite3_file* id, int desiredFlags, int* usedFlags) { - HANDLE h = WebCore::ChromiumBridge::databaseOpenFile(fileName, desiredFlags); + HANDLE h = ChromiumBridge::databaseOpenFile(fileName, desiredFlags); if (h == INVALID_HANDLE_VALUE) { if (desiredFlags & SQLITE_OPEN_READWRITE) { int newFlags = (desiredFlags | SQLITE_OPEN_READONLY) & ~SQLITE_OPEN_READWRITE; @@ -80,10 +82,7 @@ int chromiumOpen(sqlite3_vfs*, const char* fileName, // should be synched after the file is deleted. int chromiumDelete(sqlite3_vfs*, const char* fileName, int) { - bool deleted = WebCore::ChromiumBridge::databaseDeleteFile(fileName); - DWORD rc = WebCore::ChromiumBridge::databaseGetFileAttributes(fileName); - return ((rc == INVALID_FILE_ATTRIBUTES) && deleted ? - SQLITE_OK : SQLITE_IOERR_DELETE); + return ChromiumBridge::databaseDeleteFile(fileName); } // Check the existance and status of the given file. @@ -94,7 +93,7 @@ int chromiumDelete(sqlite3_vfs*, const char* fileName, int) // res - the result. int chromiumAccess(sqlite3_vfs*, const char* fileName, int flag, int* res) { - DWORD attr = WebCore::ChromiumBridge::databaseGetFileAttributes(fileName); + DWORD attr = ChromiumBridge::databaseGetFileAttributes(fileName); switch (flag) { case SQLITE_ACCESS_READ: case SQLITE_ACCESS_EXISTS: @@ -156,7 +155,7 @@ void SQLiteFileSystem::registerSQLiteVFS() win32_vfs->mxPathname, 0, "chromium_vfs", - 0, + win32_vfs->pAppData, chromiumOpen, chromiumDelete, chromiumAccess, |