| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/files/file_util.h" | 5 #include "base/files/file_util.h" |
| 6 #include "base/files/scoped_temp_dir.h" | 6 #include "base/files/scoped_temp_dir.h" |
| 7 #include "base/stl_util.h" | 7 #include "base/stl_util.h" |
| 8 #include "base/strings/string_util.h" | 8 #include "base/strings/string_util.h" |
| 9 #include "chrome/browser/sessions/session_backend.h" | 9 #include "chrome/browser/sessions/session_backend.h" |
| 10 #include "testing/gtest/include/gtest/gtest.h" | 10 #include "testing/gtest/include/gtest/gtest.h" |
| 11 | 11 |
| 12 namespace { | 12 namespace { |
| 13 | 13 |
| 14 typedef std::vector<SessionCommand*> SessionCommands; | 14 typedef ScopedVector<SessionCommand> SessionCommands; |
| 15 | 15 |
| 16 struct TestData { | 16 struct TestData { |
| 17 SessionCommand::id_type command_id; | 17 SessionCommand::id_type command_id; |
| 18 std::string data; | 18 std::string data; |
| 19 }; | 19 }; |
| 20 | 20 |
| 21 SessionCommand* CreateCommandFromData(const TestData& data) { | 21 SessionCommand* CreateCommandFromData(const TestData& data) { |
| 22 SessionCommand* command = | 22 SessionCommand* command = |
| 23 new SessionCommand( | 23 new SessionCommand( |
| 24 data.command_id, | 24 data.command_id, |
| 25 static_cast<SessionCommand::size_type>(data.data.size())); | 25 static_cast<SessionCommand::size_type>(data.data.size())); |
| 26 if (!data.data.empty()) | 26 if (!data.data.empty()) |
| 27 memcpy(command->contents(), data.data.c_str(), data.data.size()); | 27 memcpy(command->contents(), data.data.c_str(), data.data.size()); |
| 28 return command; | 28 return command; |
| 29 } | 29 } |
| 30 | 30 |
| 31 // Create a new SessionCommands structure and swap existing commands into them. |
| 32 SessionCommands* CreateNewSessionCommands(SessionCommands* commands) { |
| 33 SessionCommands* swapped_commands = new SessionCommands; |
| 34 swapped_commands->swap(*commands); |
| 35 return swapped_commands; |
| 36 } |
| 37 |
| 31 } // namespace | 38 } // namespace |
| 32 | 39 |
| 33 class SessionBackendTest : public testing::Test { | 40 class SessionBackendTest : public testing::Test { |
| 34 protected: | 41 protected: |
| 35 virtual void SetUp() { | 42 virtual void SetUp() { |
| 36 ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); | 43 ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); |
| 37 path_ = temp_dir_.path().Append(FILE_PATH_LITERAL("SessionTestDirs")); | 44 path_ = temp_dir_.path().Append(FILE_PATH_LITERAL("SessionTestDirs")); |
| 38 base::CreateDirectory(path_); | 45 base::CreateDirectory(path_); |
| 39 } | 46 } |
| 40 | 47 |
| 41 void AssertCommandEqualsData(const TestData& data, SessionCommand* command) { | 48 void AssertCommandEqualsData(const TestData& data, SessionCommand* command) { |
| 42 EXPECT_EQ(data.command_id, command->id()); | 49 EXPECT_EQ(data.command_id, command->id()); |
| 43 EXPECT_EQ(data.data.size(), command->size()); | 50 EXPECT_EQ(data.data.size(), command->size()); |
| 44 EXPECT_TRUE( | 51 EXPECT_TRUE( |
| 45 memcmp(command->contents(), data.data.c_str(), command->size()) == 0); | 52 memcmp(command->contents(), data.data.c_str(), command->size()) == 0); |
| 46 } | 53 } |
| 47 | 54 |
| 48 // Path used in testing. | 55 // Path used in testing. |
| 49 base::FilePath path_; | 56 base::FilePath path_; |
| 50 base::ScopedTempDir temp_dir_; | 57 base::ScopedTempDir temp_dir_; |
| 51 }; | 58 }; |
| 52 | 59 |
| 53 TEST_F(SessionBackendTest, SimpleReadWrite) { | 60 TEST_F(SessionBackendTest, SimpleReadWrite) { |
| 54 scoped_refptr<SessionBackend> backend( | 61 scoped_refptr<SessionBackend> backend( |
| 55 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); | 62 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); |
| 56 struct TestData data = { 1, "a" }; | 63 struct TestData data = { 1, "a" }; |
| 57 std::vector<SessionCommand*> commands; | 64 SessionCommands commands; |
| 58 commands.push_back(CreateCommandFromData(data)); | 65 commands.push_back(CreateCommandFromData(data)); |
| 59 backend->AppendCommands(new SessionCommands(commands), false); | 66 backend->AppendCommands(CreateNewSessionCommands(&commands), false); |
| 60 commands.clear(); | 67 DCHECK(commands.empty()); |
| 61 | 68 |
| 62 // Read it back in. | 69 // Read it back in. |
| 63 backend = NULL; | 70 backend = NULL; |
| 64 backend = new SessionBackend(BaseSessionService::SESSION_RESTORE, path_); | 71 backend = new SessionBackend(BaseSessionService::SESSION_RESTORE, path_); |
| 65 backend->ReadLastSessionCommandsImpl(&commands); | 72 backend->ReadLastSessionCommandsImpl(&commands); |
| 66 | 73 |
| 67 ASSERT_EQ(1U, commands.size()); | 74 ASSERT_EQ(1U, commands.size()); |
| 68 AssertCommandEqualsData(data, commands[0]); | 75 AssertCommandEqualsData(data, commands[0]); |
| 69 | 76 |
| 70 STLDeleteElements(&commands); | 77 commands.clear(); |
| 71 | 78 |
| 72 backend = NULL; | 79 backend = NULL; |
| 73 backend = new SessionBackend(BaseSessionService::SESSION_RESTORE, path_); | 80 backend = new SessionBackend(BaseSessionService::SESSION_RESTORE, path_); |
| 74 backend->ReadLastSessionCommandsImpl(&commands); | 81 backend->ReadLastSessionCommandsImpl(&commands); |
| 75 | 82 |
| 76 ASSERT_EQ(0U, commands.size()); | 83 ASSERT_EQ(0U, commands.size()); |
| 77 | 84 |
| 78 // Make sure we can delete. | 85 // Make sure we can delete. |
| 79 backend->DeleteLastSession(); | 86 backend->DeleteLastSession(); |
| 80 backend->ReadLastSessionCommandsImpl(&commands); | 87 backend->ReadLastSessionCommandsImpl(&commands); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 94 { 9, "abcdefghi" }, | 101 { 9, "abcdefghi" }, |
| 95 { 10, "abcdefghij" }, | 102 { 10, "abcdefghij" }, |
| 96 { 11, "abcdefghijk" }, | 103 { 11, "abcdefghijk" }, |
| 97 { 12, "abcdefghijkl" }, | 104 { 12, "abcdefghijkl" }, |
| 98 { 13, "abcdefghijklm" }, | 105 { 13, "abcdefghijklm" }, |
| 99 }; | 106 }; |
| 100 | 107 |
| 101 for (size_t i = 0; i < arraysize(data); ++i) { | 108 for (size_t i = 0; i < arraysize(data); ++i) { |
| 102 scoped_refptr<SessionBackend> backend( | 109 scoped_refptr<SessionBackend> backend( |
| 103 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); | 110 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); |
| 104 std::vector<SessionCommand*> commands; | 111 SessionCommands commands; |
| 105 if (i != 0) { | 112 if (i != 0) { |
| 106 // Read previous data. | 113 // Read previous data. |
| 107 backend->ReadLastSessionCommandsImpl(&commands); | 114 backend->ReadLastSessionCommandsImpl(&commands); |
| 108 ASSERT_EQ(i, commands.size()); | 115 ASSERT_EQ(i, commands.size()); |
| 109 for (std::vector<SessionCommand*>::iterator j = commands.begin(); | 116 for (std::vector<SessionCommand*>::iterator j = commands.begin(); |
| 110 j != commands.end(); ++j) { | 117 j != commands.end(); ++j) { |
| 111 AssertCommandEqualsData(data[j - commands.begin()], *j); | 118 AssertCommandEqualsData(data[j - commands.begin()], *j); |
| 112 } | 119 } |
| 113 backend->AppendCommands(new SessionCommands(commands), false); | 120 backend->AppendCommands(CreateNewSessionCommands(&commands), false); |
| 114 commands.clear(); | |
| 115 } | 121 } |
| 116 commands.push_back(CreateCommandFromData(data[i])); | 122 commands.push_back(CreateCommandFromData(data[i])); |
| 117 backend->AppendCommands(new SessionCommands(commands), false); | 123 backend->AppendCommands(CreateNewSessionCommands(&commands), false); |
| 118 } | 124 } |
| 119 } | 125 } |
| 120 | 126 |
| 121 TEST_F(SessionBackendTest, BigData) { | 127 TEST_F(SessionBackendTest, BigData) { |
| 122 struct TestData data[] = { | 128 struct TestData data[] = { |
| 123 { 1, "a" }, | 129 { 1, "a" }, |
| 124 { 2, "ab" }, | 130 { 2, "ab" }, |
| 125 }; | 131 }; |
| 126 | 132 |
| 127 scoped_refptr<SessionBackend> backend( | 133 scoped_refptr<SessionBackend> backend( |
| 128 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); | 134 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); |
| 129 std::vector<SessionCommand*> commands; | 135 ScopedVector<SessionCommand> commands; |
| 136 |
| 130 commands.push_back(CreateCommandFromData(data[0])); | 137 commands.push_back(CreateCommandFromData(data[0])); |
| 131 const SessionCommand::size_type big_size = | 138 const SessionCommand::size_type big_size = |
| 132 SessionBackend::kFileReadBufferSize + 100; | 139 SessionBackend::kFileReadBufferSize + 100; |
| 133 const SessionCommand::id_type big_id = 50; | 140 const SessionCommand::id_type big_id = 50; |
| 134 SessionCommand* big_command = new SessionCommand(big_id, big_size); | 141 SessionCommand* big_command = new SessionCommand(big_id, big_size); |
| 135 reinterpret_cast<char*>(big_command->contents())[0] = 'a'; | 142 reinterpret_cast<char*>(big_command->contents())[0] = 'a'; |
| 136 reinterpret_cast<char*>(big_command->contents())[big_size - 1] = 'z'; | 143 reinterpret_cast<char*>(big_command->contents())[big_size - 1] = 'z'; |
| 137 commands.push_back(big_command); | 144 commands.push_back(big_command); |
| 138 commands.push_back(CreateCommandFromData(data[1])); | 145 commands.push_back(CreateCommandFromData(data[1])); |
| 139 backend->AppendCommands(new SessionCommands(commands), false); | 146 backend->AppendCommands(CreateNewSessionCommands(&commands), false); |
| 140 commands.clear(); | |
| 141 | 147 |
| 142 backend = NULL; | 148 backend = NULL; |
| 143 backend = new SessionBackend(BaseSessionService::SESSION_RESTORE, path_); | 149 backend = new SessionBackend(BaseSessionService::SESSION_RESTORE, path_); |
| 144 commands.clear(); | 150 |
| 145 backend->ReadLastSessionCommandsImpl(&commands); | 151 backend->ReadLastSessionCommandsImpl(&commands); |
| 146 ASSERT_EQ(3U, commands.size()); | 152 ASSERT_EQ(3U, commands.size()); |
| 147 AssertCommandEqualsData(data[0], commands[0]); | 153 AssertCommandEqualsData(data[0], commands[0]); |
| 148 AssertCommandEqualsData(data[1], commands[2]); | 154 AssertCommandEqualsData(data[1], commands[2]); |
| 149 | 155 |
| 150 EXPECT_EQ(big_id, commands[1]->id()); | 156 EXPECT_EQ(big_id, commands[1]->id()); |
| 151 ASSERT_EQ(big_size, commands[1]->size()); | 157 ASSERT_EQ(big_size, commands[1]->size()); |
| 152 EXPECT_EQ('a', reinterpret_cast<char*>(commands[1]->contents())[0]); | 158 EXPECT_EQ('a', reinterpret_cast<char*>(commands[1]->contents())[0]); |
| 153 EXPECT_EQ('z', | 159 EXPECT_EQ('z', |
| 154 reinterpret_cast<char*>(commands[1]->contents())[big_size - 1]); | 160 reinterpret_cast<char*>(commands[1]->contents())[big_size - 1]); |
| 155 STLDeleteElements(&commands); | 161 commands.clear(); |
| 156 } | 162 } |
| 157 | 163 |
| 158 TEST_F(SessionBackendTest, EmptyCommand) { | 164 TEST_F(SessionBackendTest, EmptyCommand) { |
| 159 TestData empty_command; | 165 TestData empty_command; |
| 160 empty_command.command_id = 1; | 166 empty_command.command_id = 1; |
| 161 scoped_refptr<SessionBackend> backend( | 167 scoped_refptr<SessionBackend> backend( |
| 162 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); | 168 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); |
| 163 std::vector<SessionCommand*>* empty_commands = | 169 SessionCommands* empty_commands = new SessionCommands(); |
| 164 new std::vector<SessionCommand*>(); | |
| 165 empty_commands->push_back(CreateCommandFromData(empty_command)); | 170 empty_commands->push_back(CreateCommandFromData(empty_command)); |
| 166 backend->AppendCommands(empty_commands, true); | 171 backend->AppendCommands(empty_commands, true); |
| 167 backend->MoveCurrentSessionToLastSession(); | 172 backend->MoveCurrentSessionToLastSession(); |
| 168 | 173 |
| 169 std::vector<SessionCommand*> commands; | 174 SessionCommands commands; |
| 170 backend->ReadLastSessionCommandsImpl(&commands); | 175 backend->ReadLastSessionCommandsImpl(&commands); |
| 171 ASSERT_EQ(1U, commands.size()); | 176 ASSERT_EQ(1U, commands.size()); |
| 172 AssertCommandEqualsData(empty_command, commands[0]); | 177 AssertCommandEqualsData(empty_command, commands[0]); |
| 173 STLDeleteElements(&commands); | 178 commands.clear(); |
| 174 } | 179 } |
| 175 | 180 |
| 176 // Writes a command, appends another command with reset to true, then reads | 181 // Writes a command, appends another command with reset to true, then reads |
| 177 // making sure we only get back the second command. | 182 // making sure we only get back the second command. |
| 178 TEST_F(SessionBackendTest, Truncate) { | 183 TEST_F(SessionBackendTest, Truncate) { |
| 179 scoped_refptr<SessionBackend> backend( | 184 scoped_refptr<SessionBackend> backend( |
| 180 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); | 185 new SessionBackend(BaseSessionService::SESSION_RESTORE, path_)); |
| 181 struct TestData first_data = { 1, "a" }; | 186 struct TestData first_data = { 1, "a" }; |
| 182 std::vector<SessionCommand*> commands; | 187 SessionCommands commands; |
| 183 commands.push_back(CreateCommandFromData(first_data)); | 188 commands.push_back(CreateCommandFromData(first_data)); |
| 184 backend->AppendCommands(new SessionCommands(commands), false); | 189 backend->AppendCommands(CreateNewSessionCommands(&commands), false); |
| 185 commands.clear(); | |
| 186 | 190 |
| 187 // Write another command, this time resetting the file when appending. | 191 // Write another command, this time resetting the file when appending. |
| 188 struct TestData second_data = { 2, "b" }; | 192 struct TestData second_data = { 2, "b" }; |
| 189 commands.push_back(CreateCommandFromData(second_data)); | 193 commands.push_back(CreateCommandFromData(second_data)); |
| 190 backend->AppendCommands(new SessionCommands(commands), true); | 194 backend->AppendCommands(CreateNewSessionCommands(&commands), true); |
| 191 commands.clear(); | |
| 192 | 195 |
| 193 // Read it back in. | 196 // Read it back in. |
| 194 backend = NULL; | 197 backend = NULL; |
| 195 backend = new SessionBackend(BaseSessionService::SESSION_RESTORE, path_); | 198 backend = new SessionBackend(BaseSessionService::SESSION_RESTORE, path_); |
| 196 backend->ReadLastSessionCommandsImpl(&commands); | 199 backend->ReadLastSessionCommandsImpl(&commands); |
| 197 | 200 |
| 198 // And make sure we get back the expected data. | 201 // And make sure we get back the expected data. |
| 199 ASSERT_EQ(1U, commands.size()); | 202 ASSERT_EQ(1U, commands.size()); |
| 200 AssertCommandEqualsData(second_data, commands[0]); | 203 AssertCommandEqualsData(second_data, commands[0]); |
| 201 | 204 |
| 202 STLDeleteElements(&commands); | 205 commands.clear(); |
| 203 } | 206 } |
| OLD | NEW |