| Index: pkg/analysis_server/bin/fuzz/logging_client_channel.dart
|
| diff --git a/pkg/analysis_server/bin/fuzz/logging_client_channel.dart b/pkg/analysis_server/bin/fuzz/logging_client_channel.dart
|
| deleted file mode 100644
|
| index 941646dc43b492502fccf2e8d665686e5c1d22e1..0000000000000000000000000000000000000000
|
| --- a/pkg/analysis_server/bin/fuzz/logging_client_channel.dart
|
| +++ /dev/null
|
| @@ -1,85 +0,0 @@
|
| -// 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.
|
| -
|
| -part of server.manager;
|
| -
|
| -/**
|
| - * A client channel that logs communication to stdout
|
| - * and handles errors received from the server.
|
| - */
|
| -class LoggingClientChannel implements ClientCommunicationChannel {
|
| - final ClientCommunicationChannel channel;
|
| - int serverErrorCount = 0;
|
| -
|
| - LoggingClientChannel(this.channel) {
|
| - channel.notificationStream.listen((Notification notification) {
|
| - _logNotification(notification);
|
| - if (notification.event == 'server.error') {
|
| - ServerErrorParams error =
|
| - new ServerErrorParams.fromNotification(notification);
|
| - _handleError(
|
| - 'Server reported error: ${error.message}',
|
| - error.stackTrace);
|
| - }
|
| - });
|
| - }
|
| -
|
| - @override
|
| - Stream<Notification> get notificationStream => channel.notificationStream;
|
| -
|
| - @override
|
| - void set notificationStream(Stream<Notification> _notificationStream) {
|
| - throw 'invalid operation';
|
| - }
|
| -
|
| - @override
|
| - Stream<Response> get responseStream => channel.responseStream;
|
| -
|
| - @override
|
| - void set responseStream(Stream<Response> _responseStream) {
|
| - throw 'invalid operation';
|
| - }
|
| -
|
| - @override
|
| - Future close() {
|
| - print('Requesting client channel be closed');
|
| - return channel.close().then((_) {
|
| - print('Client channel closed');
|
| - });
|
| - }
|
| -
|
| - @override
|
| - Future<Response> sendRequest(Request request) {
|
| - _logOperation('=>', request);
|
| - return channel.sendRequest(request).then((Response response) {
|
| - RequestError error = response.error;
|
| - if (error != null) {
|
| - error.code;
|
| - stderr.write('Server Error ${error.code}: ${error.message}');
|
| - print(error.stackTrace);
|
| - exitCode = 31;
|
| - }
|
| - _logOperation('<=', request);
|
| - return response;
|
| - });
|
| - }
|
| -
|
| - void _handleError(String errMsg, String stackTrace) {
|
| - //error.isFatal;
|
| - stderr.writeln('>>> Server reported exception');
|
| - stderr.writeln(errMsg);
|
| - print(stackTrace);
|
| - serverErrorCount++;
|
| - }
|
| -
|
| - void _logNotification(Notification notification) {
|
| - print('<= ${notification.event}');
|
| - }
|
| -
|
| - void _logOperation(String direction, Request request) {
|
| - String id = request.id.padLeft(5);
|
| - String method = request.method.padRight(20);
|
| - print('$direction $id $method');
|
| - }
|
| -}
|
|
|