Home | History | Annotate | Download | only in Plugins 
      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 #include <wtf/StdLibExtras.h>
     38 
     39 #if PLATFORM(MAC)
     40 #include "MachPort.h"
     41 #endif
     42 
     43 namespace WebKit {
     44 
     45 PluginProcessConnectionManager& PluginProcessConnectionManager::shared()
     46 {
     47     DEFINE_STATIC_LOCAL(PluginProcessConnectionManager, pluginProcessConnectionManager, ());
     48     return pluginProcessConnectionManager;
     49 }
     50 
     51 PluginProcessConnectionManager::PluginProcessConnectionManager()
     52 {
     53 }
     54 
     55 PluginProcessConnectionManager::~PluginProcessConnectionManager()
     56 {
     57 }
     58 
     59 PluginProcessConnection* PluginProcessConnectionManager::getPluginProcessConnection(const String& pluginPath)
     60 {
     61     for (size_t i = 0; i < m_pluginProcessConnections.size(); ++i) {
     62         if (m_pluginProcessConnections[i]->pluginPath() == pluginPath)
     63             return m_pluginProcessConnections[i].get();
     64     }
     65 
     66     CoreIPC::Connection::Identifier connectionIdentifier;
     67 #if PLATFORM(MAC)
     68     CoreIPC::MachPort connectionMachPort;
     69 
     70     if (!WebProcess::shared().connection()->sendSync(Messages::WebProcessProxy::GetPluginProcessConnection(pluginPath), Messages::WebProcessProxy::GetPluginProcessConnection::Reply(connectionMachPort), 0))
     71         return 0;
     72 
     73     connectionIdentifier = connectionMachPort.port();
     74 #else
     75     // FIXME: Implement.
     76     connectionIdentifier = 0;
     77     ASSERT_NOT_REACHED();
     78 #endif
     79     if (!connectionIdentifier)
     80         return 0;
     81 
     82     RefPtr<PluginProcessConnection> pluginProcessConnection = PluginProcessConnection::create(this, pluginPath, connectionIdentifier);
     83     m_pluginProcessConnections.append(pluginProcessConnection);
     84 
     85     return pluginProcessConnection.get();
     86 }
     87 
     88 void PluginProcessConnectionManager::removePluginProcessConnection(PluginProcessConnection* pluginProcessConnection)
     89 {
     90     size_t vectorIndex = m_pluginProcessConnections.find(pluginProcessConnection);
     91     ASSERT(vectorIndex != notFound);
     92 
     93     m_pluginProcessConnections.remove(vectorIndex);
     94 }
     95 
     96 } // namespace WebKit
     97 
     98 #endif // ENABLE(PLUGIN_PROCESS)
     99