From 24b20c1c38058fd5c39da3a9b249b9b030d5de16 Mon Sep 17 00:00:00 2001
From: Leszek Zalewski <leszek.zalewski@shopify.com>
Date: Thu, 12 Oct 2023 15:01:50 +0200
Subject: [PATCH] moar debugging

---
 ferry.go                              | 1 +
 test/lib/go/integrationferry/ferry.go | 3 +++
 2 files changed, 4 insertions(+)

diff --git a/ferry.go b/ferry.go
index c933443e..1a327713 100644
--- a/ferry.go
+++ b/ferry.go
@@ -880,6 +880,7 @@ func (f *Ferry) WaitUntilBinlogStreamerCatchesUp() {
 // You will know that the BinlogStreamer finished when .Run() returns.
 func (f *Ferry) FlushBinlogAndStopStreaming() {
 	if f.WaitUntilReplicaIsCaughtUpToMaster != nil {
+		f.logger.Info("flush binlog and stop streaming: wait until replica is caught up to master")
 		isReplica, err := CheckDbIsAReplica(f.WaitUntilReplicaIsCaughtUpToMaster.MasterDB)
 		if err != nil {
 			f.ErrorHandler.Fatal("wait_replica", err)
diff --git a/test/lib/go/integrationferry/ferry.go b/test/lib/go/integrationferry/ferry.go
index f1b4ce89..155f1f23 100644
--- a/test/lib/go/integrationferry/ferry.go
+++ b/test/lib/go/integrationferry/ferry.go
@@ -148,11 +148,14 @@ func (f *IntegrationFerry) Main() error {
 		return err
 	}
 
+	f.logger.Debug("flush binlog and stop streaming")
 	// TODO: this method should return errors rather than calling
 	// the error handler to panic directly.
 	f.FlushBinlogAndStopStreaming()
+	f.logger.Debug("wait for Ferry to exit")
 	wg.Wait()
 
+	f.logger.Debug("finished waiting")
 	if f.Verifier != nil {
 		err := f.SendStatusAndWaitUntilContinue(StatusVerifyDuringCutover)
 		if err != nil {