OLD | NEW |
1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 part of dart.io; | 5 part of dart.io; |
6 | 6 |
7 abstract class _IOResourceInfo { | 7 abstract class _IOResourceInfo { |
8 final String type; | 8 final String type; |
9 final int id; | 9 final int id; |
10 String get name; | 10 String get name; |
(...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
105 static FileClosed(_FileResourceInfo info) { | 105 static FileClosed(_FileResourceInfo info) { |
106 assert(openFiles.containsKey(info.id)); | 106 assert(openFiles.containsKey(info.id)); |
107 openFiles.remove(info.id); | 107 openFiles.remove(info.id); |
108 } | 108 } |
109 | 109 |
110 static Iterable<Map<String, String>> getOpenFilesList() { | 110 static Iterable<Map<String, String>> getOpenFilesList() { |
111 return new List.from(openFiles.values.map((e) => e.referenceValueMap)); | 111 return new List.from(openFiles.values.map((e) => e.referenceValueMap)); |
112 } | 112 } |
113 | 113 |
114 static Future<ServiceExtensionResponse> getOpenFiles(function, params) { | 114 static Future<ServiceExtensionResponse> getOpenFiles(function, params) { |
115 assert(function == '__getOpenFiles'); | 115 assert(function == 'ext.dart.io.getOpenFiles'); |
116 var data = {'type': '_openfiles', 'data': getOpenFilesList()}; | 116 var data = {'type': '_openfiles', 'data': getOpenFilesList()}; |
117 var json = JSON.encode(data); | 117 var json = JSON.encode(data); |
118 return new Future.value(new ServiceExtensionResponse.result(json)); | 118 return new Future.value(new ServiceExtensionResponse.result(json)); |
119 } | 119 } |
120 | 120 |
121 Map<String, String> getFileInfoMap() { | 121 Map<String, String> getFileInfoMap() { |
122 var result = fullValueMap; | 122 var result = fullValueMap; |
123 return result; | 123 return result; |
124 } | 124 } |
125 | 125 |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
175 static ProcessStopped(_ProcessResourceInfo info) { | 175 static ProcessStopped(_ProcessResourceInfo info) { |
176 assert(startedProcesses.containsKey(info.id)); | 176 assert(startedProcesses.containsKey(info.id)); |
177 startedProcesses.remove(info.id); | 177 startedProcesses.remove(info.id); |
178 } | 178 } |
179 | 179 |
180 static Iterable<Map<String, String>> getStartedProcessesList() => | 180 static Iterable<Map<String, String>> getStartedProcessesList() => |
181 new List.from(startedProcesses.values.map((e) => e.referenceValueMap)); | 181 new List.from(startedProcesses.values.map((e) => e.referenceValueMap)); |
182 | 182 |
183 static Future<ServiceExtensionResponse> getStartedProcesses( | 183 static Future<ServiceExtensionResponse> getStartedProcesses( |
184 String function, Map<String, String> params) { | 184 String function, Map<String, String> params) { |
185 assert(function == '__getProcesses'); | 185 assert(function == 'ext.dart.io.getProcesses'); |
186 var data = {'type': '_startedprocesses', 'data': getStartedProcessesList()}; | 186 var data = {'type': '_startedprocesses', 'data': getStartedProcessesList()}; |
187 var json = JSON.encode(data); | 187 var json = JSON.encode(data); |
188 return new Future.value(new ServiceExtensionResponse.result(json)); | 188 return new Future.value(new ServiceExtensionResponse.result(json)); |
189 } | 189 } |
190 | 190 |
191 static Future<ServiceExtensionResponse> getProcessInfoMapById( | 191 static Future<ServiceExtensionResponse> getProcessInfoMapById( |
192 String function, Map<String, String> params) { | 192 String function, Map<String, String> params) { |
193 var id = int.parse(params['id']); | 193 var id = int.parse(params['id']); |
194 var result = startedProcesses.containsKey(id) | 194 var result = startedProcesses.containsKey(id) |
195 ? startedProcesses[id].fullValueMap | 195 ? startedProcesses[id].fullValueMap |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
257 String function, Map<String, String> params) { | 257 String function, Map<String, String> params) { |
258 assert(params.containsKey('id')); | 258 assert(params.containsKey('id')); |
259 var id = int.parse(params['id']); | 259 var id = int.parse(params['id']); |
260 var result = | 260 var result = |
261 openSockets.containsKey(id) ? openSockets[id].getSocketInfoMap() : {}; | 261 openSockets.containsKey(id) ? openSockets[id].getSocketInfoMap() : {}; |
262 var json = JSON.encode(result); | 262 var json = JSON.encode(result); |
263 return new Future.value(new ServiceExtensionResponse.result(json)); | 263 return new Future.value(new ServiceExtensionResponse.result(json)); |
264 } | 264 } |
265 | 265 |
266 static Future<ServiceExtensionResponse> getOpenSockets(function, params) { | 266 static Future<ServiceExtensionResponse> getOpenSockets(function, params) { |
267 assert(function == '__getOpenSockets'); | 267 assert(function == 'ext.dart.io.getOpenSockets'); |
268 var data = {'type': '_opensockets', 'data': getOpenSocketsList()}; | 268 var data = {'type': '_opensockets', 'data': getOpenSocketsList()}; |
269 var json = JSON.encode(data); | 269 var json = JSON.encode(data); |
270 return new Future.value(new ServiceExtensionResponse.result(json)); | 270 return new Future.value(new ServiceExtensionResponse.result(json)); |
271 } | 271 } |
272 | 272 |
273 static SocketOpened(_SocketResourceInfo info) { | 273 static SocketOpened(_SocketResourceInfo info) { |
274 assert(!openSockets.containsKey(info.id)); | 274 assert(!openSockets.containsKey(info.id)); |
275 openSockets[info.id] = info; | 275 openSockets[info.id] = info; |
276 } | 276 } |
277 | 277 |
278 static SocketClosed(_SocketResourceInfo info) { | 278 static SocketClosed(_SocketResourceInfo info) { |
279 assert(openSockets.containsKey(info.id)); | 279 assert(openSockets.containsKey(info.id)); |
280 openSockets.remove(info.id); | 280 openSockets.remove(info.id); |
281 } | 281 } |
282 | 282 |
283 } | 283 } |
OLD | NEW |