code.vuplus.com Git - vuplus_webkit/blob - Source/WebKit2/WebProcess/Plugins/PluginProcessConnectionManager.cpp

   1 /*
   2  * Copyright (C) 2010 Apple Inc. All rights reserved.
   3  *
   4  * Redistribution and use in source and binary forms, with or without
   5  * modification, are permitted provided that the following conditions
   6  * are met:
   7  * 1. Redistributions of source code must retain the above copyright
   8  *    notice, this list of conditions and the following disclaimer.
   9  * 2. Redistributions in binary form must reproduce the above copyright
  10  *    notice, this list of conditions and the following disclaimer in the
  11  *    documentation and/or other materials provided with the distribution.
  12  *
  13  * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
  14  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
  15  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  16  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
  17  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  18  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  19  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  20  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  21  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  22  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  23  * THE POSSIBILITY OF SUCH DAMAGE.
  24  */
  25
  26 #include "config.h"
  27 #include "PluginProcessConnectionManager.h"
  28
  29 #if ENABLE(PLUGIN_PROCESS)
  30
  31 #include "ArgumentDecoder.h"
  32 #include "ArgumentEncoder.h"
  33 #include "PluginProcessConnection.h"
  34 #include "WebCoreArgumentCoders.h"
  35 #include "WebProcess.h"
  36 #include "WebProcessProxyMessages.h"
  37
  38 #if PLATFORM(MAC)
  39 #include "MachPort.h"
  40 #endif
  41
  42 namespace WebKit {
  43
  44 PluginProcessConnectionManager::PluginProcessConnectionManager()
  45 {
  46 }
  47
  48 PluginProcessConnectionManager::~PluginProcessConnectionManager()
  49 {
  50 }
  51
  52 PluginProcessConnection* PluginProcessConnectionManager::getPluginProcessConnection(const String& pluginPath)
  53 {
  54     for (size_t i = 0; i < m_pluginProcessConnections.size(); ++i) {
  55         if (m_pluginProcessConnections[i]->pluginPath() == pluginPath)
  56             return m_pluginProcessConnections[i].get();
  57     }
  58
  59     CoreIPC::Attachment encodedConnectionIdentifier;
  60     if (!WebProcess::shared().connection()->sendSync(Messages::WebProcessProxy::GetPluginProcessConnection(pluginPath),
  61                                                      Messages::WebProcessProxy::GetPluginProcessConnection::Reply(encodedConnectionIdentifier), 0))
  62         return 0;
  63
  64 #if PLATFORM(MAC)
  65     CoreIPC::Connection::Identifier connectionIdentifier = encodedConnectionIdentifier.port();
  66     if (!connectionIdentifier)
  67         return 0;
  68 #elif USE(UNIX_DOMAIN_SOCKETS)
  69     CoreIPC::Connection::Identifier connectionIdentifier = encodedConnectionIdentifier.fileDescriptor();
  70     if (connectionIdentifier == -1)
  71         return 0;
  72 #endif
  73
  74     RefPtr<PluginProcessConnection> pluginProcessConnection = PluginProcessConnection::create(this, pluginPath, connectionIdentifier);
  75     m_pluginProcessConnections.append(pluginProcessConnection);
  76
  77     {
  78         MutexLocker locker(m_pathsAndConnectionsMutex);
  79         ASSERT(!m_pathsAndConnections.contains(pluginProcessConnection->pluginPath()));
  80
  81         m_pathsAndConnections.set(pluginPath, pluginProcessConnection->connection());
  82     }
  83
  84     return pluginProcessConnection.get();
  85 }
  86
  87 void PluginProcessConnectionManager::removePluginProcessConnection(PluginProcessConnection* pluginProcessConnection)
  88 {
  89     size_t vectorIndex = m_pluginProcessConnections.find(pluginProcessConnection);
  90     ASSERT(vectorIndex != notFound);
  91
  92     {
  93         MutexLocker locker(m_pathsAndConnectionsMutex);
  94         ASSERT(m_pathsAndConnections.contains(pluginProcessConnection->pluginPath()));
  95
  96         m_pathsAndConnections.remove(pluginProcessConnection->pluginPath());
  97     }
  98
  99     m_pluginProcessConnections.remove(vectorIndex);
 100 }
 101
 102 void PluginProcessConnectionManager::pluginProcessCrashed(const String& pluginPath)
 103 {
 104     MutexLocker locker(m_pathsAndConnectionsMutex);
 105     CoreIPC::Connection* connection = m_pathsAndConnections.get(pluginPath).get();
 106
 107     // It's OK for connection to be null here; it will happen if this web process doesn't know
 108     // anything about the plug-in process.
 109     if (!connection)
 110         return;
 111
 112     connection->postConnectionDidCloseOnConnectionWorkQueue();
 113 }
 114
 115 } // namespace WebKit
 116
 117 #endif // ENABLE(PLUGIN_PROCESS)