pkg/compiler/lib/src/common/ram_usage.dart

// Copyright (c) 2022, 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.

/// This library contains logic to fetch RAM utilization information.
/// It is implemented as an RPC that connects to the VM's vm_service isolate and
/// all necessary details.
///
/// This is similar to the information that the VM prints when provided the
/// `--print_metrics` flag. However, this API allows us to obtain the data
/// directly while the process is running and embedded in the compiler output
/// (and in the future in dump-info).
///
/// Note that one could alternatively use Process.maxRss instead, however that
/// number may have a lot more variability depending on system conditions.
/// Our goal with this number is not so much to be exact, but to have a good
/// metric we can track overtime and use to detect improvements and regressions.
import 'dart:developer';
import 'package:vm_service/vm_service_io.dart' as vm_service_io;

Future<int?> _currentHeapCapacity() async {
  final info =
      await Service.controlWebServer(enable: true, silenceOutput: true);
  final observatoryUri = info.serverUri;
  if (observatoryUri == null) return null;
  final wsUri = 'ws://${observatoryUri.authority}${observatoryUri.path}ws';
  final vmService = await vm_service_io.vmServiceConnectUri(wsUri);
  int sum = 0;
  for (final group in (await vmService.getVM()).isolateGroups!) {
    final usage = await vmService.getIsolateGroupMemoryUsage(group.id!);
    sum += usage.heapCapacity!;
  }
  vmService.dispose();
  return sum;
}

Future<String> currentHeapCapacityInMb() async {
  final capacity = await _currentHeapCapacity();
  if (capacity == null) return "N/A MB";
  return "${(capacity / (1024 * 1024)).toStringAsFixed(3)} MB";
}