| // 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" |
| "fmt" |
| "sync" |
| |
| "golang.org/x/tools/gopls/internal/lsp/cache" |
| "golang.org/x/tools/gopls/internal/lsp/protocol" |
| "golang.org/x/tools/internal/event" |
| ) |
| |
| func (s *server) DidChangeWorkspaceFolders(ctx context.Context, params *protocol.DidChangeWorkspaceFoldersParams) error { |
| event := params.Event |
| for _, folder := range event.Removed { |
| view := s.session.ViewByName(folder.Name) |
| if view != nil { |
| s.session.RemoveView(view) |
| } else { |
| return fmt.Errorf("view %s for %v not found", folder.Name, folder.URI) |
| } |
| } |
| return s.addFolders(ctx, event.Added) |
| } |
| |
| // addView returns a Snapshot and a release function that must be |
| // called when it is no longer needed. |
| func (s *server) addView(ctx context.Context, name string, uri protocol.DocumentURI) (*cache.Snapshot, func(), error) { |
| s.stateMu.Lock() |
| state := s.state |
| s.stateMu.Unlock() |
| if state < serverInitialized { |
| return nil, nil, fmt.Errorf("addView called before server initialized") |
| } |
| options, err := s.fetchFolderOptions(ctx, uri) |
| if err != nil { |
| return nil, nil, err |
| } |
| folder := &cache.Folder{ |
| Dir: uri, |
| Name: name, |
| Options: options, |
| } |
| _, snapshot, release, err := s.session.NewView(ctx, folder) |
| return snapshot, release, err |
| } |
| |
| func (s *server) DidChangeConfiguration(ctx context.Context, _ *protocol.DidChangeConfigurationParams) error { |
| ctx, done := event.Start(ctx, "lsp.Server.didChangeConfiguration") |
| defer done() |
| |
| // Apply any changes to the session-level settings. |
| options, err := s.fetchFolderOptions(ctx, "") |
| if err != nil { |
| return err |
| } |
| s.SetOptions(options) |
| |
| // Collect options for all workspace folders. |
| seen := make(map[protocol.DocumentURI]bool) |
| for _, view := range s.session.Views() { |
| if seen[view.Folder()] { |
| continue |
| } |
| seen[view.Folder()] = true |
| options, err := s.fetchFolderOptions(ctx, view.Folder()) |
| if err != nil { |
| return err |
| } |
| s.session.SetFolderOptions(ctx, view.Folder(), options) |
| } |
| |
| var wg sync.WaitGroup |
| for _, view := range s.session.Views() { |
| view := view |
| wg.Add(1) |
| go func() { |
| defer wg.Done() |
| snapshot, release, err := view.Snapshot() |
| if err != nil { |
| return // view is shut down; no need to diagnose |
| } |
| defer release() |
| s.diagnoseSnapshot(snapshot, nil, false, 0) |
| }() |
| } |
| |
| if s.Options().VerboseWorkDoneProgress { |
| work := s.progress.Start(ctx, DiagnosticWorkTitle(FromDidChangeConfiguration), "Calculating diagnostics...", nil, nil) |
| go func() { |
| wg.Wait() |
| work.End(ctx, "Done.") |
| }() |
| } |
| |
| // An options change may have affected the detected Go version. |
| s.checkViewGoVersions() |
| |
| return nil |
| } |