| 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_INTERNAL_H_ | 5 #ifndef MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_INTERNAL_H_ |
| 6 #define MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_INTERNAL_H_ | 6 #define MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_INTERNAL_H_ |
| 7 | 7 |
| 8 #include <algorithm> // For |std::swap()|. | 8 #include <algorithm> // For |std::swap()|. |
| 9 | 9 |
| 10 #include "mojo/public/cpp/bindings/lib/filter_chain.h" | 10 #include "mojo/public/cpp/bindings/lib/filter_chain.h" |
| 11 #include "mojo/public/cpp/bindings/lib/message_header_validator.h" | 11 #include "mojo/public/cpp/bindings/lib/message_header_validator.h" |
| 12 #include "mojo/public/cpp/bindings/lib/router.h" | 12 #include "mojo/public/cpp/bindings/lib/router.h" |
| 13 #include "mojo/public/cpp/environment/logging.h" | 13 #include "mojo/public/cpp/environment/logging.h" |
| 14 | 14 |
| 15 struct MojoAsyncWaiter; | 15 struct MojoAsyncWaiter; |
| 16 | 16 |
| 17 namespace mojo { | 17 namespace mojo { |
| 18 namespace internal { | 18 namespace internal { |
| 19 | 19 |
| 20 template <typename Interface> | 20 template <typename Interface> |
| 21 class InterfacePtrState { | 21 class InterfacePtrState { |
| 22 public: | 22 public: |
| 23 InterfacePtrState() : proxy_(NULL), router_(NULL), waiter_(NULL) {} | 23 InterfacePtrState() : proxy_(nullptr), router_(nullptr), waiter_(nullptr) {} |
| 24 | 24 |
| 25 ~InterfacePtrState() { | 25 ~InterfacePtrState() { |
| 26 // Destruction order matters here. We delete |proxy_| first, even though | 26 // Destruction order matters here. We delete |proxy_| first, even though |
| 27 // |router_| may have a reference to it, so that |~Interface| may have a | 27 // |router_| may have a reference to it, so that |~Interface| may have a |
| 28 // shot at generating new outbound messages (ie, invoking client methods). | 28 // shot at generating new outbound messages (ie, invoking client methods). |
| 29 delete proxy_; | 29 delete proxy_; |
| 30 delete router_; | 30 delete router_; |
| 31 } | 31 } |
| 32 | 32 |
| 33 Interface* instance() { | 33 Interface* instance() { |
| 34 ConfigureProxyIfNecessary(); | 34 ConfigureProxyIfNecessary(); |
| 35 | 35 |
| 36 // This will be NULL if the object is not bound. | 36 // This will be null if the object is not bound. |
| 37 return proxy_; | 37 return proxy_; |
| 38 } | 38 } |
| 39 | 39 |
| 40 void Swap(InterfacePtrState* other) { | 40 void Swap(InterfacePtrState* other) { |
| 41 std::swap(other->proxy_, proxy_); | 41 std::swap(other->proxy_, proxy_); |
| 42 std::swap(other->router_, router_); | 42 std::swap(other->router_, router_); |
| 43 handle_.swap(other->handle_); | 43 handle_.swap(other->handle_); |
| 44 std::swap(other->waiter_, waiter_); | 44 std::swap(other->waiter_, waiter_); |
| 45 } | 45 } |
| 46 | 46 |
| (...skipping 11 matching lines...) Expand all Loading... |
| 58 ConfigureProxyIfNecessary(); | 58 ConfigureProxyIfNecessary(); |
| 59 | 59 |
| 60 MOJO_DCHECK(router_); | 60 MOJO_DCHECK(router_); |
| 61 return router_->WaitForIncomingMessage(); | 61 return router_->WaitForIncomingMessage(); |
| 62 } | 62 } |
| 63 | 63 |
| 64 ScopedMessagePipeHandle PassMessagePipe() { | 64 ScopedMessagePipeHandle PassMessagePipe() { |
| 65 if (router_) | 65 if (router_) |
| 66 return router_->PassMessagePipe(); | 66 return router_->PassMessagePipe(); |
| 67 | 67 |
| 68 waiter_ = NULL; | 68 waiter_ = nullptr; |
| 69 return handle_.Pass(); | 69 return handle_.Pass(); |
| 70 } | 70 } |
| 71 | 71 |
| 72 bool is_bound() const { | 72 bool is_bound() const { |
| 73 return handle_.is_valid() || router_; | 73 return handle_.is_valid() || router_; |
| 74 } | 74 } |
| 75 | 75 |
| 76 void set_client(typename Interface::Client* client) { | 76 void set_client(typename Interface::Client* client) { |
| 77 ConfigureProxyIfNecessary(); | 77 ConfigureProxyIfNecessary(); |
| 78 | 78 |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 118 MOJO_DCHECK(!handle_.is_valid()); | 118 MOJO_DCHECK(!handle_.is_valid()); |
| 119 return; | 119 return; |
| 120 } | 120 } |
| 121 | 121 |
| 122 FilterChain filters; | 122 FilterChain filters; |
| 123 filters.Append<MessageHeaderValidator>(); | 123 filters.Append<MessageHeaderValidator>(); |
| 124 filters.Append<typename Interface::Client::RequestValidator_>(); | 124 filters.Append<typename Interface::Client::RequestValidator_>(); |
| 125 filters.Append<typename Interface::ResponseValidator_>(); | 125 filters.Append<typename Interface::ResponseValidator_>(); |
| 126 | 126 |
| 127 router_ = new Router(handle_.Pass(), filters.Pass(), waiter_); | 127 router_ = new Router(handle_.Pass(), filters.Pass(), waiter_); |
| 128 waiter_ = NULL; | 128 waiter_ = nullptr; |
| 129 | 129 |
| 130 ProxyWithStub* proxy = new ProxyWithStub(router_); | 130 ProxyWithStub* proxy = new ProxyWithStub(router_); |
| 131 router_->set_incoming_receiver(&proxy->stub); | 131 router_->set_incoming_receiver(&proxy->stub); |
| 132 | 132 |
| 133 proxy_ = proxy; | 133 proxy_ = proxy; |
| 134 } | 134 } |
| 135 | 135 |
| 136 ProxyWithStub* proxy_; | 136 ProxyWithStub* proxy_; |
| 137 Router* router_; | 137 Router* router_; |
| 138 | 138 |
| 139 // |proxy_| and |router_| are not initialized until read/write with the | 139 // |proxy_| and |router_| are not initialized until read/write with the |
| 140 // message pipe handle is needed. Before that, |handle_| and |waiter_| store | 140 // message pipe handle is needed. Before that, |handle_| and |waiter_| store |
| 141 // the arguments of Bind(). | 141 // the arguments of Bind(). |
| 142 ScopedMessagePipeHandle handle_; | 142 ScopedMessagePipeHandle handle_; |
| 143 const MojoAsyncWaiter* waiter_; | 143 const MojoAsyncWaiter* waiter_; |
| 144 | 144 |
| 145 MOJO_DISALLOW_COPY_AND_ASSIGN(InterfacePtrState); | 145 MOJO_DISALLOW_COPY_AND_ASSIGN(InterfacePtrState); |
| 146 }; | 146 }; |
| 147 | 147 |
| 148 } // namespace internal | 148 } // namespace internal |
| 149 } // namespace mojo | 149 } // namespace mojo |
| 150 | 150 |
| 151 #endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_INTERNAL_H_ | 151 #endif // MOJO_PUBLIC_CPP_BINDINGS_LIB_INTERFACE_PTR_INTERNAL_H_ |
| OLD | NEW |