Index: webrtc/base/stream_unittest.cc |
diff --git a/webrtc/base/stream_unittest.cc b/webrtc/base/stream_unittest.cc |
index 4d5066ab55fce576d2be82df4c4eef937511d147..4172a9726c8bec8939242f20fbc99b0cd1be7140 100644 |
--- a/webrtc/base/stream_unittest.cc |
+++ b/webrtc/base/stream_unittest.cc |
@@ -372,162 +372,4 @@ TEST(FifoBufferTest, WriteOffsetAndReadOffset) { |
EXPECT_EQ(SR_BLOCK, buf.ReadOffset(out, 10, 16, NULL)); |
} |
-class CircularFileStreamTest : public ::testing::Test { |
- protected: |
- static size_t const kMaxSize = 12; |
- |
- CircularFileStreamTest() : is_open_(false), stream_(kMaxSize) { |
- Pathname temp_dir; |
- if (Filesystem::GetAppTempFolder(&temp_dir)) { |
- logfile_name_ = |
- Filesystem::TempFilename(temp_dir, "CircularFileStreamTest"); |
- } |
- } |
- |
- virtual void SetUp() { |
- int error = -1; |
- is_open_ = stream_.Open(logfile_name_, "wb", &error); |
- } |
- |
- virtual void TearDown() { |
- if (!Filesystem::IsAbsent(logfile_name_)) { |
- Filesystem::DeleteFile(logfile_name_); |
- } |
- } |
- |
- bool is_open_; |
- CircularFileStream stream_; |
- std::string logfile_name_; |
-}; |
- |
-TEST_F(CircularFileStreamTest, ReadWriteWithinCapacity) { |
- EXPECT_TRUE(is_open_); |
- // Write contents. |
- const uint8_t bytes[] = {1, 2, 3, 4, 5, 6}; |
- size_t written = 0; |
- int error = 0; |
- EXPECT_EQ(SR_SUCCESS, stream_.Write(bytes, sizeof(bytes), &written, &error)); |
- EXPECT_EQ(0, error); |
- EXPECT_EQ(written, sizeof(bytes)); |
- stream_.Close(); |
- |
- // Check file contents. |
- uint8_t content_bytes[sizeof(bytes)] = {}; |
- scoped_ptr<FileStream> content_stream( |
- Filesystem::OpenFile(logfile_name_, "r")); |
- size_t num_content_bytes_read = 0; |
- EXPECT_TRUE(content_stream); |
- error = 0; |
- EXPECT_EQ(SR_SUCCESS, |
- content_stream->Read(content_bytes, sizeof(content_bytes), |
- &num_content_bytes_read, &error)); |
- EXPECT_EQ(sizeof(content_bytes), num_content_bytes_read); |
- ASSERT_EQ(sizeof(content_bytes), sizeof(bytes)); |
- EXPECT_EQ(0, memcmp(content_bytes, bytes, sizeof(content_bytes))); |
- |
- // Check read result. |
- error = 0; |
- size_t file_size = 0; |
- EXPECT_TRUE(stream_.Open(logfile_name_, "r", &error)); |
- EXPECT_TRUE(stream_.GetSize(&file_size)); |
- EXPECT_EQ(0, error); |
- EXPECT_EQ(sizeof(bytes), file_size); |
- scoped_ptr<uint8_t[]> read_bytes(new uint8_t[file_size]); |
- size_t num_read_bytes = 0; |
- error = 0; |
- EXPECT_EQ(SR_SUCCESS, stream_.ReadAll(read_bytes.get(), file_size, |
- &num_read_bytes, &error)); |
- EXPECT_EQ(sizeof(bytes), num_read_bytes); |
- EXPECT_EQ(0, memcmp(bytes, read_bytes.get(), file_size)); |
-} |
- |
-TEST_F(CircularFileStreamTest, ReadWriteAtCapacity) { |
- EXPECT_TRUE(is_open_); |
- // Write contents. |
- const uint8_t bytes[] = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12}; |
- size_t written = 0; |
- int error = 0; |
- EXPECT_EQ(SR_SUCCESS, stream_.Write(bytes, sizeof(bytes), &written, &error)); |
- EXPECT_EQ(0, error); |
- EXPECT_EQ(written, sizeof(bytes)); |
- stream_.Close(); |
- |
- // Check file contents. |
- uint8_t content_bytes[sizeof(bytes)] = {}; |
- scoped_ptr<FileStream> content_stream( |
- Filesystem::OpenFile(logfile_name_, "r")); |
- size_t num_content_bytes_read = 0; |
- EXPECT_TRUE(content_stream); |
- error = 0; |
- EXPECT_EQ(SR_SUCCESS, |
- content_stream->Read(content_bytes, sizeof(content_bytes), |
- &num_content_bytes_read, &error)); |
- EXPECT_EQ(sizeof(content_bytes), num_content_bytes_read); |
- ASSERT_EQ(sizeof(content_bytes), sizeof(bytes)); |
- EXPECT_EQ(0, memcmp(content_bytes, bytes, sizeof(content_bytes))); |
- |
- // Check read result. |
- error = 0; |
- size_t file_size = 0; |
- EXPECT_TRUE(stream_.Open(logfile_name_, "r", &error)); |
- EXPECT_TRUE(stream_.GetSize(&file_size)); |
- EXPECT_EQ(0, error); |
- EXPECT_EQ(sizeof(bytes), file_size); |
- scoped_ptr<uint8_t[]> read_bytes(new uint8_t[file_size]); |
- size_t num_read_bytes = 0; |
- error = 0; |
- EXPECT_EQ(SR_SUCCESS, stream_.ReadAll(read_bytes.get(), file_size, |
- &num_read_bytes, &error)); |
- EXPECT_EQ(sizeof(bytes), num_read_bytes); |
- EXPECT_EQ(0, memcmp(bytes, read_bytes.get(), file_size)); |
-} |
- |
-TEST_F(CircularFileStreamTest, ReadWriteOverCapacity) { |
- EXPECT_TRUE(is_open_); |
- // Write contents. |
- const uint8_t bytes[] = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15}; |
- size_t written = 0; |
- int error = 0; |
- EXPECT_EQ(SR_SUCCESS, |
- stream_.WriteAll(bytes, sizeof(bytes), &written, &error)); |
- EXPECT_EQ(0, error); |
- EXPECT_EQ(written, sizeof(bytes)); |
- stream_.Close(); |
- |
- // Check file contents. |
- uint8_t content_bytes[kMaxSize] = {}; |
- scoped_ptr<FileStream> content_stream( |
- Filesystem::OpenFile(logfile_name_, "r")); |
- size_t num_content_bytes_read = 0; |
- EXPECT_TRUE(content_stream); |
- error = 0; |
- EXPECT_EQ(SR_SUCCESS, |
- content_stream->Read(content_bytes, sizeof(content_bytes), |
- &num_content_bytes_read, &error)); |
- EXPECT_EQ(sizeof(content_bytes), num_content_bytes_read); |
- const uint8_t expected_content_bytes[] = { |
- 1, 2, 3, 4, 5, 6, 13, 14, 15, 10, 11, 12}; |
- ASSERT_EQ(sizeof(content_bytes), sizeof(expected_content_bytes)); |
- EXPECT_EQ( |
- 0, memcmp(expected_content_bytes, content_bytes, sizeof(content_bytes))); |
- |
- // Check read result. |
- error = 0; |
- size_t file_size = 0; |
- EXPECT_TRUE(stream_.Open(logfile_name_, "r", &error)); |
- EXPECT_TRUE(stream_.GetSize(&file_size)); |
- EXPECT_EQ(0, error); |
- EXPECT_EQ(sizeof(content_bytes), file_size); |
- scoped_ptr<uint8_t[]> read_bytes(new uint8_t[file_size]); |
- size_t num_read_bytes = 0; |
- error = 0; |
- EXPECT_EQ(SR_SUCCESS, stream_.ReadAll(read_bytes.get(), file_size, |
- &num_read_bytes, &error)); |
- |
- const uint8_t expected_read_bytes[] = { |
- 1, 2, 3, 4, 5, 6, 10, 11, 12, 13, 14, 15}; |
- EXPECT_EQ(sizeof(expected_read_bytes), num_read_bytes); |
- EXPECT_EQ(0, memcmp(expected_read_bytes, read_bytes.get(), file_size)); |
-} |
- |
} // namespace rtc |