| Index: mojo/public/cpp/bindings/lib/interface_impl_internal.h
|
| diff --git a/mojo/public/cpp/bindings/lib/interface_impl_internal.h b/mojo/public/cpp/bindings/lib/interface_impl_internal.h
|
| index 50fe5665360b3f6bd11950503b52311d16592eaa..c47c2e7d895f398c4981e738b804354067d8c6a2 100644
|
| --- a/mojo/public/cpp/bindings/lib/interface_impl_internal.h
|
| +++ b/mojo/public/cpp/bindings/lib/interface_impl_internal.h
|
| @@ -7,6 +7,8 @@
|
|
|
| #include "mojo/public/cpp/bindings/error_handler.h"
|
| #include "mojo/public/cpp/bindings/interface_ptr.h"
|
| +#include "mojo/public/cpp/bindings/lib/filter_chain.h"
|
| +#include "mojo/public/cpp/bindings/lib/message_header_validator.h"
|
| #include "mojo/public/cpp/system/macros.h"
|
|
|
| namespace mojo {
|
| @@ -42,7 +44,12 @@ class InterfaceImplState : public ErrorHandler {
|
| MojoAsyncWaiter* waiter) {
|
| assert(!router_);
|
|
|
| - router_ = new Router(handle.Pass(), waiter);
|
| + FilterChain validators;
|
| + validators.Append(new MessageHeaderValidator)
|
| + .Append(new typename Interface::RequestValidator_)
|
| + .Append(new typename Interface::Client_::ResponseValidator_);
|
| +
|
| + router_ = new Router(handle.Pass(), validators.Pass(), waiter);
|
| router_->set_incoming_receiver(&stub_);
|
| router_->set_error_handler(this);
|
|
|
| @@ -59,7 +66,7 @@ class InterfaceImplState : public ErrorHandler {
|
| OnConnectionError();
|
| }
|
|
|
| - internal::Router* router_;
|
| + Router* router_;
|
| typename Interface::Client_::Proxy_* proxy_;
|
| typename Interface::Stub_ stub_;
|
|
|
|
|