Log details of calls to "pub list" to instrumentation.

pkg/analyzer/lib/instrumentation/instrumentation.dart

 // Copyright (c) 2014, 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.
 
 library instrumentation;
 
+import 'dart:convert';
+
 /**
  * A container with analysis performance constants.
  */
 class AnalysisPerformanceKind {
   static const String FULL = 'analysis_full';
   static const String INCREMENTAL = 'analysis_incremental';
 }
 
 /**
  * The interface used by client code to communicate with an instrumentation
@@ skipping 38 matching lines @@
 
   static const String TAG_ANALYSIS_TASK = 'Task';
   static const String TAG_ERROR = 'Err';
   static const String TAG_EXCEPTION = 'Ex';
   static const String TAG_FILE_READ = 'Read';
   static const String TAG_LOG_ENTRY = 'Log';
   static const String TAG_NOTIFICATION = 'Noti';
   static const String TAG_PERFORMANCE = 'Perf';
   static const String TAG_REQUEST = 'Req';
   static const String TAG_RESPONSE = 'Res';
+  static const String TAG_SUBPROCESS_START = 'SPStart';
+  static const String TAG_SUBPROCESS_RESULT = 'SPResult';
   static const String TAG_VERSION = 'Ver';
   static const String TAG_WATCH_EVENT = 'Watch';
 
   /**
    * The instrumentation server used to communicate with the server, or `null`
    * if instrumentation data should not be logged.
    */
   InstrumentationServer _instrumentationServer;
 
   /**
+   * Counter used to generate unique ID's for [logSubprocessStart].
+   */
+  int _subprocessCounter = 0;
+
+  /**
    * Initialize a newly created instrumentation service to comunicate with the
    * given [instrumentationServer].
    */
   InstrumentationService(this._instrumentationServer);
 
   /**
    * Return `true` if this [InstrumentationService] was initialized with a
    * non-`null` server (and hence instrumentation is active).
    */
   bool get isActive => _instrumentationServer != null;
@@ skipping 99 matching lines @@
   }
 
   /**
    * Log that a response has been sent to the client.
    */
   void logResponse(String response) {
     _log(TAG_RESPONSE, response);
   }
 
   /**
+   * Log the result of executing a subprocess.  [subprocessId] should be the
+   * unique IDreturned by [logSubprocessStart].
+   */
+  void logSubprocessResult(
+      int subprocessId, int exitCode, String stdout, String stderr) {
+    if (_instrumentationServer != null) {
+      _instrumentationServer.log(_join([
+        TAG_SUBPROCESS_RESULT,
+        subprocessId.toString(),
+        exitCode.toString(),
+        JSON.encode(stdout),
+        JSON.encode(stderr)
+      ]));
+    }
+  }
+
+  /**
+   * Log that the given subprocess is about to be executed.  Returns a unique
+   * identifier that can be used to identify the subprocess for later log
+   * entries.
+   */
+  int logSubprocessStart(
+      String executablePath, List<String> arguments, String workingDirectory) {
+    int subprocessId = _subprocessCounter++;
+    if (_instrumentationServer != null) {
+      _instrumentationServer.log(_join([
+        TAG_SUBPROCESS_START,
+        subprocessId.toString(),
+        executablePath,
+        workingDirectory,
+        JSON.encode(arguments)
+      ]));
+    }
+    return subprocessId;
+  }
+
+  /**
    * Signal that the client has started analysis server.
    * This method should be invoked exactly one time.
    */
   void logVersion(String uuid, String clientId, String clientVersion,
       String serverVersion, String sdkVersion) {
     String normalize(String value) =>
         value != null && value.length > 0 ? value : 'unknown';
 
     if (_instrumentationServer != null) {
       _instrumentationServer.logWithPriority(_join([
@@ skipping 107 matching lines @@
     }
   }
 
   @override
   void shutdown() {
     for (InstrumentationServer server in _servers) {
       server.shutdown();
     }
   }
 }