Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(135)

Side by Side Diff: content/renderer/pepper/pepper_plugin_delegate_impl.cc

Issue 12220050: Provide a way to disable Nagle's algorithm on Pepper TCP sockets. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Add missing completion callback implementation. Created 7 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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/pepper_plugin_delegate_impl.h" 5 #include "content/renderer/pepper/pepper_plugin_delegate_impl.h"
6 6
7 #include <cmath> 7 #include <cmath>
8 #include <cstddef> 8 #include <cstddef>
9 #include <map> 9 #include <map>
10 #include <queue> 10 #include <queue>
(...skipping 1165 matching lines...) Expand 10 before | Expand all | Expand 10 after
1176 1176
1177 void PepperPluginDelegateImpl::TCPSocketDisconnect(uint32 socket_id) { 1177 void PepperPluginDelegateImpl::TCPSocketDisconnect(uint32 socket_id) {
1178 // There are no DCHECK(tcp_sockets_.Lookup(socket_id)) because it 1178 // There are no DCHECK(tcp_sockets_.Lookup(socket_id)) because it
1179 // can be called before 1179 // can be called before
1180 // TCPSocketConnect/TCPSocketConnectWithNetAddress is called. 1180 // TCPSocketConnect/TCPSocketConnectWithNetAddress is called.
1181 render_view_->Send(new PpapiHostMsg_PPBTCPSocket_Disconnect(socket_id)); 1181 render_view_->Send(new PpapiHostMsg_PPBTCPSocket_Disconnect(socket_id));
1182 if (tcp_sockets_.Lookup(socket_id)) 1182 if (tcp_sockets_.Lookup(socket_id))
1183 tcp_sockets_.Remove(socket_id); 1183 tcp_sockets_.Remove(socket_id);
1184 } 1184 }
1185 1185
1186 void PepperPluginDelegateImpl::TCPSocketSetBoolFeature(
1187 uint32 socket_id, int32_t name, bool value) {
yzshen1 2013/02/08 21:51:11 - wrong indent. - From chromium style guide: "For
Wez 2013/02/10 04:47:02 Done.
1188 DCHECK(tcp_sockets_.Lookup(socket_id));
1189 render_view_->Send(
1190 new PpapiHostMsg_PPBTCPSocket_SetBoolFeature(socket_id, name, value));
1191 }
1192
1186 void PepperPluginDelegateImpl::RegisterTCPSocket( 1193 void PepperPluginDelegateImpl::RegisterTCPSocket(
1187 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket, 1194 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket,
1188 uint32 socket_id) { 1195 uint32 socket_id) {
1189 tcp_sockets_.AddWithID(socket, socket_id); 1196 tcp_sockets_.AddWithID(socket, socket_id);
1190 } 1197 }
1191 1198
1192 void PepperPluginDelegateImpl::TCPServerSocketListen( 1199 void PepperPluginDelegateImpl::TCPServerSocketListen(
1193 PP_Resource socket_resource, 1200 PP_Resource socket_resource,
1194 const PP_NetAddress_Private& addr, 1201 const PP_NetAddress_Private& addr,
1195 int32_t backlog) { 1202 int32_t backlog) {
(...skipping 230 matching lines...) Expand 10 before | Expand all | Expand 10 after
1426 1433
1427 bool PepperPluginDelegateImpl::OnMessageReceived(const IPC::Message& message) { 1434 bool PepperPluginDelegateImpl::OnMessageReceived(const IPC::Message& message) {
1428 bool handled = true; 1435 bool handled = true;
1429 IPC_BEGIN_MESSAGE_MAP(PepperPluginDelegateImpl, message) 1436 IPC_BEGIN_MESSAGE_MAP(PepperPluginDelegateImpl, message)
1430 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_ConnectACK, 1437 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_ConnectACK,
1431 OnTCPSocketConnectACK) 1438 OnTCPSocketConnectACK)
1432 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_SSLHandshakeACK, 1439 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_SSLHandshakeACK,
1433 OnTCPSocketSSLHandshakeACK) 1440 OnTCPSocketSSLHandshakeACK)
1434 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_ReadACK, OnTCPSocketReadACK) 1441 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_ReadACK, OnTCPSocketReadACK)
1435 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_WriteACK, OnTCPSocketWriteACK) 1442 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_WriteACK, OnTCPSocketWriteACK)
1443 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_SetBoolFeatureACK,
1444 OnTCPSocketSetBoolFeatureACK)
1436 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPServerSocket_ListenACK, 1445 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPServerSocket_ListenACK,
1437 OnTCPServerSocketListenACK) 1446 OnTCPServerSocketListenACK)
1438 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPServerSocket_AcceptACK, 1447 IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPServerSocket_AcceptACK,
1439 OnTCPServerSocketAcceptACK) 1448 OnTCPServerSocketAcceptACK)
1440 IPC_MESSAGE_HANDLER(PpapiMsg_PPBHostResolver_ResolveACK, 1449 IPC_MESSAGE_HANDLER(PpapiMsg_PPBHostResolver_ResolveACK,
1441 OnHostResolverResolveACK) 1450 OnHostResolverResolveACK)
1442 IPC_MESSAGE_UNHANDLED(handled = false) 1451 IPC_MESSAGE_UNHANDLED(handled = false)
1443 IPC_END_MESSAGE_MAP() 1452 IPC_END_MESSAGE_MAP()
1444 return handled; 1453 return handled;
1445 } 1454 }
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
1488 void PepperPluginDelegateImpl::OnTCPSocketWriteACK(uint32 plugin_dispatcher_id, 1497 void PepperPluginDelegateImpl::OnTCPSocketWriteACK(uint32 plugin_dispatcher_id,
1489 uint32 socket_id, 1498 uint32 socket_id,
1490 bool succeeded, 1499 bool succeeded,
1491 int32_t bytes_written) { 1500 int32_t bytes_written) {
1492 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket = 1501 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket =
1493 tcp_sockets_.Lookup(socket_id); 1502 tcp_sockets_.Lookup(socket_id);
1494 if (socket) 1503 if (socket)
1495 socket->OnWriteCompleted(succeeded, bytes_written); 1504 socket->OnWriteCompleted(succeeded, bytes_written);
1496 } 1505 }
1497 1506
1507 void PepperPluginDelegateImpl::OnTCPSocketSetBoolFeatureACK(
1508 uint32 plugin_dispatcher_id, uint32 socket_id, bool succeeded) {
yzshen1 2013/02/08 21:51:11 From chromium style guide: "For function declarati
Wez 2013/02/10 04:47:02 Done.
1509 webkit::ppapi::PPB_TCPSocket_Private_Impl* socket =
1510 tcp_sockets_.Lookup(socket_id);
1511 if (socket)
1512 socket->OnSetSocketFeatureCompleted(succeeded);
1513 }
1514
1498 void PepperPluginDelegateImpl::OnTCPServerSocketListenACK( 1515 void PepperPluginDelegateImpl::OnTCPServerSocketListenACK(
1499 uint32 plugin_dispatcher_id, 1516 uint32 plugin_dispatcher_id,
1500 PP_Resource socket_resource, 1517 PP_Resource socket_resource,
1501 uint32 socket_id, 1518 uint32 socket_id,
1502 int32_t status) { 1519 int32_t status) {
1503 ppapi::thunk::EnterResource<ppapi::thunk::PPB_TCPServerSocket_Private_API> 1520 ppapi::thunk::EnterResource<ppapi::thunk::PPB_TCPServerSocket_Private_API>
1504 enter(socket_resource, true); 1521 enter(socket_resource, true);
1505 if (enter.succeeded()) { 1522 if (enter.succeeded()) {
1506 ppapi::PPB_TCPServerSocket_Shared* socket = 1523 ppapi::PPB_TCPServerSocket_Shared* socket =
1507 static_cast<ppapi::PPB_TCPServerSocket_Shared*>(enter.object()); 1524 static_cast<ppapi::PPB_TCPServerSocket_Shared*>(enter.object());
(...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after
1642 RenderWidgetFullscreenPepper* container = 1659 RenderWidgetFullscreenPepper* container =
1643 static_cast<RenderWidgetFullscreenPepper*>( 1660 static_cast<RenderWidgetFullscreenPepper*>(
1644 instance->fullscreen_container()); 1661 instance->fullscreen_container());
1645 return container->mouse_lock_dispatcher(); 1662 return container->mouse_lock_dispatcher();
1646 } else { 1663 } else {
1647 return render_view_->mouse_lock_dispatcher(); 1664 return render_view_->mouse_lock_dispatcher();
1648 } 1665 }
1649 } 1666 }
1650 1667
1651 } // namespace content 1668 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698