Index: third_party/mojo/src/mojo/public/dart/lib/src/control_message.dart |
diff --git a/third_party/mojo/src/mojo/public/dart/lib/src/control_message.dart b/third_party/mojo/src/mojo/public/dart/lib/src/control_message.dart |
deleted file mode 100644 |
index de71a980423903c3b9205b585f4c6c9d03b91bd5..0000000000000000000000000000000000000000 |
--- a/third_party/mojo/src/mojo/public/dart/lib/src/control_message.dart |
+++ /dev/null |
@@ -1,61 +0,0 @@ |
-// Copyright 2015 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. |
- |
-part of bindings; |
- |
-// Handles InterfaceControlMessages for a stub. |
-class ControlMessageHandler { |
- static bool isControlMessage(ServiceMessage message) => |
- _isRun(message) || _isRunOrClose(message); |
- |
- static bool _isRun(ServiceMessage message) => |
- (message.header.type == icm.kRunMessageId); |
- |
- static bool _isRunOrClose(ServiceMessage message) => |
- (message.header.type == icm.kRunOrClosePipeMessageId); |
- |
- static Future<Message> handleMessage(Stub stub, |
- int interface_version, |
- ServiceMessage message) { |
- assert(isControlMessage(message)); |
- if (_isRun(message)) { |
- return _handleRun(stub, interface_version, message); |
- } else { |
- assert(_isRunOrClose(message)); |
- return _handleRunOrClose(stub, interface_version, message); |
- } |
- } |
- |
- static Future<Message> _handleRun(Stub stub, |
- int interface_version, |
- ServiceMessage message) { |
- // Construct RunMessage response. |
- var response = new icm.RunResponseMessageParams(); |
- response.reserved0 = 16; |
- response.reserved1 = 0; |
- response.queryVersionResult = new icm.QueryVersionResult(); |
- response.queryVersionResult.version = interface_version; |
- // Return response. |
- return new Future.value( |
- stub.buildResponseWithId(response, |
- icm.kRunMessageId, |
- message.header.requestId, |
- MessageHeader.kMessageIsResponse)); |
- } |
- |
- static Future<Message> _handleRunOrClose(Stub stub, |
- int interface_version, |
- ServiceMessage message) { |
- // Deserialize message. |
- var params = icm.RunOrClosePipeMessageParams.deserialize(message.payload); |
- // Grab required version. |
- var requiredVersion = params.requireVersion.version; |
- if (interface_version >= requiredVersion) { |
- // Stub meets the requirements. |
- return; |
- } |
- // Stub does not implement required version. Close the pipe immediately. |
- stub.close(immediate: true); |
- } |
-} |