Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(882)

Unified Diff: mojo/public/dart/mojo/lib/src/control_message.dart

Issue 1441033002: Move mojo and mojom from mojo/public/dart to mojo/dart/packages (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/public/dart/mojo/lib/src/codec.dart ('k') | mojo/public/dart/mojo/lib/src/data_pipe.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/public/dart/mojo/lib/src/control_message.dart
diff --git a/mojo/public/dart/mojo/lib/src/control_message.dart b/mojo/public/dart/mojo/lib/src/control_message.dart
deleted file mode 100644
index e5cd5827dc7b98f72d4a0573ff83fea34b1b5467..0000000000000000000000000000000000000000
--- a/mojo/public/dart/mojo/lib/src/control_message.dart
+++ /dev/null
@@ -1,60 +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 _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 does not implement required version. Close the pipe immediately.
- stub.close(immediate: true);
- }
- return null;
- }
-}
« no previous file with comments | « mojo/public/dart/mojo/lib/src/codec.dart ('k') | mojo/public/dart/mojo/lib/src/data_pipe.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698