Skip to content

Commit 0252167

Browse files
committed
prs5 debug set
1 parent 3656c04 commit 0252167

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

go/vt/vttablet/tabletmanager/replmanager.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,7 @@ func (rm *replManager) checkActionLocked() {
126126
ctx, cancel := context.WithTimeout(rm.ctx, 5*time.Second)
127127
defer cancel()
128128
if err := rm.tm.repairReplication(ctx); err != nil {
129+
log.Infof("vm-debug: repairReplication failed with=%v", err)
129130
if !rm.failed {
130131
rm.failed = true
131132
log.Infof("Failed to reconnect to primary: %v, will keep retrying.", err)

go/vt/vttablet/tabletmanager/rpc_replication.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1149,6 +1149,7 @@ func (tm *TabletManager) handleRelayLogError(err error) error {
11491149
// repairReplication tries to connect this server to whoever is
11501150
// the current primary of the shard, and start replicating.
11511151
func (tm *TabletManager) repairReplication(ctx context.Context) error {
1152+
log.Infof("vm-debug: entering repairReplication")
11521153
tablet := tm.Tablet()
11531154

11541155
si, err := tm.TopoServer.GetShard(ctx, tablet.Keyspace, tablet.Shard)

0 commit comments

Comments
 (0)