Index: chrome/browser/safe_browsing/prefix_set_unittest.cc |
diff --git a/chrome/browser/safe_browsing/prefix_set_unittest.cc b/chrome/browser/safe_browsing/prefix_set_unittest.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..c858e3bf9e5a4949fb0653783056b78d90a0c98b |
--- /dev/null |
+++ b/chrome/browser/safe_browsing/prefix_set_unittest.cc |
@@ -0,0 +1,726 @@ |
+// Copyright (c) 2012 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+#include "chrome/browser/safe_browsing/prefix_set.h" |
+ |
+#include <algorithm> |
+#include <iterator> |
+#include <set> |
+#include <string> |
+ |
+#include "base/files/file_util.h" |
+#include "base/files/scoped_file.h" |
+#include "base/files/scoped_temp_dir.h" |
+#include "base/logging.h" |
+#include "base/md5.h" |
+#include "base/memory/scoped_ptr.h" |
+#include "base/path_service.h" |
+#include "base/rand_util.h" |
+#include "base/strings/string_number_conversions.h" |
+#include "base/strings/string_util.h" |
+#include "chrome/common/chrome_paths.h" |
+#include "testing/gtest/include/gtest/gtest.h" |
+#include "testing/platform_test.h" |
+ |
+namespace { |
+ |
+const SBPrefix kHighBitClear = 1000u * 1000u * 1000u; |
+const SBPrefix kHighBitSet = 3u * 1000u * 1000u * 1000u; |
+ |
+} // namespace |
+ |
+namespace safe_browsing { |
+ |
+class PrefixSetTest : public PlatformTest { |
+ protected: |
+ // Constants for the v1 format. |
+ static const size_t kMagicOffset = 0 * sizeof(uint32); |
+ static const size_t kVersionOffset = 1 * sizeof(uint32); |
+ static const size_t kIndexSizeOffset = 2 * sizeof(uint32); |
+ static const size_t kDeltasSizeOffset = 3 * sizeof(uint32); |
+ static const size_t kFullHashesSizeOffset = 4 * sizeof(uint32); |
+ static const size_t kPayloadOffset = 5 * sizeof(uint32); |
+ |
+ // Generate a set of random prefixes to share between tests. For |
+ // most tests this generation was a large fraction of the test time. |
+ // |
+ // The set should contain sparse areas where adjacent items are more |
+ // than 2^16 apart, and dense areas where adjacent items are less |
+ // than 2^16 apart. |
+ static void SetUpTestCase() { |
+ // Distribute clusters of prefixes. |
+ for (size_t i = 0; i < 250; ++i) { |
+ // Unsigned for overflow characteristics. |
+ const uint32 base = static_cast<uint32>(base::RandUint64()); |
+ for (size_t j = 0; j < 10; ++j) { |
+ const uint32 delta = static_cast<uint32>(base::RandUint64() & 0xFFFF); |
+ const SBPrefix prefix = static_cast<SBPrefix>(base + delta); |
+ shared_prefixes_.push_back(prefix); |
+ } |
+ } |
+ |
+ // Lay down a sparsely-distributed layer. |
+ const size_t count = shared_prefixes_.size(); |
+ for (size_t i = 0; i < count; ++i) { |
+ const SBPrefix prefix = static_cast<SBPrefix>(base::RandUint64()); |
+ shared_prefixes_.push_back(prefix); |
+ } |
+ |
+ // Sort for use with PrefixSet constructor. |
+ std::sort(shared_prefixes_.begin(), shared_prefixes_.end()); |
+ } |
+ |
+ // Check that all elements of |prefixes| are in |prefix_set|, and |
+ // that nearby elements are not (for lack of a more sensible set of |
+ // items to check for absence). |
+ static void CheckPrefixes(const PrefixSet& prefix_set, |
+ const std::vector<SBPrefix> &prefixes) { |
+ // The set can generate the prefixes it believes it has, so that's |
+ // a good starting point. |
+ std::set<SBPrefix> check(prefixes.begin(), prefixes.end()); |
+ std::vector<SBPrefix> prefixes_copy; |
+ prefix_set.GetPrefixes(&prefixes_copy); |
+ EXPECT_EQ(prefixes_copy.size(), check.size()); |
+ EXPECT_TRUE(std::equal(check.begin(), check.end(), prefixes_copy.begin())); |
+ |
+ for (size_t i = 0; i < prefixes.size(); ++i) { |
+ EXPECT_TRUE(prefix_set.PrefixExists(prefixes[i])); |
+ |
+ const SBPrefix left_sibling = prefixes[i] - 1; |
+ if (check.count(left_sibling) == 0) |
+ EXPECT_FALSE(prefix_set.PrefixExists(left_sibling)); |
+ |
+ const SBPrefix right_sibling = prefixes[i] + 1; |
+ if (check.count(right_sibling) == 0) |
+ EXPECT_FALSE(prefix_set.PrefixExists(right_sibling)); |
+ } |
+ } |
+ |
+ // Generate a |PrefixSet| file from |shared_prefixes_|, store it in |
+ // a temporary file, and return the filename in |filenamep|. |
+ // Returns |true| on success. |
+ bool GetPrefixSetFile(base::FilePath* filenamep) { |
+ if (!temp_dir_.IsValid() && !temp_dir_.CreateUniqueTempDir()) |
+ return false; |
+ |
+ base::FilePath filename = temp_dir_.path().AppendASCII("PrefixSetTest"); |
+ |
+ PrefixSetBuilder builder(shared_prefixes_); |
+ if (!builder.GetPrefixSetNoHashes()->WriteFile(filename)) |
+ return false; |
+ |
+ *filenamep = filename; |
+ return true; |
+ } |
+ |
+ // Helper function to read the uint32 value at |offset|, increment it |
+ // by |inc|, and write it back in place. |fp| should be opened in |
+ // r+ mode. |
+ static void IncrementIntAt(FILE* fp, long offset, int inc) { |
+ uint32 value = 0; |
+ |
+ ASSERT_NE(-1, fseek(fp, offset, SEEK_SET)); |
+ ASSERT_EQ(1U, fread(&value, sizeof(value), 1, fp)); |
+ |
+ value += inc; |
+ |
+ ASSERT_NE(-1, fseek(fp, offset, SEEK_SET)); |
+ ASSERT_EQ(1U, fwrite(&value, sizeof(value), 1, fp)); |
+ } |
+ |
+ // Helper function to re-generated |fp|'s checksum to be correct for |
+ // the file's contents. |fp| should be opened in r+ mode. |
+ static void CleanChecksum(FILE* fp) { |
+ base::MD5Context context; |
+ base::MD5Init(&context); |
+ |
+ ASSERT_NE(-1, fseek(fp, 0, SEEK_END)); |
+ long file_size = ftell(fp); |
+ |
+ using base::MD5Digest; |
+ size_t payload_size = static_cast<size_t>(file_size) - sizeof(MD5Digest); |
+ size_t digested_size = 0; |
+ ASSERT_NE(-1, fseek(fp, 0, SEEK_SET)); |
+ while (digested_size < payload_size) { |
+ char buf[1024]; |
+ size_t nitems = std::min(payload_size - digested_size, sizeof(buf)); |
+ ASSERT_EQ(nitems, fread(buf, 1, nitems, fp)); |
+ base::MD5Update(&context, base::StringPiece(buf, nitems)); |
+ digested_size += nitems; |
+ } |
+ ASSERT_EQ(digested_size, payload_size); |
+ ASSERT_EQ(static_cast<long>(digested_size), ftell(fp)); |
+ |
+ base::MD5Digest new_digest; |
+ base::MD5Final(&new_digest, &context); |
+ ASSERT_NE(-1, fseek(fp, digested_size, SEEK_SET)); |
+ ASSERT_EQ(1U, fwrite(&new_digest, sizeof(new_digest), 1, fp)); |
+ ASSERT_EQ(file_size, ftell(fp)); |
+ } |
+ |
+ // Open |filename| and increment the uint32 at |offset| by |inc|. |
+ // Then re-generate the checksum to account for the new contents. |
+ void ModifyAndCleanChecksum(const base::FilePath& filename, long offset, |
+ int inc) { |
+ int64 size_64; |
+ ASSERT_TRUE(base::GetFileSize(filename, &size_64)); |
+ |
+ base::ScopedFILE file(base::OpenFile(filename, "r+b")); |
+ IncrementIntAt(file.get(), offset, inc); |
+ CleanChecksum(file.get()); |
+ file.reset(); |
+ |
+ int64 new_size_64; |
+ ASSERT_TRUE(base::GetFileSize(filename, &new_size_64)); |
+ ASSERT_EQ(new_size_64, size_64); |
+ } |
+ |
+ // Fill |prefixes| with values read from a reference file. The reference file |
+ // was generated from a specific |shared_prefixes_|. |
+ bool ReadReferencePrefixes(std::vector<SBPrefix>* prefixes) { |
+ const char kRefname[] = "PrefixSetRef"; |
+ base::FilePath ref_path; |
+ if (!PathService::Get(chrome::DIR_TEST_DATA, &ref_path)) |
+ return false; |
+ ref_path = ref_path.AppendASCII("SafeBrowsing"); |
+ ref_path = ref_path.AppendASCII(kRefname); |
+ |
+ base::ScopedFILE file(base::OpenFile(ref_path, "r")); |
+ if (!file.get()) |
+ return false; |
+ char buf[1024]; |
+ while (fgets(buf, sizeof(buf), file.get())) { |
+ std::string trimmed; |
+ if (base::TRIM_TRAILING != |
+ base::TrimWhitespace(buf, base::TRIM_ALL, &trimmed)) |
+ return false; |
+ unsigned prefix; |
+ if (!base::StringToUint(trimmed, &prefix)) |
+ return false; |
+ prefixes->push_back(prefix); |
+ } |
+ return true; |
+ } |
+ |
+ // Tests should not modify this shared resource. |
+ static std::vector<SBPrefix> shared_prefixes_; |
+ |
+ base::ScopedTempDir temp_dir_; |
+}; |
+ |
+std::vector<SBPrefix> PrefixSetTest::shared_prefixes_; |
+ |
+// Test that a small sparse random input works. |
+TEST_F(PrefixSetTest, Baseline) { |
+ PrefixSetBuilder builder(shared_prefixes_); |
+ CheckPrefixes(*builder.GetPrefixSetNoHashes(), shared_prefixes_); |
+} |
+ |
+// Test that the empty set doesn't appear to have anything in it. |
+TEST_F(PrefixSetTest, Empty) { |
+ const std::vector<SBPrefix> empty; |
+ PrefixSetBuilder builder(empty); |
+ scoped_ptr<const PrefixSet> prefix_set = builder.GetPrefixSetNoHashes(); |
+ for (size_t i = 0; i < shared_prefixes_.size(); ++i) { |
+ EXPECT_FALSE(prefix_set->PrefixExists(shared_prefixes_[i])); |
+ } |
+} |
+ |
+// Single-element set should work fine. |
+TEST_F(PrefixSetTest, OneElement) { |
+ const std::vector<SBPrefix> prefixes(100, 0u); |
+ PrefixSetBuilder builder(prefixes); |
+ scoped_ptr<const PrefixSet> prefix_set = builder.GetPrefixSetNoHashes(); |
+ EXPECT_FALSE(prefix_set->PrefixExists(static_cast<SBPrefix>(-1))); |
+ EXPECT_TRUE(prefix_set->PrefixExists(prefixes[0])); |
+ EXPECT_FALSE(prefix_set->PrefixExists(1u)); |
+ |
+ // Check that |GetPrefixes()| returns the same set of prefixes as |
+ // was passed in. |
+ std::vector<SBPrefix> prefixes_copy; |
+ prefix_set->GetPrefixes(&prefixes_copy); |
+ EXPECT_EQ(1U, prefixes_copy.size()); |
+ EXPECT_EQ(prefixes[0], prefixes_copy[0]); |
+} |
+ |
+// Edges of the 32-bit integer range. |
+TEST_F(PrefixSetTest, IntMinMax) { |
+ std::vector<SBPrefix> prefixes; |
+ |
+ // Using bit patterns rather than portable constants because this |
+ // really is testing how the entire 32-bit integer range is handled. |
+ prefixes.push_back(0x00000000); |
+ prefixes.push_back(0x0000FFFF); |
+ prefixes.push_back(0x7FFF0000); |
+ prefixes.push_back(0x7FFFFFFF); |
+ prefixes.push_back(0x80000000); |
+ prefixes.push_back(0x8000FFFF); |
+ prefixes.push_back(0xFFFF0000); |
+ prefixes.push_back(0xFFFFFFFF); |
+ |
+ std::sort(prefixes.begin(), prefixes.end()); |
+ PrefixSetBuilder builder(prefixes); |
+ scoped_ptr<const PrefixSet> prefix_set = builder.GetPrefixSetNoHashes(); |
+ |
+ // Check that |GetPrefixes()| returns the same set of prefixes as |
+ // was passed in. |
+ std::vector<SBPrefix> prefixes_copy; |
+ prefix_set->GetPrefixes(&prefixes_copy); |
+ ASSERT_EQ(prefixes_copy.size(), prefixes.size()); |
+ EXPECT_TRUE(std::equal(prefixes.begin(), prefixes.end(), |
+ prefixes_copy.begin())); |
+} |
+ |
+// A range with only large deltas. |
+TEST_F(PrefixSetTest, AllBig) { |
+ std::vector<SBPrefix> prefixes; |
+ |
+ const unsigned kDelta = 10 * 1000 * 1000; |
+ for (SBPrefix prefix = kHighBitClear; |
+ prefix < kHighBitSet; prefix += kDelta) { |
+ prefixes.push_back(prefix); |
+ } |
+ |
+ std::sort(prefixes.begin(), prefixes.end()); |
+ PrefixSetBuilder builder(prefixes); |
+ scoped_ptr<const PrefixSet> prefix_set = builder.GetPrefixSetNoHashes(); |
+ |
+ // Check that |GetPrefixes()| returns the same set of prefixes as |
+ // was passed in. |
+ std::vector<SBPrefix> prefixes_copy; |
+ prefix_set->GetPrefixes(&prefixes_copy); |
+ prefixes.erase(std::unique(prefixes.begin(), prefixes.end()), prefixes.end()); |
+ EXPECT_EQ(prefixes_copy.size(), prefixes.size()); |
+ EXPECT_TRUE(std::equal(prefixes.begin(), prefixes.end(), |
+ prefixes_copy.begin())); |
+} |
+ |
+// Use artificial inputs to test various edge cases in PrefixExists(). Items |
+// before the lowest item aren't present. Items after the largest item aren't |
+// present. Create a sequence of items with deltas above and below 2^16, and |
+// make sure they're all present. Create a very long sequence with deltas below |
+// 2^16 to test crossing |kMaxRun|. |
+TEST_F(PrefixSetTest, EdgeCases) { |
+ std::vector<SBPrefix> prefixes; |
+ |
+ // Put in a high-bit prefix. |
+ SBPrefix prefix = kHighBitSet; |
+ prefixes.push_back(prefix); |
+ |
+ // Add a sequence with very large deltas. |
+ unsigned delta = 100 * 1000 * 1000; |
+ for (int i = 0; i < 10; ++i) { |
+ prefix += delta; |
+ prefixes.push_back(prefix); |
+ } |
+ |
+ // Add a sequence with deltas that start out smaller than the |
+ // maximum delta, and end up larger. Also include some duplicates. |
+ delta = 256 * 256 - 100; |
+ for (int i = 0; i < 200; ++i) { |
+ prefix += delta; |
+ prefixes.push_back(prefix); |
+ prefixes.push_back(prefix); |
+ delta++; |
+ } |
+ |
+ // Add a long sequence with deltas smaller than the maximum delta, |
+ // so a new index item will be injected. |
+ delta = 256 * 256 - 1; |
+ prefix = kHighBitClear - delta * 1000; |
+ prefixes.push_back(prefix); |
+ for (int i = 0; i < 1000; ++i) { |
+ prefix += delta; |
+ prefixes.push_back(prefix); |
+ delta--; |
+ } |
+ |
+ std::sort(prefixes.begin(), prefixes.end()); |
+ PrefixSetBuilder builder(prefixes); |
+ scoped_ptr<const PrefixSet> prefix_set = builder.GetPrefixSetNoHashes(); |
+ |
+ // Check that |GetPrefixes()| returns the same set of prefixes as |
+ // was passed in. |
+ std::vector<SBPrefix> prefixes_copy; |
+ prefix_set->GetPrefixes(&prefixes_copy); |
+ prefixes.erase(std::unique(prefixes.begin(), prefixes.end()), prefixes.end()); |
+ EXPECT_EQ(prefixes_copy.size(), prefixes.size()); |
+ EXPECT_TRUE(std::equal(prefixes.begin(), prefixes.end(), |
+ prefixes_copy.begin())); |
+ |
+ // Items before and after the set are not present, and don't crash. |
+ EXPECT_FALSE(prefix_set->PrefixExists(kHighBitSet - 100)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(kHighBitClear + 100)); |
+ |
+ // Check that the set correctly flags all of the inputs, and also |
+ // check items just above and below the inputs to make sure they |
+ // aren't present. |
+ for (size_t i = 0; i < prefixes.size(); ++i) { |
+ EXPECT_TRUE(prefix_set->PrefixExists(prefixes[i])); |
+ |
+ EXPECT_FALSE(prefix_set->PrefixExists(prefixes[i] - 1)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(prefixes[i] + 1)); |
+ } |
+} |
+ |
+// Test writing a prefix set to disk and reading it back in. |
+TEST_F(PrefixSetTest, ReadWrite) { |
+ base::FilePath filename; |
+ |
+ // Write the sample prefix set out, read it back in, and check all |
+ // the prefixes. Leaves the path in |filename|. |
+ { |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_TRUE(prefix_set.get()); |
+ CheckPrefixes(*prefix_set, shared_prefixes_); |
+ } |
+ |
+ // Test writing and reading a very sparse set containing no deltas. |
+ { |
+ std::vector<SBPrefix> prefixes; |
+ prefixes.push_back(kHighBitClear); |
+ prefixes.push_back(kHighBitSet); |
+ |
+ PrefixSetBuilder builder(prefixes); |
+ ASSERT_TRUE(builder.GetPrefixSetNoHashes()->WriteFile(filename)); |
+ |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_TRUE(prefix_set.get()); |
+ CheckPrefixes(*prefix_set, prefixes); |
+ } |
+ |
+ // Test writing and reading an empty set. |
+ { |
+ std::vector<SBPrefix> prefixes; |
+ PrefixSetBuilder builder(prefixes); |
+ ASSERT_TRUE(builder.GetPrefixSetNoHashes()->WriteFile(filename)); |
+ |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_TRUE(prefix_set.get()); |
+ CheckPrefixes(*prefix_set, prefixes); |
+ } |
+ |
+ // Test that full hashes are persisted. |
+ { |
+ std::vector<SBFullHash> hashes; |
+ hashes.push_back(SBFullHashForString("one")); |
+ hashes.push_back(SBFullHashForString("two")); |
+ hashes.push_back(SBFullHashForString("three")); |
+ |
+ std::vector<SBPrefix> prefixes(shared_prefixes_); |
+ |
+ // Remove any collisions from the prefixes. |
+ for (size_t i = 0; i < hashes.size(); ++i) { |
+ std::vector<SBPrefix>::iterator iter = |
+ std::lower_bound(prefixes.begin(), prefixes.end(), hashes[i].prefix); |
+ if (iter != prefixes.end() && *iter == hashes[i].prefix) |
+ prefixes.erase(iter); |
+ } |
+ |
+ PrefixSetBuilder builder(prefixes); |
+ ASSERT_TRUE(builder.GetPrefixSet(hashes)->WriteFile(filename)); |
+ |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_TRUE(prefix_set.get()); |
+ CheckPrefixes(*prefix_set, prefixes); |
+ |
+ EXPECT_TRUE(prefix_set->Exists(hashes[0])); |
+ EXPECT_TRUE(prefix_set->Exists(hashes[1])); |
+ EXPECT_TRUE(prefix_set->Exists(hashes[2])); |
+ EXPECT_FALSE(prefix_set->PrefixExists(hashes[0].prefix)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(hashes[1].prefix)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(hashes[2].prefix)); |
+ } |
+} |
+ |
+// Check that |CleanChecksum()| makes an acceptable checksum. |
+TEST_F(PrefixSetTest, CorruptionHelpers) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ // This will modify data in |index_|, which will fail the digest check. |
+ base::ScopedFILE file(base::OpenFile(filename, "r+b")); |
+ IncrementIntAt(file.get(), kPayloadOffset, 1); |
+ file.reset(); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+ |
+ // Fix up the checksum and it will read successfully (though the |
+ // data will be wrong). |
+ file.reset(base::OpenFile(filename, "r+b")); |
+ CleanChecksum(file.get()); |
+ file.reset(); |
+ prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_TRUE(prefix_set.get()); |
+} |
+ |
+// Bad magic is caught by the sanity check. |
+TEST_F(PrefixSetTest, CorruptionMagic) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ ASSERT_NO_FATAL_FAILURE( |
+ ModifyAndCleanChecksum(filename, kMagicOffset, 1)); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Bad version is caught by the sanity check. |
+TEST_F(PrefixSetTest, CorruptionVersion) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ ASSERT_NO_FATAL_FAILURE( |
+ ModifyAndCleanChecksum(filename, kVersionOffset, 10)); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Bad |index_| size is caught by the sanity check. |
+TEST_F(PrefixSetTest, CorruptionIndexSize) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ ASSERT_NO_FATAL_FAILURE( |
+ ModifyAndCleanChecksum(filename, kIndexSizeOffset, 1)); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Bad |deltas_| size is caught by the sanity check. |
+TEST_F(PrefixSetTest, CorruptionDeltasSize) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ ASSERT_NO_FATAL_FAILURE( |
+ ModifyAndCleanChecksum(filename, kDeltasSizeOffset, 1)); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Bad |full_hashes_| size is caught by the sanity check. |
+TEST_F(PrefixSetTest, CorruptionFullHashesSize) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ ASSERT_NO_FATAL_FAILURE( |
+ ModifyAndCleanChecksum(filename, kFullHashesSizeOffset, 1)); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Test that the digest catches corruption in the middle of the file |
+// (in the payload between the header and the digest). |
+TEST_F(PrefixSetTest, CorruptionPayload) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ base::ScopedFILE file(base::OpenFile(filename, "r+b")); |
+ ASSERT_NO_FATAL_FAILURE(IncrementIntAt(file.get(), 666, 1)); |
+ file.reset(); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Test corruption in the digest itself. |
+TEST_F(PrefixSetTest, CorruptionDigest) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ int64 size_64; |
+ ASSERT_TRUE(base::GetFileSize(filename, &size_64)); |
+ base::ScopedFILE file(base::OpenFile(filename, "r+b")); |
+ long digest_offset = static_cast<long>(size_64 - sizeof(base::MD5Digest)); |
+ ASSERT_NO_FATAL_FAILURE(IncrementIntAt(file.get(), digest_offset, 1)); |
+ file.reset(); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Test excess data after the digest (fails the size test). |
+TEST_F(PrefixSetTest, CorruptionExcess) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ // Add some junk to the trunk. |
+ base::ScopedFILE file(base::OpenFile(filename, "ab")); |
+ const char buf[] = "im in ur base, killing ur d00dz."; |
+ ASSERT_EQ(strlen(buf), fwrite(buf, 1, strlen(buf), file.get())); |
+ file.reset(); |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Test that files which had 64-bit size_t are discarded. |
+TEST_F(PrefixSetTest, SizeTRecovery) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ // Open the file for rewrite. |
+ base::ScopedFILE file(base::OpenFile(filename, "r+b")); |
+ |
+ // Leave existing magic and version. |
+ ASSERT_NE(-1, fseek(file.get(), sizeof(uint32) * 2, SEEK_SET)); |
+ |
+ // Indicate two index values and two deltas. |
+ uint32 val = 2; |
+ ASSERT_EQ(sizeof(val), fwrite(&val, 1, sizeof(val), file.get())); |
+ ASSERT_EQ(sizeof(val), fwrite(&val, 1, sizeof(val), file.get())); |
+ |
+ // Write two index values with 64-bit "size_t". |
+ std::pair<SBPrefix, uint64> item; |
+ memset(&item, 0, sizeof(item)); // Includes any padding. |
+ item.first = 17; |
+ item.second = 0; |
+ ASSERT_EQ(sizeof(item), fwrite(&item, 1, sizeof(item), file.get())); |
+ item.first = 100042; |
+ item.second = 1; |
+ ASSERT_EQ(sizeof(item), fwrite(&item, 1, sizeof(item), file.get())); |
+ |
+ // Write two delta values. |
+ uint16 delta = 23; |
+ ASSERT_EQ(sizeof(delta), fwrite(&delta, 1, sizeof(delta), file.get())); |
+ ASSERT_EQ(sizeof(delta), fwrite(&delta, 1, sizeof(delta), file.get())); |
+ |
+ // Leave space for the digest at the end, and regenerate it. |
+ base::MD5Digest dummy = { { 0 } }; |
+ ASSERT_EQ(sizeof(dummy), fwrite(&dummy, 1, sizeof(dummy), file.get())); |
+ ASSERT_TRUE(base::TruncateFile(file.get())); |
+ CleanChecksum(file.get()); |
+ file.reset(); // Flush updates. |
+ |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Test Exists() against full hashes passed to builder. |
+TEST_F(PrefixSetTest, FullHashBuild) { |
+ const SBFullHash kHash1 = SBFullHashForString("one"); |
+ const SBFullHash kHash2 = SBFullHashForString("two"); |
+ const SBFullHash kHash3 = SBFullHashForString("three"); |
+ const SBFullHash kHash4 = SBFullHashForString("four"); |
+ const SBFullHash kHash5 = SBFullHashForString("five"); |
+ const SBFullHash kHash6 = SBFullHashForString("six"); |
+ |
+ std::vector<SBPrefix> prefixes; |
+ prefixes.push_back(kHash1.prefix); |
+ prefixes.push_back(kHash2.prefix); |
+ std::sort(prefixes.begin(), prefixes.end()); |
+ |
+ std::vector<SBFullHash> hashes; |
+ hashes.push_back(kHash4); |
+ hashes.push_back(kHash5); |
+ |
+ PrefixSetBuilder builder(prefixes); |
+ scoped_ptr<const PrefixSet> prefix_set = builder.GetPrefixSet(hashes); |
+ |
+ EXPECT_TRUE(prefix_set->Exists(kHash1)); |
+ EXPECT_TRUE(prefix_set->Exists(kHash2)); |
+ EXPECT_FALSE(prefix_set->Exists(kHash3)); |
+ EXPECT_TRUE(prefix_set->Exists(kHash4)); |
+ EXPECT_TRUE(prefix_set->Exists(kHash5)); |
+ EXPECT_FALSE(prefix_set->Exists(kHash6)); |
+ |
+ EXPECT_TRUE(prefix_set->PrefixExists(kHash1.prefix)); |
+ EXPECT_TRUE(prefix_set->PrefixExists(kHash2.prefix)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(kHash3.prefix)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(kHash4.prefix)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(kHash5.prefix)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(kHash6.prefix)); |
+} |
+ |
+// Test that a version 1 file is discarded on read. |
+TEST_F(PrefixSetTest, ReadSigned) { |
+ base::FilePath filename; |
+ ASSERT_TRUE(GetPrefixSetFile(&filename)); |
+ |
+ // Open the file for rewrite. |
+ base::ScopedFILE file(base::OpenFile(filename, "r+b")); |
+ |
+ // Leave existing magic. |
+ ASSERT_NE(-1, fseek(file.get(), sizeof(uint32), SEEK_SET)); |
+ |
+ // Version 1. |
+ uint32 version = 1; |
+ ASSERT_EQ(sizeof(version), fwrite(&version, 1, sizeof(version), file.get())); |
+ |
+ // Indicate two index values and two deltas. |
+ uint32 val = 2; |
+ ASSERT_EQ(sizeof(val), fwrite(&val, 1, sizeof(val), file.get())); |
+ ASSERT_EQ(sizeof(val), fwrite(&val, 1, sizeof(val), file.get())); |
+ |
+ std::pair<int32, uint32> item; |
+ memset(&item, 0, sizeof(item)); // Includes any padding. |
+ item.first = -1000; |
+ item.second = 0; |
+ ASSERT_EQ(sizeof(item), fwrite(&item, 1, sizeof(item), file.get())); |
+ item.first = 1000; |
+ item.second = 1; |
+ ASSERT_EQ(sizeof(item), fwrite(&item, 1, sizeof(item), file.get())); |
+ |
+ // Write two delta values. |
+ uint16 delta = 23; |
+ ASSERT_EQ(sizeof(delta), fwrite(&delta, 1, sizeof(delta), file.get())); |
+ ASSERT_EQ(sizeof(delta), fwrite(&delta, 1, sizeof(delta), file.get())); |
+ |
+ // Leave space for the digest at the end, and regenerate it. |
+ base::MD5Digest dummy = { { 0 } }; |
+ ASSERT_EQ(sizeof(dummy), fwrite(&dummy, 1, sizeof(dummy), file.get())); |
+ ASSERT_TRUE(base::TruncateFile(file.get())); |
+ CleanChecksum(file.get()); |
+ file.reset(); // Flush updates. |
+ |
+ scoped_ptr<const PrefixSet> prefix_set = PrefixSet::LoadFile(filename); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+ |
+// Test that a golden v2 file is discarded on read. All platforms generating v2 |
+// files are little-endian, so there is no point to testing this transition |
+// if/when a big-endian port is added. |
+#if defined(ARCH_CPU_LITTLE_ENDIAN) |
+TEST_F(PrefixSetTest, Version2) { |
+ std::vector<SBPrefix> ref_prefixes; |
+ ASSERT_TRUE(ReadReferencePrefixes(&ref_prefixes)); |
+ |
+ const char kBasename[] = "PrefixSetVersion2"; |
+ base::FilePath golden_path; |
+ ASSERT_TRUE(PathService::Get(chrome::DIR_TEST_DATA, &golden_path)); |
+ golden_path = golden_path.AppendASCII("SafeBrowsing"); |
+ golden_path = golden_path.AppendASCII(kBasename); |
+ |
+ scoped_ptr<const PrefixSet> prefix_set(PrefixSet::LoadFile(golden_path)); |
+ ASSERT_FALSE(prefix_set.get()); |
+} |
+#endif |
+ |
+// Test that a golden v3 file can be read by the current code. All platforms |
+// generating v3 files are little-endian, so there is no point to testing this |
+// transition if/when a big-endian port is added. |
+#if defined(ARCH_CPU_LITTLE_ENDIAN) |
+TEST_F(PrefixSetTest, Version3) { |
+ std::vector<SBPrefix> ref_prefixes; |
+ ASSERT_TRUE(ReadReferencePrefixes(&ref_prefixes)); |
+ |
+ const char kBasename[] = "PrefixSetVersion3"; |
+ base::FilePath golden_path; |
+ ASSERT_TRUE(PathService::Get(chrome::DIR_TEST_DATA, &golden_path)); |
+ golden_path = golden_path.AppendASCII("SafeBrowsing"); |
+ golden_path = golden_path.AppendASCII(kBasename); |
+ |
+ scoped_ptr<const PrefixSet> prefix_set(PrefixSet::LoadFile(golden_path)); |
+ ASSERT_TRUE(prefix_set.get()); |
+ CheckPrefixes(*prefix_set, ref_prefixes); |
+ |
+ const SBFullHash kHash1 = SBFullHashForString("www.evil.com/malware.html"); |
+ const SBFullHash kHash2 = SBFullHashForString("www.evil.com/phishing.html"); |
+ |
+ EXPECT_TRUE(prefix_set->Exists(kHash1)); |
+ EXPECT_TRUE(prefix_set->Exists(kHash2)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(kHash1.prefix)); |
+ EXPECT_FALSE(prefix_set->PrefixExists(kHash2.prefix)); |
+} |
+#endif |
+ |
+} // namespace safe_browsing |