| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 <stddef.h> | 5 #include <stddef.h> |
| 6 #include <utility> | 6 #include <utility> |
| 7 | 7 |
| 8 #include "base/bind.h" | 8 #include "base/bind.h" |
| 9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
| 10 #include "base/run_loop.h" | 10 #include "base/run_loop.h" |
| (...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 153 return true; | 153 return true; |
| 154 } | 154 } |
| 155 } | 155 } |
| 156 | 156 |
| 157 internal::MessageBuilder builder(count, 0, 8, 0); | 157 internal::MessageBuilder builder(count, 0, 8, 0); |
| 158 bool result = sender_->Accept(builder.message()); | 158 bool result = sender_->Accept(builder.message()); |
| 159 DCHECK(result); | 159 DCHECK(result); |
| 160 return true; | 160 return true; |
| 161 } | 161 } |
| 162 | 162 |
| 163 bool AcceptWithResponder(Message* message, | 163 bool AcceptWithResponder( |
| 164 MessageReceiverWithStatus* responder) override { | 164 Message* message, |
| 165 std::unique_ptr<MessageReceiverWithStatus> responder) override { |
| 165 NOTREACHED(); | 166 NOTREACHED(); |
| 166 return true; | 167 return true; |
| 167 } | 168 } |
| 168 | 169 |
| 169 base::TimeDelta Serve(uint32_t expected_count) { | 170 base::TimeDelta Serve(uint32_t expected_count) { |
| 170 base::RunLoop run_loop; | 171 base::RunLoop run_loop; |
| 171 | 172 |
| 172 expected_count_ = expected_count; | 173 expected_count_ = expected_count; |
| 173 quit_closure_ = run_loop.QuitClosure(); | 174 quit_closure_ = run_loop.QuitClosure(); |
| 174 | 175 |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 225 kTestIterations / duration.InSecondsF(), "pings/second"); | 226 kTestIterations / duration.InSecondsF(), "pings/second"); |
| 226 } | 227 } |
| 227 | 228 |
| 228 class CounterReceiver : public MessageReceiverWithResponderStatus { | 229 class CounterReceiver : public MessageReceiverWithResponderStatus { |
| 229 public: | 230 public: |
| 230 bool Accept(Message* message) override { | 231 bool Accept(Message* message) override { |
| 231 counter_++; | 232 counter_++; |
| 232 return true; | 233 return true; |
| 233 } | 234 } |
| 234 | 235 |
| 235 bool AcceptWithResponder(Message* message, | 236 bool AcceptWithResponder( |
| 236 MessageReceiverWithStatus* responder) override { | 237 Message* message, |
| 238 std::unique_ptr<MessageReceiverWithStatus> responder) override { |
| 237 NOTREACHED(); | 239 NOTREACHED(); |
| 238 return true; | 240 return true; |
| 239 } | 241 } |
| 240 | 242 |
| 241 uint32_t counter() const { return counter_; } | 243 uint32_t counter() const { return counter_; } |
| 242 | 244 |
| 243 void Reset() { counter_ = 0; } | 245 void Reset() { counter_ = 0; } |
| 244 | 246 |
| 245 private: | 247 private: |
| 246 uint32_t counter_ = 0; | 248 uint32_t counter_ = 0; |
| (...skipping 28 matching lines...) Expand all Loading... |
| 275 if (i == 1) { | 277 if (i == 1) { |
| 276 test::LogPerfResult("MultiplexRouterDispatchCost", nullptr, | 278 test::LogPerfResult("MultiplexRouterDispatchCost", nullptr, |
| 277 kIterations[i] / duration.InSecondsF(), | 279 kIterations[i] / duration.InSecondsF(), |
| 278 "times/second"); | 280 "times/second"); |
| 279 } | 281 } |
| 280 } | 282 } |
| 281 } | 283 } |
| 282 | 284 |
| 283 } // namespace | 285 } // namespace |
| 284 } // namespace mojo | 286 } // namespace mojo |
| OLD | NEW |