Merge pull request #193 from rubixchain/hari/distribured-pledging-fix

fix: distributed pledging exit when quorum count is <7

core/quorum.go

@@ -82,25 +82,25 @@ func (qm *QuorumManager) GetQuorum(t int, lastChar string) []string {
 			return nil
 		}
 		var quorumAddrList []string
-		quorumCount := 0
+		quorumAddrCount := 0
 		for _, q := range quorumList {
 			addr := string(q.PeerID + "." + q.DID)
 			quorumAddrList = append(quorumAddrList, addr)
-			quorumCount = quorumCount + 1
-			if quorumCount == 7 {
+			quorumAddrCount = quorumAddrCount + 1
+			if quorumAddrCount == 7 {
 				break
 			}
 		}
 		return quorumAddrList
 	case QuorumTypeTwo:
 		var quorumAddrList []string
-		quorumCount := 0
+		quorumAddrCount := 0
 		for _, q := range qm.ql {
 			peerID := qm.GetPeerID(q)
 			addr := string(peerID + "." + q)
 			quorumAddrList = append(quorumAddrList, addr)
-			quorumCount = quorumCount + 1
-			if quorumCount == 7 {
+			quorumAddrCount = quorumAddrCount + 1
+			if quorumAddrCount == 7 {
 				break
 			}
 		}

core/quorum_initiator.go

@@ -364,8 +364,8 @@ func (c *Core) initiateConsensus(cr *ConensusRequest, sc *contract.Contract, dc
 		delete(c.pd, cr.ReqID)
 		c.qlock.Unlock()
 	}()
-	c.quorumCount = 0
-	c.noBalanceQuorumCount = 0
+	c.quorumCount = QuorumRequired - len(cr.QuorumList)
+	c.noBalanceQuorumCount = QuorumRequired - len(cr.QuorumList)
 	for _, a := range cr.QuorumList {
 		//This part of code is trying to connect to the quorums in quorum list, where various functions are called to pledge the tokens
 		//and checking of transaction by the quorum i.e. consensus for the transaction. Once the quorum is connected, it pledges and