Unverified Commit 5ea2be69 authored by Ben Konyi's avatar Ben Konyi Committed by GitHub

Reland "Fix issue where DevTools would not be immediately available when using...

Reland "Fix issue where DevTools would not be immediately available when using --start-paused (#126698)" (#129368)

**Original Description:**

> Service extensions are unable to handle requests when the isolate they
were registered on is paused. The DevTools launcher logic was waiting
for some service extension invocations to complete before advertising
the already active DevTools instance, but when --start-paused was
provided these requests would never complete, preventing users from
using DevTools to resume the paused isolate.
> 
> Fixes https://github.com/flutter/flutter/issues/126691

**Additional changes in this PR:**

The failures listed in https://github.com/flutter/flutter/pull/128117
appear to be related to a shutdown race. It's possible for the test to
complete while the tool is in the process of starting and advertising
DevTools, so we need to perform a check of `_shutdown` in
`FlutterResidentDevtoolsHandler` before advertising DevTools.

Before the original fix, this check was being performed immediately
after invoking the service extensions, which creates an asynchronous gap
in execution. With #126698, the callsite of the service extensions was
moved and the `_shutdown` check wasn't, allowing for the tool to attempt
to advertise DevTools after the DevTools server had been cleaned up.

---------
Co-authored-by: 's avatarZachary Anderson <zanderso@users.noreply.github.com>
parent 9531cd40
...@@ -35,6 +35,7 @@ abstract class ResidentDevtoolsHandler { ...@@ -35,6 +35,7 @@ abstract class ResidentDevtoolsHandler {
Future<void> serveAndAnnounceDevTools({ Future<void> serveAndAnnounceDevTools({
Uri? devToolsServerAddress, Uri? devToolsServerAddress,
required List<FlutterDevice?> flutterDevices, required List<FlutterDevice?> flutterDevices,
bool isStartPaused = false,
}); });
bool launchDevToolsInBrowser({required List<FlutterDevice?> flutterDevices}); bool launchDevToolsInBrowser({required List<FlutterDevice?> flutterDevices});
...@@ -71,6 +72,7 @@ class FlutterResidentDevtoolsHandler implements ResidentDevtoolsHandler { ...@@ -71,6 +72,7 @@ class FlutterResidentDevtoolsHandler implements ResidentDevtoolsHandler {
Future<void> serveAndAnnounceDevTools({ Future<void> serveAndAnnounceDevTools({
Uri? devToolsServerAddress, Uri? devToolsServerAddress,
required List<FlutterDevice?> flutterDevices, required List<FlutterDevice?> flutterDevices,
bool isStartPaused = false,
}) async { }) async {
assert(!_readyToAnnounce); assert(!_readyToAnnounce);
if (!_residentRunner.supportsServiceProtocol || _devToolsLauncher == null) { if (!_residentRunner.supportsServiceProtocol || _devToolsLauncher == null) {
...@@ -88,20 +90,10 @@ class FlutterResidentDevtoolsHandler implements ResidentDevtoolsHandler { ...@@ -88,20 +90,10 @@ class FlutterResidentDevtoolsHandler implements ResidentDevtoolsHandler {
assert(!_readyToAnnounce); assert(!_readyToAnnounce);
return; return;
} }
final List<FlutterDevice?> devicesWithExtension = await _devicesWithExtensions(flutterDevices);
await _maybeCallDevToolsUriServiceExtension(devicesWithExtension);
await _callConnectedVmServiceUriExtension(devicesWithExtension);
if (_shutdown) {
// If we're shutting down, no point reporting the debugger list.
return;
}
_readyToAnnounce = true;
assert(_devToolsLauncher!.activeDevToolsServer != null);
final Uri? devToolsUrl = _devToolsLauncher!.devToolsUrl; final Uri? devToolsUrl = _devToolsLauncher!.devToolsUrl;
if (devToolsUrl != null) { if (devToolsUrl != null) {
for (final FlutterDevice? device in devicesWithExtension) { for (final FlutterDevice? device in flutterDevices) {
if (device == null) { if (device == null) {
continue; continue;
} }
...@@ -111,11 +103,43 @@ class FlutterResidentDevtoolsHandler implements ResidentDevtoolsHandler { ...@@ -111,11 +103,43 @@ class FlutterResidentDevtoolsHandler implements ResidentDevtoolsHandler {
} }
} }
Future<void> callServiceExtensions() async {
final List<FlutterDevice?> devicesWithExtension = await _devicesWithExtensions(flutterDevices);
await Future.wait(
<Future<void>>[
_maybeCallDevToolsUriServiceExtension(devicesWithExtension),
_callConnectedVmServiceUriExtension(devicesWithExtension)
]
);
}
// If the application is starting paused, we can't invoke service extensions
// as they're handled on the target app's paused isolate. Since invoking
// service extensions will block in this situation, we should wait to invoke
// them until after we've output the DevTools connection details.
if (!isStartPaused) {
await callServiceExtensions();
}
// This check needs to happen after the possible asynchronous call above,
// otherwise a shutdown event might be missed and the DevTools launcher may
// no longer be initialized.
if (_shutdown) {
// If we're shutting down, no point reporting the debugger list.
return;
}
_readyToAnnounce = true;
assert(_devToolsLauncher!.activeDevToolsServer != null);
if (_residentRunner.reportedDebuggers) { if (_residentRunner.reportedDebuggers) {
// Since the DevTools only just became available, we haven't had a chance to // Since the DevTools only just became available, we haven't had a chance to
// report their URLs yet. Do so now. // report their URLs yet. Do so now.
_residentRunner.printDebuggerList(includeVmService: false); _residentRunner.printDebuggerList(includeVmService: false);
} }
if (isStartPaused) {
await callServiceExtensions();
}
} }
// This must be guaranteed not to return a Future that fails. // This must be guaranteed not to return a Future that fails.
...@@ -295,7 +319,11 @@ class NoOpDevtoolsHandler implements ResidentDevtoolsHandler { ...@@ -295,7 +319,11 @@ class NoOpDevtoolsHandler implements ResidentDevtoolsHandler {
} }
@override @override
Future<void> serveAndAnnounceDevTools({Uri? devToolsServerAddress, List<FlutterDevice?>? flutterDevices}) async { Future<void> serveAndAnnounceDevTools({
Uri? devToolsServerAddress,
List<FlutterDevice?>? flutterDevices,
bool isStartPaused = false,
}) async {
return; return;
} }
......
...@@ -86,6 +86,7 @@ class ColdRunner extends ResidentRunner { ...@@ -86,6 +86,7 @@ class ColdRunner extends ResidentRunner {
unawaited(residentDevtoolsHandler!.serveAndAnnounceDevTools( unawaited(residentDevtoolsHandler!.serveAndAnnounceDevTools(
devToolsServerAddress: debuggingOptions.devToolsServerAddress, devToolsServerAddress: debuggingOptions.devToolsServerAddress,
flutterDevices: flutterDevices, flutterDevices: flutterDevices,
isStartPaused: debuggingOptions.startPaused,
)); ));
} }
if (debuggingOptions.serveObservatory) { if (debuggingOptions.serveObservatory) {
...@@ -173,6 +174,7 @@ class ColdRunner extends ResidentRunner { ...@@ -173,6 +174,7 @@ class ColdRunner extends ResidentRunner {
unawaited(residentDevtoolsHandler!.serveAndAnnounceDevTools( unawaited(residentDevtoolsHandler!.serveAndAnnounceDevTools(
devToolsServerAddress: debuggingOptions.devToolsServerAddress, devToolsServerAddress: debuggingOptions.devToolsServerAddress,
flutterDevices: flutterDevices, flutterDevices: flutterDevices,
isStartPaused: debuggingOptions.startPaused,
)); ));
} }
if (debuggingOptions.serveObservatory) { if (debuggingOptions.serveObservatory) {
......
...@@ -249,6 +249,7 @@ class HotRunner extends ResidentRunner { ...@@ -249,6 +249,7 @@ class HotRunner extends ResidentRunner {
unawaited(residentDevtoolsHandler!.serveAndAnnounceDevTools( unawaited(residentDevtoolsHandler!.serveAndAnnounceDevTools(
devToolsServerAddress: debuggingOptions.devToolsServerAddress, devToolsServerAddress: debuggingOptions.devToolsServerAddress,
flutterDevices: flutterDevices, flutterDevices: flutterDevices,
isStartPaused: debuggingOptions.startPaused,
)); ));
} }
......
...@@ -156,6 +156,7 @@ void main() { ...@@ -156,6 +156,7 @@ void main() {
}, },
), ),
listViews, listViews,
listViews,
const FakeVmServiceRequest( const FakeVmServiceRequest(
method: 'ext.flutter.activeDevToolsServerAddress', method: 'ext.flutter.activeDevToolsServerAddress',
args: <String, Object>{ args: <String, Object>{
...@@ -163,7 +164,6 @@ void main() { ...@@ -163,7 +164,6 @@ void main() {
'value': 'http://localhost:8080', 'value': 'http://localhost:8080',
}, },
), ),
listViews,
const FakeVmServiceRequest( const FakeVmServiceRequest(
method: 'ext.flutter.connectedVmServiceUri', method: 'ext.flutter.connectedVmServiceUri',
args: <String, Object>{ args: <String, Object>{
...@@ -314,6 +314,7 @@ void main() { ...@@ -314,6 +314,7 @@ void main() {
}, },
), ),
listViews, listViews,
listViews,
const FakeVmServiceRequest( const FakeVmServiceRequest(
method: 'ext.flutter.activeDevToolsServerAddress', method: 'ext.flutter.activeDevToolsServerAddress',
args: <String, Object>{ args: <String, Object>{
...@@ -321,7 +322,6 @@ void main() { ...@@ -321,7 +322,6 @@ void main() {
'value': 'http://localhost:8080', 'value': 'http://localhost:8080',
}, },
), ),
listViews,
const FakeVmServiceRequest( const FakeVmServiceRequest(
method: 'ext.flutter.connectedVmServiceUri', method: 'ext.flutter.connectedVmServiceUri',
args: <String, Object>{ args: <String, Object>{
......
// Copyright 2014 The Flutter Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
import 'dart:async';
import 'package:flutter_tools/src/base/file_system.dart';
import 'package:flutter_tools/src/base/io.dart';
import 'package:flutter_tools/src/convert.dart';
import '../src/common.dart';
import 'test_data/basic_project.dart';
import 'test_utils.dart';
void main() {
late Directory tempDir;
final BasicProject project = BasicProject();
setUp(() async {
tempDir = createResolvedTempDirectorySync('run_test.');
await project.setUpIn(tempDir);
});
tearDown(() async {
tryToDelete(tempDir);
});
// Regression test for https://github.com/flutter/flutter/issues/126691
testWithoutContext('flutter run --start-paused prints DevTools URI', () async {
final Completer<void> completer = Completer<void>();
const String matcher = 'The Flutter DevTools debugger and profiler on';
final String flutterBin = fileSystem.path.join(getFlutterRoot(), 'bin', 'flutter');
final Process process = await processManager.start(<String>[
flutterBin,
'run',
'--start-paused',
'-d',
'flutter-tester',
], workingDirectory: tempDir.path);
final StreamSubscription<String> sub;
sub = process.stdout.transform(utf8.decoder).listen((String message) {
if (message.contains(matcher)) {
completer.complete();
}
});
await completer.future;
await sub.cancel();
process.kill();
await process.exitCode;
});
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment