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

Unified Diff: mojo/public/cpp/bindings/lib/interface_ptr_state.h

Issue 2318793002: Mojo C++ bindings: support disconnect with a reason. (Closed)
Patch Set: . Created 4 years, 3 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/public/cpp/bindings/lib/interface_endpoint_client.cc ('k') | mojo/public/cpp/bindings/lib/router.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/public/cpp/bindings/lib/interface_ptr_state.h
diff --git a/mojo/public/cpp/bindings/lib/interface_ptr_state.h b/mojo/public/cpp/bindings/lib/interface_ptr_state.h
index c701e5a60bd816719d39d70a48298a62b5bec429..8fb8b068508cb2eada5c0ed145819f38864364b2 100644
--- a/mojo/public/cpp/bindings/lib/interface_ptr_state.h
+++ b/mojo/public/cpp/bindings/lib/interface_ptr_state.h
@@ -9,6 +9,7 @@
#include <algorithm> // For |std::swap()|.
#include <memory>
+#include <string>
#include <utility>
#include "base/bind.h"
@@ -19,6 +20,7 @@
#include "base/memory/ref_counted.h"
#include "base/single_thread_task_runner.h"
#include "mojo/public/cpp/bindings/associated_group.h"
+#include "mojo/public/cpp/bindings/connection_error_callback.h"
#include "mojo/public/cpp/bindings/filter_chain.h"
#include "mojo/public/cpp/bindings/interface_endpoint_client.h"
#include "mojo/public/cpp/bindings/interface_id.h"
@@ -86,6 +88,13 @@ class InterfacePtrState<Interface, false> {
router_->control_message_proxy()->FlushForTesting();
}
+ void SendDisconnectReason(uint32_t custom_reason,
+ const std::string& description) {
+ ConfigureProxyIfNecessary();
+ router_->control_message_proxy()->SendDisconnectReason(custom_reason,
+ description);
+ }
+
void Swap(InterfacePtrState* other) {
using std::swap;
swap(other->proxy_, proxy_);
@@ -130,6 +139,14 @@ class InterfacePtrState<Interface, false> {
router_->set_connection_error_handler(error_handler);
}
+ void set_connection_error_with_reason_handler(
+ const ConnectionErrorWithReasonCallback& error_handler) {
+ ConfigureProxyIfNecessary();
+
+ DCHECK(router_);
+ router_->set_connection_error_with_reason_handler(error_handler);
+ }
+
// Returns true if bound and awaiting a response to a message.
bool has_pending_callbacks() const {
return router_ && router_->has_pending_responders();
@@ -234,6 +251,13 @@ class InterfacePtrState<Interface, true> {
endpoint_client_->control_message_proxy()->FlushForTesting();
}
+ void SendDisconnectReason(uint32_t custom_reason,
+ const std::string& description) {
+ ConfigureProxyIfNecessary();
+ endpoint_client_->control_message_proxy()->SendDisconnectReason(
+ custom_reason, description);
+ }
+
void Swap(InterfacePtrState* other) {
using std::swap;
swap(other->router_, router_);
@@ -284,6 +308,14 @@ class InterfacePtrState<Interface, true> {
endpoint_client_->set_connection_error_handler(error_handler);
}
+ void set_connection_error_with_reason_handler(
+ const ConnectionErrorWithReasonCallback& error_handler) {
+ ConfigureProxyIfNecessary();
+
+ DCHECK(endpoint_client_);
+ endpoint_client_->set_connection_error_with_reason_handler(error_handler);
+ }
+
// Returns true if bound and awaiting a response to a message.
bool has_pending_callbacks() const {
return endpoint_client_ && endpoint_client_->has_pending_responders();
« no previous file with comments | « mojo/public/cpp/bindings/lib/interface_endpoint_client.cc ('k') | mojo/public/cpp/bindings/lib/router.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698