| Index: net/tools/quic/quic_simple_client.cc
|
| diff --git a/net/tools/quic/quic_simple_client.cc b/net/tools/quic/quic_simple_client.cc
|
| index 141ba60d8bb59bf9069a14127d9f8e51b7789379..d7bb26faed23135c83f5cd5d151bb9746f0365f1 100644
|
| --- a/net/tools/quic/quic_simple_client.cc
|
| +++ b/net/tools/quic/quic_simple_client.cc
|
| @@ -43,11 +43,11 @@ QuicSimpleClient::QuicSimpleClient(
|
| CreateQuicConnectionHelper(),
|
| CreateQuicAlarmFactory(),
|
| std::move(proof_verifier)),
|
| - server_address_(server_address),
|
| - local_port_(0),
|
| initialized_(false),
|
| packet_reader_started_(false),
|
| - weak_factory_(this) {}
|
| + weak_factory_(this) {
|
| + set_server_address(server_address);
|
| +}
|
|
|
| QuicSimpleClient::QuicSimpleClient(
|
| IPEndPoint server_address,
|
| @@ -61,11 +61,11 @@ QuicSimpleClient::QuicSimpleClient(
|
| CreateQuicConnectionHelper(),
|
| CreateQuicAlarmFactory(),
|
| std::move(proof_verifier)),
|
| - server_address_(server_address),
|
| - local_port_(0),
|
| initialized_(false),
|
| packet_reader_started_(false),
|
| - weak_factory_(this) {}
|
| + weak_factory_(this) {
|
| + set_server_address(server_address);
|
| +}
|
|
|
| QuicSimpleClient::~QuicSimpleClient() {
|
| if (connected()) {
|
| @@ -93,16 +93,16 @@ bool QuicSimpleClient::CreateUDPSocket() {
|
| new UDPClientSocket(DatagramSocket::DEFAULT_BIND, RandIntCallback(),
|
| &net_log_, NetLog::Source()));
|
|
|
| - int address_family = server_address_.GetSockAddrFamily();
|
| - if (bind_to_address_.size() != 0) {
|
| - client_address_ = IPEndPoint(bind_to_address_, local_port_);
|
| + int address_family = server_address().GetSockAddrFamily();
|
| + if (bind_to_address().size() != 0) {
|
| + client_address_ = IPEndPoint(bind_to_address(), local_port());
|
| } else if (address_family == AF_INET) {
|
| - client_address_ = IPEndPoint(IPAddress::IPv4AllZeros(), local_port_);
|
| + client_address_ = IPEndPoint(IPAddress::IPv4AllZeros(), local_port());
|
| } else {
|
| - client_address_ = IPEndPoint(IPAddress::IPv6AllZeros(), local_port_);
|
| + client_address_ = IPEndPoint(IPAddress::IPv6AllZeros(), local_port());
|
| }
|
|
|
| - int rc = socket->Connect(server_address_);
|
| + int rc = socket->Connect(server_address());
|
| if (rc != OK) {
|
| LOG(ERROR) << "Connect failed: " << ErrorToShortString(rc);
|
| return false;
|
| @@ -195,7 +195,7 @@ void QuicSimpleClient::StartConnect() {
|
| }
|
|
|
| CreateQuicClientSession(new QuicConnection(
|
| - GetNextConnectionId(), server_address_, helper(), alarm_factory(),
|
| + GetNextConnectionId(), server_address(), helper(), alarm_factory(),
|
| writer(),
|
| /* owns_writer= */ false, Perspective::IS_CLIENT, supported_versions()));
|
|
|
| @@ -293,7 +293,7 @@ bool QuicSimpleClient::MigrateSocket(const IPAddress& new_host) {
|
| return false;
|
| }
|
|
|
| - bind_to_address_ = new_host;
|
| + set_bind_to_address(new_host);
|
| if (!CreateUDPSocket()) {
|
| return false;
|
| }
|
| @@ -307,40 +307,6 @@ bool QuicSimpleClient::MigrateSocket(const IPAddress& new_host) {
|
| return true;
|
| }
|
|
|
| -void QuicSimpleClient::OnClose(QuicSpdyStream* stream) {
|
| - DCHECK(stream != nullptr);
|
| - QuicSpdyClientStream* client_stream =
|
| - static_cast<QuicSpdyClientStream*>(stream);
|
| - HttpResponseInfo response;
|
| - SpdyHeadersToHttpResponse(client_stream->response_headers(), &response);
|
| - if (response_listener_.get() != nullptr) {
|
| - response_listener_->OnCompleteResponse(stream->id(), *response.headers,
|
| - client_stream->data());
|
| - }
|
| -
|
| - // Store response headers and body.
|
| - if (store_response_) {
|
| - latest_response_code_ = client_stream->response_code();
|
| - response.headers->GetNormalizedHeaders(&latest_response_headers_);
|
| - latest_response_body_ = client_stream->data();
|
| - }
|
| -}
|
| -
|
| -size_t QuicSimpleClient::latest_response_code() const {
|
| - LOG_IF(DFATAL, !store_response_) << "Response not stored!";
|
| - return latest_response_code_;
|
| -}
|
| -
|
| -const string& QuicSimpleClient::latest_response_headers() const {
|
| - LOG_IF(DFATAL, !store_response_) << "Response not stored!";
|
| - return latest_response_headers_;
|
| -}
|
| -
|
| -const string& QuicSimpleClient::latest_response_body() const {
|
| - LOG_IF(DFATAL, !store_response_) << "Response not stored!";
|
| - return latest_response_body_;
|
| -}
|
| -
|
| QuicConnectionId QuicSimpleClient::GenerateNewConnectionId() {
|
| return helper()->GetRandomGenerator()->RandUint64();
|
| }
|
|
|