Index: mojo/public/js/lib/pipe_control_message_handler.js |
diff --git a/mojo/public/js/lib/pipe_control_message_handler.js b/mojo/public/js/lib/pipe_control_message_handler.js |
deleted file mode 100644 |
index 2eb45d16266fe8fddf19696af797d683a28d4efd..0000000000000000000000000000000000000000 |
--- a/mojo/public/js/lib/pipe_control_message_handler.js |
+++ /dev/null |
@@ -1,61 +0,0 @@ |
-// Copyright 2017 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-define("mojo/public/js/lib/pipe_control_message_handler", [ |
- "mojo/public/interfaces/bindings/pipe_control_messages.mojom", |
- "mojo/public/js/codec", |
- "mojo/public/js/interface_types", |
- "mojo/public/js/validator", |
-], function(pipeControlMessages, codec, types, validator) { |
- |
- var Validator = validator.Validator; |
- |
- function validateControlRequestWithoutResponse(message) { |
- var messageValidator = new Validator(message); |
- var error = messageValidator.validateMessageIsRequestWithoutResponse(); |
- if (error != validator.validationError.NONE) { |
- throw error; |
- } |
- |
- if (message.getName() != pipeControlMessages.kRunOrClosePipeMessageId) { |
- throw new Error("Control message name is not kRunOrClosePipeMessageId"); |
- } |
- |
- // Validate payload. |
- error = pipeControlMessages.RunOrClosePipeMessageParams.validate( |
- messageValidator, message.getHeaderNumBytes()); |
- if (error != validator.validationError.NONE) { |
- throw error; |
- } |
- } |
- |
- function runOrClosePipe(message, delegate) { |
- var reader = new codec.MessageReader(message); |
- var runOrClosePipeMessageParams = reader.decodeStruct( |
- pipeControlMessages.RunOrClosePipeMessageParams); |
- var event = runOrClosePipeMessageParams.input |
- .peer_associated_endpoint_closed_event; |
- return delegate.onPeerAssociatedEndpointClosed(event.id, |
- event.disconnect_reason); |
- } |
- |
- function isPipeControlMessage(message) { |
- return !types.isValidInterfaceId(message.getInterfaceId()); |
- } |
- |
- function PipeControlMessageHandler(delegate) { |
- this.delegate_ = delegate; |
- } |
- |
- PipeControlMessageHandler.prototype.accept = function(message) { |
- validateControlRequestWithoutResponse(message); |
- return runOrClosePipe(message, this.delegate_); |
- }; |
- |
- var exports = {}; |
- exports.PipeControlMessageHandler = PipeControlMessageHandler; |
- exports.isPipeControlMessage = isPipeControlMessage; |
- |
- return exports; |
-}); |