overflow_supported_(false),
supported_versions_(supported_versions),
print_response_(print_response) {
- config_.SetDefaults();
}
QuicClient::QuicClient(IPEndPoint server_address,
DCHECK(!initialized_);
epoll_server_->set_timeout_in_us(50 * 1000);
- crypto_config_.SetDefaults();
if (!CreateUDPSocket()) {
return false;
factory,
/* owns_writer= */ false,
/* is_server= */ false,
- supported_versions_)));
+ supported_versions_),
+ server_id_.is_https()));
// Reset |writer_| after |session_| so that the old writer outlives the old
// session.
BalsaHeaders headers;
headers.SetRequestFirstlineFromStringPieces("GET", args[i], "HTTP/1.1");
QuicSpdyClientStream* stream = CreateReliableClientStream();
- DCHECK(stream != NULL);
+ DCHECK(stream != nullptr);
stream->SendRequest(headers, "", true);
stream->set_visitor(this);
}
QuicSpdyClientStream* QuicClient::CreateReliableClientStream() {
if (!connected()) {
- return NULL;
+ return nullptr;
}
return session_->CreateOutgoingDataStream();
void QuicClient::OnClose(QuicDataStream* stream) {
QuicSpdyClientStream* client_stream =
static_cast<QuicSpdyClientStream*>(stream);
- if (response_listener_.get() != NULL) {
+ if (response_listener_.get() != nullptr) {
response_listener_->OnCompleteResponse(
stream->id(), client_stream->headers(), client_stream->data());
}
IPEndPoint* server_address,
IPAddressNumber* client_ip) {
return QuicSocketUtils::ReadPacket(
- fd_, buffer, buffer_len, overflow_supported_ ? &packets_dropped_ : NULL,
- client_ip, server_address);
+ fd_, buffer, buffer_len,
+ overflow_supported_ ? &packets_dropped_ : nullptr, client_ip,
+ server_address);
}
bool QuicClient::ReadAndProcessPacket() {