1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "remoting/protocol/pseudotcp_channel_factory.h"
#include "base/bind.h"
#include "net/base/net_errors.h"
#include "remoting/base/constants.h"
#include "remoting/protocol/datagram_channel_factory.h"
#include "remoting/protocol/p2p_datagram_socket.h"
#include "remoting/protocol/pseudotcp_adapter.h"
namespace remoting {
namespace protocol {
namespace {
// Value is chosen to balance the extra latency against the reduced
// load due to ACK traffic.
const int kTcpAckDelayMilliseconds = 10;
// Values for the TCP send and receive buffer size. This should be tuned to
// accommodate high latency network but not backlog the decoding pipeline.
const int kTcpReceiveBufferSize = 256 * 1024;
const int kTcpSendBufferSize = kTcpReceiveBufferSize + 30 * 1024;
} // namespace
PseudoTcpChannelFactory::PseudoTcpChannelFactory(
DatagramChannelFactory* datagram_channel_factory)
: datagram_channel_factory_(datagram_channel_factory) {
}
PseudoTcpChannelFactory::~PseudoTcpChannelFactory() {
// CancelChannelCreation() is expected to be called before destruction.
DCHECK(pending_sockets_.empty());
}
void PseudoTcpChannelFactory::CreateChannel(
const std::string& name,
const ChannelCreatedCallback& callback) {
datagram_channel_factory_->CreateChannel(
name,
base::Bind(&PseudoTcpChannelFactory::OnDatagramChannelCreated,
base::Unretained(this), name, callback));
}
void PseudoTcpChannelFactory::CancelChannelCreation(const std::string& name) {
PendingSocketsMap::iterator it = pending_sockets_.find(name);
if (it == pending_sockets_.end()) {
datagram_channel_factory_->CancelChannelCreation(name);
} else {
delete it->second;
pending_sockets_.erase(it);
}
}
void PseudoTcpChannelFactory::OnDatagramChannelCreated(
const std::string& name,
const ChannelCreatedCallback& callback,
scoped_ptr<P2PDatagramSocket> datagram_socket) {
PseudoTcpAdapter* adapter = new PseudoTcpAdapter(datagram_socket.Pass());
pending_sockets_[name] = adapter;
adapter->SetSendBufferSize(kTcpSendBufferSize);
adapter->SetReceiveBufferSize(kTcpReceiveBufferSize);
adapter->SetNoDelay(true);
adapter->SetAckDelay(kTcpAckDelayMilliseconds);
// TODO(sergeyu): This is a hack to improve latency of the video channel.
// Consider removing it once we have better flow control implemented.
if (name == kVideoChannelName)
adapter->SetWriteWaitsForSend(true);
int result = adapter->Connect(
base::Bind(&PseudoTcpChannelFactory::OnPseudoTcpConnected,
base::Unretained(this), name, callback));
if (result != net::ERR_IO_PENDING)
OnPseudoTcpConnected(name, callback, result);
}
void PseudoTcpChannelFactory::OnPseudoTcpConnected(
const std::string& name,
const ChannelCreatedCallback& callback,
int result) {
PendingSocketsMap::iterator it = pending_sockets_.find(name);
DCHECK(it != pending_sockets_.end());
scoped_ptr<P2PStreamSocket> socket(it->second);
pending_sockets_.erase(it);
if (result != net::OK)
socket.reset();
callback.Run(socket.Pass());
}
} // namespace protocol
} // namespace remoting
|
