mirror/naiveproxy
1
0
Fork 0
mirror of https://github.com/klzgrad/naiveproxy.git synced 2024-11-28 00:06:09 +03:00
Code Issues Projects Releases Wiki Activity

Fix DCHECK from malformed query in redirect resolver

Browse Source
This commit is contained in:
klzgrad 2023-01-07 12:38:54 +08:00
parent e30e3cb457
commit 9d972a87da
1 changed files with 24 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/net/tools/naive/redirect_resolver.cc
View File

@ -98,15 +98,23 @@ int RedirectResolver::HandleReadResult(int result) {
return ERR_INVALID_ARGUMENT; return ERR_INVALID_ARGUMENT;
} }
int size; auto name_or = DnsDomainToString(query.qname());
if (query.qtype() == dns_protocol::kTypeA) { DnsResponse response;
absl::optional<DnsQuery> query_opt;
query_opt.emplace(query.id(), query.qname(), query.qtype());
if (!name_or || !IsValidDNSDomain(name_or.value())) {
response =
DnsResponse(query.id(), /*is_authoritative=*/false, /*answers=*/{},
/*authority_records=*/{}, /*additional_records=*/{},
query_opt, dns_protocol::kRcodeFORMERR);
} else if (query.qtype() != dns_protocol::kTypeA) {
response =
DnsResponse(query.id(), /*is_authoritative=*/false, /*answers=*/{},
/*authority_records=*/{}, /*additional_records=*/{},
query_opt, dns_protocol::kRcodeNOTIMP);
} else {
Resolution res; Resolution res;
auto name_or = DnsDomainToString(query.qname());
if (!name_or) {
LOG(INFO) << "Malformed DNS query from " << recv_address_.ToString();
return ERR_INVALID_ARGUMENT;
}
const auto& name = name_or.value(); const auto& name = name_or.value();
auto by_name_lookup = resolution_by_name_.emplace(name, resolutions_.end()); auto by_name_lookup = resolution_by_name_.emplace(name, resolutions_.end());
@ -196,29 +204,16 @@ int RedirectResolver::HandleReadResult(int result) {
uint32_t addr = by_name->second->addr; uint32_t addr = by_name->second->addr;
record.SetOwnedRdata(IPAddressToPackedString( record.SetOwnedRdata(IPAddressToPackedString(
IPAddress(addr >> 24, addr >> 16, addr >> 8, addr))); IPAddress(addr >> 24, addr >> 16, addr >> 8, addr)));
absl::optional<DnsQuery> query_opt; response = DnsResponse(query.id(), /*is_authoritative=*/false,
query_opt.emplace(query.id(), query.qname(), query.qtype());
DnsResponse response(query.id(), /*is_authoritative=*/false,
/*answers=*/{std::move(record)}, /*answers=*/{std::move(record)},
/*authority_records=*/{}, /*additional_records=*/{}, /*authority_records=*/{}, /*additional_records=*/{},
query_opt); query_opt);
size = response.io_buffer_size(); }
int size = response.io_buffer_size();
if (size > buffer_->size() || !response.io_buffer()) { if (size > buffer_->size() || !response.io_buffer()) {
return ERR_NO_BUFFER_SPACE; return ERR_NO_BUFFER_SPACE;
} }
std::memcpy(buffer_->data(), response.io_buffer()->data(), size); std::memcpy(buffer_->data(), response.io_buffer()->data(), size);
} else {
absl::optional<DnsQuery> query_opt;
query_opt.emplace(query.id(), query.qname(), query.qtype());
DnsResponse response(query.id(), /*is_authoritative=*/false, /*answers=*/{},
/*authority_records=*/{}, /*additional_records=*/{},
query_opt, dns_protocol::kRcodeSERVFAIL);
size = response.io_buffer_size();
if (size > buffer_->size() || !response.io_buffer()) {
return ERR_NO_BUFFER_SPACE;
}
std::memcpy(buffer_->data(), response.io_buffer()->data(), size);
}
return socket_->SendTo( return socket_->SendTo(
buffer_.get(), size, recv_address_, buffer_.get(), size, recv_address_,