From 6a65b2a8c913382ea568c709c5b88679b58c81ee Mon Sep 17 00:00:00 2001 From: Amit Kulkarni Date: Tue, 18 Aug 2020 01:30:38 +0530 Subject: [PATCH] MB-37589: Prioritise rebalance runnnig check over another DDL check Change-Id: I390e1cbbb06694a8a6cb21f7b20a7b30947bf5b7 --- secondary/manager/lifecycle.go | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/secondary/manager/lifecycle.go b/secondary/manager/lifecycle.go index 6396fd734..104206b85 100644 --- a/secondary/manager/lifecycle.go +++ b/secondary/manager/lifecycle.go @@ -510,6 +510,15 @@ func (m *LifecycleMgr) handlePrepareCreateIndex(content []byte) ([]byte, error) } if prepareCreateIndex.Op == client.PREPARE { + if _, err := m.repo.GetLocalValue("RebalanceRunning"); err == nil { + logging.Infof("LifecycleMgr.handlePrepareCreateIndex() : Reject %v because rebalance in progress", prepareCreateIndex.DefnId) + response := &client.PrepareCreateResponse{ + Accept: false, + Msg: client.RespRebalanceRunning, + } + return client.MarshallPrepareCreateResponse(response) + } + if m.prepareLock != nil { if m.prepareLock.RequesterId != prepareCreateIndex.RequesterId || m.prepareLock.DefnId != prepareCreateIndex.DefnId { @@ -527,15 +536,6 @@ func (m *LifecycleMgr) handlePrepareCreateIndex(content []byte) ([]byte, error) } } - if _, err := m.repo.GetLocalValue("RebalanceRunning"); err == nil { - logging.Infof("LifecycleMgr.handlePrepareCreateIndex() : Reject %v because rebalance in progress", prepareCreateIndex.DefnId) - response := &client.PrepareCreateResponse{ - Accept: false, - Msg: client.RespRebalanceRunning, - } - return client.MarshallPrepareCreateResponse(response) - } - m.prepareLock = prepareCreateIndex m.prepareLock.StartTime = time.Now().UnixNano()