OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 <stdint.h> | 5 #include <stdint.h> |
6 #include <stdio.h> | 6 #include <stdio.h> |
7 #include <string.h> | 7 #include <string.h> |
8 | 8 |
9 #include <string> | 9 #include <string> |
10 #include <vector> | 10 #include <vector> |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
43 payload_ = Pickle(); | 43 payload_ = Pickle(); |
44 payload_.WriteString(std::string(message_size, '*')); | 44 payload_.WriteString(std::string(message_size, '*')); |
45 read_buffer_.resize(message_size * 2); | 45 read_buffer_.resize(message_size * 2); |
46 } | 46 } |
47 | 47 |
48 protected: | 48 protected: |
49 void WriteWaitThenRead(scoped_refptr<MessagePipe> mp) { | 49 void WriteWaitThenRead(scoped_refptr<MessagePipe> mp) { |
50 CHECK_EQ(mp->WriteMessage(0, | 50 CHECK_EQ(mp->WriteMessage(0, |
51 UserPointer<const void>(payload_.data()), | 51 UserPointer<const void>(payload_.data()), |
52 static_cast<uint32_t>(payload_.size()), | 52 static_cast<uint32_t>(payload_.size()), |
53 NULL, | 53 nullptr, |
54 MOJO_WRITE_MESSAGE_FLAG_NONE), | 54 MOJO_WRITE_MESSAGE_FLAG_NONE), |
55 MOJO_RESULT_OK); | 55 MOJO_RESULT_OK); |
56 HandleSignalsState hss; | 56 HandleSignalsState hss; |
57 CHECK_EQ(test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss), | 57 CHECK_EQ(test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss), |
58 MOJO_RESULT_OK); | 58 MOJO_RESULT_OK); |
59 uint32_t read_buffer_size = static_cast<uint32_t>(read_buffer_.size()); | 59 uint32_t read_buffer_size = static_cast<uint32_t>(read_buffer_.size()); |
60 CHECK_EQ(mp->ReadMessage(0, | 60 CHECK_EQ(mp->ReadMessage(0, |
61 UserPointer<void>(&read_buffer_[0]), | 61 UserPointer<void>(&read_buffer_[0]), |
62 MakeUserPointer(&read_buffer_size), | 62 MakeUserPointer(&read_buffer_size), |
63 NULL, | 63 nullptr, |
64 NULL, | 64 nullptr, |
65 MOJO_READ_MESSAGE_FLAG_NONE), | 65 MOJO_READ_MESSAGE_FLAG_NONE), |
66 MOJO_RESULT_OK); | 66 MOJO_RESULT_OK); |
67 CHECK_EQ(read_buffer_size, static_cast<uint32_t>(payload_.size())); | 67 CHECK_EQ(read_buffer_size, static_cast<uint32_t>(payload_.size())); |
68 } | 68 } |
69 | 69 |
70 void SendQuitMessage(scoped_refptr<MessagePipe> mp) { | 70 void SendQuitMessage(scoped_refptr<MessagePipe> mp) { |
71 CHECK_EQ(mp->WriteMessage(0, | 71 CHECK_EQ(mp->WriteMessage(0, |
72 UserPointer<const void>(""), | 72 UserPointer<const void>(""), |
73 0, | 73 0, |
74 NULL, | 74 nullptr, |
75 MOJO_WRITE_MESSAGE_FLAG_NONE), | 75 MOJO_WRITE_MESSAGE_FLAG_NONE), |
76 MOJO_RESULT_OK); | 76 MOJO_RESULT_OK); |
77 } | 77 } |
78 | 78 |
79 void Measure(scoped_refptr<MessagePipe> mp) { | 79 void Measure(scoped_refptr<MessagePipe> mp) { |
80 // Have one ping-pong to ensure channel being established. | 80 // Have one ping-pong to ensure channel being established. |
81 WriteWaitThenRead(mp); | 81 WriteWaitThenRead(mp); |
82 | 82 |
83 std::string test_name = | 83 std::string test_name = |
84 base::StringPrintf("IPC_Perf_%dx_%u", | 84 base::StringPrintf("IPC_Perf_%dx_%u", |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
123 test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss); | 123 test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss); |
124 if (result != MOJO_RESULT_OK) { | 124 if (result != MOJO_RESULT_OK) { |
125 rv = result; | 125 rv = result; |
126 break; | 126 break; |
127 } | 127 } |
128 | 128 |
129 uint32_t read_size = static_cast<uint32_t>(buffer.size()); | 129 uint32_t read_size = static_cast<uint32_t>(buffer.size()); |
130 CHECK_EQ(mp->ReadMessage(0, | 130 CHECK_EQ(mp->ReadMessage(0, |
131 UserPointer<void>(&buffer[0]), | 131 UserPointer<void>(&buffer[0]), |
132 MakeUserPointer(&read_size), | 132 MakeUserPointer(&read_size), |
133 NULL, | 133 nullptr, |
134 NULL, | 134 nullptr, |
135 MOJO_READ_MESSAGE_FLAG_NONE), | 135 MOJO_READ_MESSAGE_FLAG_NONE), |
136 MOJO_RESULT_OK); | 136 MOJO_RESULT_OK); |
137 | 137 |
138 // Empty message indicates quitting | 138 // Empty message indicates quitting |
139 if (0 == read_size) | 139 if (0 == read_size) |
140 break; | 140 break; |
141 | 141 |
142 CHECK_EQ(mp->WriteMessage(0, | 142 CHECK_EQ(mp->WriteMessage(0, |
143 UserPointer<const void>(&buffer[0]), | 143 UserPointer<const void>(&buffer[0]), |
144 static_cast<uint32_t>(read_size), | 144 static_cast<uint32_t>(read_size), |
145 NULL, | 145 nullptr, |
146 MOJO_WRITE_MESSAGE_FLAG_NONE), | 146 MOJO_WRITE_MESSAGE_FLAG_NONE), |
147 MOJO_RESULT_OK); | 147 MOJO_RESULT_OK); |
148 } | 148 } |
149 | 149 |
150 mp->Close(0); | 150 mp->Close(0); |
151 return rv; | 151 return rv; |
152 } | 152 } |
153 | 153 |
154 // Repeatedly sends messages as previous one got replied by the child. | 154 // Repeatedly sends messages as previous one got replied by the child. |
155 // Waits for the child to close its end before quitting once specified | 155 // Waits for the child to close its end before quitting once specified |
(...skipping 15 matching lines...) Expand all Loading... |
171 } | 171 } |
172 | 172 |
173 SendQuitMessage(mp); | 173 SendQuitMessage(mp); |
174 mp->Close(0); | 174 mp->Close(0); |
175 EXPECT_EQ(0, helper()->WaitForChildShutdown()); | 175 EXPECT_EQ(0, helper()->WaitForChildShutdown()); |
176 } | 176 } |
177 | 177 |
178 } // namespace | 178 } // namespace |
179 } // namespace system | 179 } // namespace system |
180 } // namespace mojo | 180 } // namespace mojo |
OLD | NEW |