OLD | NEW |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 <string> | 5 #include <string> |
6 | 6 |
7 #include "base/scoped_ptr.h" | 7 #include "base/scoped_ptr.h" |
8 #include "net/base/io_buffer.h" | 8 #include "net/base/io_buffer.h" |
9 #include "remoting/base/multiple_array_input_stream.h" | 9 #include "remoting/base/multiple_array_input_stream.h" |
10 #include "testing/gtest/include/gtest/gtest.h" | 10 #include "testing/gtest/include/gtest/gtest.h" |
(...skipping 28 matching lines...) Expand all Loading... |
39 out += in_size; | 39 out += in_size; |
40 out_size -= in_size; | 40 out_size -= in_size; |
41 } | 41 } |
42 } | 42 } |
43 | 43 |
44 static void ReadString(MultipleArrayInputStream* input, | 44 static void ReadString(MultipleArrayInputStream* input, |
45 const std::string& str) { | 45 const std::string& str) { |
46 scoped_array<char> buffer(new char[str.size() + 1]); | 46 scoped_array<char> buffer(new char[str.size() + 1]); |
47 buffer[str.size()] = '\0'; | 47 buffer[str.size()] = '\0'; |
48 EXPECT_EQ(ReadFromInput(input, buffer.get(), str.size()), str.size()); | 48 EXPECT_EQ(ReadFromInput(input, buffer.get(), str.size()), str.size()); |
49 EXPECT_STREQ(str.data(), buffer.get()); | 49 EXPECT_STREQ(str.c_str(), buffer.get()); |
50 } | 50 } |
51 | 51 |
52 // Construct and prepare data in the |output_stream|. | 52 // Construct and prepare data in the |output_stream|. |
53 static void PrepareData(scoped_ptr<MultipleArrayInputStream>* stream) { | 53 static void PrepareData(scoped_ptr<MultipleArrayInputStream>* stream) { |
54 static const std::string kTestData = | 54 static const std::string kTestData = |
55 "Hello world!" | 55 "Hello world!" |
56 "This is testing" | 56 "This is testing" |
57 "MultipleArrayInputStream" | 57 "MultipleArrayInputStream" |
58 "for Chromoting"; | 58 "for Chromoting"; |
59 | 59 |
60 // Determine how many segments to split kTestData. We split the data in | 60 // Determine how many segments to split kTestData. We split the data in |
61 // 1 character, 2 characters, 1 character, 2 characters ... | 61 // 1 character, 2 characters, 1 character, 2 characters ... |
62 int segments = (kTestData.length() / 3) * 2; | 62 int segments = (kTestData.length() / 3) * 2; |
63 int remaining_chars = kTestData.length() % 3; | 63 int remaining_chars = kTestData.length() % 3; |
64 if (remaining_chars) { | 64 if (remaining_chars) { |
65 if (remaining_chars == 1) | 65 if (remaining_chars == 1) |
66 ++segments; | 66 ++segments; |
67 else | 67 else |
68 segments += 2; | 68 segments += 2; |
69 } | 69 } |
70 | 70 |
71 MultipleArrayInputStream* mstream = new MultipleArrayInputStream(); | 71 MultipleArrayInputStream* mstream = new MultipleArrayInputStream(); |
72 const char* data = kTestData.data(); | 72 const char* data = kTestData.c_str(); |
73 for (int i = 0; i < segments; ++i) { | 73 for (int i = 0; i < segments; ++i) { |
74 int size = i % 2 == 0 ? 1 : 2; | 74 int size = i % 2 == 0 ? 1 : 2; |
75 mstream->AddBuffer(new net::StringIOBuffer(std::string(data, size)), size); | 75 mstream->AddBuffer(new net::StringIOBuffer(std::string(data, size)), size); |
76 data += size; | 76 data += size; |
77 } | 77 } |
78 stream->reset(mstream); | 78 stream->reset(mstream); |
79 } | 79 } |
80 | 80 |
81 TEST(MultipleArrayInputStreamTest, BasicOperations) { | 81 TEST(MultipleArrayInputStreamTest, BasicOperations) { |
82 scoped_ptr<MultipleArrayInputStream> stream; | 82 scoped_ptr<MultipleArrayInputStream> stream; |
83 PrepareData(&stream); | 83 PrepareData(&stream); |
84 | 84 |
85 ReadString(stream.get(), "Hello world!"); | 85 ReadString(stream.get(), "Hello world!"); |
86 ReadString(stream.get(), "This "); | 86 ReadString(stream.get(), "This "); |
87 ReadString(stream.get(), "is test"); | 87 ReadString(stream.get(), "is test"); |
88 EXPECT_TRUE(stream->Skip(3)); | 88 EXPECT_TRUE(stream->Skip(3)); |
89 ReadString(stream.get(), "MultipleArrayInput"); | 89 ReadString(stream.get(), "MultipleArrayInput"); |
90 EXPECT_TRUE(stream->Skip(6)); | 90 EXPECT_TRUE(stream->Skip(6)); |
91 ReadString(stream.get(), "f"); | 91 ReadString(stream.get(), "f"); |
92 ReadString(stream.get(), "o"); | 92 ReadString(stream.get(), "o"); |
93 ReadString(stream.get(), "r"); | 93 ReadString(stream.get(), "r"); |
94 ReadString(stream.get(), " "); | 94 ReadString(stream.get(), " "); |
95 ReadString(stream.get(), "Chromoting"); | 95 ReadString(stream.get(), "Chromoting"); |
96 } | 96 } |
97 | 97 |
98 } // namespace remoting | 98 } // namespace remoting |
OLD | NEW |