From 684b20edb391bc8d65d63e03274ed1a47e942b02 Mon Sep 17 00:00:00 2001 From: Travis Date: Thu, 14 Jan 2021 23:02:58 -0600 Subject: [PATCH] disco open/close debugging --- server.go | 4 ++++ testhook/hook.go | 1 + 2 files changed, 5 insertions(+) diff --git a/server.go b/server.go index 375c2cb96..519cfa56e 100644 --- a/server.go +++ b/server.go @@ -611,6 +611,7 @@ func (s *Server) Open() error { if err != nil { return errors.Wrap(err, "starting DisCo") } + fmt.Println("--- disco: open:", s.disCo.ID()) _ = initState // Set node ID. @@ -679,6 +680,7 @@ func (s *Server) Open() error { // Close closes the server and waits for it to shutdown. func (s *Server) Close() error { + fmt.Println("--- disco: server close:", s.disCo.ID()) errE := s.executor.Close() // Notify goroutines to stop. @@ -693,7 +695,9 @@ func (s *Server) Close() error { } errhs = s.syncer.stopTranslationSync() if s.disCo != nil { + fmt.Println("--- disco: try close:", s.disCo.ID()) errd = s.disCo.Close() + fmt.Println("--- disco: closed", s.disCo.ID(), errd) } if s.holder != nil { errh = s.holder.Close() diff --git a/testhook/hook.go b/testhook/hook.go index 8316d0806..a478a7cbb 100644 --- a/testhook/hook.go +++ b/testhook/hook.go @@ -87,6 +87,7 @@ func TempDir(tb testing.TB, pattern string) (path string, err error) { if err == nil { Cleanup(tb, func() { os.RemoveAll(path) + fmt.Println("--- testhook:", path, tb.Name()) }) } return path, err