Index: content/renderer/p2p/socket_dispatcher.cc |
diff --git a/content/renderer/p2p/socket_dispatcher.cc b/content/renderer/p2p/socket_dispatcher.cc |
index c999e621399c6e51197ae9b5086000453564e29c..7fe71eeb1c70f9c21b0b3cf7fecc909138cd9cf7 100644 |
--- a/content/renderer/p2p/socket_dispatcher.cc |
+++ b/content/renderer/p2p/socket_dispatcher.cc |
@@ -63,6 +63,7 @@ bool P2PSocketDispatcher::OnMessageReceived(const IPC::Message& message) { |
IPC_MESSAGE_HANDLER(P2PMsg_GetHostAddressResult, OnGetHostAddressResult) |
IPC_MESSAGE_HANDLER(P2PMsg_OnSocketCreated, OnSocketCreated) |
IPC_MESSAGE_HANDLER(P2PMsg_OnIncomingTcpConnection, OnIncomingTcpConnection) |
+ IPC_MESSAGE_HANDLER(P2PMsg_OnSendComplete, OnSendComplete) |
IPC_MESSAGE_HANDLER(P2PMsg_OnError, OnError) |
IPC_MESSAGE_HANDLER(P2PMsg_OnDataReceived, OnDataReceived) |
IPC_MESSAGE_UNHANDLED(handled = false) |
@@ -152,6 +153,13 @@ void P2PSocketDispatcher::OnIncomingTcpConnection( |
} |
} |
+void P2PSocketDispatcher::OnSendComplete(int socket_id) { |
+ P2PSocketClient* client = GetClient(socket_id); |
+ if (client) { |
+ client->OnSendComplete(); |
+ } |
+} |
+ |
void P2PSocketDispatcher::OnError(int socket_id) { |
P2PSocketClient* client = GetClient(socket_id); |
if (client) { |