Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(320)

Side by Side Diff: mojo/public/cpp/bindings/lib/multiplex_router.h

Issue 2725133002: Mojo: Armed Watchers (Closed)
Patch Set: . Created 3 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 112 matching lines...) Expand 10 before | Expand all | Expand 10 after
123 return connector_.WaitForIncomingMessage(deadline); 123 return connector_.WaitForIncomingMessage(deadline);
124 } 124 }
125 125
126 // See Binding for details of pause/resume. 126 // See Binding for details of pause/resume.
127 void PauseIncomingMethodCallProcessing(); 127 void PauseIncomingMethodCallProcessing();
128 void ResumeIncomingMethodCallProcessing(); 128 void ResumeIncomingMethodCallProcessing();
129 129
130 // Whether there are any associated interfaces running currently. 130 // Whether there are any associated interfaces running currently.
131 bool HasAssociatedEndpoints() const; 131 bool HasAssociatedEndpoints() const;
132 132
133 void EnableNestedDispatch(bool enabled);
134
133 // Sets this object to testing mode. 135 // Sets this object to testing mode.
134 // In testing mode, the object doesn't disconnect the underlying message pipe 136 // In testing mode, the object doesn't disconnect the underlying message pipe
135 // when it receives unexpected or invalid messages. 137 // when it receives unexpected or invalid messages.
136 void EnableTestingMode(); 138 void EnableTestingMode();
137 139
138 // Is the router bound to a message pipe handle? 140 // Is the router bound to a message pipe handle?
139 bool is_valid() const { 141 bool is_valid() const {
140 DCHECK(thread_checker_.CalledOnValidThread()); 142 DCHECK(thread_checker_.CalledOnValidThread());
141 return connector_.is_valid(); 143 return connector_.is_valid();
142 } 144 }
(...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after
266 268
267 bool testing_mode_; 269 bool testing_mode_;
268 270
269 DISALLOW_COPY_AND_ASSIGN(MultiplexRouter); 271 DISALLOW_COPY_AND_ASSIGN(MultiplexRouter);
270 }; 272 };
271 273
272 } // namespace internal 274 } // namespace internal
273 } // namespace mojo 275 } // namespace mojo
274 276
275 #endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_ 277 #endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_
OLDNEW
« no previous file with comments | « mojo/public/cpp/bindings/lib/interface_ptr_state.h ('k') | mojo/public/cpp/bindings/lib/multiplex_router.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698