Method CheckSignatures

consensus/dbft/dbft_service.go:195–242

()

}

func (ds *DbftService) CheckSignatures() error {
	log.Debug()

	//check if get enough signatures
	if ds.context.GetSignaturesCount() >= ds.context.M() {
		//build block
		block := ds.context.MakeHeader()
		sigs := make([]SignaturesData, ds.context.M())
		for i, j := 0, 0; i < len(ds.context.Bookkeepers) && j < ds.context.M(); i++ {
			if ds.context.Signatures[i] != nil {
				sig := ds.context.Signatures[i]
				sigs[j].Index = uint16(i)
				sigs[j].Signature = sig

				block.Header.SigData = append(block.Header.SigData, sig)
				j++
			}
		}

		block.Header.Bookkeepers = ds.context.Bookkeepers

		//fill transactions
		block.Transactions = ds.context.Transactions

		hash := block.Hash()
		isExist, err := ds.ledger.IsContainBlock(hash)
		if err != nil {
			log.Errorf("DefLedger.IsContainBlock Hash:%x error:%s", hash, err)
			return err
		}
		if !isExist {
			// save block
			result, err := ds.ledger.ExecuteBlock(block)
			if err != nil {
				return fmt.Errorf("CheckSignatures DefLedgerPid.RequestFuture Height:%d error:%s", block.Header.Height, err)
			}
			err = ds.ledger.SubmitBlock(block, result)
			if err != nil {
				return fmt.Errorf("CheckSignatures DefLedgerPid.RequestFuture Height:%d error:%s", block.Header.Height, err)
			}

			ds.context.State |= BlockGenerated
			payload := ds.context.MakeBlockSignatures(sigs)
			ds.SignAndRelay(payload)
		}
	}
	return nil
}

func (ds *DbftService) ChangeViewReceived(payload *p2pmsg.ConsensusPayload, message *ChangeView) {
	log.Debug()