| 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_BINDING_H_ | 5 #ifndef MOJO_PUBLIC_CPP_BINDINGS_BINDING_H_ |
| 6 #define MOJO_PUBLIC_CPP_BINDINGS_BINDING_H_ | 6 #define MOJO_PUBLIC_CPP_BINDINGS_BINDING_H_ |
| 7 | 7 |
| 8 #include <string> |
| 8 #include <utility> | 9 #include <utility> |
| 9 | 10 |
| 10 #include "base/callback_forward.h" | 11 #include "base/callback_forward.h" |
| 11 #include "base/macros.h" | 12 #include "base/macros.h" |
| 12 #include "base/memory/ref_counted.h" | 13 #include "base/memory/ref_counted.h" |
| 13 #include "base/single_thread_task_runner.h" | 14 #include "base/single_thread_task_runner.h" |
| 14 #include "base/threading/thread_task_runner_handle.h" | 15 #include "base/threading/thread_task_runner_handle.h" |
| 16 #include "mojo/public/cpp/bindings/connection_error_callback.h" |
| 15 #include "mojo/public/cpp/bindings/interface_ptr.h" | 17 #include "mojo/public/cpp/bindings/interface_ptr.h" |
| 16 #include "mojo/public/cpp/bindings/interface_ptr_info.h" | 18 #include "mojo/public/cpp/bindings/interface_ptr_info.h" |
| 17 #include "mojo/public/cpp/bindings/interface_request.h" | 19 #include "mojo/public/cpp/bindings/interface_request.h" |
| 18 #include "mojo/public/cpp/bindings/lib/binding_state.h" | 20 #include "mojo/public/cpp/bindings/lib/binding_state.h" |
| 19 #include "mojo/public/cpp/system/core.h" | 21 #include "mojo/public/cpp/system/core.h" |
| 20 | 22 |
| 21 namespace mojo { | 23 namespace mojo { |
| 22 | 24 |
| 23 class AssociatedGroup; | 25 class AssociatedGroup; |
| 24 class MessageReceiver; | 26 class MessageReceiver; |
| (...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 191 bool WaitForIncomingMethodCall( | 193 bool WaitForIncomingMethodCall( |
| 192 MojoDeadline deadline = MOJO_DEADLINE_INDEFINITE) { | 194 MojoDeadline deadline = MOJO_DEADLINE_INDEFINITE) { |
| 193 CHECK(!HasAssociatedInterfaces()); | 195 CHECK(!HasAssociatedInterfaces()); |
| 194 return internal_state_.WaitForIncomingMethodCall(deadline); | 196 return internal_state_.WaitForIncomingMethodCall(deadline); |
| 195 } | 197 } |
| 196 | 198 |
| 197 // Closes the message pipe that was previously bound. Put this object into a | 199 // Closes the message pipe that was previously bound. Put this object into a |
| 198 // state where it can be rebound to a new pipe. | 200 // state where it can be rebound to a new pipe. |
| 199 void Close() { internal_state_.Close(); } | 201 void Close() { internal_state_.Close(); } |
| 200 | 202 |
| 203 // Similar to the method above, but also specifies a disconnect reason. |
| 204 void CloseWithReason(uint32_t custom_reason, const std::string& description) { |
| 205 internal_state_.CloseWithReason(custom_reason, description); |
| 206 } |
| 207 |
| 201 // Unbinds the underlying pipe from this binding and returns it so it can be | 208 // Unbinds the underlying pipe from this binding and returns it so it can be |
| 202 // used in another context, such as on another thread or with a different | 209 // used in another context, such as on another thread or with a different |
| 203 // implementation. Put this object into a state where it can be rebound to a | 210 // implementation. Put this object into a state where it can be rebound to a |
| 204 // new pipe. | 211 // new pipe. |
| 205 // | 212 // |
| 206 // This method may only be called if the object has been bound to a message | 213 // This method may only be called if the object has been bound to a message |
| 207 // pipe and there are no associated interfaces running. | 214 // pipe and there are no associated interfaces running. |
| 208 // | 215 // |
| 209 // TODO(yzshen): For now, users need to make sure there is no one holding | 216 // TODO(yzshen): For now, users need to make sure there is no one holding |
| 210 // on to associated interface endpoint handles at both sides of the | 217 // on to associated interface endpoint handles at both sides of the |
| 211 // message pipe in order to call this method. We need a way to forcefully | 218 // message pipe in order to call this method. We need a way to forcefully |
| 212 // invalidate associated interface endpoint handles. | 219 // invalidate associated interface endpoint handles. |
| 213 InterfaceRequest<Interface> Unbind() { | 220 InterfaceRequest<Interface> Unbind() { |
| 214 CHECK(!HasAssociatedInterfaces()); | 221 CHECK(!HasAssociatedInterfaces()); |
| 215 return internal_state_.Unbind(); | 222 return internal_state_.Unbind(); |
| 216 } | 223 } |
| 217 | 224 |
| 218 // Sets an error handler that will be called if a connection error occurs on | 225 // Sets an error handler that will be called if a connection error occurs on |
| 219 // the bound message pipe. | 226 // the bound message pipe. |
| 220 // | 227 // |
| 221 // This method may only be called after this Binding has been bound to a | 228 // This method may only be called after this Binding has been bound to a |
| 222 // message pipe. The error handler will be reset when this Binding is unbound | 229 // message pipe. The error handler will be reset when this Binding is unbound |
| 223 // or closed. | 230 // or closed. |
| 224 void set_connection_error_handler(const base::Closure& error_handler) { | 231 void set_connection_error_handler(const base::Closure& error_handler) { |
| 225 DCHECK(is_bound()); | 232 DCHECK(is_bound()); |
| 226 internal_state_.set_connection_error_handler(error_handler); | 233 internal_state_.set_connection_error_handler(error_handler); |
| 227 } | 234 } |
| 228 | 235 |
| 236 void set_connection_error_with_reason_handler( |
| 237 const ConnectionErrorWithReasonCallback& error_handler) { |
| 238 DCHECK(is_bound()); |
| 239 internal_state_.set_connection_error_with_reason_handler(error_handler); |
| 240 } |
| 241 |
| 229 // Returns the interface implementation that was previously specified. Caller | 242 // Returns the interface implementation that was previously specified. Caller |
| 230 // does not take ownership. | 243 // does not take ownership. |
| 231 Interface* impl() { return internal_state_.impl(); } | 244 Interface* impl() { return internal_state_.impl(); } |
| 232 | 245 |
| 233 // Indicates whether the binding has been completed (i.e., whether a message | 246 // Indicates whether the binding has been completed (i.e., whether a message |
| 234 // pipe has been bound to the implementation). | 247 // pipe has been bound to the implementation). |
| 235 bool is_bound() const { return internal_state_.is_bound(); } | 248 bool is_bound() const { return internal_state_.is_bound(); } |
| 236 | 249 |
| 237 // Returns the value of the handle currently bound to this Binding which can | 250 // Returns the value of the handle currently bound to this Binding which can |
| 238 // be used to make explicit Wait/WaitMany calls. Requires that the Binding be | 251 // be used to make explicit Wait/WaitMany calls. Requires that the Binding be |
| (...skipping 21 matching lines...) Expand all Loading... |
| 260 private: | 273 private: |
| 261 internal::BindingState<Interface, Interface::PassesAssociatedKinds_> | 274 internal::BindingState<Interface, Interface::PassesAssociatedKinds_> |
| 262 internal_state_; | 275 internal_state_; |
| 263 | 276 |
| 264 DISALLOW_COPY_AND_ASSIGN(Binding); | 277 DISALLOW_COPY_AND_ASSIGN(Binding); |
| 265 }; | 278 }; |
| 266 | 279 |
| 267 } // namespace mojo | 280 } // namespace mojo |
| 268 | 281 |
| 269 #endif // MOJO_PUBLIC_CPP_BINDINGS_BINDING_H_ | 282 #endif // MOJO_PUBLIC_CPP_BINDINGS_BINDING_H_ |
| OLD | NEW |