Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "net/dns/fuzzed_host_resolver.h" | |
| 6 | |
| 7 #include <stdint.h> | |
| 8 | |
| 9 #include <limits> | |
| 10 #include <string> | |
| 11 | |
| 12 #include "base/bind.h" | |
| 13 #include "base/logging.h" | |
| 14 #include "base/macros.h" | |
| 15 #include "base/memory/ref_counted.h" | |
| 16 #include "base/single_thread_task_runner.h" | |
| 17 #include "base/threading/thread_task_runner_handle.h" | |
| 18 #include "net/base/address_list.h" | |
| 19 #include "net/base/fuzzed_data_provider.h" | |
| 20 #include "net/base/ip_address.h" | |
| 21 #include "net/base/ip_endpoint.h" | |
| 22 #include "net/base/net_errors.h" | |
| 23 #include "net/dns/dns_client.h" | |
| 24 #include "net/dns/dns_config_service.h" | |
| 25 #include "net/dns/dns_hosts.h" | |
| 26 | |
| 27 namespace net { | |
| 28 | |
| 29 namespace { | |
| 30 | |
| 31 // Returns a fuzzed non-zero port number. | |
| 32 uint16_t FuzzPort(FuzzedDataProvider* data_provider) { | |
| 33 uint16_t port = data_provider->ConsumeUint16(); | |
| 34 // Port 0 is magic. | |
|
eroman
2016/06/01 01:47:21
but shouldn't be
mmenke
2016/06/01 21:21:51
It's a reserved port, so presumably it should be?
eroman
2016/06/01 21:46:06
Sorry I should have been clearer.
My comment was
mmenke
2016/06/01 21:53:28
I've removed the check - I think it was inspired b
mmenke
2016/06/01 21:54:26
Actually, it was inspired by the belief that *conn
| |
| 35 if (port == 0) | |
| 36 return 53; | |
| 37 return port; | |
| 38 } | |
| 39 | |
| 40 // Returns a fuzzed IPv4 address. Can return invalid / reserved addresses. | |
| 41 IPAddress FuzzIPv4Address(FuzzedDataProvider* data_provider) { | |
| 42 return IPAddress(data_provider->ConsumeUint8(), data_provider->ConsumeUint8(), | |
| 43 data_provider->ConsumeUint8(), | |
| 44 data_provider->ConsumeUint8()); | |
| 45 } | |
| 46 | |
| 47 // Returns a fuzzed IPv6 address. Can return invalid / reserved addresses. | |
| 48 IPAddress FuzzIPv6Address(FuzzedDataProvider* data_provider) { | |
| 49 return IPAddress(data_provider->ConsumeUint8(), data_provider->ConsumeUint8(), | |
| 50 data_provider->ConsumeUint8(), data_provider->ConsumeUint8(), | |
| 51 data_provider->ConsumeUint8(), data_provider->ConsumeUint8(), | |
| 52 data_provider->ConsumeUint8(), data_provider->ConsumeUint8(), | |
| 53 data_provider->ConsumeUint8(), data_provider->ConsumeUint8(), | |
| 54 data_provider->ConsumeUint8(), data_provider->ConsumeUint8(), | |
| 55 data_provider->ConsumeUint8(), data_provider->ConsumeUint8(), | |
| 56 data_provider->ConsumeUint8(), | |
| 57 data_provider->ConsumeUint8()); | |
| 58 } | |
| 59 | |
| 60 // Returns a fuzzed address, which can be either IPv4 or IPv6. Can return | |
| 61 // invalid / reserved addresses. | |
| 62 IPAddress FuzzIPAddress(FuzzedDataProvider* data_provider) { | |
| 63 if (data_provider->ConsumeBool()) | |
| 64 return FuzzIPv4Address(data_provider); | |
| 65 return FuzzIPv6Address(data_provider); | |
| 66 } | |
| 67 | |
| 68 // HostResolverProc that returns a random set of results, and can succeed or | |
| 69 // fail. Must only be run on the thread it's created on. | |
| 70 class FuzzedHostResolverProc : public HostResolverProc { | |
| 71 public: | |
| 72 // Can safely be used after the destruction of |data_provider|. This can | |
| 73 // happen if a request is issued but the code never waits for the result | |
| 74 // before the test ends. | |
| 75 explicit FuzzedHostResolverProc( | |
| 76 base::WeakPtr<FuzzedDataProvider> data_provider) | |
| 77 : HostResolverProc(nullptr), | |
| 78 data_provider_(data_provider), | |
| 79 network_task_runner_(base::ThreadTaskRunnerHandle::Get()) {} | |
| 80 | |
| 81 int Resolve(const std::string& host, | |
| 82 AddressFamily address_family, | |
| 83 HostResolverFlags host_resolver_flags, | |
| 84 AddressList* addrlist, | |
| 85 int* os_error) override { | |
| 86 DCHECK(network_task_runner_->BelongsToCurrentThread()); | |
| 87 | |
| 88 if (os_error) | |
| 89 *os_error = 0; | |
| 90 | |
| 91 // If the data provider is no longer avaiable, just fail. The HostResolver | |
| 92 // has already been deleted by this point, anyways. | |
| 93 if (!data_provider_) | |
| 94 return ERR_FAILED; | |
| 95 | |
| 96 AddressList result; | |
| 97 | |
| 98 // Put IPv6 addresses before IPv4 ones. This code doesn't sort addresses | |
| 99 // correctly, but when sorted according to spec, IPv6 addresses are | |
| 100 // generally before IPv4 ones. | |
| 101 if (address_family == ADDRESS_FAMILY_UNSPECIFIED || | |
| 102 address_family == ADDRESS_FAMILY_IPV6) { | |
| 103 uint16_t num_ipv6_addresses = data_provider_->ConsumeUint8(); | |
|
eroman
2016/06/01 01:47:21
nit: any reason to use uint16 here (rather than ui
mmenke
2016/06/01 21:21:51
I initially used uint16_t for number of addresses,
| |
| 104 for (uint16_t i = 0; i < num_ipv6_addresses; ++i) { | |
| 105 result.push_back( | |
| 106 net::IPEndPoint(FuzzIPv6Address(data_provider_.get()), 0)); | |
| 107 } | |
| 108 } | |
| 109 | |
| 110 if (address_family == ADDRESS_FAMILY_UNSPECIFIED || | |
| 111 address_family == ADDRESS_FAMILY_IPV4) { | |
| 112 uint16_t num_ipv4_addresses = data_provider_->ConsumeUint8(); | |
|
eroman
2016/06/01 01:47:21
ditto
mmenke
2016/06/01 21:21:51
Done.
| |
| 113 for (uint16_t i = 0; i < num_ipv4_addresses; ++i) { | |
| 114 result.push_back( | |
| 115 net::IPEndPoint(FuzzIPv4Address(data_provider_.get()), 0)); | |
| 116 } | |
| 117 } | |
| 118 | |
| 119 if (result.empty()) | |
| 120 return ERR_NAME_NOT_RESOLVED; | |
| 121 | |
| 122 if (host_resolver_flags & HOST_RESOLVER_CANONNAME) { | |
| 123 // Don't bother to fuzz this - almost nothing cares. | |
| 124 result.set_canonical_name("foo.com"); | |
| 125 } | |
| 126 | |
| 127 *addrlist = result; | |
| 128 return OK; | |
| 129 } | |
| 130 | |
| 131 private: | |
| 132 ~FuzzedHostResolverProc() override {} | |
| 133 | |
| 134 base::WeakPtr<FuzzedDataProvider> data_provider_; | |
| 135 | |
| 136 // Just used for thread-safety checks. | |
| 137 scoped_refptr<base::SingleThreadTaskRunner> network_task_runner_; | |
| 138 | |
| 139 DISALLOW_COPY_AND_ASSIGN(FuzzedHostResolverProc); | |
| 140 }; | |
| 141 | |
| 142 } // namespace | |
| 143 | |
| 144 FuzzedHostResolver::FuzzedHostResolver(const Options& options, | |
| 145 NetLog* net_log, | |
| 146 FuzzedDataProvider* data_provider) | |
| 147 : HostResolverImpl(options, net_log, base::ThreadTaskRunnerHandle::Get()), | |
| 148 data_provider_(data_provider), | |
| 149 socket_factory_(data_provider), | |
| 150 is_ipv6_reachable_(data_provider->ConsumeBool()), | |
| 151 net_log_(net_log), | |
| 152 data_provider_weak_factory_(data_provider) { | |
| 153 HostResolverImpl::ProcTaskParams proc_task_params( | |
| 154 new FuzzedHostResolverProc(data_provider_weak_factory_.GetWeakPtr()), | |
| 155 // Retries are only used when the original request hangs, which this class | |
| 156 // currently can't simulate. | |
| 157 0 /* max_retry_attempts */); | |
| 158 set_proc_params_for_test(proc_task_params); | |
| 159 } | |
| 160 | |
| 161 FuzzedHostResolver::~FuzzedHostResolver() {} | |
| 162 | |
| 163 void FuzzedHostResolver::SetDnsClientEnabled(bool enabled) { | |
| 164 if (!enabled) { | |
| 165 HostResolverImpl::SetDnsClientEnabled(false); | |
| 166 return; | |
| 167 } | |
| 168 | |
| 169 // Fuzz DNS configuration. | |
| 170 | |
| 171 DnsConfig config; | |
| 172 | |
| 173 // Fuzz name servers. | |
| 174 uint32_t num_nameservers = data_provider_->ConsumeUint32InRange(0, 4); | |
| 175 for (uint32_t i = 0; i < num_nameservers; ++i) { | |
| 176 config.nameservers.push_back( | |
| 177 IPEndPoint(FuzzIPAddress(data_provider_), FuzzPort(data_provider_))); | |
| 178 } | |
| 179 | |
| 180 // Fuzz suffix search list. Each case deliberately falls through. | |
| 181 switch (data_provider_->ConsumeUint32InRange(0, 3)) { | |
| 182 case 3: | |
| 183 config.search.push_back("foo.com"); | |
| 184 case 2: | |
| 185 config.search.push_back("bar"); | |
| 186 case 1: | |
| 187 config.search.push_back("com"); | |
| 188 default: | |
| 189 break; | |
| 190 } | |
| 191 | |
| 192 net::DnsHosts hosts; | |
| 193 // Fuzz hosts file. | |
| 194 uint8_t num_hosts_entries = data_provider_->ConsumeUint8(); | |
| 195 for (uint8_t i = 0; i < num_hosts_entries; ++i) { | |
| 196 const char* kHostnames[] = {"foo", "foo.com", "a.foo.com", | |
| 197 "bar", "localhost", "localhost6"}; | |
| 198 const char* hostname = data_provider_->PickArrayEntry(kHostnames); | |
| 199 net::IPAddress address = FuzzIPAddress(data_provider_); | |
| 200 config.hosts[net::DnsHostsKey(hostname, net::GetAddressFamily(address))] = | |
| 201 address; | |
| 202 } | |
| 203 | |
| 204 config.unhandled_options = data_provider_->ConsumeBool(); | |
| 205 config.append_to_multi_label_name = data_provider_->ConsumeBool(); | |
| 206 config.randomize_ports = data_provider_->ConsumeBool(); | |
| 207 config.ndots = data_provider_->ConsumeInt32InRange(0, 3); | |
| 208 config.attempts = data_provider_->ConsumeInt32InRange(1, 3); | |
| 209 | |
| 210 // Timeouts don't really work for fuzzing. Even a timeout of 0 milliseconds | |
| 211 // will be increased after the first timeout, resulting in inconsistent | |
| 212 // behavior. | |
| 213 config.timeout = base::TimeDelta::FromDays(10); | |
| 214 | |
| 215 config.rotate = data_provider_->ConsumeBool(); | |
| 216 | |
| 217 // Doesn't currently seem to do anything. | |
| 218 config.edns0 = false; | |
| 219 | |
| 220 config.use_local_ipv6 = data_provider_->ConsumeBool(); | |
| 221 | |
| 222 std::unique_ptr<DnsClient> dns_client = DnsClient::CreateClientForTesting( | |
| 223 net_log_, &socket_factory_, | |
| 224 base::Bind(&FuzzedDataProvider::ConsumeInt32InRange, | |
| 225 base::Unretained(data_provider_))); | |
| 226 dns_client->SetConfig(config); | |
| 227 SetDnsClient(std::move(dns_client)); | |
| 228 } | |
| 229 | |
| 230 bool FuzzedHostResolver::IsIPv6Reachable(const BoundNetLog& net_log) { | |
| 231 return is_ipv6_reachable_; | |
| 232 } | |
| 233 | |
| 234 void FuzzedHostResolver::RunLoopbackProbeJob() { | |
| 235 SetHaveOnlyLoopbackAddresses(data_provider_->ConsumeBool()); | |
| 236 } | |
| 237 | |
| 238 } // namespace net | |
| OLD | NEW |