OLD | NEW |
| (Empty) |
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 | |
3 // found in the LICENSE file. | |
4 | |
5 part of bindings; | |
6 | |
7 // Handles InterfaceControlMessages for a stub. | |
8 class ControlMessageHandler { | |
9 static bool isControlMessage(ServiceMessage message) => | |
10 _isRun(message) || _isRunOrClose(message); | |
11 | |
12 static bool _isRun(ServiceMessage message) => | |
13 (message.header.type == icm.kRunMessageId); | |
14 | |
15 static bool _isRunOrClose(ServiceMessage message) => | |
16 (message.header.type == icm.kRunOrClosePipeMessageId); | |
17 | |
18 static Future<Message> handleMessage(Stub stub, | |
19 int interface_version, | |
20 ServiceMessage message) { | |
21 assert(isControlMessage(message)); | |
22 if (_isRun(message)) { | |
23 return _handleRun(stub, interface_version, message); | |
24 } else { | |
25 assert(_isRunOrClose(message)); | |
26 return _handleRunOrClose(stub, interface_version, message); | |
27 } | |
28 } | |
29 | |
30 static Future<Message> _handleRun(Stub stub, | |
31 int interface_version, | |
32 ServiceMessage message) { | |
33 // Construct RunMessage response. | |
34 var response = new icm.RunResponseMessageParams(); | |
35 response.reserved0 = 16; | |
36 response.reserved1 = 0; | |
37 response.queryVersionResult = new icm.QueryVersionResult(); | |
38 response.queryVersionResult.version = interface_version; | |
39 // Return response. | |
40 return new Future.value( | |
41 stub.buildResponseWithId(response, | |
42 icm.kRunMessageId, | |
43 message.header.requestId, | |
44 MessageHeader.kMessageIsResponse)); | |
45 } | |
46 | |
47 static Future<Message> _handleRunOrClose(Stub stub, | |
48 int interface_version, | |
49 ServiceMessage message) { | |
50 // Deserialize message. | |
51 var params = icm.RunOrClosePipeMessageParams.deserialize(message.payload); | |
52 // Grab required version. | |
53 var requiredVersion = params.requireVersion.version; | |
54 if (interface_version >= requiredVersion) { | |
55 // Stub meets the requirements. | |
56 return; | |
57 } | |
58 // Stub does not implement required version. Close the pipe immediately. | |
59 stub.close(immediate: true); | |
60 } | |
61 } | |
OLD | NEW |