| 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_INTERFACE_PTR_H_ | 5 #ifndef MOJO_PUBLIC_CPP_BINDINGS_INTERFACE_PTR_H_ |
| 6 #define MOJO_PUBLIC_CPP_BINDINGS_INTERFACE_PTR_H_ | 6 #define MOJO_PUBLIC_CPP_BINDINGS_INTERFACE_PTR_H_ |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 107 // end of the message pipe asynchronously. This does nothing if it's already | 107 // end of the message pipe asynchronously. This does nothing if it's already |
| 108 // known that the remote side supports the specified version, i.e., if | 108 // known that the remote side supports the specified version, i.e., if |
| 109 // |version <= this->version()|. | 109 // |version <= this->version()|. |
| 110 // | 110 // |
| 111 // After calling RequireVersion() with a version not supported by the remote | 111 // After calling RequireVersion() with a version not supported by the remote |
| 112 // side, all subsequent calls to interface methods will be ignored. | 112 // side, all subsequent calls to interface methods will be ignored. |
| 113 void RequireVersion(uint32_t version) { | 113 void RequireVersion(uint32_t version) { |
| 114 internal_state_.RequireVersion(version); | 114 internal_state_.RequireVersion(version); |
| 115 } | 115 } |
| 116 | 116 |
| 117 // Sends a no-op message on the underlying message pipe and runs the current |
| 118 // message loop until its response is received. This can be used in tests to |
| 119 // verify that no message was sent on a message pipe in response to some |
| 120 // stimulus. |
| 121 void FlushForTesting() { internal_state_.FlushForTesting(); } |
| 122 |
| 117 // Closes the bound message pipe (if any) and returns the pointer to the | 123 // Closes the bound message pipe (if any) and returns the pointer to the |
| 118 // unbound state. | 124 // unbound state. |
| 119 void reset() { | 125 void reset() { |
| 120 State doomed; | 126 State doomed; |
| 121 internal_state_.Swap(&doomed); | 127 internal_state_.Swap(&doomed); |
| 122 } | 128 } |
| 123 | 129 |
| 124 // Whether there are any associated interfaces running on the pipe currently. | 130 // Whether there are any associated interfaces running on the pipe currently. |
| 125 bool HasAssociatedInterfaces() const { | 131 bool HasAssociatedInterfaces() const { |
| 126 return internal_state_.HasAssociatedInterfaces(); | 132 return internal_state_.HasAssociatedInterfaces(); |
| (...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 223 base::ThreadTaskRunnerHandle::Get()) { | 229 base::ThreadTaskRunnerHandle::Get()) { |
| 224 InterfacePtr<Interface> ptr; | 230 InterfacePtr<Interface> ptr; |
| 225 if (info.is_valid()) | 231 if (info.is_valid()) |
| 226 ptr.Bind(std::move(info), std::move(runner)); | 232 ptr.Bind(std::move(info), std::move(runner)); |
| 227 return std::move(ptr); | 233 return std::move(ptr); |
| 228 } | 234 } |
| 229 | 235 |
| 230 } // namespace mojo | 236 } // namespace mojo |
| 231 | 237 |
| 232 #endif // MOJO_PUBLIC_CPP_BINDINGS_INTERFACE_PTR_H_ | 238 #endif // MOJO_PUBLIC_CPP_BINDINGS_INTERFACE_PTR_H_ |
| OLD | NEW |