Konstantin Shcheglov
af2e729fca
If following flags are specified for DAS, in IntelliJ in Registry as "dart.server.additional.arguments": --new-analysis-driver-log=file:/Users/scheglov/tmp/das.log --include-protocol-to-driver-log then abbreviated requests, and request execution statistics is written to the file. We also write abbreviated notifications. The goal is to be able to see what work was requested, what was analyzed, and identify why some requests took long to get responses. R=brianwilkerson@google.com Change-Id: I98e99a73f10f2842c5efb350189a9675f29f45df Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/113800 Commit-Queue: Konstantin Shcheglov <scheglov@google.com> Reviewed-by: Brian Wilkerson <brianwilkerson@google.com>
104 lines
4.1 KiB
Dart
104 lines
4.1 KiB
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.
|
|
|
|
import 'package:analysis_server/protocol/protocol.dart';
|
|
import 'package:analysis_server/protocol/protocol_generated.dart';
|
|
import 'package:analysis_server/src/analysis_server.dart';
|
|
import 'package:analysis_server/src/analysis_server_abstract.dart';
|
|
import 'package:analysis_server/src/channel/channel.dart';
|
|
import 'package:analysis_server/src/server/detachable_filesystem_manager.dart';
|
|
import 'package:analysis_server/src/server/diagnostic_server.dart';
|
|
import 'package:analysis_server/src/utilities/request_statistics.dart';
|
|
import 'package:analyzer/file_system/physical_file_system.dart';
|
|
import 'package:analyzer/instrumentation/instrumentation.dart';
|
|
import 'package:analyzer/src/generated/sdk.dart';
|
|
import 'package:analyzer/src/plugin/resolver_provider.dart';
|
|
|
|
abstract class AbstractSocketServer {
|
|
AnalysisServerOptions get analysisServerOptions;
|
|
AbstractAnalysisServer get analysisServer;
|
|
DiagnosticServer get diagnosticServer;
|
|
}
|
|
|
|
/**
|
|
* Instances of the class [SocketServer] implement the common parts of
|
|
* http-based and stdio-based analysis servers. The primary responsibility of
|
|
* the SocketServer is to manage the lifetime of the AnalysisServer and to
|
|
* encode and decode the JSON messages exchanged with the client.
|
|
*/
|
|
class SocketServer implements AbstractSocketServer {
|
|
final AnalysisServerOptions analysisServerOptions;
|
|
|
|
/**
|
|
* The function used to create a new SDK using the default SDK.
|
|
*/
|
|
final DartSdkManager sdkManager;
|
|
|
|
final InstrumentationService instrumentationService;
|
|
final RequestStatisticsHelper requestStatistics;
|
|
final DiagnosticServer diagnosticServer;
|
|
final ResolverProvider fileResolverProvider;
|
|
final ResolverProvider packageResolverProvider;
|
|
final DetachableFileSystemManager detachableFileSystemManager;
|
|
|
|
/**
|
|
* The analysis server that was created when a client established a
|
|
* connection, or `null` if no such connection has yet been established.
|
|
*/
|
|
AnalysisServer analysisServer;
|
|
|
|
SocketServer(
|
|
this.analysisServerOptions,
|
|
this.sdkManager,
|
|
this.instrumentationService,
|
|
this.requestStatistics,
|
|
this.diagnosticServer,
|
|
this.fileResolverProvider,
|
|
this.packageResolverProvider,
|
|
this.detachableFileSystemManager);
|
|
|
|
/**
|
|
* Create an analysis server which will communicate with the client using the
|
|
* given serverChannel.
|
|
*/
|
|
void createAnalysisServer(ServerCommunicationChannel serverChannel) {
|
|
if (analysisServer != null) {
|
|
RequestError error = new RequestError(
|
|
RequestErrorCode.SERVER_ALREADY_STARTED, "Server already started");
|
|
serverChannel.sendResponse(new Response('', error: error));
|
|
serverChannel.listen((Request request) {
|
|
serverChannel.sendResponse(new Response(request.id, error: error));
|
|
});
|
|
return;
|
|
}
|
|
|
|
PhysicalResourceProvider resourceProvider;
|
|
if (analysisServerOptions.fileReadMode == 'as-is') {
|
|
resourceProvider = new PhysicalResourceProvider(null,
|
|
stateLocation: analysisServerOptions.cacheFolder);
|
|
} else if (analysisServerOptions.fileReadMode == 'normalize-eol-always') {
|
|
resourceProvider = new PhysicalResourceProvider(
|
|
PhysicalResourceProvider.NORMALIZE_EOL_ALWAYS,
|
|
stateLocation: analysisServerOptions.cacheFolder);
|
|
} else {
|
|
throw new Exception(
|
|
'File read mode was set to the unknown mode: $analysisServerOptions.fileReadMode');
|
|
}
|
|
|
|
analysisServer = new AnalysisServer(
|
|
serverChannel,
|
|
resourceProvider,
|
|
analysisServerOptions,
|
|
sdkManager,
|
|
instrumentationService,
|
|
requestStatistics: requestStatistics,
|
|
diagnosticServer: diagnosticServer,
|
|
fileResolverProvider: fileResolverProvider,
|
|
packageResolverProvider: packageResolverProvider,
|
|
detachableFileSystemManager: detachableFileSystemManager,
|
|
);
|
|
detachableFileSystemManager?.setAnalysisServer(analysisServer);
|
|
}
|
|
}
|