Changeset 220105 in webkit
- Timestamp:
- Aug 1, 2017, 11:18:03 AM (9 years ago)
- Location:
- trunk
- Files:
-
- 52 edited
-
Source/WebKit/ChangeLog (modified) (1 diff)
-
Source/WebKit/NetworkProcess/NetworkConnectionToWebProcess.cpp (modified) (1 diff)
-
Source/WebKit/NetworkProcess/NetworkProcess.cpp (modified) (2 diffs)
-
Source/WebKit/NetworkProcess/NetworkProcess.h (modified) (2 diffs)
-
Source/WebKit/NetworkProcess/NetworkProcess.messages.in (modified) (1 diff)
-
Source/WebKit/Shared/ProcessExecutablePath.h (modified) (1 diff)
-
Source/WebKit/Shared/gtk/ProcessExecutablePathGtk.cpp (modified) (1 diff)
-
Source/WebKit/Shared/wpe/ProcessExecutablePathWPE.cpp (modified) (1 diff)
-
Source/WebKit/StorageProcess/IndexedDB/WebIDBConnectionToClient.cpp (modified) (1 diff)
-
Source/WebKit/StorageProcess/StorageProcess.cpp (modified) (6 diffs)
-
Source/WebKit/StorageProcess/StorageProcess.h (modified) (4 diffs)
-
Source/WebKit/StorageProcess/StorageProcess.messages.in (modified) (1 diff)
-
Source/WebKit/StorageProcess/mac/StorageProcessMac.mm (modified) (1 diff)
-
Source/WebKit/UIProcess/API/C/WKContext.cpp (modified) (1 diff)
-
Source/WebKit/UIProcess/API/Cocoa/WKProcessPool.mm (modified) (2 diffs)
-
Source/WebKit/UIProcess/API/Cocoa/WKProcessPoolPrivate.h (modified) (1 diff)
-
Source/WebKit/UIProcess/ChildProcessProxy.cpp (modified) (1 diff)
-
Source/WebKit/UIProcess/Launcher/ProcessLauncher.h (modified) (1 diff)
-
Source/WebKit/UIProcess/Launcher/gtk/ProcessLauncherGtk.cpp (modified) (1 diff)
-
Source/WebKit/UIProcess/Launcher/mac/ProcessLauncherMac.mm (modified) (1 diff)
-
Source/WebKit/UIProcess/Launcher/wpe/ProcessLauncherWPE.cpp (modified) (1 diff)
-
Source/WebKit/UIProcess/Network/NetworkProcessProxy.cpp (modified) (2 diffs)
-
Source/WebKit/UIProcess/Network/NetworkProcessProxy.h (modified) (1 diff)
-
Source/WebKit/UIProcess/Network/NetworkProcessProxy.messages.in (modified) (1 diff)
-
Source/WebKit/UIProcess/Storage/StorageProcessProxy.cpp (modified) (6 diffs)
-
Source/WebKit/UIProcess/Storage/StorageProcessProxy.h (modified) (3 diffs)
-
Source/WebKit/UIProcess/Storage/StorageProcessProxy.messages.in (modified) (1 diff)
-
Source/WebKit/UIProcess/WebContextClient.cpp (modified) (1 diff)
-
Source/WebKit/UIProcess/WebContextClient.h (modified) (1 diff)
-
Source/WebKit/UIProcess/WebProcessPool.cpp (modified) (7 diffs)
-
Source/WebKit/UIProcess/WebProcessPool.h (modified) (6 diffs)
-
Source/WebKit/UIProcess/WebProcessProxy.cpp (modified) (1 diff)
-
Source/WebKit/UIProcess/WebProcessProxy.h (modified) (1 diff)
-
Source/WebKit/UIProcess/WebProcessProxy.messages.in (modified) (1 diff)
-
Source/WebKit/UIProcess/WebsiteData/WebsiteDataStore.cpp (modified) (4 diffs)
-
Source/WebKit/UIProcess/WebsiteData/WebsiteDataStore.h (modified) (1 diff)
-
Source/WebKit/WebProcess/Databases/IndexedDB/WebIDBConnectionToServer.cpp (modified) (1 diff)
-
Source/WebKit/WebProcess/Databases/IndexedDB/WebIDBConnectionToServer.h (modified) (1 diff)
-
Source/WebKit/WebProcess/Databases/WebDatabaseProvider.cpp (modified) (1 diff)
-
Source/WebKit/WebProcess/Storage/WebToStorageProcessConnection.cpp (modified) (4 diffs)
-
Source/WebKit/WebProcess/Storage/WebToStorageProcessConnection.h (modified) (2 diffs)
-
Source/WebKit/WebProcess/WebProcess.cpp (modified) (2 diffs)
-
Source/WebKit/WebProcess/WebProcess.h (modified) (3 diffs)
-
Tools/ChangeLog (modified) (1 diff)
-
Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IDBDeleteRecovery.mm (modified) (1 diff)
-
Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IDBIndexUpgradeToV2.mm (modified) (1 diff)
-
Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBDatabaseProcessKill.mm (modified) (1 diff)
-
Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBMultiProcess.mm (modified) (1 diff)
-
Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBPersistence.mm (modified) (1 diff)
-
Tools/TestWebKitAPI/Tests/WebKit2Cocoa/ResourceLoadStatistics.mm (modified) (2 diffs)
-
Tools/TestWebKitAPI/Tests/WebKit2Cocoa/WebProcessKillIDBCleanup.mm (modified) (1 diff)
-
Tools/TestWebKitAPI/Tests/WebKit2Cocoa/WebsiteDataStoreCustomPaths.mm (modified) (2 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Source/WebKit/ChangeLog
r220094 r220105 1 2017-08-01 Brady Eidson <beidson@apple.com> 2 3 Part 2 of: Rename DatabaseProcess to StorageProcess. 4 https://bugs.webkit.org/show_bug.cgi?id=174880 5 6 Reviewed by Andy Estes. 7 8 Rename some more variables, classes, etc. to reflect the change. 9 10 * NetworkProcess/NetworkConnectionToWebProcess.cpp: 11 (WebKit::NetworkConnectionToWebProcess::writeBlobsToTemporaryFiles): 12 13 * NetworkProcess/NetworkProcess.cpp: 14 (WebKit::NetworkProcess::grantSandboxExtensionsToStorageProcessForBlobs): 15 (WebKit::NetworkProcess::didGrantSandboxExtensionsToStorageProcessForBlobs): 16 (WebKit::NetworkProcess::grantSandboxExtensionsToDatabaseProcessForBlobs): Deleted. 17 (WebKit::NetworkProcess::didGrantSandboxExtensionsToDatabaseProcessForBlobs): Deleted. 18 * NetworkProcess/NetworkProcess.h: 19 * NetworkProcess/NetworkProcess.messages.in: 20 21 * Shared/ProcessExecutablePath.h: 22 * Shared/gtk/ProcessExecutablePathGtk.cpp: 23 (WebKit::executablePathOfStorageProcess): 24 (WebKit::executablePathOfDatabaseProcess): Deleted. 25 * Shared/wpe/ProcessExecutablePathWPE.cpp: 26 (WebKit::executablePathOfStorageProcess): 27 (WebKit::executablePathOfDatabaseProcess): Deleted. 28 29 * StorageProcess/IndexedDB/WebIDBConnectionToClient.cpp: 30 (WebKit::WebIDBConnectionToClient::putOrAdd): 31 32 * StorageProcess/StorageProcess.cpp: 33 (WebKit::StorageProcess::initializeWebsiteDataStore): 34 (WebKit::StorageProcess::postStorageTask): 35 (WebKit::StorageProcess::performNextStorageTask): 36 (WebKit::StorageProcess::createStorageToWebProcessConnection): 37 (WebKit::StorageProcess::fetchWebsiteData): 38 (WebKit::StorageProcess::postDatabaseTask): Deleted. 39 (WebKit::StorageProcess::performNextDatabaseTask): Deleted. 40 (WebKit::StorageProcess::createDatabaseToWebProcessConnection): Deleted. 41 * StorageProcess/StorageProcess.h: 42 * StorageProcess/StorageProcess.messages.in: 43 * StorageProcess/mac/StorageProcessMac.mm: 44 (WebKit::StorageProcess::initializeProcessName): 45 46 * UIProcess/API/C/WKContext.cpp: 47 (WKContextGetDatabaseProcessIdentifier): 48 49 * UIProcess/API/Cocoa/WKProcessPool.mm: 50 (-[WKProcessPool _terminateStorageProcess]): 51 (-[WKProcessPool _storageProcessIdentifier]): 52 (-[WKProcessPool _terminateDatabaseProcess]): Deleted. 53 (-[WKProcessPool _databaseProcessIdentifier]): Deleted. 54 * UIProcess/API/Cocoa/WKProcessPoolPrivate.h: 55 56 * UIProcess/ChildProcessProxy.cpp: 57 (WebKit::ChildProcessProxy::getLaunchOptions): 58 59 * UIProcess/Launcher/ProcessLauncher.h: 60 * UIProcess/Launcher/gtk/ProcessLauncherGtk.cpp: 61 (WebKit::ProcessLauncher::launchProcess): 62 * UIProcess/Launcher/mac/ProcessLauncherMac.mm: 63 (WebKit::serviceName): 64 * UIProcess/Launcher/wpe/ProcessLauncherWPE.cpp: 65 (WebKit::ProcessLauncher::launchProcess): 66 67 * UIProcess/Network/NetworkProcessProxy.cpp: 68 (WebKit::NetworkProcessProxy::grantSandboxExtensionsToStorageProcessForBlobs): 69 (WebKit::NetworkProcessProxy::grantSandboxExtensionsToDatabaseProcessForBlobs): Deleted. 70 * UIProcess/Network/NetworkProcessProxy.h: 71 * UIProcess/Network/NetworkProcessProxy.messages.in: 72 73 * UIProcess/Storage/StorageProcessProxy.cpp: 74 (WebKit::StorageProcessProxy::getLaunchOptions): 75 (WebKit::StorageProcessProxy::getStorageProcessConnection): 76 (WebKit::StorageProcessProxy::didClose): 77 (WebKit::StorageProcessProxy::didCreateStorageToWebProcessConnection): 78 (WebKit::StorageProcessProxy::didFinishLaunching): 79 (WebKit::StorageProcessProxy::getDatabaseProcessConnection): Deleted. 80 (WebKit::StorageProcessProxy::didCreateDatabaseToWebProcessConnection): Deleted. 81 * UIProcess/Storage/StorageProcessProxy.h: 82 * UIProcess/Storage/StorageProcessProxy.messages.in: 83 84 * UIProcess/WebContextClient.cpp: 85 (WebKit::WebContextClient::storageProcessDidCrash): 86 (WebKit::WebContextClient::databaseProcessDidCrash): Deleted. 87 * UIProcess/WebContextClient.h: 88 89 * UIProcess/WebProcessPool.cpp: 90 (WebKit::WebProcessPool::ensureStorageProcessAndWebsiteDataStore): 91 (WebKit::WebProcessPool::getStorageProcessConnection): 92 (WebKit::WebProcessPool::storageProcessCrashed): 93 (WebKit::WebProcessPool::pageAddedToProcess): 94 (WebKit::WebProcessPool::storageProcessIdentifier): 95 (WebKit::WebProcessPool::terminateStorageProcess): 96 (WebKit::WebProcessPool::ensureDatabaseProcessAndWebsiteDataStore): Deleted. 97 (WebKit::WebProcessPool::getDatabaseProcessConnection): Deleted. 98 (WebKit::WebProcessPool::databaseProcessCrashed): Deleted. 99 (WebKit::WebProcessPool::databaseProcessIdentifier): Deleted. 100 (WebKit::WebProcessPool::terminateDatabaseProcess): Deleted. 101 * UIProcess/WebProcessPool.h: 102 (WebKit::WebProcessPool::sendToStorageProcessRelaunchingIfNecessary): 103 (WebKit::WebProcessPool::sendToDatabaseProcessRelaunchingIfNecessary): Deleted. 104 105 * UIProcess/WebProcessProxy.cpp: 106 (WebKit::WebProcessProxy::getStorageProcessConnection): 107 (WebKit::WebProcessProxy::getDatabaseProcessConnection): Deleted. 108 * UIProcess/WebProcessProxy.h: 109 * UIProcess/WebProcessProxy.messages.in: 110 111 * UIProcess/WebsiteData/WebsiteDataStore.cpp: 112 (WebKit::WebsiteDataStore::fetchDataAndApply): 113 (WebKit::WebsiteDataStore::removeData): 114 (WebKit::WebsiteDataStore::storageProcessParameters): 115 (WebKit::WebsiteDataStore::databaseProcessParameters): Deleted. 116 * UIProcess/WebsiteData/WebsiteDataStore.h: 117 118 * WebProcess/Databases/IndexedDB/WebIDBConnectionToServer.cpp: 119 (WebKit::WebIDBConnectionToServer::messageSenderConnection): 120 * WebProcess/Databases/IndexedDB/WebIDBConnectionToServer.h: 121 122 * WebProcess/Databases/WebDatabaseProvider.cpp: 123 (WebKit::WebDatabaseProvider::idbConnectionToServerForSession): 124 125 * WebProcess/Storage/WebToStorageProcessConnection.cpp: 126 (WebKit::WebToStorageProcessConnection::WebToStorageProcessConnection): 127 (WebKit::WebToStorageProcessConnection::~WebToStorageProcessConnection): 128 (WebKit::WebToStorageProcessConnection::didReceiveMessage): 129 (WebKit::WebToStorageProcessConnection::didClose): 130 (WebKit::WebToStorageProcessConnection::didReceiveInvalidMessage): 131 (WebKit::WebToStorageProcessConnection::idbConnectionToServerForSession): 132 (WebKit::WebToDatabaseProcessConnection::WebToDatabaseProcessConnection): Deleted. 133 (WebKit::WebToDatabaseProcessConnection::~WebToDatabaseProcessConnection): Deleted. 134 (WebKit::WebToDatabaseProcessConnection::didReceiveMessage): Deleted. 135 (WebKit::WebToDatabaseProcessConnection::didClose): Deleted. 136 (WebKit::WebToDatabaseProcessConnection::didReceiveInvalidMessage): Deleted. 137 (WebKit::WebToDatabaseProcessConnection::idbConnectionToServerForSession): Deleted. 138 * WebProcess/Storage/WebToStorageProcessConnection.h: 139 (WebKit::WebToStorageProcessConnection::create): 140 (WebKit::WebToDatabaseProcessConnection::create): Deleted. 141 (WebKit::WebToDatabaseProcessConnection::connection): Deleted. 142 143 * WebProcess/WebProcess.cpp: 144 (WebKit::WebProcess::webToStorageProcessConnectionClosed): 145 (WebKit::WebProcess::webToStorageProcessConnection): 146 (WebKit::WebProcess::ensureWebToStorageProcessConnection): 147 (WebKit::WebProcess::webToDatabaseProcessConnectionClosed): Deleted. 148 (WebKit::WebProcess::webToDatabaseProcessConnection): Deleted. 149 (WebKit::WebProcess::ensureWebToDatabaseProcessConnection): Deleted. 150 * WebProcess/WebProcess.h: 151 1 152 2017-08-01 Brady Eidson <beidson@apple.com> 2 153 -
trunk/Source/WebKit/NetworkProcess/NetworkConnectionToWebProcess.cpp
r220037 r220105 399 399 file->revokeFileAccess(); 400 400 401 NetworkProcess::singleton().grantSandboxExtensionsTo DatabaseProcessForBlobs(fileNames, [this, protectedThis = WTFMove(protectedThis), requestIdentifier, fileNames]() {401 NetworkProcess::singleton().grantSandboxExtensionsToStorageProcessForBlobs(fileNames, [this, protectedThis = WTFMove(protectedThis), requestIdentifier, fileNames]() { 402 402 if (!m_connection->isValid()) 403 403 return; -
trunk/Source/WebKit/NetworkProcess/NetworkProcess.cpp
r220037 r220105 304 304 } 305 305 306 void NetworkProcess::grantSandboxExtensionsTo DatabaseProcessForBlobs(const Vector<String>& filenames, Function<void ()>&& completionHandler)306 void NetworkProcess::grantSandboxExtensionsToStorageProcessForBlobs(const Vector<String>& filenames, Function<void ()>&& completionHandler) 307 307 { 308 308 static uint64_t lastRequestID; … … 310 310 uint64_t requestID = ++lastRequestID; 311 311 m_sandboxExtensionForBlobsCompletionHandlers.set(requestID, WTFMove(completionHandler)); 312 parentProcessConnection()->send(Messages::NetworkProcessProxy::GrantSandboxExtensionsTo DatabaseProcessForBlobs(requestID, filenames), 0);313 } 314 315 void NetworkProcess::didGrantSandboxExtensionsTo DatabaseProcessForBlobs(uint64_t requestID)312 parentProcessConnection()->send(Messages::NetworkProcessProxy::GrantSandboxExtensionsToStorageProcessForBlobs(requestID, filenames), 0); 313 } 314 315 void NetworkProcess::didGrantSandboxExtensionsToStorageProcessForBlobs(uint64_t requestID) 316 316 { 317 317 if (auto handler = m_sandboxExtensionForBlobsCompletionHandlers.take(requestID)) -
trunk/Source/WebKit/NetworkProcess/NetworkProcess.h
r220037 r220105 116 116 void ensurePrivateBrowsingSession(WebsiteDataStoreParameters&&); 117 117 118 void grantSandboxExtensionsTo DatabaseProcessForBlobs(const Vector<String>& filenames, Function<void ()>&& completionHandler);118 void grantSandboxExtensionsToStorageProcessForBlobs(const Vector<String>& filenames, Function<void ()>&& completionHandler); 119 119 120 120 #if HAVE(CFNETWORK_STORAGE_PARTITIONING) … … 198 198 void syncAllCookies(); 199 199 200 void didGrantSandboxExtensionsTo DatabaseProcessForBlobs(uint64_t requestID);200 void didGrantSandboxExtensionsToStorageProcessForBlobs(uint64_t requestID); 201 201 202 202 #if USE(SOUP) -
trunk/Source/WebKit/NetworkProcess/NetworkProcess.messages.in
r220037 r220105 81 81 ProcessDidResume() 82 82 83 DidGrantSandboxExtensionsTo DatabaseProcessForBlobs(uint64_t requestID)83 DidGrantSandboxExtensionsToStorageProcessForBlobs(uint64_t requestID) 84 84 85 85 #if HAVE(CFNETWORK_STORAGE_PARTITIONING) -
trunk/Source/WebKit/Shared/ProcessExecutablePath.h
r220037 r220105 33 33 String executablePathOfPluginProcess(); 34 34 String executablePathOfNetworkProcess(); 35 String executablePathOf DatabaseProcess();35 String executablePathOfStorageProcess(); 36 36 37 37 } -
trunk/Source/WebKit/Shared/gtk/ProcessExecutablePathGtk.cpp
r220037 r220105 85 85 } 86 86 87 String executablePathOf DatabaseProcess()87 String executablePathOfStorageProcess() 88 88 { 89 return findWebKitProcess("WebKit DatabaseProcess");89 return findWebKitProcess("WebKitStorageProcess"); 90 90 } 91 91 -
trunk/Source/WebKit/Shared/wpe/ProcessExecutablePathWPE.cpp
r220037 r220105 78 78 } 79 79 80 String executablePathOf DatabaseProcess()80 String executablePathOfStorageProcess() 81 81 { 82 return findWebKitProcess("WPE DatabaseProcess");82 return findWebKitProcess("WPEStorageProcess"); 83 83 } 84 84 -
trunk/Source/WebKit/StorageProcess/IndexedDB/WebIDBConnectionToClient.cpp
r220094 r220105 288 288 && overwriteMode != static_cast<unsigned>(IndexedDB::ObjectStoreOverwriteMode::OverwriteForCursor)) { 289 289 // FIXME: This message from the WebProcess is corrupt. 290 // The DatabaseProcess should return early at this point, but can we also kill the bad WebProcess?290 // The StorageProcess should return early at this point, but can we also kill the bad WebProcess? 291 291 return; 292 292 } -
trunk/Source/WebKit/StorageProcess/StorageProcess.cpp
r220094 r220105 122 122 SandboxExtension::consumePermanently(parameters.indexedDatabaseDirectoryExtensionHandle); 123 123 124 post DatabaseTask(createCrossThreadTask(*this, &StorageProcess::ensurePathExists, parameters.indexedDatabaseDirectory));124 postStorageTask(createCrossThreadTask(*this, &StorageProcess::ensurePathExists, parameters.indexedDatabaseDirectory)); 125 125 #endif 126 126 } … … 134 134 } 135 135 136 void StorageProcess::post DatabaseTask(CrossThreadTask&& task)136 void StorageProcess::postStorageTask(CrossThreadTask&& task) 137 137 { 138 138 ASSERT(RunLoop::isMain()); 139 139 140 LockHolder locker(m_ databaseTaskMutex);141 142 m_ databaseTasks.append(WTFMove(task));140 LockHolder locker(m_storageTaskMutex); 141 142 m_storageTasks.append(WTFMove(task)); 143 143 144 144 m_queue->dispatch([this] { 145 performNext DatabaseTask();145 performNextStorageTask(); 146 146 }); 147 147 } 148 148 149 void StorageProcess::performNext DatabaseTask()149 void StorageProcess::performNextStorageTask() 150 150 { 151 151 ASSERT(!RunLoop::isMain()); … … 153 153 CrossThreadTask task; 154 154 { 155 LockHolder locker(m_ databaseTaskMutex);156 ASSERT(!m_ databaseTasks.isEmpty());157 task = m_ databaseTasks.takeFirst();155 LockHolder locker(m_storageTaskMutex); 156 ASSERT(!m_storageTasks.isEmpty()); 157 task = m_storageTasks.takeFirst(); 158 158 } 159 159 … … 161 161 } 162 162 163 void StorageProcess::create DatabaseToWebProcessConnection()163 void StorageProcess::createStorageToWebProcessConnection() 164 164 { 165 165 #if USE(UNIX_DOMAIN_SOCKETS) 166 166 IPC::Connection::SocketPair socketPair = IPC::Connection::createPlatformConnection(); 167 167 m_databaseToWebProcessConnections.append(StorageToWebProcessConnection::create(socketPair.server)); 168 parentProcessConnection()->send(Messages::StorageProcessProxy::DidCreate DatabaseToWebProcessConnection(IPC::Attachment(socketPair.client)), 0);168 parentProcessConnection()->send(Messages::StorageProcessProxy::DidCreateStorageToWebProcessConnection(IPC::Attachment(socketPair.client)), 0); 169 169 #elif OS(DARWIN) 170 170 // Create the listening port. … … 176 176 177 177 IPC::Attachment clientPort(listeningPort, MACH_MSG_TYPE_MAKE_SEND); 178 parentProcessConnection()->send(Messages::StorageProcessProxy::DidCreate DatabaseToWebProcessConnection(clientPort), 0);178 parentProcessConnection()->send(Messages::StorageProcessProxy::DidCreateStorageToWebProcessConnection(clientPort), 0); 179 179 #else 180 180 notImplemented(); … … 197 197 if (websiteDataTypes.contains(WebsiteDataType::IndexedDBDatabases)) { 198 198 // FIXME: Pick the right database store based on the session ID. 199 post DatabaseTask(CrossThreadTask([this, completionHandler = WTFMove(completionHandler), path = WTFMove(path)]() mutable {199 postStorageTask(CrossThreadTask([this, completionHandler = WTFMove(completionHandler), path = WTFMove(path)]() mutable { 200 200 RunLoop::main().dispatch([completionHandler = WTFMove(completionHandler), securityOrigins = indexedDatabaseOrigins(path)] { 201 201 WebsiteData websiteData; -
trunk/Source/WebKit/StorageProcess/StorageProcess.h
r220094 r220105 62 62 WorkQueue& queue() { return m_queue.get(); } 63 63 64 void post DatabaseTask(CrossThreadTask&&);64 void postStorageTask(CrossThreadTask&&); 65 65 66 66 #if ENABLE(INDEXED_DATABASE) … … 91 91 // Message Handlers 92 92 void initializeWebsiteDataStore(const StorageProcessCreationParameters&); 93 void create DatabaseToWebProcessConnection();93 void createStorageToWebProcessConnection(); 94 94 95 95 void fetchWebsiteData(WebCore::SessionID, OptionSet<WebsiteDataType> websiteDataTypes, uint64_t callbackID); … … 106 106 107 107 // For execution on work queue thread only 108 void performNext DatabaseTask();108 void performNextStorageTask(); 109 109 void ensurePathExists(const String&); 110 110 … … 120 120 HashMap<uint64_t, WTF::Function<void (SandboxExtension::HandleArray&&)>> m_sandboxExtensionForBlobsCompletionHandlers; 121 121 122 Deque<CrossThreadTask> m_ databaseTasks;123 Lock m_ databaseTaskMutex;122 Deque<CrossThreadTask> m_storageTasks; 123 Lock m_storageTaskMutex; 124 124 }; 125 125 -
trunk/Source/WebKit/StorageProcess/StorageProcess.messages.in
r220094 r220105 26 26 27 27 # Creates a connection for communication with a WebProcess 28 Create DatabaseToWebProcessConnection()28 CreateStorageToWebProcessConnection() 29 29 30 30 FetchWebsiteData(WebCore::SessionID sessionID, OptionSet<WebKit::WebsiteDataType> websiteDataTypes, uint64_t callbackID) -
trunk/Source/WebKit/StorageProcess/mac/StorageProcessMac.mm
r220094 r220105 47 47 void StorageProcess::initializeProcessName(const ChildProcessInitializationParameters& parameters) 48 48 { 49 NSString *applicationName = [NSString stringWithFormat:WEB_UI_STRING("%@ Database Storage", "visible name of the database process. The argument is the application name."), (NSString *)parameters.uiProcessName];49 NSString *applicationName = [NSString stringWithFormat:WEB_UI_STRING("%@ Storage", "visible name of the storage process. The argument is the application name."), (NSString *)parameters.uiProcessName]; 50 50 WKSetVisibleApplicationName((CFStringRef)applicationName); 51 51 } -
trunk/Source/WebKit/UIProcess/API/C/WKContext.cpp
r220037 r220105 591 591 pid_t WKContextGetDatabaseProcessIdentifier(WKContextRef contextRef) 592 592 { 593 return toImpl(contextRef)-> databaseProcessIdentifier();594 } 593 return toImpl(contextRef)->storageProcessIdentifier(); 594 } -
trunk/Source/WebKit/UIProcess/API/Cocoa/WKProcessPool.mm
r220037 r220105 386 386 } 387 387 388 - (void)_terminate DatabaseProcess389 { 390 _processPool->terminate DatabaseProcess();388 - (void)_terminateStorageProcess 389 { 390 _processPool->terminateStorageProcess(); 391 391 } 392 392 … … 401 401 } 402 402 403 - (pid_t)_ databaseProcessIdentifier404 { 405 return _processPool-> databaseProcessIdentifier();403 - (pid_t)_storageProcessIdentifier 404 { 405 return _processPool->storageProcessIdentifier(); 406 406 } 407 407 -
trunk/Source/WebKit/UIProcess/API/Cocoa/WKProcessPoolPrivate.h
r220037 r220105 73 73 74 74 // Test only. Should be called only while no web content processes are running. 75 - (void)_terminate DatabaseProcess;75 - (void)_terminateStorageProcess; 76 76 - (void)_terminateNetworkProcess; 77 77 78 78 // Test only. 79 79 - (pid_t)_networkProcessIdentifier WK_API_AVAILABLE(macosx(WK_MAC_TBA), ios(WK_IOS_TBA)); 80 - (pid_t)_ databaseProcessIdentifier WK_API_AVAILABLE(macosx(WK_MAC_TBA), ios(WK_IOS_TBA));80 - (pid_t)_storageProcessIdentifier WK_API_AVAILABLE(macosx(WK_MAC_TBA), ios(WK_IOS_TBA)); 81 81 82 82 // Test only. -
trunk/Source/WebKit/UIProcess/ChildProcessProxy.cpp
r220037 r220105 71 71 varname = "NETWORK_PROCESS_CMD_PREFIX"; 72 72 break; 73 case ProcessLauncher::ProcessType:: Database:74 varname = " DATABASE_PROCESS_CMD_PREFIX";73 case ProcessLauncher::ProcessType::Storage: 74 varname = "STORAGE_PROCESS_CMD_PREFIX"; 75 75 break; 76 76 } -
trunk/Source/WebKit/UIProcess/Launcher/ProcessLauncher.h
r220037 r220105 52 52 #endif 53 53 Network, 54 Database,54 Storage, 55 55 }; 56 56 -
trunk/Source/WebKit/UIProcess/Launcher/gtk/ProcessLauncherGtk.cpp
r220037 r220105 82 82 executablePath = executablePathOfNetworkProcess(); 83 83 break; 84 case ProcessLauncher::ProcessType:: Database:85 executablePath = executablePathOf DatabaseProcess();84 case ProcessLauncher::ProcessType::Storage: 85 executablePath = executablePathOfStorageProcess(); 86 86 break; 87 87 default: -
trunk/Source/WebKit/UIProcess/Launcher/mac/ProcessLauncherMac.mm
r220038 r220105 56 56 case ProcessLauncher::ProcessType::Network: 57 57 return "com.apple.WebKit.Networking"; 58 case ProcessLauncher::ProcessType:: Database:58 case ProcessLauncher::ProcessType::Storage: 59 59 return "com.apple.WebKit.Databases"; 60 60 #if ENABLE(NETSCAPE_PLUGIN_API) -
trunk/Source/WebKit/UIProcess/Launcher/wpe/ProcessLauncherWPE.cpp
r220037 r220105 68 68 executablePath = executablePathOfNetworkProcess(); 69 69 break; 70 case ProcessLauncher::ProcessType:: Database:71 executablePath = executablePathOf DatabaseProcess();70 case ProcessLauncher::ProcessType::Storage: 71 executablePath = executablePathOfStorageProcess(); 72 72 break; 73 73 default: -
trunk/Source/WebKit/UIProcess/Network/NetworkProcessProxy.cpp
r220094 r220105 290 290 } 291 291 292 void NetworkProcessProxy::grantSandboxExtensionsTo DatabaseProcessForBlobs(uint64_t requestID, const Vector<String>& paths)292 void NetworkProcessProxy::grantSandboxExtensionsToStorageProcessForBlobs(uint64_t requestID, const Vector<String>& paths) 293 293 { 294 294 #if ENABLE(SANDBOX_EXTENSIONS) … … 296 296 extensions.allocate(paths.size()); 297 297 for (size_t i = 0; i < paths.size(); ++i) { 298 // ReadWrite is required for creating hard links as well as deleting the temporary file, which the DatabaseProcess will do.298 // ReadWrite is required for creating hard links as well as deleting the temporary file, which the StorageProcess will do. 299 299 SandboxExtension::createHandle(paths[i], SandboxExtension::ReadWrite, extensions[i]); 300 300 } 301 301 302 m_processPool.sendTo DatabaseProcessRelaunchingIfNecessary(Messages::StorageProcess::GrantSandboxExtensionsForBlobs(paths, extensions));303 #endif 304 connection()->send(Messages::NetworkProcess::DidGrantSandboxExtensionsTo DatabaseProcessForBlobs(requestID), 0);302 m_processPool.sendToStorageProcessRelaunchingIfNecessary(Messages::StorageProcess::GrantSandboxExtensionsForBlobs(paths, extensions)); 303 #endif 304 connection()->send(Messages::NetworkProcess::DidGrantSandboxExtensionsToStorageProcessForBlobs(requestID), 0); 305 305 } 306 306 -
trunk/Source/WebKit/UIProcess/Network/NetworkProcessProxy.h
r220037 r220105 112 112 void didDeleteWebsiteData(uint64_t callbackID); 113 113 void didDeleteWebsiteDataForOrigins(uint64_t callbackID); 114 void grantSandboxExtensionsTo DatabaseProcessForBlobs(uint64_t requestID, const Vector<String>& paths);114 void grantSandboxExtensionsToStorageProcessForBlobs(uint64_t requestID, const Vector<String>& paths); 115 115 void logDiagnosticMessage(uint64_t pageID, const String& message, const String& description, WebCore::ShouldSample); 116 116 void logDiagnosticMessageWithResult(uint64_t pageID, const String& message, const String& description, uint32_t result, WebCore::ShouldSample); -
trunk/Source/WebKit/UIProcess/Network/NetworkProcessProxy.messages.in
r220037 r220105 30 30 DidDeleteWebsiteDataForOrigins(uint64_t callbackID) 31 31 32 GrantSandboxExtensionsTo DatabaseProcessForBlobs(uint64_t requestID, Vector<String> paths)32 GrantSandboxExtensionsToStorageProcessForBlobs(uint64_t requestID, Vector<String> paths) 33 33 34 34 ProcessReadyToSuspend() -
trunk/Source/WebKit/UIProcess/Storage/StorageProcessProxy.cpp
r220094 r220105 67 67 void StorageProcessProxy::getLaunchOptions(ProcessLauncher::LaunchOptions& launchOptions) 68 68 { 69 launchOptions.processType = ProcessLauncher::ProcessType:: Database;69 launchOptions.processType = ProcessLauncher::ProcessType::Storage; 70 70 ChildProcessProxy::getLaunchOptions(launchOptions); 71 71 } … … 112 112 } 113 113 114 void StorageProcessProxy::get DatabaseProcessConnection(Ref<Messages::WebProcessProxy::GetDatabaseProcessConnection::DelayedReply>&& reply)114 void StorageProcessProxy::getStorageProcessConnection(Ref<Messages::WebProcessProxy::GetStorageProcessConnection::DelayedReply>&& reply) 115 115 { 116 116 m_pendingConnectionReplies.append(WTFMove(reply)); … … 121 121 } 122 122 123 send(Messages::StorageProcess::Create DatabaseToWebProcessConnection(), 0, IPC::SendOption::DispatchMessageEvenWhenWaitingForSyncReply);123 send(Messages::StorageProcess::CreateStorageToWebProcessConnection(), 0, IPC::SendOption::DispatchMessageEvenWhenWaitingForSyncReply); 124 124 } 125 125 126 126 void StorageProcessProxy::didClose(IPC::Connection&) 127 127 { 128 // The database process must have crashed or exited, so send any pending sync replies we might have.128 // The storage process must have crashed or exited, so send any pending sync replies we might have. 129 129 while (!m_pendingConnectionReplies.isEmpty()) { 130 130 auto reply = m_pendingConnectionReplies.takeFirst(); … … 151 151 m_pendingDeleteWebsiteDataForOriginsCallbacks.clear(); 152 152 153 // Tell ProcessPool to forget about this database process. This may cause us to be deleted.154 m_processPool-> databaseProcessCrashed(this);153 // Tell ProcessPool to forget about this storage process. This may cause us to be deleted. 154 m_processPool->storageProcessCrashed(this); 155 155 } 156 156 … … 159 159 } 160 160 161 void StorageProcessProxy::didCreate DatabaseToWebProcessConnection(const IPC::Attachment& connectionIdentifier)161 void StorageProcessProxy::didCreateStorageToWebProcessConnection(const IPC::Attachment& connectionIdentifier) 162 162 { 163 163 ASSERT(!m_pendingConnectionReplies.isEmpty()); 164 164 165 RefPtr<Messages::WebProcessProxy::Get DatabaseProcessConnection::DelayedReply> reply = m_pendingConnectionReplies.takeFirst();165 RefPtr<Messages::WebProcessProxy::GetStorageProcessConnection::DelayedReply> reply = m_pendingConnectionReplies.takeFirst(); 166 166 167 167 #if USE(UNIX_DOMAIN_SOCKETS) … … 216 216 217 217 for (unsigned i = 0; i < m_numPendingConnectionRequests; ++i) 218 send(Messages::StorageProcess::Create DatabaseToWebProcessConnection(), 0);218 send(Messages::StorageProcess::CreateStorageToWebProcessConnection(), 0); 219 219 220 220 m_numPendingConnectionRequests = 0; -
trunk/Source/WebKit/UIProcess/Storage/StorageProcessProxy.h
r220094 r220105 53 53 void deleteWebsiteDataForOrigins(WebCore::SessionID, OptionSet<WebsiteDataType>, const Vector<WebCore::SecurityOriginData>&, WTF::Function<void()>&& completionHandler); 54 54 55 void get DatabaseProcessConnection(Ref<Messages::WebProcessProxy::GetDatabaseProcessConnection::DelayedReply>&&);55 void getStorageProcessConnection(Ref<Messages::WebProcessProxy::GetStorageProcessConnection::DelayedReply>&&); 56 56 57 57 private: … … 70 70 71 71 // Message handlers 72 void didCreate DatabaseToWebProcessConnection(const IPC::Attachment&);72 void didCreateStorageToWebProcessConnection(const IPC::Attachment&); 73 73 void didFetchWebsiteData(uint64_t callbackID, const WebsiteData&); 74 74 void didDeleteWebsiteData(uint64_t callbackID); … … 84 84 85 85 unsigned m_numPendingConnectionRequests; 86 Deque<Ref<Messages::WebProcessProxy::Get DatabaseProcessConnection::DelayedReply>> m_pendingConnectionReplies;86 Deque<Ref<Messages::WebProcessProxy::GetStorageProcessConnection::DelayedReply>> m_pendingConnectionReplies; 87 87 88 88 HashMap<uint64_t, WTF::Function<void (WebsiteData)>> m_pendingFetchWebsiteDataCallbacks; -
trunk/Source/WebKit/UIProcess/Storage/StorageProcessProxy.messages.in
r220094 r220105 22 22 23 23 messages -> StorageProcessProxy LegacyReceiver { 24 DidCreate DatabaseToWebProcessConnection(IPC::Attachment connectionIdentifier)24 DidCreateStorageToWebProcessConnection(IPC::Attachment connectionIdentifier) 25 25 26 26 DidFetchWebsiteData(uint64_t callbackID, struct WebKit::WebsiteData websiteData) -
trunk/Source/WebKit/UIProcess/WebContextClient.cpp
r220037 r220105 47 47 } 48 48 49 void WebContextClient:: databaseProcessDidCrash(WebProcessPool* processPool)49 void WebContextClient::storageProcessDidCrash(WebProcessPool* processPool) 50 50 { 51 51 if (!m_client.databaseProcessDidCrash) -
trunk/Source/WebKit/UIProcess/WebContextClient.h
r220037 r220105 46 46 void plugInAutoStartOriginHashesChanged(WebProcessPool*); 47 47 void networkProcessDidCrash(WebProcessPool*); 48 void databaseProcessDidCrash(WebProcessPool*);48 void storageProcessDidCrash(WebProcessPool*); 49 49 }; 50 50 -
trunk/Source/WebKit/UIProcess/WebProcessPool.cpp
r220094 r220105 515 515 } 516 516 517 void WebProcessPool::ensure DatabaseProcessAndWebsiteDataStore(WebsiteDataStore* relevantDataStore)517 void WebProcessPool::ensureStorageProcessAndWebsiteDataStore(WebsiteDataStore* relevantDataStore) 518 518 { 519 519 // ********* … … 521 521 // ********* 522 522 523 if (!m_ databaseProcess) {524 m_ databaseProcess = StorageProcessProxy::create(this);523 if (!m_storageProcess) { 524 m_storageProcess = StorageProcessProxy::create(this); 525 525 526 526 StorageProcessCreationParameters parameters; … … 534 534 535 535 ASSERT(!parameters.indexedDatabaseDirectory.isEmpty()); 536 m_ databaseProcess->send(Messages::StorageProcess::InitializeWebsiteDataStore(parameters), 0);536 m_storageProcess->send(Messages::StorageProcess::InitializeWebsiteDataStore(parameters), 0); 537 537 } 538 538 … … 540 540 return; 541 541 542 m_ databaseProcess->send(Messages::StorageProcess::InitializeWebsiteDataStore(relevantDataStore->databaseProcessParameters()), 0);543 } 544 545 void WebProcessPool::get DatabaseProcessConnection(Ref<Messages::WebProcessProxy::GetDatabaseProcessConnection::DelayedReply>&& reply)546 { 547 ensure DatabaseProcessAndWebsiteDataStore(nullptr);548 549 m_ databaseProcess->getDatabaseProcessConnection(WTFMove(reply));550 } 551 552 void WebProcessPool:: databaseProcessCrashed(StorageProcessProxy* databaseProcessProxy)553 { 554 ASSERT(m_ databaseProcess);555 ASSERT( databaseProcessProxy == m_databaseProcess.get());542 m_storageProcess->send(Messages::StorageProcess::InitializeWebsiteDataStore(relevantDataStore->storageProcessParameters()), 0); 543 } 544 545 void WebProcessPool::getStorageProcessConnection(Ref<Messages::WebProcessProxy::GetStorageProcessConnection::DelayedReply>&& reply) 546 { 547 ensureStorageProcessAndWebsiteDataStore(nullptr); 548 549 m_storageProcess->getStorageProcessConnection(WTFMove(reply)); 550 } 551 552 void WebProcessPool::storageProcessCrashed(StorageProcessProxy* storageProcessProxy) 553 { 554 ASSERT(m_storageProcess); 555 ASSERT(storageProcessProxy == m_storageProcess.get()); 556 556 557 557 for (auto& supplement : m_supplements.values()) 558 supplement->processDidClose( databaseProcessProxy);559 560 m_client. databaseProcessDidCrash(this);561 m_ databaseProcess = nullptr;558 supplement->processDidClose(storageProcessProxy); 559 560 m_client.storageProcessDidCrash(this); 561 m_storageProcess = nullptr; 562 562 } 563 563 … … 960 960 961 961 #if ENABLE(INDEXED_DATABASE) 962 auto databaseParameters = page.websiteDataStore().databaseProcessParameters();963 if (! databaseParameters.indexedDatabaseDirectory.isEmpty())964 sendTo DatabaseProcessRelaunchingIfNecessary(Messages::StorageProcess::InitializeWebsiteDataStore(databaseParameters));962 auto storageParameters = page.websiteDataStore().storageProcessParameters(); 963 if (!storageParameters.indexedDatabaseDirectory.isEmpty()) 964 sendToStorageProcessRelaunchingIfNecessary(Messages::StorageProcess::InitializeWebsiteDataStore(storageParameters)); 965 965 #endif 966 966 } … … 1074 1074 } 1075 1075 1076 pid_t WebProcessPool:: databaseProcessIdentifier()1077 { 1078 if (!m_ databaseProcess)1076 pid_t WebProcessPool::storageProcessIdentifier() 1077 { 1078 if (!m_storageProcess) 1079 1079 return 0; 1080 1080 1081 return m_ databaseProcess->processIdentifier();1081 return m_storageProcess->processIdentifier(); 1082 1082 } 1083 1083 … … 1303 1303 } 1304 1304 1305 void WebProcessPool::terminate DatabaseProcess()1306 { 1307 if (!m_ databaseProcess)1308 return; 1309 1310 m_ databaseProcess->terminate();1311 m_ databaseProcess = nullptr;1305 void WebProcessPool::terminateStorageProcess() 1306 { 1307 if (!m_storageProcess) 1308 return; 1309 1310 m_storageProcess->terminate(); 1311 m_storageProcess = nullptr; 1312 1312 } 1313 1313 -
trunk/Source/WebKit/UIProcess/WebProcessPool.h
r220094 r220105 161 161 template<typename T> void sendToNetworkingProcessRelaunchingIfNecessary(T&& message); 162 162 163 // Sends the message to WebProcess or DatabaseProcess as approporiate for current process model.164 template<typename T> void sendTo DatabaseProcessRelaunchingIfNecessary(T&& message);163 // Sends the message to WebProcess or StorageProcess as approporiate for current process model. 164 template<typename T> void sendToStorageProcessRelaunchingIfNecessary(T&& message); 165 165 166 166 void processDidFinishLaunching(WebProcessProxy*); … … 200 200 201 201 pid_t networkProcessIdentifier(); 202 pid_t databaseProcessIdentifier();202 pid_t storageProcessIdentifier(); 203 203 204 204 void setAlwaysUsesComplexTextCodePath(bool); … … 256 256 257 257 void clearCachedCredentials(); 258 void terminate DatabaseProcess();258 void terminateStorageProcess(); 259 259 void terminateNetworkProcess(); 260 260 … … 313 313 void getNetworkProcessConnection(Ref<Messages::WebProcessProxy::GetNetworkProcessConnection::DelayedReply>&&); 314 314 315 void ensure DatabaseProcessAndWebsiteDataStore(WebsiteDataStore* relevantDataStore);316 StorageProcessProxy* databaseProcess() { return m_databaseProcess.get(); }317 void get DatabaseProcessConnection(Ref<Messages::WebProcessProxy::GetDatabaseProcessConnection::DelayedReply>&&);318 void databaseProcessCrashed(StorageProcessProxy*);315 void ensureStorageProcessAndWebsiteDataStore(WebsiteDataStore* relevantDataStore); 316 StorageProcessProxy* storageProcess() { return m_storageProcess.get(); } 317 void getStorageProcessConnection(Ref<Messages::WebProcessProxy::GetStorageProcessConnection::DelayedReply>&&); 318 void storageProcessCrashed(StorageProcessProxy*); 319 319 320 320 #if PLATFORM(COCOA) … … 550 550 bool m_didNetworkProcessCrash; 551 551 RefPtr<NetworkProcessProxy> m_networkProcess; 552 RefPtr<StorageProcessProxy> m_ databaseProcess;552 RefPtr<StorageProcessProxy> m_storageProcess; 553 553 554 554 HashMap<uint64_t, RefPtr<DictionaryCallback>> m_dictionaryCallbacks; … … 628 628 629 629 template<typename T> 630 void WebProcessPool::sendTo DatabaseProcessRelaunchingIfNecessary(T&& message)630 void WebProcessPool::sendToStorageProcessRelaunchingIfNecessary(T&& message) 631 631 { 632 ensure DatabaseProcessAndWebsiteDataStore(nullptr);633 m_ databaseProcess->send(std::forward<T>(message), 0);632 ensureStorageProcessAndWebsiteDataStore(nullptr); 633 m_storageProcess->send(std::forward<T>(message), 0); 634 634 } 635 635 -
trunk/Source/WebKit/UIProcess/WebProcessProxy.cpp
r220037 r220105 574 574 } 575 575 576 void WebProcessProxy::get DatabaseProcessConnection(Ref<Messages::WebProcessProxy::GetDatabaseProcessConnection::DelayedReply>&& reply)577 { 578 m_processPool->get DatabaseProcessConnection(WTFMove(reply));576 void WebProcessProxy::getStorageProcessConnection(Ref<Messages::WebProcessProxy::GetStorageProcessConnection::DelayedReply>&& reply) 577 { 578 m_processPool->getStorageProcessConnection(WTFMove(reply)); 579 579 } 580 580 -
trunk/Source/WebKit/UIProcess/WebProcessProxy.h
r220037 r220105 215 215 #endif 216 216 void getNetworkProcessConnection(Ref<Messages::WebProcessProxy::GetNetworkProcessConnection::DelayedReply>&&); 217 void get DatabaseProcessConnection(Ref<Messages::WebProcessProxy::GetDatabaseProcessConnection::DelayedReply>&&);217 void getStorageProcessConnection(Ref<Messages::WebProcessProxy::GetStorageProcessConnection::DelayedReply>&&); 218 218 219 219 bool platformIsBeingDebugged() const; -
trunk/Source/WebKit/UIProcess/WebProcessProxy.messages.in
r220037 r220105 38 38 #endif 39 39 GetNetworkProcessConnection() -> (IPC::Attachment connectionHandle) Delayed 40 Get DatabaseProcessConnection() -> (IPC::Attachment connectionHandle) Delayed40 GetStorageProcessConnection() -> (IPC::Attachment connectionHandle) Delayed 41 41 ProcessReadyToSuspend() 42 42 DidCancelProcessSuspension() -
trunk/Source/WebKit/UIProcess/WebsiteData/WebsiteDataStore.cpp
r220094 r220105 434 434 if (dataTypes.contains(WebsiteDataType::IndexedDBDatabases) && isPersistent()) { 435 435 for (auto& processPool : processPools()) { 436 processPool->ensure DatabaseProcessAndWebsiteDataStore(this);436 processPool->ensureStorageProcessAndWebsiteDataStore(this); 437 437 438 438 callbackAggregator->addPendingCallback(); 439 processPool-> databaseProcess()->fetchWebsiteData(m_sessionID, dataTypes, [callbackAggregator, processPool](WebsiteData websiteData) {439 processPool->storageProcess()->fetchWebsiteData(m_sessionID, dataTypes, [callbackAggregator, processPool](WebsiteData websiteData) { 440 440 callbackAggregator->removePendingCallback(WTFMove(websiteData)); 441 441 }); … … 728 728 if (dataTypes.contains(WebsiteDataType::IndexedDBDatabases) && isPersistent()) { 729 729 for (auto& processPool : processPools()) { 730 processPool->ensure DatabaseProcessAndWebsiteDataStore(this);730 processPool->ensureStorageProcessAndWebsiteDataStore(this); 731 731 732 732 callbackAggregator->addPendingCallback(); 733 processPool-> databaseProcess()->deleteWebsiteData(m_sessionID, dataTypes, modifiedSince, [callbackAggregator, processPool] {733 processPool->storageProcess()->deleteWebsiteData(m_sessionID, dataTypes, modifiedSince, [callbackAggregator, processPool] { 734 734 callbackAggregator->removePendingCallback(); 735 735 }); … … 1005 1005 if (dataTypes.contains(WebsiteDataType::IndexedDBDatabases) && isPersistent()) { 1006 1006 for (auto& processPool : processPools()) { 1007 processPool->ensure DatabaseProcessAndWebsiteDataStore(this);1007 processPool->ensureStorageProcessAndWebsiteDataStore(this); 1008 1008 1009 1009 callbackAggregator->addPendingCallback(); 1010 processPool-> databaseProcess()->deleteWebsiteDataForOrigins(m_sessionID, dataTypes, origins, [callbackAggregator, processPool] {1010 processPool->storageProcess()->deleteWebsiteDataForOrigins(m_sessionID, dataTypes, origins, [callbackAggregator, processPool] { 1011 1011 callbackAggregator->removePendingCallback(); 1012 1012 }); … … 1316 1316 } 1317 1317 1318 StorageProcessCreationParameters WebsiteDataStore:: databaseProcessParameters()1318 StorageProcessCreationParameters WebsiteDataStore::storageProcessParameters() 1319 1319 { 1320 1320 resolveDirectoriesIfNecessary(); -
trunk/Source/WebKit/UIProcess/WebsiteData/WebsiteDataStore.h
r220094 r220105 122 122 123 123 WebsiteDataStoreParameters parameters(); 124 StorageProcessCreationParameters databaseProcessParameters();124 StorageProcessCreationParameters storageProcessParameters(); 125 125 126 126 Vector<WebCore::Cookie> pendingCookies() const; -
trunk/Source/WebKit/WebProcess/Databases/IndexedDB/WebIDBConnectionToServer.cpp
r220094 r220105 78 78 IPC::Connection* WebIDBConnectionToServer::messageSenderConnection() 79 79 { 80 return &WebProcess::singleton().webTo DatabaseProcessConnection()->connection();80 return &WebProcess::singleton().webToStorageProcessConnection()->connection(); 81 81 } 82 82 -
trunk/Source/WebKit/WebProcess/Databases/IndexedDB/WebIDBConnectionToServer.h
r220037 r220105 80 80 void deref() override { RefCounted<WebIDBConnectionToServer>::deref(); } 81 81 82 // Messages received from DatabaseProcess82 // Messages received from StorageProcess 83 83 void didDeleteDatabase(const WebCore::IDBResultData&); 84 84 void didOpenDatabase(const WebCore::IDBResultData&); -
trunk/Source/WebKit/WebProcess/Databases/WebDatabaseProvider.cpp
r220094 r220105 80 80 } 81 81 82 ASSERT(WebProcess::singleton().webTo DatabaseProcessConnection());83 return WebProcess::singleton().webTo DatabaseProcessConnection()->idbConnectionToServerForSession(sessionID).coreConnectionToServer();82 ASSERT(WebProcess::singleton().webToStorageProcessConnection()); 83 return WebProcess::singleton().webToStorageProcessConnection()->idbConnectionToServerForSession(sessionID).coreConnectionToServer(); 84 84 } 85 85 -
trunk/Source/WebKit/WebProcess/Storage/WebToStorageProcessConnection.cpp
r220094 r220105 36 36 namespace WebKit { 37 37 38 WebTo DatabaseProcessConnection::WebToDatabaseProcessConnection(IPC::Connection::Identifier connectionIdentifier)38 WebToStorageProcessConnection::WebToStorageProcessConnection(IPC::Connection::Identifier connectionIdentifier) 39 39 : m_connection(IPC::Connection::createClientConnection(connectionIdentifier, *this)) 40 40 { … … 42 42 } 43 43 44 WebTo DatabaseProcessConnection::~WebToDatabaseProcessConnection()44 WebToStorageProcessConnection::~WebToStorageProcessConnection() 45 45 { 46 46 } 47 47 48 void WebTo DatabaseProcessConnection::didReceiveMessage(IPC::Connection& connection, IPC::Decoder& decoder)48 void WebToStorageProcessConnection::didReceiveMessage(IPC::Connection& connection, IPC::Decoder& decoder) 49 49 { 50 50 #if ENABLE(INDEXED_DATABASE) … … 60 60 } 61 61 62 void WebTo DatabaseProcessConnection::didClose(IPC::Connection& connection)62 void WebToStorageProcessConnection::didClose(IPC::Connection& connection) 63 63 { 64 64 #if ENABLE(INDEXED_DATABASE) … … 70 70 #endif 71 71 72 WebProcess::singleton().webTo DatabaseProcessConnectionClosed(this);72 WebProcess::singleton().webToStorageProcessConnectionClosed(this); 73 73 } 74 74 75 void WebTo DatabaseProcessConnection::didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference messageReceiverName, IPC::StringReference messageName)75 void WebToStorageProcessConnection::didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference messageReceiverName, IPC::StringReference messageName) 76 76 { 77 77 } 78 78 79 79 #if ENABLE(INDEXED_DATABASE) 80 WebIDBConnectionToServer& WebTo DatabaseProcessConnection::idbConnectionToServerForSession(const SessionID& sessionID)80 WebIDBConnectionToServer& WebToStorageProcessConnection::idbConnectionToServerForSession(const SessionID& sessionID) 81 81 { 82 82 auto result = m_webIDBConnectionsBySession.add(sessionID, nullptr); -
trunk/Source/WebKit/WebProcess/Storage/WebToStorageProcessConnection.h
r220094 r220105 39 39 namespace WebKit { 40 40 41 class WebTo DatabaseProcessConnection : public RefCounted<WebToDatabaseProcessConnection>, public IPC::Connection::Client, public IPC::MessageSender {41 class WebToStorageProcessConnection : public RefCounted<WebToStorageProcessConnection>, public IPC::Connection::Client, public IPC::MessageSender { 42 42 public: 43 static Ref<WebTo DatabaseProcessConnection> create(IPC::Connection::Identifier connectionIdentifier)43 static Ref<WebToStorageProcessConnection> create(IPC::Connection::Identifier connectionIdentifier) 44 44 { 45 return adoptRef(*new WebTo DatabaseProcessConnection(connectionIdentifier));45 return adoptRef(*new WebToStorageProcessConnection(connectionIdentifier)); 46 46 } 47 ~WebTo DatabaseProcessConnection();47 ~WebToStorageProcessConnection(); 48 48 49 49 IPC::Connection& connection() { return m_connection.get(); } … … 54 54 55 55 private: 56 WebTo DatabaseProcessConnection(IPC::Connection::Identifier);56 WebToStorageProcessConnection(IPC::Connection::Identifier); 57 57 58 58 // IPC::Connection::Client -
trunk/Source/WebKit/WebProcess/WebProcess.cpp
r220094 r220105 1140 1140 } 1141 1141 1142 void WebProcess::webTo DatabaseProcessConnectionClosed(WebToDatabaseProcessConnection* connection)1143 { 1144 ASSERT(m_webTo DatabaseProcessConnection);1145 ASSERT(m_webTo DatabaseProcessConnection == connection);1146 1147 m_webTo DatabaseProcessConnection = nullptr;1148 } 1149 1150 WebTo DatabaseProcessConnection* WebProcess::webToDatabaseProcessConnection()1151 { 1152 if (!m_webTo DatabaseProcessConnection)1153 ensureWebTo DatabaseProcessConnection();1154 1155 return m_webTo DatabaseProcessConnection.get();1156 } 1157 1158 void WebProcess::ensureWebTo DatabaseProcessConnection()1159 { 1160 if (m_webTo DatabaseProcessConnection)1142 void WebProcess::webToStorageProcessConnectionClosed(WebToStorageProcessConnection* connection) 1143 { 1144 ASSERT(m_webToStorageProcessConnection); 1145 ASSERT(m_webToStorageProcessConnection == connection); 1146 1147 m_webToStorageProcessConnection = nullptr; 1148 } 1149 1150 WebToStorageProcessConnection* WebProcess::webToStorageProcessConnection() 1151 { 1152 if (!m_webToStorageProcessConnection) 1153 ensureWebToStorageProcessConnection(); 1154 1155 return m_webToStorageProcessConnection.get(); 1156 } 1157 1158 void WebProcess::ensureWebToStorageProcessConnection() 1159 { 1160 if (m_webToStorageProcessConnection) 1161 1161 return; 1162 1162 1163 1163 IPC::Attachment encodedConnectionIdentifier; 1164 1164 1165 if (!parentProcessConnection()->sendSync(Messages::WebProcessProxy::GetDatabaseProcessConnection(), 1166 Messages::WebProcessProxy::GetDatabaseProcessConnection::Reply(encodedConnectionIdentifier), 0)) 1165 if (!parentProcessConnection()->sendSync(Messages::WebProcessProxy::GetStorageProcessConnection(), Messages::WebProcessProxy::GetStorageProcessConnection::Reply(encodedConnectionIdentifier), 0)) 1167 1166 return; 1168 1167 … … 1176 1175 if (IPC::Connection::identifierIsNull(connectionIdentifier)) 1177 1176 return; 1178 m_webTo DatabaseProcessConnection = WebToDatabaseProcessConnection::create(connectionIdentifier);1177 m_webToStorageProcessConnection = WebToStorageProcessConnection::create(connectionIdentifier); 1179 1178 } 1180 1179 -
trunk/Source/WebKit/WebProcess/WebProcess.h
r220037 r220105 87 87 class WebPageGroupProxy; 88 88 class WebProcessSupplement; 89 class WebTo DatabaseProcessConnection;89 class WebToStorageProcessConnection; 90 90 enum class WebsiteDataType; 91 91 struct WebPageCreationParameters; … … 165 165 #endif 166 166 167 void webTo DatabaseProcessConnectionClosed(WebToDatabaseProcessConnection*);168 WebTo DatabaseProcessConnection* webToDatabaseProcessConnection();167 void webToStorageProcessConnectionClosed(WebToStorageProcessConnection*); 168 WebToStorageProcessConnection* webToStorageProcessConnection(); 169 169 170 170 void setCacheModel(uint32_t); … … 384 384 std::unique_ptr<WebAutomationSessionProxy> m_automationSessionProxy; 385 385 386 void ensureWebTo DatabaseProcessConnection();387 RefPtr<WebTo DatabaseProcessConnection> m_webToDatabaseProcessConnection;386 void ensureWebToStorageProcessConnection(); 387 RefPtr<WebToStorageProcessConnection> m_webToStorageProcessConnection; 388 388 389 389 #if ENABLE(NETSCAPE_PLUGIN_API) -
trunk/Tools/ChangeLog
r220087 r220105 1 2017-08-01 Brady Eidson <beidson@apple.com> 2 3 Part 2 of: Rename DatabaseProcess to StorageProcess. 4 https://bugs.webkit.org/show_bug.cgi?id=174880 5 6 Reviewed by Andy Estes. 7 8 * TestWebKitAPI/Tests/WebKit2Cocoa/IDBDeleteRecovery.mm: 9 * TestWebKitAPI/Tests/WebKit2Cocoa/IDBIndexUpgradeToV2.mm: 10 * TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBDatabaseProcessKill.mm: 11 * TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBMultiProcess.mm: 12 * TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBPersistence.mm: 13 * TestWebKitAPI/Tests/WebKit2Cocoa/ResourceLoadStatistics.mm: 14 * TestWebKitAPI/Tests/WebKit2Cocoa/WebProcessKillIDBCleanup.mm: 15 * TestWebKitAPI/Tests/WebKit2Cocoa/WebsiteDataStoreCustomPaths.mm: 16 1 17 2017-07-31 Csaba Osztrogonác <ossy@webkit.org> 2 18 -
trunk/Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IDBDeleteRecovery.mm
r220037 r220105 60 60 [[configuration userContentController] addScriptMessageHandler:handler.get() name:@"testHandler"]; 61 61 62 [configuration.get().processPool _terminate DatabaseProcess];62 [configuration.get().processPool _terminateStorageProcess]; 63 63 64 64 // Copy the inconsistent database files to the database directory -
trunk/Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IDBIndexUpgradeToV2.mm
r220037 r220105 60 60 [[configuration userContentController] addScriptMessageHandler:handler.get() name:@"testHandler"]; 61 61 62 [configuration.get().processPool _terminate DatabaseProcess];62 [configuration.get().processPool _terminateStorageProcess]; 63 63 64 64 // Copy the inconsistent database files to the database directory -
trunk/Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBDatabaseProcessKill.mm
r220037 r220105 95 95 if (!killedDBProcess && openRequestUpgradeNeeded) { 96 96 killedDBProcess = true; 97 [configuration.get().processPool _terminate DatabaseProcess];97 [configuration.get().processPool _terminateStorageProcess]; 98 98 } 99 99 } -
trunk/Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBMultiProcess.mm
r220037 r220105 72 72 [[configuration userContentController] addScriptMessageHandler:handler.get() name:@"testHandler"]; 73 73 74 [configuration.get().processPool _terminate DatabaseProcess];74 [configuration.get().processPool _terminateStorageProcess]; 75 75 76 76 RetainPtr<WKWebView> webView = adoptNS([[WKWebView alloc] initWithFrame:NSMakeRect(0, 0, 800, 600) configuration:configuration.get()]); -
trunk/Tools/TestWebKitAPI/Tests/WebKit2Cocoa/IndexedDBPersistence.mm
r220037 r220105 76 76 webView = nil; 77 77 78 // Terminate the database process79 [configuration.get().processPool _terminate DatabaseProcess];78 // Terminate the storage process 79 [configuration.get().processPool _terminateStorageProcess]; 80 80 81 81 // Make a new web view to finish the test -
trunk/Tools/TestWebKitAPI/Tests/WebKit2Cocoa/ResourceLoadStatistics.mm
r220037 r220105 124 124 WKProcessPool *sharedProcessPool = [WKProcessPool _sharedProcessPool]; 125 125 126 EXPECT_EQ((pid_t)0, [sharedProcessPool _ databaseProcessIdentifier]);126 EXPECT_EQ((pid_t)0, [sharedProcessPool _storageProcessIdentifier]); 127 127 EXPECT_EQ((size_t)0, [sharedProcessPool _pluginProcessCount]); 128 128 … … 149 149 EXPECT_TRUE([[NSFileManager defaultManager] fileExistsAtPath:targetURL.path]); 150 150 151 EXPECT_EQ((pid_t)0, [sharedProcessPool _ databaseProcessIdentifier]);151 EXPECT_EQ((pid_t)0, [sharedProcessPool _storageProcessIdentifier]); 152 152 EXPECT_EQ((size_t)0, [sharedProcessPool _pluginProcessCount]); 153 153 } -
trunk/Tools/TestWebKitAPI/Tests/WebKit2Cocoa/WebProcessKillIDBCleanup.mm
r220037 r220105 73 73 [[configuration userContentController] addScriptMessageHandler:handler.get() name:@"testHandler"]; 74 74 75 [configuration.get().processPool _terminate DatabaseProcess];75 [configuration.get().processPool _terminateStorageProcess]; 76 76 77 77 RetainPtr<WKWebView> webView = adoptNS([[WKWebView alloc] initWithFrame:NSMakeRect(0, 0, 800, 600) configuration:configuration.get()]); -
trunk/Tools/TestWebKitAPI/Tests/WebKit2Cocoa/WebsiteDataStoreCustomPaths.mm
r220037 r220105 122 122 123 123 // Forcibly shut down everything of WebKit that we can. 124 [[[webView configuration] processPool] _terminate DatabaseProcess];124 [[[webView configuration] processPool] _terminateStorageProcess]; 125 125 auto pid = [webView _webProcessIdentifier]; 126 126 if (pid) … … 160 160 // Data stores can't delete anything unless a WKProcessPool exists, so make sure the shared data store exists. 161 161 auto *processPool = [WKProcessPool _sharedProcessPool]; 162 [processPool _terminate DatabaseProcess];162 [processPool _terminateStorageProcess]; 163 163 RetainPtr<WKWebsiteDataStore> dataStore = [[WKWebsiteDataStore alloc] _initWithConfiguration:websiteDataStoreConfiguration.get()]; 164 164 RetainPtr<NSSet> types = adoptNS([[NSSet alloc] initWithObjects:WKWebsiteDataTypeIndexedDBDatabases, nil]);
Note:
See TracChangeset
for help on using the changeset viewer.