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 #ifndef MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_ | 5 #ifndef MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_ |
6 #define MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_ | 6 #define MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_ |
7 | 7 |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <deque> | 10 #include <deque> |
(...skipping 111 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
122 DCHECK(thread_checker_.CalledOnValidThread()); | 122 DCHECK(thread_checker_.CalledOnValidThread()); |
123 return connector_.is_valid(); | 123 return connector_.is_valid(); |
124 } | 124 } |
125 | 125 |
126 // TODO(yzshen): consider removing this getter. | 126 // TODO(yzshen): consider removing this getter. |
127 MessagePipeHandle handle() const { | 127 MessagePipeHandle handle() const { |
128 DCHECK(thread_checker_.CalledOnValidThread()); | 128 DCHECK(thread_checker_.CalledOnValidThread()); |
129 return connector_.handle(); | 129 return connector_.handle(); |
130 } | 130 } |
131 | 131 |
| 132 bool SimulateReceivingMessageForTesting(Message* message) { |
| 133 return filters_.Accept(message); |
| 134 } |
| 135 |
132 private: | 136 private: |
133 class InterfaceEndpoint; | 137 class InterfaceEndpoint; |
134 struct Task; | 138 struct Task; |
135 | 139 |
136 ~MultiplexRouter() override; | 140 ~MultiplexRouter() override; |
137 | 141 |
138 // MessageReceiver implementation: | 142 // MessageReceiver implementation: |
139 bool Accept(Message* message) override; | 143 bool Accept(Message* message) override; |
140 | 144 |
141 // PipeControlMessageHandlerDelegate implementation: | 145 // PipeControlMessageHandlerDelegate implementation: |
(...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
236 | 240 |
237 bool testing_mode_; | 241 bool testing_mode_; |
238 | 242 |
239 DISALLOW_COPY_AND_ASSIGN(MultiplexRouter); | 243 DISALLOW_COPY_AND_ASSIGN(MultiplexRouter); |
240 }; | 244 }; |
241 | 245 |
242 } // namespace internal | 246 } // namespace internal |
243 } // namespace mojo | 247 } // namespace mojo |
244 | 248 |
245 #endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_ | 249 #endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_ |
OLD | NEW |