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 29 matching lines...) Expand all Loading... |
40 void SetUpMeasurement(int message_count, size_t message_size) { | 40 void SetUpMeasurement(int message_count, size_t message_size) { |
41 message_count_ = message_count; | 41 message_count_ = message_count; |
42 message_size_ = message_size; | 42 message_size_ = message_size; |
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, UserPointer<const void>(payload_.data()), | 50 CHECK_EQ(mp->WriteMessage(0, |
51 static_cast<uint32_t>(payload_.size()), nullptr, | 51 UserPointer<const void>(payload_.data()), |
| 52 static_cast<uint32_t>(payload_.size()), |
| 53 nullptr, |
52 MOJO_WRITE_MESSAGE_FLAG_NONE), | 54 MOJO_WRITE_MESSAGE_FLAG_NONE), |
53 MOJO_RESULT_OK); | 55 MOJO_RESULT_OK); |
54 HandleSignalsState hss; | 56 HandleSignalsState hss; |
55 CHECK_EQ(test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss), | 57 CHECK_EQ(test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss), |
56 MOJO_RESULT_OK); | 58 MOJO_RESULT_OK); |
57 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()); |
58 CHECK_EQ(mp->ReadMessage(0, UserPointer<void>(&read_buffer_[0]), | 60 CHECK_EQ(mp->ReadMessage(0, |
59 MakeUserPointer(&read_buffer_size), nullptr, | 61 UserPointer<void>(&read_buffer_[0]), |
60 nullptr, MOJO_READ_MESSAGE_FLAG_NONE), | 62 MakeUserPointer(&read_buffer_size), |
| 63 nullptr, |
| 64 nullptr, |
| 65 MOJO_READ_MESSAGE_FLAG_NONE), |
61 MOJO_RESULT_OK); | 66 MOJO_RESULT_OK); |
62 CHECK_EQ(read_buffer_size, static_cast<uint32_t>(payload_.size())); | 67 CHECK_EQ(read_buffer_size, static_cast<uint32_t>(payload_.size())); |
63 } | 68 } |
64 | 69 |
65 void SendQuitMessage(scoped_refptr<MessagePipe> mp) { | 70 void SendQuitMessage(scoped_refptr<MessagePipe> mp) { |
66 CHECK_EQ(mp->WriteMessage(0, UserPointer<const void>(""), 0, nullptr, | 71 CHECK_EQ(mp->WriteMessage(0, |
| 72 UserPointer<const void>(""), |
| 73 0, |
| 74 nullptr, |
67 MOJO_WRITE_MESSAGE_FLAG_NONE), | 75 MOJO_WRITE_MESSAGE_FLAG_NONE), |
68 MOJO_RESULT_OK); | 76 MOJO_RESULT_OK); |
69 } | 77 } |
70 | 78 |
71 void Measure(scoped_refptr<MessagePipe> mp) { | 79 void Measure(scoped_refptr<MessagePipe> mp) { |
72 // Have one ping-pong to ensure channel being established. | 80 // Have one ping-pong to ensure channel being established. |
73 WriteWaitThenRead(mp); | 81 WriteWaitThenRead(mp); |
74 | 82 |
75 std::string test_name = | 83 std::string test_name = |
76 base::StringPrintf("IPC_Perf_%dx_%u", message_count_, | 84 base::StringPrintf("IPC_Perf_%dx_%u", |
| 85 message_count_, |
77 static_cast<unsigned>(message_size_)); | 86 static_cast<unsigned>(message_size_)); |
78 base::PerfTimeLogger logger(test_name.c_str()); | 87 base::PerfTimeLogger logger(test_name.c_str()); |
79 | 88 |
80 for (int i = 0; i < message_count_; ++i) | 89 for (int i = 0; i < message_count_; ++i) |
81 WriteWaitThenRead(mp); | 90 WriteWaitThenRead(mp); |
82 | 91 |
83 logger.Done(); | 92 logger.Done(); |
84 } | 93 } |
85 | 94 |
86 private: | 95 private: |
(...skipping 24 matching lines...) Expand all Loading... |
111 // Wait for our end of the message pipe to be readable. | 120 // Wait for our end of the message pipe to be readable. |
112 HandleSignalsState hss; | 121 HandleSignalsState hss; |
113 MojoResult result = | 122 MojoResult result = |
114 test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss); | 123 test::WaitIfNecessary(mp, MOJO_HANDLE_SIGNAL_READABLE, &hss); |
115 if (result != MOJO_RESULT_OK) { | 124 if (result != MOJO_RESULT_OK) { |
116 rv = result; | 125 rv = result; |
117 break; | 126 break; |
118 } | 127 } |
119 | 128 |
120 uint32_t read_size = static_cast<uint32_t>(buffer.size()); | 129 uint32_t read_size = static_cast<uint32_t>(buffer.size()); |
121 CHECK_EQ(mp->ReadMessage(0, UserPointer<void>(&buffer[0]), | 130 CHECK_EQ(mp->ReadMessage(0, |
122 MakeUserPointer(&read_size), nullptr, nullptr, | 131 UserPointer<void>(&buffer[0]), |
| 132 MakeUserPointer(&read_size), |
| 133 nullptr, |
| 134 nullptr, |
123 MOJO_READ_MESSAGE_FLAG_NONE), | 135 MOJO_READ_MESSAGE_FLAG_NONE), |
124 MOJO_RESULT_OK); | 136 MOJO_RESULT_OK); |
125 | 137 |
126 // Empty message indicates quitting | 138 // Empty message indicates quitting |
127 if (0 == read_size) | 139 if (0 == read_size) |
128 break; | 140 break; |
129 | 141 |
130 CHECK_EQ(mp->WriteMessage(0, UserPointer<const void>(&buffer[0]), | 142 CHECK_EQ(mp->WriteMessage(0, |
131 static_cast<uint32_t>(read_size), nullptr, | 143 UserPointer<const void>(&buffer[0]), |
| 144 static_cast<uint32_t>(read_size), |
| 145 nullptr, |
132 MOJO_WRITE_MESSAGE_FLAG_NONE), | 146 MOJO_WRITE_MESSAGE_FLAG_NONE), |
133 MOJO_RESULT_OK); | 147 MOJO_RESULT_OK); |
134 } | 148 } |
135 | 149 |
136 mp->Close(0); | 150 mp->Close(0); |
137 return rv; | 151 return rv; |
138 } | 152 } |
139 | 153 |
140 // Repeatedly sends messages as previous one got replied by the child. | 154 // Repeatedly sends messages as previous one got replied by the child. |
141 // 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... |
157 } | 171 } |
158 | 172 |
159 SendQuitMessage(mp); | 173 SendQuitMessage(mp); |
160 mp->Close(0); | 174 mp->Close(0); |
161 EXPECT_EQ(0, helper()->WaitForChildShutdown()); | 175 EXPECT_EQ(0, helper()->WaitForChildShutdown()); |
162 } | 176 } |
163 | 177 |
164 } // namespace | 178 } // namespace |
165 } // namespace system | 179 } // namespace system |
166 } // namespace mojo | 180 } // namespace mojo |
OLD | NEW |