Index: content/renderer/p2p/socket_client.cc |
diff --git a/content/renderer/p2p/socket_client.cc b/content/renderer/p2p/socket_client.cc |
index e6f5a0f2974a364b35a8ebb71e738791cea200b8..ed3f211cc75a1552c51b7aec423b6eb7dd07bf09 100644 |
--- a/content/renderer/p2p/socket_client.cc |
+++ b/content/renderer/p2p/socket_client.cc |
@@ -134,6 +134,19 @@ void P2PSocketClient::DeliverOnIncomingTcpConnection( |
} |
} |
+void P2PSocketClient::OnSendComplete() { |
+ DCHECK(ipc_message_loop_->BelongsToCurrentThread()); |
+ |
+ delegate_message_loop_->PostTask( |
+ FROM_HERE, base::Bind(&P2PSocketClient::DeliverOnSendComplete, this)); |
+} |
+ |
+void P2PSocketClient::DeliverOnSendComplete() { |
+ DCHECK(delegate_message_loop_->BelongsToCurrentThread()); |
+ if (delegate_) |
+ delegate_->OnSendComplete(); |
+} |
+ |
void P2PSocketClient::OnError() { |
DCHECK(ipc_message_loop_->BelongsToCurrentThread()); |
state_ = STATE_ERROR; |