mirror of
https://github.com/golang/go
synced 2024-11-18 23:44:43 -07:00
d7101b74a4
The early return logic for didOpen events in (*snapshot).invalidateContent was preventing the creation of a new snapshot, which was in turn stopping the versions from being updated. This exposed a fundamental issue in the way we were calculating workspace diagnostics. Since we weren't waiting for diagnostics to be completed for an entire snapshot before replying that the server had been initialized, snapshots were being cloned without any type information. For quickfix code actions, we assume that we have all information cached (since we need to have sent the diagnostics that the quickfix is mapped to), so we were not finding the cached analysis results. To handle this in the short-term, we key analyses by their names, and then regenerate results as-needed for code actions. This is technically more correct than simply assuming that we have the analyses cached. In a follow-up CL, I will send a follow-up that will make sure that snapshots "wait" on each other to be fully constructed before being cloned. Change-Id: Ie89fcdb438b6b8b675f87335561bf47b768641ac Reviewed-on: https://go-review.googlesource.com/c/tools/+/208265 Run-TryBot: Rebecca Stambler <rstambler@golang.org> TryBot-Result: Gobot Gobot <gobot@golang.org> Reviewed-by: Ian Cottrell <iancottrell@google.com> Reviewed-by: Heschi Kreinick <heschi@google.com>
100 lines
3.0 KiB
Go
100 lines
3.0 KiB
Go
// Copyright 2019 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package lsp
|
|
|
|
import (
|
|
"context"
|
|
|
|
"golang.org/x/tools/internal/lsp/protocol"
|
|
"golang.org/x/tools/internal/lsp/source"
|
|
"golang.org/x/tools/internal/lsp/telemetry"
|
|
"golang.org/x/tools/internal/span"
|
|
"golang.org/x/tools/internal/telemetry/log"
|
|
)
|
|
|
|
func (s *Server) didChangeWatchedFiles(ctx context.Context, params *protocol.DidChangeWatchedFilesParams) error {
|
|
for _, change := range params.Changes {
|
|
uri := span.NewURI(change.URI)
|
|
ctx := telemetry.File.With(ctx, uri)
|
|
|
|
for _, view := range s.session.Views() {
|
|
if !view.Options().WatchFileChanges {
|
|
continue
|
|
}
|
|
action := toFileAction(change.Type)
|
|
switch action {
|
|
case source.Change, source.Create:
|
|
// If client has this file open, don't do anything.
|
|
// The client's contents must remain the source of truth.
|
|
if s.session.IsOpen(uri) {
|
|
break
|
|
}
|
|
if s.session.DidChangeOutOfBand(ctx, uri, action) {
|
|
// If we had been tracking the given file,
|
|
// recompute diagnostics to reflect updated file contents.
|
|
go s.diagnostics(view.BackgroundContext(), view.Snapshot(), uri)
|
|
}
|
|
case source.Delete:
|
|
f := view.FindFile(ctx, uri)
|
|
// If we have never seen this file before, there is nothing to do.
|
|
if f == nil {
|
|
continue
|
|
}
|
|
cphs, err := view.Snapshot().PackageHandles(ctx, f)
|
|
if err != nil {
|
|
log.Error(ctx, "didChangeWatchedFiles: CheckPackageHandles", err, telemetry.File)
|
|
continue
|
|
}
|
|
cph, err := source.WidestCheckPackageHandle(cphs)
|
|
if err != nil {
|
|
log.Error(ctx, "didChangeWatchedFiles: WidestCheckPackageHandle", err, telemetry.File)
|
|
continue
|
|
}
|
|
// Find a different file in the same package we can use to trigger diagnostics.
|
|
// TODO(rstambler): Allow diagnostics to be called per-package to avoid this.
|
|
var otherFile source.File
|
|
for _, ph := range cph.CompiledGoFiles() {
|
|
if ph.File().Identity().URI == f.URI() {
|
|
continue
|
|
}
|
|
if f := view.FindFile(ctx, ph.File().Identity().URI); f != nil && s.session.IsOpen(f.URI()) {
|
|
otherFile = f
|
|
break
|
|
}
|
|
}
|
|
|
|
// Notify the view of the deletion of the file.
|
|
s.session.DidChangeOutOfBand(ctx, uri, action)
|
|
|
|
// If this was the only file in the package, clear its diagnostics.
|
|
if otherFile == nil {
|
|
if err := s.publishDiagnostics(ctx, source.FileIdentity{
|
|
URI: uri,
|
|
}, []source.Diagnostic{}); err != nil {
|
|
log.Error(ctx, "failed to clear diagnostics", err, telemetry.URI.Of(uri))
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Refresh diagnostics for the package the file belonged to.
|
|
go s.diagnostics(view.BackgroundContext(), view.Snapshot(), otherFile.URI())
|
|
}
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func toFileAction(ct protocol.FileChangeType) source.FileAction {
|
|
switch ct {
|
|
case protocol.Changed:
|
|
return source.Change
|
|
case protocol.Created:
|
|
return source.Create
|
|
case protocol.Deleted:
|
|
return source.Delete
|
|
}
|
|
return source.UnknownFileAction
|
|
}
|