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 define("mojo/public/js/bindings/router", [ | 5 define("mojo/public/js/bindings/router", [ |
6 "mojo/public/js/bindings/codec", | 6 "mojo/public/js/bindings/codec", |
7 "mojo/public/js/bindings/connector", | 7 "mojo/public/js/bindings/connector", |
8 "mojo/public/js/bindings/validator", | 8 "mojo/public/js/bindings/validator", |
9 ], function(codec, connector, validator) { | 9 ], function(codec, connector, validator) { |
10 | 10 |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
55 Router.prototype.setIncomingReceiver = function(receiver) { | 55 Router.prototype.setIncomingReceiver = function(receiver) { |
56 this.incomingReceiver_ = receiver; | 56 this.incomingReceiver_ = receiver; |
57 }; | 57 }; |
58 | 58 |
59 Router.prototype.encounteredError = function() { | 59 Router.prototype.encounteredError = function() { |
60 return this.connector_.encounteredError(); | 60 return this.connector_.encounteredError(); |
61 }; | 61 }; |
62 | 62 |
63 Router.prototype.handleIncomingMessage_ = function(message) { | 63 Router.prototype.handleIncomingMessage_ = function(message) { |
64 var v = new validator.Validator(message); | 64 var v = new validator.Validator(message); |
65 if (v.validateMessage() !== validator.validationError.NONE) | 65 if (v.validateMessageHeader() !== validator.validationError.NONE) |
66 this.close(); | 66 this.close(); |
67 | 67 |
68 if (message.expectsResponse()) { | 68 if (message.expectsResponse()) { |
69 if (this.incomingReceiver_) { | 69 if (this.incomingReceiver_) { |
70 this.incomingReceiver_.acceptWithResponder(message, this); | 70 this.incomingReceiver_.acceptWithResponder(message, this); |
71 } else { | 71 } else { |
72 // If we receive a request expecting a response when the client is not | 72 // If we receive a request expecting a response when the client is not |
73 // listening, then we have no choice but to tear down the pipe. | 73 // listening, then we have no choice but to tear down the pipe. |
74 this.close(); | 74 this.close(); |
75 } | 75 } |
(...skipping 12 matching lines...) Expand all Loading... |
88 Router.prototype.handleConnectionError_ = function(result) { | 88 Router.prototype.handleConnectionError_ = function(result) { |
89 for (var each in this.responders_) | 89 for (var each in this.responders_) |
90 this.responders_[each].reject(result); | 90 this.responders_[each].reject(result); |
91 this.close(); | 91 this.close(); |
92 }; | 92 }; |
93 | 93 |
94 var exports = {}; | 94 var exports = {}; |
95 exports.Router = Router; | 95 exports.Router = Router; |
96 return exports; | 96 return exports; |
97 }); | 97 }); |
OLD | NEW |