blob: 6a6cc5066d7966f5fde1f2a64d4e0e25a7147a1d (
plain)
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
|
// Copyright 2015 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 "blimp/net/tcp_client_transport.h"
#include "base/callback.h"
#include "base/callback_helpers.h"
#include "base/memory/scoped_ptr.h"
#include "base/message_loop/message_loop.h"
#include "blimp/net/stream_socket_connection.h"
#include "net/socket/client_socket_factory.h"
#include "net/socket/stream_socket.h"
#include "net/socket/tcp_client_socket.h"
namespace blimp {
TCPClientTransport::TCPClientTransport(const net::IPEndPoint& ip_endpoint,
net::NetLog* net_log)
: ip_endpoint_(ip_endpoint),
net_log_(net_log),
socket_factory_(net::ClientSocketFactory::GetDefaultFactory()) {}
TCPClientTransport::~TCPClientTransport() {}
void TCPClientTransport::SetClientSocketFactoryForTest(
net::ClientSocketFactory* factory) {
DCHECK(factory);
socket_factory_ = factory;
}
void TCPClientTransport::Connect(const net::CompletionCallback& callback) {
DCHECK(!socket_);
DCHECK(!callback.is_null());
connect_callback_ = callback;
socket_ = socket_factory_->CreateTransportClientSocket(
net::AddressList(ip_endpoint_), net_log_, net::NetLog::Source());
net::CompletionCallback completion_callback = base::Bind(
&TCPClientTransport::OnTCPConnectComplete, base::Unretained(this));
int result = socket_->Connect(completion_callback);
if (result == net::ERR_IO_PENDING) {
return;
}
OnTCPConnectComplete(result);
}
scoped_ptr<BlimpConnection> TCPClientTransport::TakeConnection() {
DCHECK(connect_callback_.is_null());
DCHECK(socket_);
return make_scoped_ptr(new StreamSocketConnection(std::move(socket_)));
}
const char* TCPClientTransport::GetName() const {
return "TCP";
}
void TCPClientTransport::OnTCPConnectComplete(int result) {
DCHECK_NE(net::ERR_IO_PENDING, result);
OnConnectComplete(result);
}
void TCPClientTransport::OnConnectComplete(int result) {
if (result != net::OK) {
socket_ = nullptr;
}
base::ResetAndReturn(&connect_callback_).Run(result);
}
scoped_ptr<net::StreamSocket> TCPClientTransport::TakeSocket() {
return std::move(socket_);
}
void TCPClientTransport::SetSocket(scoped_ptr<net::StreamSocket> socket) {
DCHECK(socket);
socket_ = std::move(socket);
}
net::ClientSocketFactory* TCPClientTransport::socket_factory() const {
return socket_factory_;
}
} // namespace blimp
|
