Revert "Add auto-snapshotting and usage reporting."

This reverts commit 5fa6c5ed2a.

Reason for revert: breaks G3, we need to update //third_party/dart/leak_tracker first

Original change's description:
> Add auto-snapshotting and usage reporting.
>
> First attempt merged without passing bots and was rolled back: https://dart-review.googlesource.com/c/sdk/+/300862
>
> Change-Id: I782bf4d92394055e1f60a4275b5045e3622e239f
> Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/304101
> Reviewed-by: Samuel Rawlins <srawlins@google.com>
> Commit-Queue: Polina Cherkasova <polinach@google.com>

Change-Id: I8f1643e20f8d134cbf917dc43731798a1234cc2b
No-Presubmit: true
No-Tree-Checks: true
No-Try: true
Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/304181
Commit-Queue: Ilya Yanok <yanok@google.com>
Reviewed-by: Samuel Rawlins <srawlins@google.com>
Bot-Commit: Rubber Stamper <rubber-stamper@appspot.gserviceaccount.com>
This commit is contained in:
Ilya Yanok 2023-05-17 22:03:17 +00:00 committed by Commit Queue
parent 92faa11311
commit 0c5e1e8e48
10 changed files with 1 additions and 240 deletions

2
DEPS
View file

@ -173,7 +173,7 @@ vars = {
"test_descriptor_rev": "23e49a21fc6b4bf3164d336c699b29d1b8bb4622",
"test_process_rev": "d7a1711e57d0340f66a9ef1e712c55be7b072cb0",
"test_reflective_loader_rev": "d1b763f6281a46a48e1da6f0a6e8152e3480e8d2",
"tools_rev": "49da4cabaddec3c82485b15d83ddac2278f947db",
"tools_rev": "62c96040d8090bc1bb866db75d40bd1707876cf9",
"typed_data_rev": "921f5c0380c6c487d8a065c45618162efa4cbd92",
"usage_rev": "929a4e31f0bd4f861dd0e34d4c6f7184c751b569",
"vector_math_rev": "e3de8da3e7db3b9b4f56a16061e9e480539fb08c",

View file

@ -20,7 +20,6 @@ import 'package:analysis_server/src/protocol_server.dart';
import 'package:analysis_server/src/status/pages.dart';
import 'package:analyzer/dart/analysis/analysis_context.dart';
import 'package:collection/collection.dart';
import 'package:leak_tracker/src/usage_tracking/model.dart';
import 'package:unified_analytics/unified_analytics.dart';
/// An interface for managing and reporting analytics.
@ -191,28 +190,6 @@ class AnalyticsManager {
requestData.addValue('openWorkspacePaths', openWorkspacePaths.length);
}
Future<void> sendMemoryUsage(MemoryUsageEvent event) async {
final delta = event.delta;
var seconds = event.period?.inSeconds;
assert((event.delta == null) == (event.period == null));
if (delta == null || seconds == null) {
await analytics.sendEvent(eventName: DashEvent.memoryInfo, eventData: {
'rss': event.rss,
});
return;
}
if (seconds == 0) seconds = 1;
await analytics.sendEvent(eventName: DashEvent.memoryInfo, eventData: {
'rss': event.rss,
'periodSec': seconds,
'mbPerSec': delta / seconds,
});
}
/// Record that the given [response] was sent to the client.
void sentResponse({required Response response}) {
var sendTime = DateTime.now();

View file

@ -41,8 +41,6 @@ import 'package:telemetry/crash_reporting.dart';
import 'package:telemetry/telemetry.dart' as telemetry;
import 'package:unified_analytics/unified_analytics.dart';
import '../utilities/usage_tracking/usage_tracking.dart';
/// The [Driver] class represents a single running instance of the analysis
/// server application. It is responsible for parsing command line options
/// and starting the HTTP and/or stdio servers.
@ -357,11 +355,6 @@ class Driver implements ServerStarter {
errorNotifier,
sendPort);
}
configureMemoryUsageTracking(
arguments,
(memoryUsageEvent) => analyticsManager.sendMemoryUsage(memoryUsageEvent),
);
}
void startAnalysisServer(

View file

@ -1,48 +0,0 @@
# Auto-snapshotting
IMPORTANT: memory snapshots should not be requested from external users because they may contain PII.
If a user reports that the process `dart:analysis_server.dart.snapshot` takes too much memory,
and the issue is hard to reproduce, you may want to request memory snapshots from the user.
## Request numbers
Ask user to provide memory footprint for the process `dart:analysis_server.dart.snapshot`.
If there are many instances of the process, ask for the biggest memory footprint among
the instances.
- **Mac**: column 'Real Mem' in 'Activity Monitor'
- **Windows**: TODO: add content
- **Linux**: TODO: add content
## Create auto-snapshotting argument
Based on the reported and expected values, construct auto-snapshotting argument. See example in
the [test file](../../../../test/utilities/usage_tracking/usage_tracking_test.dart), the
constant `_autosnapshottingArg`.
See explanation of parameters in
[documentation for AutoSnapshottingConfig](https://github.com/dart-lang/leak_tracker/blob/main/lib/src/usage_tracking/model.dart).
## Instruct user to configure analyzer
Pass the created argument to the user and instruct them to configure
analyzer.
### For VSCode
1. Open Settings > Extensions > Dart > Analyser
2. Add the argument to `Dart: Analyzer Additional Args`
### For Android Studio
1. Double-press Shift
2. Type 'Registry' into search field
3. Click 'Registry...'
4. Add the argument to the value of the key 'dart.server.additional.arguments'
## Analyze snapshots
Ask user to provide the collected snapshots and analyze them.
TODO (polina-c): link DevTools documentation

View file

@ -1,88 +0,0 @@
// Copyright (c) 2023, 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.
import 'package:args/args.dart';
import 'package:collection/collection.dart';
import 'package:leak_tracker/src/usage_tracking/model.dart';
import 'package:leak_tracker/src/usage_tracking/usage_tracking.dart';
void configureMemoryUsageTracking(
List<String> arguments,
UsageCallback callback,
) {
final config = UsageTrackingConfig(
interval: const Duration(seconds: 1),
usageEventsConfig: UsageEventsConfig(
callback,
deltaMb: 512,
),
autoSnapshottingConfig: parseAutoSnapshottingConfig(arguments),
);
trackMemoryUsage(config);
}
/// Parses the config for autosnapshotting from CLI [args].
///
/// See example of config in tests for this function.
///
/// If there is no argument that starts with '--autosnapshotting=', returns null.
///
/// In case of error throws exception.
AutoSnapshottingConfig? parseAutoSnapshottingConfig(List<String> args) {
const argName = 'autosnapshotting';
final arg = args.firstWhereOrNull((a) => a.contains('--$argName'));
if (arg == null) return null;
var parser = ArgParser()..addMultiOption(argName, splitCommas: true);
final parsedArgs = parser.parse([arg]);
assert(parsedArgs.options.contains(argName));
final values = parsedArgs[argName] as List<String>;
if (values.isEmpty) return null;
final items = Map.fromEntries(values.map((e) {
final keyValue = e.split('=');
if (keyValue.length != 2) {
throw ArgumentError(
'Invalid auto-snapshotting config: $values.\n'
'Expected "key-value", got "$e".',
);
}
final keyString = keyValue[0];
try {
final key = _Keys.values.byName(keyString);
return MapEntry(key, keyValue[1]);
} on ArgumentError {
throw ArgumentError('Invalid auto-snapshotting key: $keyString".');
}
}));
if (!items.containsKey(_Keys.dir)) {
throw ArgumentError(
'${_Keys.dir.name} should be provided for auto-snapshotting.');
}
return AutoSnapshottingConfig(
thresholdMb: _parseKey(_Keys.thresholdMb, items, 7000),
increaseMb: _parseKey(_Keys.increaseMb, items, 500),
directory: items[_Keys.dir]!,
directorySizeLimitMb: _parseKey(_Keys.dirLimitMb, items, 30000),
minDelayBetweenSnapshots: Duration(
seconds: _parseKey(_Keys.delaySec, items, 20),
),
);
}
int _parseKey(_Keys key, Map<_Keys, String> items, int defaultValue) {
final value = items[key];
if (value == null || value.trim().isEmpty) return defaultValue;
final result = int.tryParse(value);
if (result == null) {
throw ArgumentError(
'Invalid auto-snapshotting value for ${key.name}: $value.');
}
return result;
}
enum _Keys {
thresholdMb,
increaseMb,
dir,
dirLimitMb,
delaySec,
}

View file

@ -16,7 +16,6 @@ dependencies:
crypto: any
dart_style: any
http: any
leak_tracker: any
linter: any
meta: any
path: any

View file

@ -26,7 +26,6 @@ import 'services/test_all.dart' as services;
import 'socket_server_test.dart' as socket_server;
import 'src/test_all.dart' as src;
import 'tool/test_all.dart' as tool;
import 'utilities/test_all.dart' as utilities;
import 'verify_error_fix_status_test.dart' as verify_error_fix_status;
import 'verify_no_solo_test.dart' as verify_no_solo;
import 'verify_sorted_test.dart' as verify_sorted;
@ -55,7 +54,6 @@ void main() {
socket_server.main();
src.main();
tool.main();
utilities.main();
verify_error_fix_status.main();
verify_no_solo.main();
verify_sorted.main();

View file

@ -1,13 +0,0 @@
// Copyright (c) 2023, 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.
import 'package:test_reflective_loader/test_reflective_loader.dart';
import 'usage_tracking/test_all.dart' as usage_tracking;
void main() {
defineReflectiveSuite(() {
usage_tracking.main();
}, name: 'utilities');
}

View file

@ -1,13 +0,0 @@
// Copyright (c) 2023, 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.
import 'package:test_reflective_loader/test_reflective_loader.dart';
import 'usage_tracking_test.dart' as usage_tracking;
void main() {
defineReflectiveSuite(() {
usage_tracking.main();
}, name: 'usage_tracking');
}

View file

@ -1,44 +0,0 @@
// Copyright (c) 2023, 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.
import 'package:analysis_server/src/utilities/usage_tracking/usage_tracking.dart';
import 'package:test/test.dart';
void main() {
group('parseAutoSnapshottingConfig', () {
test('parses correct config', () {
final config = parseAutoSnapshottingConfig(_argsWithSnapshotting)!;
expect(config.thresholdMb, 200);
expect(config.increaseMb, 100);
expect(config.directory, '/Users/polinach/Downloads/analyzer_snapshots');
expect(config.directorySizeLimitMb, 10000);
expect(config.minDelayBetweenSnapshots, Duration(seconds: 20));
});
test('returns null for no config', () {
final config = parseAutoSnapshottingConfig(_argsNoSnapshotting);
expect(config, null);
});
test('throws for wrong config', () {
final wrongAutosnapshottingArg =
'--autosnapshotting--wrong-configuration';
expect(
() => parseAutoSnapshottingConfig(
[wrongAutosnapshottingArg, 'some other arg']),
throwsA(isA<Object>()),
);
});
});
}
const _argsNoSnapshotting = [
'--sdk=C:/b/s/w/ir/x/w/sdk/sdk/',
'--train-using=C:/b/s/w/ir/x/w/sdk/pkg/compiler/lib'
];
const _argsWithSnapshotting = [
_autosnapshottingArg,
'--sdk=C:/b/s/w/ir/x/w/sdk/sdk/',
'--train-using=C:/b/s/w/ir/x/w/sdk/pkg/compiler/lib'
];
// This constant is referenced in README.md for auto-snapshotting.
const _autosnapshottingArg =
'--autosnapshotting=thresholdMb=200,increaseMb=100,dir=/Users/polinach/Downloads/analyzer_snapshots,dirLimitMb=10000,delaySec=20';