Add resource metadata for open files.

sdk/lib/io/io_resource_info.dart

 // Copyright (c) 2015, the Dart project authors.  Please see the AUTHORS file
 // for details. 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 dart.io;
 
-const String TCP_STRING = 'TCP';
-const String UDP_STRING = 'UDP';
-
-
 abstract class _IOResourceInfo {
   final String type;
   final int id;
   String get name;
   static int _count = 0;
 
   _IOResourceInfo(this.type) : id = _IOResourceInfo.getNextID();
 
   String toJSON();
 
   /// Get the full set of values for a specific implementation. This is normally
   /// looked up based on an id from a referenceValueMap.
   Map<String, String> get fullValueMap;
 
   /// The reference map, used to return a list of values, e.g., getting
   /// all open sockets. The structure of this is shared among all subclasses.
   Map<String, String> get referenceValueMap =>
       {
         // The type for a reference object is prefixed with @ in observatory.
         'type': '@$type',
         'id': id,
         'name': name,
       };
 
   static int getNextID() => _count++;
 }
 
+// TODO(ricow): Move stopwatch into this class and use it for both files

[Ivan Posva, 2015/09/08 18:06:36]

Can you please explain what you mean by moving stopwatch into this class? Do you
mean adding a stopwatch instance? Not moving the stopwatch implementation,
correct?

[ricow1, 2015/09/08 18:33:39]

Correct. You can see the follow up here:
https://codereview.chromium.org/1320023008/

+// and sockets (by using setters on totalRead/totalWritten). Also, consider
+// setting readCount and writeCount in those setters.
 abstract class _ReadWriteResourceInfo extends _IOResourceInfo {
   int totalRead;
   int totalWritten;
   int readCount;
   int writeCount;
   double lastRead;
   double lastWrite;
 
   _ReadWriteResourceInfo(String type) :
     totalRead = 0,
@@ skipping 15 matching lines @@
       'write_count': writeCount,
       'last_read': lastRead,
       'last_write': lastWrite
     };
 
   String toJSON() {
     return JSON.encode(fullValueMap);
   }
 }
 
+class _FileResourceInfo extends _ReadWriteResourceInfo {
+  static const String TYPE = '_file';
+
+  final file;
+
+  static Map<int, _FileResourceInfo> openFiles =
+      new Map<int, _FileResourceInfo>();
+
+  _FileResourceInfo(this.file) : super(TYPE) {
+    FileOpened(this);
+  }
+
+  static FileOpened(_FileResourceInfo info) {
+    assert(!openFiles.containsKey(info.id));
+    openFiles[info.id] = info;
+  }
+
+  static FileClosed(_FileResourceInfo info) {
+    assert(openFiles.containsKey(info.id));
+    openFiles.remove(info.id);
+  }
+
+  static Iterable<Map<String, String>> getOpenFilesList() {
+    return new List.from(openFiles.values.map((e) => e.referenceValueMap));
+  }
+
+  static Future<ServiceExtensionResponse> getOpenFiles(function, params) {
+    assert(function == '__getOpenFiles');
+    var data = {'type': '_openfiles', 'data': getOpenFilesList()};
+    var json = JSON.encode(data);
+    return new Future.value(new ServiceExtensionResponse.result(json));
+  }
+
+  Map<String, String> getFileInfoMap() {
+    var result = fullValueMap;
+    return result;
+  }
+
+  static Future<ServiceExtensionResponse> getFileInfoMapByID(function, params) {
+    assert(params.containsKey('id'));
+    var id = int.parse(params['id']);
+    var result =
+      openFiles.containsKey(id) ? openFiles[id].getFileInfoMap() : {};
+    var json = JSON.encode(result);
+    return new Future.value(new ServiceExtensionResponse.result(json));
+  }
+
+  String get name {
+    return '${file.path}';
+  }
+}
+
 class _SocketResourceInfo extends _ReadWriteResourceInfo {
+  static const String TCP_STRING = 'TCP';
+  static const String UDP_STRING = 'UDP';
+  static const String TYPE = '_socket';
+
   final socket;
 
   static Map<int, _SocketResourceInfo> openSockets =
       new Map<int, _SocketResourceInfo>();
 
-  _SocketResourceInfo(this.socket) : super('_socket') {
+  _SocketResourceInfo(this.socket) : super(TYPE) {
     SocketOpened(this);
   }
 
   String get name {
     if (socket.isListening) {
       return 'listening:${socket.address.host}:${socket.port}';
     }
     var remote = '';
     try {
       var remoteHost = socket.remoteAddress.host;
@@ skipping 51 matching lines @@
     assert(!openSockets.containsKey(info.id));
     openSockets[info.id] = info;
   }
 
   static SocketClosed(_SocketResourceInfo info) {
     assert(openSockets.containsKey(info.id));
     openSockets.remove(info.id);
   }
 
 }