| Index: content/renderer/p2p/socket_client.cc
|
| diff --git a/content/renderer/p2p/socket_client.cc b/content/renderer/p2p/socket_client.cc
|
| index 68797db66cc3451f91d084789d2e3257508cc9f3..6d559619f6b12911214cf2ab98c236652e5e9f97 100644
|
| --- a/content/renderer/p2p/socket_client.cc
|
| +++ b/content/renderer/p2p/socket_client.cc
|
| @@ -48,8 +48,10 @@ void P2PSocketClient::DoInit(P2PSocketType type,
|
| type, socket_id_, local_address, remote_address));
|
| }
|
|
|
| -void P2PSocketClient::Send(const net::IPEndPoint& address,
|
| - const std::vector<char>& data) {
|
| +void P2PSocketClient::SendWithDscp(
|
| + const net::IPEndPoint& address,
|
| + const std::vector<char>& data,
|
| + net::DiffServCodePoint dscp) {
|
| if (!ipc_message_loop_->BelongsToCurrentThread()) {
|
| ipc_message_loop_->PostTask(
|
| FROM_HERE, base::Bind(&P2PSocketClient::Send, this, address, data));
|
| @@ -59,10 +61,16 @@ void P2PSocketClient::Send(const net::IPEndPoint& address,
|
| // Can send data only when the socket is open.
|
| DCHECK(state_ == STATE_OPEN || state_ == STATE_ERROR);
|
| if (state_ == STATE_OPEN) {
|
| - dispatcher_->SendP2PMessage(new P2PHostMsg_Send(socket_id_, address, data));
|
| + dispatcher_->SendP2PMessage(
|
| + new P2PHostMsg_Send(socket_id_, address, data, dscp));
|
| }
|
| }
|
|
|
| +void P2PSocketClient::Send(const net::IPEndPoint& address,
|
| + const std::vector<char>& data) {
|
| + SendWithDscp(address, data, net::DSCP_NO_CHANGE);
|
| +}
|
| +
|
| void P2PSocketClient::Close() {
|
| DCHECK(delegate_message_loop_->BelongsToCurrentThread());
|
|
|
|
|