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

Side by Side Diff: third_party/mojo/src/mojo/public/cpp/bindings/interface_impl.h

Issue 1311043003: Update mojo sdk to rev c02a28868825edfa57ab77947b8cb15e741c5598 (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 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 unified diff | Download patch
OLDNEW
(Empty)
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
3 // found in the LICENSE file.
4
5 #ifndef MOJO_PUBLIC_CPP_BINDINGS_INTERFACE_IMPL_H_
6 #define MOJO_PUBLIC_CPP_BINDINGS_INTERFACE_IMPL_H_
7
8 #include "mojo/public/cpp/bindings/binding.h"
9 #include "mojo/public/cpp/bindings/interface_ptr_info.h"
10 #include "mojo/public/cpp/bindings/interface_request.h"
11 #include "mojo/public/cpp/environment/environment.h"
12 #include "mojo/public/cpp/system/macros.h"
13
14 namespace mojo {
15
16 // DEPRECATED! Please use mojo::Binding instead of InterfaceImpl<> in new code.
17 //
18 // InterfaceImpl<..> is designed to be the base class of an interface
19 // implementation. It may be bound to a pipe or a proxy, see BindToPipe and
20 // BindToProxy.
21 template <typename Interface>
22 class InterfaceImpl : public Interface, public ErrorHandler {
23 public:
24 using ImplementedInterface = Interface;
25
26 InterfaceImpl() : binding_(this), error_handler_impl_(this) {
27 binding_.set_error_handler(&error_handler_impl_);
28 }
29 virtual ~InterfaceImpl() {}
30
31 void BindToHandle(
32 ScopedMessagePipeHandle handle,
33 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
34 binding_.Bind(handle.Pass(), waiter);
35 }
36
37 bool WaitForIncomingMethodCall() {
38 return binding_.WaitForIncomingMethodCall();
39 }
40
41 internal::Router* internal_router() { return binding_.internal_router(); }
42
43 // Implements ErrorHandler.
44 //
45 // Called when the underlying pipe is closed. After this point no more
46 // calls will be made on Interface and all responses will be silently ignored.
47 void OnConnectionError() override {}
48
49 void set_delete_on_error(bool delete_on_error) {
50 error_handler_impl_.set_delete_on_error(delete_on_error);
51 }
52
53 private:
54 class ErrorHandlerImpl : public ErrorHandler {
55 public:
56 explicit ErrorHandlerImpl(InterfaceImpl* impl) : impl_(impl) {}
57 ~ErrorHandlerImpl() override {}
58
59 // ErrorHandler implementation:
60 void OnConnectionError() override {
61 // If the the instance is not bound to the pipe, the instance might choose
62 // to delete the binding in the OnConnectionError handler, which would in
63 // turn delete |this|. Save the error behavior before invoking the error
64 // handler so we can correctly decide what to do.
65 bool delete_on_error = delete_on_error_;
66 impl_->OnConnectionError();
67 if (delete_on_error)
68 delete impl_;
69 }
70
71 void set_delete_on_error(bool delete_on_error) {
72 delete_on_error_ = delete_on_error;
73 }
74
75 private:
76 InterfaceImpl* impl_;
77 bool delete_on_error_ = false;
78
79 MOJO_DISALLOW_COPY_AND_ASSIGN(ErrorHandlerImpl);
80 };
81
82 Binding<Interface> binding_;
83 ErrorHandlerImpl error_handler_impl_;
84
85 MOJO_DISALLOW_COPY_AND_ASSIGN(InterfaceImpl);
86 };
87
88 // Takes an instance of an InterfaceImpl<..> subclass and binds it to the given
89 // MessagePipe. The instance is returned for convenience in member initializer
90 // lists, etc.
91 //
92 // If the pipe is closed, the instance's OnConnectionError method will be called
93 // and then the instance will be deleted.
94 //
95 // The instance is also bound to the current thread. Its methods will only be
96 // called on the current thread, and if the current thread exits, then the end
97 // point of the pipe will be closed and the error handler's OnConnectionError
98 // method will be called.
99 template <typename Impl>
100 Impl* BindToPipe(
101 Impl* instance,
102 ScopedMessagePipeHandle handle,
103 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
104 instance->set_delete_on_error(true);
105 instance->BindToHandle(handle.Pass(), waiter);
106 return instance;
107 }
108
109 // Like BindToPipe but does not delete the instance after a channel error.
110 template <typename Impl>
111 Impl* WeakBindToPipe(
112 Impl* instance,
113 ScopedMessagePipeHandle handle,
114 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
115 instance->BindToHandle(handle.Pass(), waiter);
116 return instance;
117 }
118
119 // Takes an instance of an InterfaceImpl<..> subclass and binds it to the given
120 // InterfacePtr<..>. The instance is returned for convenience in member
121 // initializer lists, etc. If the pipe is closed, the instance's
122 // OnConnectionError method will be called and then the instance will be
123 // deleted.
124 //
125 // The instance is also bound to the current thread. Its methods will only be
126 // called on the current thread, and if the current thread exits, then it will
127 // also be deleted, and along with it, its end point of the pipe will be closed.
128 template <typename Impl, typename Interface>
129 Impl* BindToProxy(
130 Impl* instance,
131 InterfacePtr<Interface>* ptr,
132 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
133 instance->set_delete_on_error(true);
134 WeakBindToProxy(instance, ptr, waiter);
135 return instance;
136 }
137
138 // Like BindToProxy but does not delete the instance after a channel error.
139 template <typename Impl, typename Interface>
140 Impl* WeakBindToProxy(
141 Impl* instance,
142 InterfacePtr<Interface>* ptr,
143 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
144 MessagePipe pipe;
145 ptr->Bind(InterfacePtrInfo<Interface>(pipe.handle0.Pass(), 0u), waiter);
146 instance->BindToHandle(pipe.handle1.Pass(), waiter);
147 return instance;
148 }
149
150 // Takes an instance of an InterfaceImpl<..> subclass and binds it to the given
151 // InterfaceRequest<..>. The instance is returned for convenience in member
152 // initializer lists, etc. If the pipe is closed, the instance's
153 // OnConnectionError method will be called and then the instance will be
154 // deleted.
155 //
156 // The instance is also bound to the current thread. Its methods will only be
157 // called on the current thread, and if the current thread exits, then it will
158 // also be deleted, and along with it, its end point of the pipe will be closed.
159 template <typename Impl, typename Interface>
160 Impl* BindToRequest(
161 Impl* instance,
162 InterfaceRequest<Interface>* request,
163 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
164 return BindToPipe(instance, request->PassMessagePipe(), waiter);
165 }
166
167 // Like BindToRequest but does not delete the instance after a channel error.
168 template <typename Impl, typename Interface>
169 Impl* WeakBindToRequest(
170 Impl* instance,
171 InterfaceRequest<Interface>* request,
172 const MojoAsyncWaiter* waiter = Environment::GetDefaultAsyncWaiter()) {
173 return WeakBindToPipe(instance, request->PassMessagePipe(), waiter);
174 }
175
176 } // namespace mojo
177
178 #endif // MOJO_PUBLIC_CPP_BINDINGS_INTERFACE_IMPL_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698