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

Side by Side Diff: mojo/dart/packages/mojo/lib/src/control_message.dart

Issue 1983453002: Dart: Refactor Stubs (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Merge Created 4 years, 7 months 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 unified diff | Download patch
« no previous file with comments | « mojo/dart/packages/mojo/lib/src/codec.dart ('k') | mojo/dart/packages/mojo/lib/src/proxy.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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 part of bindings; 5 part of bindings;
6 6
7 // Handles InterfaceControlMessages for a stub. 7 // Handles InterfaceControlMessages for a stub.
8 class ControlMessageHandler { 8 class ControlMessageHandler {
9 static bool isControlMessage(ServiceMessage message) => 9 static bool isControlMessage(ServiceMessage message) =>
10 _isRun(message) || _isRunOrClose(message); 10 _isRun(message) || _isRunOrClose(message);
11 11
12 static bool _isRun(ServiceMessage message) => 12 static bool _isRun(ServiceMessage message) =>
13 (message.header.type == icm.kRunMessageId); 13 (message.header.type == icm.kRunMessageId);
14 14
15 static bool _isRunOrClose(ServiceMessage message) => 15 static bool _isRunOrClose(ServiceMessage message) =>
16 (message.header.type == icm.kRunOrClosePipeMessageId); 16 (message.header.type == icm.kRunOrClosePipeMessageId);
17 17
18 static Future<Message> handleMessage(Stub stub, 18 static Future<Message> handleMessage(StubControl stubControl,
19 int interface_version, 19 int interface_version,
20 ServiceMessage message) { 20 ServiceMessage message) {
21 assert(isControlMessage(message)); 21 assert(isControlMessage(message));
22 if (_isRun(message)) { 22 if (_isRun(message)) {
23 return _handleRun(stub, interface_version, message); 23 return _handleRun(stubControl, interface_version, message);
24 } else { 24 } else {
25 assert(_isRunOrClose(message)); 25 assert(_isRunOrClose(message));
26 return _handleRunOrClose(stub, interface_version, message); 26 return _handleRunOrClose(stubControl, interface_version, message);
27 } 27 }
28 } 28 }
29 29
30 static Future<Message> _handleRun(Stub stub, 30 static Future<Message> _handleRun(StubControl stubControl,
31 int interface_version, 31 int interface_version,
32 ServiceMessage message) { 32 ServiceMessage message) {
33 // Construct RunMessage response. 33 // Construct RunMessage response.
34 var response = new icm.RunResponseMessageParams(); 34 var response = new icm.RunResponseMessageParams();
35 response.reserved0 = 16; 35 response.reserved0 = 16;
36 response.reserved1 = 0; 36 response.reserved1 = 0;
37 response.queryVersionResult = new icm.QueryVersionResult(); 37 response.queryVersionResult = new icm.QueryVersionResult();
38 response.queryVersionResult.version = interface_version; 38 response.queryVersionResult.version = interface_version;
39 // Return response. 39 // Return response.
40 return new Future.value( 40 return new Future.value(
41 stub.buildResponseWithId(response, 41 stubControl.buildResponseWithId(response,
42 icm.kRunMessageId, 42 icm.kRunMessageId,
43 message.header.requestId, 43 message.header.requestId,
44 MessageHeader.kMessageIsResponse)); 44 MessageHeader.kMessageIsResponse));
45 } 45 }
46 46
47 static Future _handleRunOrClose(Stub stub, 47 static Future _handleRunOrClose(StubControl stubControl,
48 int interface_version, 48 int interface_version,
49 ServiceMessage message) { 49 ServiceMessage message) {
50 // Deserialize message. 50 // Deserialize message.
51 var params = icm.RunOrClosePipeMessageParams.deserialize(message.payload); 51 var params = icm.RunOrClosePipeMessageParams.deserialize(message.payload);
52 // Grab required version. 52 // Grab required version.
53 var requiredVersion = params.requireVersion.version; 53 var requiredVersion = params.requireVersion.version;
54 if (interface_version < requiredVersion) { 54 if (interface_version < requiredVersion) {
55 // Stub does not implement required version. Close the pipe immediately. 55 // Stub does not implement required version. Close the pipe immediately.
56 stub.close(immediate: true); 56 stubControl.close(immediate: true);
57 } 57 }
58 return null; 58 return null;
59 } 59 }
60 } 60 }
OLDNEW
« no previous file with comments | « mojo/dart/packages/mojo/lib/src/codec.dart ('k') | mojo/dart/packages/mojo/lib/src/proxy.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698