| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/renderer/pepper_plugin_delegate_impl.h" | 5 #include "content/renderer/pepper_plugin_delegate_impl.h" |
| 6 | 6 |
| 7 #include <cmath> | 7 #include <cmath> |
| 8 #include <queue> | 8 #include <queue> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 68 #include "webkit/fileapi/file_system_callback_dispatcher.h" | 68 #include "webkit/fileapi/file_system_callback_dispatcher.h" |
| 69 #include "webkit/glue/context_menu.h" | 69 #include "webkit/glue/context_menu.h" |
| 70 #include "webkit/plugins/npapi/webplugin.h" | 70 #include "webkit/plugins/npapi/webplugin.h" |
| 71 #include "webkit/plugins/ppapi/file_path.h" | 71 #include "webkit/plugins/ppapi/file_path.h" |
| 72 #include "webkit/plugins/ppapi/ppb_file_io_impl.h" | 72 #include "webkit/plugins/ppapi/ppb_file_io_impl.h" |
| 73 #include "webkit/plugins/ppapi/plugin_module.h" | 73 #include "webkit/plugins/ppapi/plugin_module.h" |
| 74 #include "webkit/plugins/ppapi/ppapi_plugin_instance.h" | 74 #include "webkit/plugins/ppapi/ppapi_plugin_instance.h" |
| 75 #include "webkit/plugins/ppapi/ppb_broker_impl.h" | 75 #include "webkit/plugins/ppapi/ppb_broker_impl.h" |
| 76 #include "webkit/plugins/ppapi/ppb_flash_impl.h" | 76 #include "webkit/plugins/ppapi/ppb_flash_impl.h" |
| 77 #include "webkit/plugins/ppapi/ppb_flash_net_connector_impl.h" | 77 #include "webkit/plugins/ppapi/ppb_flash_net_connector_impl.h" |
| 78 #include "webkit/plugins/ppapi/ppb_tcp_socket_private_impl.h" | |
| 79 #include "webkit/plugins/ppapi/ppb_udp_socket_private_impl.h" | |
| 80 #include "webkit/plugins/ppapi/resource_helper.h" | 78 #include "webkit/plugins/ppapi/resource_helper.h" |
| 81 #include "webkit/plugins/webplugininfo.h" | 79 #include "webkit/plugins/webplugininfo.h" |
| 82 | 80 |
| 83 using WebKit::WebView; | 81 using WebKit::WebView; |
| 84 | 82 |
| 85 namespace { | 83 namespace { |
| 86 | 84 |
| 87 base::SyncSocket::Handle DuplicateHandle(base::SyncSocket::Handle handle) { | 85 base::SyncSocket::Handle DuplicateHandle(base::SyncSocket::Handle handle) { |
| 88 base::SyncSocket::Handle out_handle = base::kInvalidPlatformFileValue; | 86 base::SyncSocket::Handle out_handle = base::kInvalidPlatformFileValue; |
| 89 #if defined(OS_WIN) | 87 #if defined(OS_WIN) |
| (...skipping 1587 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1677 base::PlatformFile socket, | 1675 base::PlatformFile socket, |
| 1678 const PP_NetAddress_Private& local_addr, | 1676 const PP_NetAddress_Private& local_addr, |
| 1679 const PP_NetAddress_Private& remote_addr) { | 1677 const PP_NetAddress_Private& remote_addr) { |
| 1680 scoped_refptr<webkit::ppapi::PPB_Flash_NetConnector_Impl> connector = | 1678 scoped_refptr<webkit::ppapi::PPB_Flash_NetConnector_Impl> connector = |
| 1681 *pending_connect_tcps_.Lookup(request_id); | 1679 *pending_connect_tcps_.Lookup(request_id); |
| 1682 pending_connect_tcps_.Remove(request_id); | 1680 pending_connect_tcps_.Remove(request_id); |
| 1683 | 1681 |
| 1684 connector->CompleteConnectTcp(socket, local_addr, remote_addr); | 1682 connector->CompleteConnectTcp(socket, local_addr, remote_addr); |
| 1685 } | 1683 } |
| 1686 | 1684 |
| 1687 uint32 PepperPluginDelegateImpl::TCPSocketCreate() { | |
| 1688 if (!render_view_->CanUseSocketAPIs()) | |
| 1689 return 0; | |
| 1690 | |
| 1691 uint32 socket_id = 0; | |
| 1692 render_view_->Send(new PpapiHostMsg_PPBTCPSocket_Create( | |
| 1693 render_view_->routing_id(), 0, &socket_id)); | |
| 1694 return socket_id; | |
| 1695 } | |
| 1696 | |
| 1697 void PepperPluginDelegateImpl::TCPSocketConnect( | |
| 1698 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket, | |
| 1699 uint32 socket_id, | |
| 1700 const std::string& host, | |
| 1701 uint16_t port) { | |
| 1702 tcp_sockets_.AddWithID(socket, socket_id); | |
| 1703 render_view_->Send( | |
| 1704 new PpapiHostMsg_PPBTCPSocket_Connect(socket_id, host, port)); | |
| 1705 } | |
| 1706 | |
| 1707 void PepperPluginDelegateImpl::TCPSocketConnectWithNetAddress( | |
| 1708 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket, | |
| 1709 uint32 socket_id, | |
| 1710 const PP_NetAddress_Private& addr) { | |
| 1711 tcp_sockets_.AddWithID(socket, socket_id); | |
| 1712 render_view_->Send( | |
| 1713 new PpapiHostMsg_PPBTCPSocket_ConnectWithNetAddress(socket_id, addr)); | |
| 1714 } | |
| 1715 | |
| 1716 void PepperPluginDelegateImpl::OnTCPSocketConnectACK( | |
| 1717 uint32 socket_id, | |
| 1718 bool succeeded, | |
| 1719 const PP_NetAddress_Private& local_addr, | |
| 1720 const PP_NetAddress_Private& remote_addr) { | |
| 1721 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket = | |
| 1722 tcp_sockets_.Lookup(socket_id); | |
| 1723 if (socket) | |
| 1724 socket->OnConnectCompleted(succeeded, local_addr, remote_addr); | |
| 1725 } | |
| 1726 | |
| 1727 void PepperPluginDelegateImpl::TCPSocketSSLHandshake( | |
| 1728 uint32 socket_id, | |
| 1729 const std::string& server_name, | |
| 1730 uint16_t server_port) { | |
| 1731 DCHECK(tcp_sockets_.Lookup(socket_id)); | |
| 1732 render_view_->Send(new PpapiHostMsg_PPBTCPSocket_SSLHandshake( | |
| 1733 socket_id, server_name, server_port)); | |
| 1734 } | |
| 1735 | |
| 1736 void PepperPluginDelegateImpl::OnTCPSocketSSLHandshakeACK(uint32 socket_id, | |
| 1737 bool succeeded) { | |
| 1738 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket = | |
| 1739 tcp_sockets_.Lookup(socket_id); | |
| 1740 if (socket) | |
| 1741 socket->OnSSLHandshakeCompleted(succeeded); | |
| 1742 } | |
| 1743 | |
| 1744 void PepperPluginDelegateImpl::TCPSocketRead(uint32 socket_id, | |
| 1745 int32_t bytes_to_read) { | |
| 1746 DCHECK(tcp_sockets_.Lookup(socket_id)); | |
| 1747 render_view_->Send( | |
| 1748 new PpapiHostMsg_PPBTCPSocket_Read(socket_id, bytes_to_read)); | |
| 1749 } | |
| 1750 | |
| 1751 void PepperPluginDelegateImpl::OnTCPSocketReadACK(uint32 socket_id, | |
| 1752 bool succeeded, | |
| 1753 const std::string& data) { | |
| 1754 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket = | |
| 1755 tcp_sockets_.Lookup(socket_id); | |
| 1756 if (socket) | |
| 1757 socket->OnReadCompleted(succeeded, data); | |
| 1758 } | |
| 1759 | |
| 1760 void PepperPluginDelegateImpl::TCPSocketWrite(uint32 socket_id, | |
| 1761 const std::string& buffer) { | |
| 1762 DCHECK(tcp_sockets_.Lookup(socket_id)); | |
| 1763 render_view_->Send(new PpapiHostMsg_PPBTCPSocket_Write(socket_id, buffer)); | |
| 1764 } | |
| 1765 | |
| 1766 void PepperPluginDelegateImpl::OnTCPSocketWriteACK(uint32 socket_id, | |
| 1767 bool succeeded, | |
| 1768 int32_t bytes_written) { | |
| 1769 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket = | |
| 1770 tcp_sockets_.Lookup(socket_id); | |
| 1771 if (socket) | |
| 1772 socket->OnWriteCompleted(succeeded, bytes_written); | |
| 1773 } | |
| 1774 | |
| 1775 void PepperPluginDelegateImpl::TCPSocketDisconnect(uint32 socket_id) { | |
| 1776 // There are no DCHECK(tcp_sockets_.Lookup(socket_id)) because it | |
| 1777 // can be called before | |
| 1778 // TCPSocketConnect/TCPSocketConnectWithNetAddress is called. | |
| 1779 render_view_->Send(new PpapiHostMsg_PPBTCPSocket_Disconnect(socket_id)); | |
| 1780 tcp_sockets_.Remove(socket_id); | |
| 1781 } | |
| 1782 | |
| 1783 uint32 PepperPluginDelegateImpl::UDPSocketCreate() { | |
| 1784 if (!render_view_->CanUseSocketAPIs()) | |
| 1785 return 0; | |
| 1786 | |
| 1787 uint32 socket_id = 0; | |
| 1788 render_view_->Send(new PpapiHostMsg_PPBUDPSocket_Create( | |
| 1789 render_view_->routing_id(), 0, &socket_id)); | |
| 1790 return socket_id; | |
| 1791 } | |
| 1792 | |
| 1793 void PepperPluginDelegateImpl::UDPSocketBind( | |
| 1794 webkit::ppapi::PPB_UDPSocket_Private_Impl* socket, | |
| 1795 uint32 socket_id, | |
| 1796 const PP_NetAddress_Private& addr) { | |
| 1797 udp_sockets_.AddWithID(socket, socket_id); | |
| 1798 render_view_->Send(new PpapiHostMsg_PPBUDPSocket_Bind(socket_id, addr)); | |
| 1799 } | |
| 1800 | |
| 1801 void PepperPluginDelegateImpl::OnUDPSocketBindACK(uint32 socket_id, | |
| 1802 bool succeeded) { | |
| 1803 webkit::ppapi::PPB_UDPSocket_Private_Impl* socket = | |
| 1804 udp_sockets_.Lookup(socket_id); | |
| 1805 if (socket) | |
| 1806 socket->OnBindCompleted(succeeded); | |
| 1807 } | |
| 1808 | |
| 1809 void PepperPluginDelegateImpl::UDPSocketRecvFrom(uint32 socket_id, | |
| 1810 int32_t num_bytes) { | |
| 1811 DCHECK(udp_sockets_.Lookup(socket_id)); | |
| 1812 render_view_->Send( | |
| 1813 new PpapiHostMsg_PPBUDPSocket_RecvFrom(socket_id, num_bytes)); | |
| 1814 } | |
| 1815 | |
| 1816 void PepperPluginDelegateImpl::OnUDPSocketRecvFromACK( | |
| 1817 uint32 socket_id, | |
| 1818 bool succeeded, | |
| 1819 const std::string& data, | |
| 1820 const PP_NetAddress_Private& remote_addr) { | |
| 1821 webkit::ppapi::PPB_UDPSocket_Private_Impl* socket = | |
| 1822 udp_sockets_.Lookup(socket_id); | |
| 1823 if (socket) | |
| 1824 socket->OnRecvFromCompleted(succeeded, data, remote_addr); | |
| 1825 } | |
| 1826 | |
| 1827 void PepperPluginDelegateImpl::UDPSocketSendTo( | |
| 1828 uint32 socket_id, | |
| 1829 const std::string& buffer, | |
| 1830 const PP_NetAddress_Private& net_addr) { | |
| 1831 DCHECK(udp_sockets_.Lookup(socket_id)); | |
| 1832 render_view_->Send( | |
| 1833 new PpapiHostMsg_PPBUDPSocket_SendTo(socket_id, buffer, net_addr)); | |
| 1834 } | |
| 1835 | |
| 1836 void PepperPluginDelegateImpl::OnUDPSocketSendToACK(uint32 socket_id, | |
| 1837 bool succeeded, | |
| 1838 int32_t bytes_written) { | |
| 1839 webkit::ppapi::PPB_UDPSocket_Private_Impl* socket = | |
| 1840 udp_sockets_.Lookup(socket_id); | |
| 1841 if (socket) | |
| 1842 socket->OnSendToCompleted(succeeded, bytes_written); | |
| 1843 } | |
| 1844 | |
| 1845 void PepperPluginDelegateImpl::UDPSocketClose(uint32 socket_id) { | |
| 1846 // There are no DCHECK(udp_sockets_.Lookup(socket_id)) because it | |
| 1847 // can be called before UDPSocketBind is called. | |
| 1848 render_view_->Send(new PpapiHostMsg_PPBUDPSocket_Close(socket_id)); | |
| 1849 udp_sockets_.Remove(socket_id); | |
| 1850 } | |
| 1851 | |
| 1852 int32_t PepperPluginDelegateImpl::ShowContextMenu( | 1685 int32_t PepperPluginDelegateImpl::ShowContextMenu( |
| 1853 webkit::ppapi::PluginInstance* instance, | 1686 webkit::ppapi::PluginInstance* instance, |
| 1854 webkit::ppapi::PPB_Flash_Menu_Impl* menu, | 1687 webkit::ppapi::PPB_Flash_Menu_Impl* menu, |
| 1855 const gfx::Point& position) { | 1688 const gfx::Point& position) { |
| 1856 int32 render_widget_id = render_view_->routing_id(); | 1689 int32 render_widget_id = render_view_->routing_id(); |
| 1857 if (instance->FlashIsFullscreen(instance->pp_instance())) { | 1690 if (instance->FlashIsFullscreen(instance->pp_instance())) { |
| 1858 webkit::ppapi::FullscreenContainer* container = | 1691 webkit::ppapi::FullscreenContainer* container = |
| 1859 instance->fullscreen_container(); | 1692 instance->fullscreen_container(); |
| 1860 DCHECK(container); | 1693 DCHECK(container); |
| 1861 render_widget_id = | 1694 render_widget_id = |
| (...skipping 239 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2101 if (!context) | 1934 if (!context) |
| 2102 return NULL; | 1935 return NULL; |
| 2103 if (!context->makeContextCurrent() || context->isContextLost()) | 1936 if (!context->makeContextCurrent() || context->isContextLost()) |
| 2104 return NULL; | 1937 return NULL; |
| 2105 | 1938 |
| 2106 RendererGLContext* parent_context = context->context(); | 1939 RendererGLContext* parent_context = context->context(); |
| 2107 if (!parent_context) | 1940 if (!parent_context) |
| 2108 return NULL; | 1941 return NULL; |
| 2109 return parent_context; | 1942 return parent_context; |
| 2110 } | 1943 } |
| OLD | NEW |