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 #ifndef MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_STATE_H_ | 5 #ifndef MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_STATE_H_ |
6 #define MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_STATE_H_ | 6 #define MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_STATE_H_ |
7 | 7 |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <algorithm> // For |std::swap()|. | 10 #include <algorithm> // For |std::swap()|. |
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
101 DCHECK_EQ(0u, version_); | 101 DCHECK_EQ(0u, version_); |
102 DCHECK(info.is_valid()); | 102 DCHECK(info.is_valid()); |
103 | 103 |
104 handle_ = info.PassHandle(); | 104 handle_ = info.PassHandle(); |
105 version_ = info.version(); | 105 version_ = info.version(); |
106 runner_ = std::move(runner); | 106 runner_ = std::move(runner); |
107 } | 107 } |
108 | 108 |
109 bool HasAssociatedInterfaces() const { return false; } | 109 bool HasAssociatedInterfaces() const { return false; } |
110 | 110 |
111 bool WaitForIncomingResponse() { | |
112 ConfigureProxyIfNecessary(); | |
113 | |
114 DCHECK(router_); | |
115 return router_->WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE); | |
116 } | |
117 | |
118 // After this method is called, the object is in an invalid state and | 111 // After this method is called, the object is in an invalid state and |
119 // shouldn't be reused. | 112 // shouldn't be reused. |
120 InterfacePtrInfo<Interface> PassInterface() { | 113 InterfacePtrInfo<Interface> PassInterface() { |
121 return InterfacePtrInfo<Interface>( | 114 return InterfacePtrInfo<Interface>( |
122 router_ ? router_->PassMessagePipe() : std::move(handle_), version_); | 115 router_ ? router_->PassMessagePipe() : std::move(handle_), version_); |
123 } | 116 } |
124 | 117 |
125 bool is_bound() const { return handle_.is_valid() || router_; } | 118 bool is_bound() const { return handle_.is_valid() || router_; } |
126 | 119 |
127 bool encountered_error() const { | 120 bool encountered_error() const { |
(...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
258 | 251 |
259 handle_ = info.PassHandle(); | 252 handle_ = info.PassHandle(); |
260 version_ = info.version(); | 253 version_ = info.version(); |
261 runner_ = std::move(runner); | 254 runner_ = std::move(runner); |
262 } | 255 } |
263 | 256 |
264 bool HasAssociatedInterfaces() const { | 257 bool HasAssociatedInterfaces() const { |
265 return router_ ? router_->HasAssociatedEndpoints() : false; | 258 return router_ ? router_->HasAssociatedEndpoints() : false; |
266 } | 259 } |
267 | 260 |
268 bool WaitForIncomingResponse() { | |
269 ConfigureProxyIfNecessary(); | |
270 | |
271 DCHECK(router_); | |
272 return router_->WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE); | |
273 } | |
274 | |
275 // After this method is called, the object is in an invalid state and | 261 // After this method is called, the object is in an invalid state and |
276 // shouldn't be reused. | 262 // shouldn't be reused. |
277 InterfacePtrInfo<Interface> PassInterface() { | 263 InterfacePtrInfo<Interface> PassInterface() { |
278 endpoint_client_.reset(); | 264 endpoint_client_.reset(); |
279 proxy_.reset(); | 265 proxy_.reset(); |
280 return InterfacePtrInfo<Interface>( | 266 return InterfacePtrInfo<Interface>( |
281 router_ ? router_->PassMessagePipe() : std::move(handle_), version_); | 267 router_ ? router_->PassMessagePipe() : std::move(handle_), version_); |
282 } | 268 } |
283 | 269 |
284 bool is_bound() const { return handle_.is_valid() || endpoint_client_; } | 270 bool is_bound() const { return handle_.is_valid() || endpoint_client_; } |
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
353 | 339 |
354 uint32_t version_; | 340 uint32_t version_; |
355 | 341 |
356 DISALLOW_COPY_AND_ASSIGN(InterfacePtrState); | 342 DISALLOW_COPY_AND_ASSIGN(InterfacePtrState); |
357 }; | 343 }; |
358 | 344 |
359 } // namespace internal | 345 } // namespace internal |
360 } // namespace mojo | 346 } // namespace mojo |
361 | 347 |
362 #endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_STATE_H_ | 348 #endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_STATE_H_ |
OLD | NEW |