Index: mojo/public/cpp/bindings/lib/router.cc |
diff --git a/mojo/public/cpp/bindings/lib/router.cc b/mojo/public/cpp/bindings/lib/router.cc |
index ec68bba9459bf2b73754a9ee1ec648022ebb1227..74dced1dcf13d69e71a17b3dbe0bfa77e5a2cc2d 100644 |
--- a/mojo/public/cpp/bindings/lib/router.cc |
+++ b/mojo/public/cpp/bindings/lib/router.cc |
@@ -62,13 +62,17 @@ bool Router::HandleIncomingMessageThunk::AcceptWithResponder( |
// ---------------------------------------------------------------------------- |
-Router::Router(ScopedMessagePipeHandle message_pipe, MojoAsyncWaiter* waiter) |
- : connector_(message_pipe.Pass(), waiter), |
+Router::Router(ScopedMessagePipeHandle message_pipe, |
+ FilterChain validators, |
+ MojoAsyncWaiter* waiter) |
+ : thunk_(this), |
+ validators_(validators.Pass()), |
darin (slow to review)
2014/05/14 06:51:51
s/validators/filters/
yzshen1
2014/05/14 08:14:03
Done.
|
+ connector_(message_pipe.Pass(), waiter), |
weak_self_(this), |
incoming_receiver_(NULL), |
- thunk_(this), |
next_request_id_(0) { |
- connector_.set_incoming_receiver(&thunk_); |
+ validators_.set_sink(&thunk_); |
+ connector_.set_incoming_receiver(validators_.GetHead()); |
darin (slow to review)
2014/05/14 06:51:51
maybe set_sink and GetHead could be combined since
yzshen1
2014/05/14 08:14:03
FilterChain was implemented to work correctly even
|
} |
Router::~Router() { |