| Index: components/certificate_transparency/mock_log_dns_traffic.cc
|
| diff --git a/components/certificate_transparency/mock_log_dns_traffic.cc b/components/certificate_transparency/mock_log_dns_traffic.cc
|
| index 303d8492dda69e8de00494c25947d9410b44ef13..22599950dd70a1df0a034adf0d6e230f73dd162b 100644
|
| --- a/components/certificate_transparency/mock_log_dns_traffic.cc
|
| +++ b/components/certificate_transparency/mock_log_dns_traffic.cc
|
| @@ -23,10 +23,6 @@
|
|
|
| namespace {
|
|
|
| -// This is used for the last mock socket response as a sentinel to prevent
|
| -// trying to read more data than expected.
|
| -const net::MockRead kNoMoreData(net::SYNCHRONOUS, net::ERR_UNEXPECTED, 2);
|
| -
|
| // Necessary to expose SetDnsConfig for testing.
|
| class DnsChangeNotifier : public net::NetworkChangeNotifier {
|
| public:
|
| @@ -47,7 +43,7 @@
|
|
|
| std::vector<char> CreateDnsTxtRequest(base::StringPiece qname) {
|
| std::string encoded_qname;
|
| - DCHECK(net::DNSDomainFromDot(qname, &encoded_qname));
|
| + EXPECT_TRUE(net::DNSDomainFromDot(qname, &encoded_qname));
|
|
|
| // DNS query section:
|
| // N bytes - qname
|
| @@ -64,12 +60,12 @@
|
| net::dns_protocol::Header header = {};
|
| header.flags = base::HostToNet16(net::dns_protocol::kFlagRD);
|
| header.qdcount = base::HostToNet16(1);
|
| - DCHECK(writer.WriteBytes(&header, sizeof(header)));
|
| + EXPECT_TRUE(writer.WriteBytes(&header, sizeof(header)));
|
| // Query section
|
| - DCHECK(writer.WriteBytes(encoded_qname.data(), encoded_qname.size()));
|
| - DCHECK(writer.WriteU16(net::dns_protocol::kTypeTXT));
|
| - DCHECK(writer.WriteU16(net::dns_protocol::kClassIN));
|
| - DCHECK_EQ(0, writer.remaining());
|
| + EXPECT_TRUE(writer.WriteBytes(encoded_qname.data(), encoded_qname.size()));
|
| + EXPECT_TRUE(writer.WriteU16(net::dns_protocol::kTypeTXT));
|
| + EXPECT_TRUE(writer.WriteU16(net::dns_protocol::kClassIN));
|
| + EXPECT_EQ(0, writer.remaining());
|
|
|
| return request;
|
| }
|
| @@ -98,15 +94,15 @@
|
| // Write the answer section
|
| base::BigEndianWriter writer(response.data() + request.size(),
|
| response.size() - request.size());
|
| - DCHECK(writer.WriteU8(0xc0)); // qname is a pointer
|
| - DCHECK(writer.WriteU8(
|
| + EXPECT_TRUE(writer.WriteU8(0xc0)); // qname is a pointer
|
| + EXPECT_TRUE(writer.WriteU8(
|
| sizeof(*header))); // address of qname (start of query section)
|
| - DCHECK(writer.WriteU16(net::dns_protocol::kTypeTXT));
|
| - DCHECK(writer.WriteU16(net::dns_protocol::kClassIN));
|
| - DCHECK(writer.WriteU32(ttl));
|
| - DCHECK(writer.WriteU16(answer.size()));
|
| - DCHECK(writer.WriteBytes(answer.data(), answer.size()));
|
| - DCHECK_EQ(0, writer.remaining());
|
| + EXPECT_TRUE(writer.WriteU16(net::dns_protocol::kTypeTXT));
|
| + EXPECT_TRUE(writer.WriteU16(net::dns_protocol::kClassIN));
|
| + EXPECT_TRUE(writer.WriteU32(ttl));
|
| + EXPECT_TRUE(writer.WriteU16(answer.size()));
|
| + EXPECT_TRUE(writer.WriteBytes(answer.data(), answer.size()));
|
| + EXPECT_EQ(0, writer.remaining());
|
|
|
| return response;
|
| }
|
| @@ -125,81 +121,56 @@
|
|
|
| } // namespace
|
|
|
| -// A container for all of the data needed for simulating a socket.
|
| -// This is useful because Mock{Read,Write}, SequencedSocketData and
|
| -// MockClientSocketFactory all do not take ownership of or copy their arguments,
|
| -// so it is necessary to manage the lifetime of those arguments. Wrapping all
|
| -// of that up in a single class simplifies this.
|
| -class MockLogDnsTraffic::MockSocketData {
|
| - public:
|
| - // A socket that expects one write and one read operation.
|
| - MockSocketData(const std::vector<char>& write, const std::vector<char>& read)
|
| - : expected_write_payload_(write),
|
| - expected_read_payload_(read),
|
| - expected_write_(net::SYNCHRONOUS,
|
| - expected_write_payload_.data(),
|
| - expected_write_payload_.size(),
|
| - 0),
|
| - expected_reads_{net::MockRead(net::ASYNC,
|
| - expected_read_payload_.data(),
|
| - expected_read_payload_.size(),
|
| - 1),
|
| - kNoMoreData},
|
| - socket_data_(expected_reads_, 2, &expected_write_, 1) {}
|
| -
|
| - // A socket that expects one write and a read error.
|
| - MockSocketData(const std::vector<char>& write, net::Error error)
|
| - : expected_write_payload_(write),
|
| - expected_write_(net::SYNCHRONOUS,
|
| - expected_write_payload_.data(),
|
| - expected_write_payload_.size(),
|
| - 0),
|
| - expected_reads_{net::MockRead(net::ASYNC, error, 1), kNoMoreData},
|
| - socket_data_(expected_reads_, 2, &expected_write_, 1) {}
|
| -
|
| - // A socket that expects one write and no response.
|
| - explicit MockSocketData(const std::vector<char>& write)
|
| - : expected_write_payload_(write),
|
| - expected_write_(net::SYNCHRONOUS,
|
| - expected_write_payload_.data(),
|
| - expected_write_payload_.size(),
|
| - 0),
|
| - expected_reads_{net::MockRead(net::SYNCHRONOUS, net::ERR_IO_PENDING, 1),
|
| - kNoMoreData},
|
| - socket_data_(expected_reads_, 2, &expected_write_, 1) {}
|
| -
|
| - ~MockSocketData() {}
|
| -
|
| - void SetWriteMode(net::IoMode mode) { expected_write_.mode = mode; }
|
| - void SetReadMode(net::IoMode mode) { expected_reads_[0].mode = mode; }
|
| -
|
| - void AddToFactory(net::MockClientSocketFactory* socket_factory) {
|
| - socket_factory->AddSocketDataProvider(&socket_data_);
|
| - }
|
| -
|
| - private:
|
| - // This class only supports one write and one read, so just need to store one
|
| - // payload each.
|
| - const std::vector<char> expected_write_payload_;
|
| - const std::vector<char> expected_read_payload_;
|
| -
|
| - // Encapsulates the data that is expected to be written to a socket.
|
| - net::MockWrite expected_write_;
|
| -
|
| - // Encapsulates the data/error that should be returned when reading from a
|
| - // socket. The second "expected" read is a sentinel that causes socket reads
|
| - // beyond the first to hang until they timeout. This results in better
|
| - // test failure messages (rather than a CHECK-fail due to a socket read
|
| - // overrunning the MockRead array) and behaviour more like a real socket when
|
| - // an unexpected second socket read occurs.
|
| - net::MockRead expected_reads_[2];
|
| -
|
| - // Holds pointers to |expected_write_| and |expected_reads_|. This is what is
|
| - // added to net::MockClientSocketFactory to prepare a mock socket.
|
| - net::SequencedSocketData socket_data_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(MockSocketData);
|
| -};
|
| +namespace internal {
|
| +
|
| +MockSocketData::MockSocketData(const std::vector<char>& write,
|
| + const std::vector<char>& read)
|
| + : expected_write_payload_(write),
|
| + expected_read_payload_(read),
|
| + expected_write_(net::SYNCHRONOUS,
|
| + expected_write_payload_.data(),
|
| + expected_write_payload_.size(),
|
| + 0),
|
| + expected_reads_{net::MockRead(net::ASYNC,
|
| + expected_read_payload_.data(),
|
| + expected_read_payload_.size(),
|
| + 1),
|
| + no_more_data_},
|
| + socket_data_(expected_reads_, 2, &expected_write_, 1) {}
|
| +
|
| +MockSocketData::MockSocketData(const std::vector<char>& write, int net_error)
|
| + : expected_write_payload_(write),
|
| + expected_write_(net::SYNCHRONOUS,
|
| + expected_write_payload_.data(),
|
| + expected_write_payload_.size(),
|
| + 0),
|
| + expected_reads_{net::MockRead(net::ASYNC, net_error, 1), no_more_data_},
|
| + socket_data_(expected_reads_, 2, &expected_write_, 1) {}
|
| +
|
| +MockSocketData::MockSocketData(const std::vector<char>& write)
|
| + : expected_write_payload_(write),
|
| + expected_write_(net::SYNCHRONOUS,
|
| + expected_write_payload_.data(),
|
| + expected_write_payload_.size(),
|
| + 0),
|
| + expected_reads_{net::MockRead(net::SYNCHRONOUS, net::ERR_IO_PENDING, 1),
|
| + no_more_data_},
|
| + socket_data_(expected_reads_, 2, &expected_write_, 1) {}
|
| +
|
| +MockSocketData::~MockSocketData() {}
|
| +
|
| +void MockSocketData::AddToFactory(
|
| + net::MockClientSocketFactory* socket_factory) {
|
| + socket_factory->AddSocketDataProvider(&socket_data_);
|
| +}
|
| +
|
| +const net::MockRead MockSocketData::no_more_data_(net::SYNCHRONOUS,
|
| + net::ERR_IO_PENDING,
|
| + 2);
|
| +
|
| +} // namespace internal
|
| +
|
| +using internal::MockSocketData;
|
|
|
| MockLogDnsTraffic::MockLogDnsTraffic() : socket_read_mode_(net::ASYNC) {}
|
|
|
| @@ -213,8 +184,8 @@
|
| }
|
|
|
| void MockLogDnsTraffic::ExpectRequestAndSocketError(base::StringPiece qname,
|
| - net::Error error) {
|
| - EmplaceMockSocketData(CreateDnsTxtRequest(qname), error);
|
| + int net_error) {
|
| + EmplaceMockSocketData(CreateDnsTxtRequest(qname), net_error);
|
| }
|
|
|
| void MockLogDnsTraffic::ExpectRequestAndTimeout(base::StringPiece qname) {
|
|
|