2. 程式人生 > >超級賬本 Fabric交易提交過程詳解

超級賬本 Fabric交易提交過程詳解

阿新 • • 發佈：2018-12-16

Peer 啟動後會在後臺執行 gossip 服務，包括若干 goroutine，實現位於 gossip/state/state.go#NewGossipStateProvider(chainID string, services *ServicesMediator, ledger ledgerResources) GossipStateProvider 方法。

其中一個協程專門負責處理收到的區塊資訊。

  1. // Deliver in order messages into the incoming channel
  2. go s.deliverPayloads()

deliverPayloads() 方法實現位於同一個檔案的 GossipStateProviderImpl 結構下，其主要過程為迴圈從收到的 Gossip 訊息載荷緩衝區按序拿到封裝訊息，解析後進行處理。核心程式碼邏輯如下：

  1. // gossip/state/state.go#GossipStateProviderImpl.deliverPayloads()
  2. for {
  3.     select {
  4.     case <-s.payloads.Ready(): // 等待訊息
  5.         // 依次處理收到的訊息
  6.         for payload := s.payloads.Pop(); payload != nil; payload = s.payloads.Pop() {
  7.             rawBlock := &common.Block{}
  8.             // 從載荷資料中嘗試解析區塊結構，失敗則嘗試下個訊息
     
  9.             if err := pb.Unmarshal(payload.Data, rawBlock); err != nil {
  10.                 logger.Errorf("Error getting block with seqNum = %d due to (%+v)...dropping block", payload.SeqNum, errors.WithStack(err))
  11.                 continue
  12.             }
  13. 			// 檢查區塊結構是否完整，失敗則嘗試下個訊息
  14.             if rawBlock.Data == nil
     
     || rawBlock.Header == nil {
  15.                 logger.Errorf("Block with claimed sequence %d has no header (%v) or data (%v)",
  16.                     payload.SeqNum, rawBlock.Header, rawBlock.Data)
  17.                 continue
  18.             }
  19.             // 從載荷中解析私密資料，失敗則嘗試下個訊息
  20.             var p util.PvtDataCollections
  21.             if payload.PrivateData != nil {
  22.                 err := p.Unmarshal(payload.PrivateData)
  23.                 if err != nil {
  24.                     logger.Errorf("Wasn't able to unmarshal private data for block seqNum = %d due to (%+v)...dropping block", payload.SeqNum, errors.WithStack(err))
  25.                     continue
  26.                 }
  27.             }
  28.             // 核心部分：提交區塊到本地賬本
  29.             if err := s.commitBlock(rawBlock, p); err != nil {
  30.                 if executionErr, isExecutionErr := err.(*vsccErrors.VSCCExecutionFailureError); isExecutionErr {
  31.                     logger.Errorf("Failed executing VSCC due to %v. Aborting chain processing", executionErr)
  32.                     return
  33.                 }
  34.                 logger.Panicf("Cannot commit block to the ledger due to %+v", errors.WithStack(err))
  35.             }
  36.         }
  37.     case <-s.stopCh: // 停止處理訊息
  38.         s.stopCh <- struct{}{}
  39.         logger.Debug("State provider has been stopped, finishing to push new blocks.")
  40.         return
  41.     }
  42. }

整體邏輯

s.commitBlock(rawBlock, p) 是對區塊進行處理和提交的核心邏輯，主要包括提交前準備、提交過程和提交後處理三部分，如下圖所示。

Peer 提交區塊過程

下面分別進行介紹三個階段的實現過程。

提交前準備

主要完成對區塊中交易格式的檢查和獲取關聯該區塊但缺失的私密資料，最後構建 blockAndPvtData 結構。

格式檢查

對區塊格式的檢查主要在 core/committer/txvalidator/validator.go#TxValidator.Validate(block *common.Block) error 方法中完成，包括檢查交易格式、對應賬本是否存在、是否雙花、滿足 VSCC 和 Policy 等。核心邏輯如下。

  1. // core/committer/txvalidator/validator.go#TxValidator.Validate(block *common.Block) error
  2. // 併發驗證交易有效性
  3. go func() {
  4.     for tIdx, d := range block.Data.Data {
  5.         // ensure that we don't have too many concurrent validation workers
  6.         v.Support.Acquire(context.Background(), 1)
  7.         go func(index int, data []byte) {
  8.             defer v.Support.Release(1)
  9.             v.validateTx(&blockValidationRequest{
  10.                 d:     data,
  11.                 block: block,
  12.                 tIdx:  index,
  13.             }, results)
  14.         }(tIdx, d)
  15.     }
  16. }()
  17. // 處理檢查結果
  18. for i := 0; i < len(block.Data.Data); i++ {
  19.     res := <-results
  20.     if res.err != nil {
  21.         if err == nil || res.tIdx < errPos {
  22.             err = res.err
  23.             errPos = res.tIdx
  24.         }
  25.     } else { // 設定有效標記，記錄鏈碼名稱，更新鏈碼資訊
  26.         txsfltr.SetFlag(res.tIdx, res.validationCode)
  27.         if res.validationCode == peer.TxValidationCode_VALID {
  28.             if res.txsChaincodeName != nil {
  29.                 txsChaincodeNames[res.tIdx] = res.txsChaincodeName
  30.             }
  31.             if res.txsUpgradedChaincode != nil {
  32.                 txsUpgradedChaincodes[res.tIdx] = res.txsUpgradedChaincode
  33.             }
  34.             txidArray[res.tIdx] = res.txid
  35.         }
  36.     }
  37. }
  38. // 標記雙花交易
  39. if v.Support.Capabilities().ForbidDuplicateTXIdInBlock() {
  40.     markTXIdDuplicates(txidArray, txsfltr)
  41. }
  42. // 防止多次升級操作
  43. v.invalidTXsForUpgradeCC(txsChaincodeNames, txsUpgradedChaincodes, txsfltr)
  44. // 確認所有交易都完成檢查
  45. err = v.allValidated(txsfltr, block)
  46. if err != nil {
  47.     return err
  48. }
  49. // 更新交易有效標籤到元資料
  50. utils.InitBlockMetadata(block)
  51. block.Metadata.Metadata[common.BlockMetadataIndex_TRANSACTIONS_FILTER] = txsflt

獲取缺失的私密資料

首先根據已有的私密資料計算區塊中交易關聯的讀寫集資訊。如果仍有缺失，則嘗試從其它節點獲取。

  1. // gossip/privdata/coordinator.go#coordinator.StoreBlock(block *common.Block, privateDataSets util.PvtDataCollections) error
  2. // 利用已有的私密資料計算讀寫集
  3. ownedRWsets, err := computeOwnedRWsets(block, privateDataSets)
  4. privateInfo, err := c.listMissingPrivateData(block, ownedRWsets)
  5. // 獲取缺失私密資料
  6. for len(privateInfo.missingKeys) > 0 && time.Now().Before(limit) {
  7.     c.fetchFromPeers(block.Header.Number, ownedRWsets, privateInfo)
  8.     if len(privateInfo.missingKeys) == 0 {
  9.         break
  10.     }
  11.     time.Sleep(pullRetrySleepInterval)
  12. }

構建 blockAndPvtData 結構

blockAndPvtData 結構用於後續的提交工作，因此，需要包括相關的區塊和私密資料。

主要實現邏輯如下：

  1. // gossip/privdata/coordinator.go#coordinator.StoreBlock(block *common.Block, privateDataSets util.PvtDataCollections) error
  2. // 填充私密讀寫集資訊
  3. for seqInBlock, nsRWS := range ownedRWsets.bySeqsInBlock() {
  4.     rwsets := nsRWS.toRWSet()
  5.     blockAndPvtData.BlockPvtData[seqInBlock] = &ledger.TxPvtData{
  6.         SeqInBlock: seqInBlock,
  7.         WriteSet:   rwsets,
  8.     }
  9. }
  10. // 填充缺失私密資料資訊
  11. for missingRWS := range privateInfo.missingKeys {
  12.     blockAndPvtData.Missing = append(blockAndPvtData.Missing, ledger.MissingPrivateData{
  13.         TxId:       missingRWS.txID,
  14.         Namespace:  missingRWS.namespace,
  15.         Collection: missingRWS.collection,
  16.         SeqInBlock: int(missingRWS.seqInBlock),
  17.     })
  18. }

提交過程

提交過程是核心過程，主要包括預處理、驗證交易、更新本地區塊鏈結構、更新本地資料庫結構四個步驟。

預處理

預處理階段負責構造一個有效的內部區塊結構。包括：

  • 處理 Endorser 交易：只保留有效的 Endorser 交易；
  • 處理配置交易：獲取配置更新的模擬結果，放入讀寫集；
  • 校驗寫集合：如果狀態資料庫採用 CouchDB，要按照 CouchDB 約束檢查鍵值的格式：Key 必須為非下劃線開頭的 UTF-8 字串，Value 必須為合法的字典結構，且不包括下劃線開頭的鍵名。

核心實現程式碼位於 core/ledger/kvledger/txmgmt/validator/valimpl/helper.go#preprocessProtoBlock(txmgr txmgr.TxMgr, validateKVFunc func(key string, value []byte) error, block *common.Block, doMVCCValidation bool) (*valinternal.Block, error)，如下所示：

  1. // core/ledger/kvledger/txmgmt/validator/valimpl/helper.go#preprocessProtoBlock(txmgr txmgr.TxMgr, validateKVFunc func(key string, value []byte) error, block *common.Block, doMVCCValidation bool) (*valinternal.Block, error)
  2. // 處理 endorser 交易
  3. if txType == common.HeaderType_ENDORSER_TRANSACTION {
  4.     // extract actions from the envelope message
  5.     respPayload, err := utils.GetActionFromEnvelope(envBytes)
  6.     if err != nil {
  7.         txsFilter.SetFlag(txIndex, peer.TxValidationCode_NIL_TXACTION)
  8.         continue
  9.     }
  10.     txRWSet = &rwsetutil.TxRwSet{}
  11.     if err = txRWSet.FromProtoBytes(respPayload.Results); err != nil {
  12.         txsFilter.SetFlag(txIndex, peer.TxValidationCode_INVALID_OTHER_REASON)
  13.         continue
  14.     }
  15. } else { // 處理配置更新交易
  16.     rwsetProto, err := processNonEndorserTx(env, chdr.TxId, txType, txmgr, !doMVCCValidation)
  17.     if _, ok := err.(*customtx.InvalidTxError); ok {
  18.         txsFilter.SetFlag(txIndex, peer.TxValidationCode_INVALID_OTHER_REASON)
  19.         continue
  20.     }
  21.     if err != nil {
  22.         return nil, err
  23.     }
  24.     if rwsetProto != nil {
  25.         if txRWSet, err = rwsetutil.TxRwSetFromProtoMsg(rwsetProto); err != nil {
  26.             return nil, err
  27.         }
  28.     }
  29. }
  30. // 檢查讀寫集是否符合資料庫要求格式
  31. if txRWSet != nil {
  32.     if err := validateWriteset(txRWSet, validateKVFunc); err != nil {
  33.         txsFilter.SetFlag(txIndex, peer.TxValidationCode_INVALID_WRITESET)
  34.         continue
  35.     }
  36.     b.Txs = append(b.Txs, &valinternal.Transaction{IndexInBlock: txIndex, ID: chdr.TxId, RWSet: txRWSet})
  37. }

驗證交易

接下來，對區塊中交易進行 MVCC 檢查，並校驗私密讀寫集，更新區塊元資料中的交易有效標記列表。

MVCC 檢查需要逐個驗證塊中的 Endorser 交易，滿足下列條件者才認為有效：

  • 公共讀集合中 key 版本在該交易前未變；
  • RangeQuery 的結果未變；
  • 私密讀集合中 key 版本未變。

實現在 core/ledger/kvledger/txmgmt/validator/statebasedval/state_based_validator.go#Validator.ValidateAndPrepareBatch(block *valinternal.Block, doMVCCValidation bool) (*valinternal.PubAndHashUpdates, error) 方法中，主要邏輯如下：

  1. // core/ledger/kvledger/txmgmt/validator/statebasedval/state_based_validator.go#Validator.ValidateAndPrepareBatch(block *valinternal.Block, doMVCCValidation bool) (*valinternal.PubAndHashUpdates, error)
  2. // 依次順序檢查每個交易
  3. for _, tx := range block.Txs {
  4.     var validationCode peer.TxValidationCode
  5.     var err error
  6.     // 檢查 Endorser 交易
  7.     if validationCode, err = v.validateEndorserTX(tx.RWSet, doMVCCValidation, updates); err != nil {
  8.         return nil, err
  9.     }
  10.     tx.ValidationCode = validationCode
  11.     // 有效交易則將其讀寫集放到更新集合中
  12.     if validationCode == peer.TxValidationCode_VALID {
  13.         committingTxHeight := version.NewHeight(block.Num, uint64(tx.IndexInBlock))
  14.         updates.ApplyWriteSet(tx.RWSet, committingTxHeight)
  15.     } else {
  16.         logger.Warningf("Block [%d] Transaction index [%d] TxId [%s] marked as invalid by state validator. Reason code [%s]",
  17.             block.Num, tx.IndexInBlock, tx.ID, validationCode.String())
  18.     }
  19. }

對私密讀寫集的校驗主要是再次檢查 Hash 值是否匹配，實現在 core/ledger/kvledger/txmgmt/validator/valimpl/helper.go#validatePvtdata(tx *valinternal.Transaction, pvtdata *ledger.TxPvtData) error 方法中。

  1. // core/ledger/kvledger/txmgmt/validator/valimpl/helper.go#validatePvtdata(tx *valinternal.Transaction, pvtdata *ledger.TxPvtData) error
  2. for _, nsPvtdata := range pvtdata.WriteSet.NsPvtRwset {
  3.     for _, collPvtdata := range nsPvtdata.CollectionPvtRwset {
  4.         collPvtdataHash := util.ComputeHash(collPvtdata.Rwset)
  5.         hashInPubdata := tx.RetrieveHash(nsPvtdata.Namespace, collPvtdata.CollectionName)
  6.         // 重新計算私密資料 Hash 值，對比公共資料中的記錄
  7.         if !bytes.Equal(collPvtdataHash, hashInPubdata) {
  8.             return &validator.ErrPvtdataHashMissmatch{
  9.                 Msg: fmt.Sprintf(`Hash of pvt data for collection [%s:%s] does not match with the corresponding hash in the public data.
  10.                 public hash = [%#v], pvt data hash = [%#v]`, nsPvtdata.Namespace, collPvtdata.CollectionName, hashInPubdata, collPvtdataHash),
  11.             }
  12.         }
  13.     }
  14. }

最後，更新區塊元資料中的交易有效標記列表，實現位於 core/ledger/kvledger/txmgmt/validator/valimpl/helper.go#postprocessProtoBlock(block *common.Block, validatedBlock *valinternal.Block) 方法，程式碼如下所示。

  1. // core/ledger/kvledger/txmgmt/validator/valimpl/helper.go#postprocessProtoBlock(block *common.Block, validatedBlock *valinternal.Block)
  2. func postprocessProtoBlock(block *common.Block, validatedBlock *valinternal.Block) {
  3. 	txsFilter := util.TxValidationFlags(block.Metadata.Metadata[common.BlockMetadataIndex_TRANSACTIONS_FILTER])
  4. 	for _, tx := range validatedBlock.Txs {
  5. 		txsFilter.SetFlag(tx.IndexInBlock, tx.ValidationCode)
  6. 	}
  7. 	block.Metadata.Metadata[common.BlockMetadataIndex_TRANSACTIONS_FILTER] = txsFilter
  8. }

接下來，需要更新本地的賬本結構，包括區塊鏈結構和相關的本地資料庫。

更新本地區塊鏈結構

入口在 core/ledger/ledgerstorage/store.go#Store.CommitWithPvtData(blockAndPvtdata *ledger.BlockAndPvtData) error 方法中，主要包括如下步驟：

  • 將區塊寫入本地 Chunk 檔案；
  • 更新索引資料庫（區塊號、Hash值、檔案指標、交易偏移、區塊元資料）；
  • 更新所提交的區塊號到私密資料庫；

區塊寫入 Chunk 檔案主要實現在 common/ledger/blkstorage/fsblkstorage/blockfile_mgr.go#blockfileMgr.addBlock(block *common.Block) error 方法中，主要邏輯如下所示：

  1. // common/ledger/blkstorage/fsblkstorage/blockfile_mgr.go#blockfileMgr.addBlock(block *common.Block) error
  2. // 計算長度資訊
  3. blockBytesLen := len(blockBytes)
  4. blockBytesEncodedLen := proto.EncodeVarint(uint64(blockBytesLen))
  5. totalBytesToAppend := blockBytesLen + len(blockBytesEncodedLen)
  6. // 新增長度資訊到 Chunk 檔案
  7. err = mgr.currentFileWriter.append(blockBytesEncodedLen, false)
  8. // 更新 checkpoint 資訊
  9. newCPInfo := &checkpointInfo{
  10. 	latestFileChunkSuffixNum: currentCPInfo.latestFileChunkSuffixNum,
  11. 	latestFileChunksize:      currentCPInfo.latestFileChunksize + totalBytesToAppend,
  12. 	isChainEmpty:             false,
  13. 	lastBlockNumber:          block.Header.Number}
  14. mgr.saveCurrentInfo(newCPInfo, false);
  15. // 更新區塊在檔案中索引位置和交易偏移量
  16. blockFLP := &fileLocPointer{fileSuffixNum: newCPInfo.latestFileChunkSuffixNum}
  17. 	blockFLP.offset = currentOffset
  18. for _, txOffset := range txOffsets {
  19. 		txOffset.loc.offset += len(blockBytesEncodedLen)
  20. }
  21. // 更新索引資料庫
  22. mgr.index.indexBlock(&blockIdxInfo{
  23. 	blockNum: block.Header.Number, blockHash: blockHash,
  24. 	flp: blockFLP, txOffsets: txOffsets, metadata: block.Metadata})
  25. // 更新 checkpoint 資訊和區塊鏈資訊
  26. mgr.updateCheckpoint(newCPInfo)
  27. mgr.updateBlockchainInfo(blockHash, block)

更新本地資料庫結構

更新資料庫是提交交易的最後一步，主要包括如下步驟：

  • 刪除過期私密資料；
  • 更新私密資料生命週期記錄資料庫；
  • 更新本地公共狀態資料庫和私密狀態資料庫；
  • 如果啟用了歷史資料庫，更新資料。

實現程式碼在 core/ledger/kvledger/txmgmt/txmgr/lockbasedtxmgr/lockbased_txmgr.go#LockBasedTxMgr.Commit() error 方法中，主要邏輯如下。

  1. // core/ledger/kvledger/txmgmt/txmgr/lockbasedtxmgr/lockbased_txmgr.go#LockBasedTxMgr.Commit() error
  2. // 準備過期的私密鍵值清理
  3. txmgr.pvtdataPurgeMgr.PrepareForExpiringKeys(txmgr.current.blockNum())
  4. // 更新私密資料生命週期記錄資料庫，這裡記錄了每個私密鍵值的存活期限
  5. if err := txmgr.pvtdataPurgeMgr.DeleteExpiredAndUpdateBookkeeping(
  6. 		txmgr.current.batch.PvtUpdates, txmgr.current.batch.HashUpdates); err != nil{
  7. 	return err
  8. }
  9. // 更新本地公共狀態資料庫和私密狀態資料庫
  10. if err := txmgr.db.ApplyPrivacyAwareUpdates(txmgr.current.batch, commitHeight); err != nil {
  11. 	return err
  12. }
  13. // 如果啟用了歷史資料庫，更新資料
  14. if ledgerconfig.IsHistoryDBEnabled() {
  15. 	if err := l.historyDB.Commit(block); err != nil {
  16. 		panic(errors.WithMessage(err, "Error during commit to history db"))
  17. 	}
  18. }

提交後處理

提交後的處理比較簡單，包括清理本地的臨時狀態資料庫和更新賬本高度資訊。

清理工作包括區塊關聯的臨時私密資料和舊區塊關聯的臨時私密資料。

======關於本文 =======

更多區塊鏈深度技術可參考 區塊鏈技術指南 開源專案。

轉載請註明原文連結。

Peer 啟動後會在後臺執行 gossip 服務，包括若干 goroutine，實現位於 gossip/state/state.go#NewGossipStateProvider(chainID string, services *ServicesMediator, ledger ledgerResources) GossipStateProvider 方法。

其中一個協程專門負責處理收到的區塊資訊。

  1. // Deliver in order messages into the incoming channel
  2. go s.deliverPayloads()

deliverPayloads() 方法實現位於同一個檔案的 GossipStateProviderImpl 結構下，其主要過程為迴圈從收到的 Gossip 訊息載荷緩衝區按序拿到封裝訊息，解析後進行處理。核心程式碼邏輯如下：

  1. // gossip/state/state.go#GossipStateProviderImpl.deliverPayloads()
  2. for {
  3.     select {
  4.     case <-s.payloads.Ready(): // 等待訊息
  5.         // 依次處理收到的訊息
  6.         for payload := s.payloads.Pop(); payload != nil; payload = s.payloads.Pop() {
  7.             rawBlock := &common.Block{}
  8.             // 從載荷資料中嘗試解析區塊結構，失敗則嘗試下個訊息
  9.             if err := pb.Unmarshal(payload.Data, rawBlock); err != nil {
  10.                 logger.Errorf("Error getting block with seqNum = %d due to (%+v)...dropping block", payload.SeqNum, errors.WithStack(err))
  11.                 continue
  12.             }
  13. 			// 檢查區塊結構是否完整，失敗則嘗試下個訊息
  14.             if rawBlock.Data == nil || rawBlock.Header == nil {
  15.                 logger.Errorf("Block with claimed sequence %d has no header (%v) or data (%v)",
  16.                     payload.SeqNum, rawBlock.Header, rawBlock.Data)
  17.                 continue
  18.             }
  19.             // 從載荷中解析私密資料，失敗則嘗試下個訊息
  20.             var p util.PvtDataCollections
  21.             if payload.PrivateData != nil {
  22.                 err := p.Unmarshal(payload.PrivateData)
  23.                 if err != nil {
  24.                     logger.Errorf("Wasn't able to unmarshal private data for block seqNum = %d due to (%+v)...dropping block", payload.SeqNum, errors.WithStack(err))
  25.                     continue
  26.                 }
  27.             }
  28.             // 核心部分：提交區塊到本地賬本
  29.             if err := s.commitBlock(rawBlock, p); err != nil {
  30.                 if executionErr, isExecutionErr := err.(*vsccErrors.VSCCExecutionFailureError); isExecutionErr {
  31.                     logger.Errorf("Failed executing VSCC due to %v. Aborting chain processing", executionErr)
  32.                     return
  33.                 }
  34.                 logger.Panicf("Cannot commit block to the ledger due to %+v", errors.WithStack(err))
  35.             }
  36.         }
  37.     case <-s.stopCh: // 停止處理訊息
  38.         s.stopCh <- struct{}{}
  39.         logger.Debug("State provider has been stopped, finishing to push new blocks.")
  40.         return
  41.     }
  42. }

整體邏輯

s.commitBlock(rawBlock, p) 是對區塊進行處理和提交的核心邏輯，主要包括提交前準備、提交過程和提交後處理三部分，如下圖所示。

Peer 提交區塊過程

下面分別進行介紹三個階段的實現過程。

提交前準備

主要完成對區塊中交易格式的檢查和獲取關聯該區塊但缺失的私密資料，最後構建 blockAndPvtData 結構。

格式檢查

對區塊格式的檢查主要在 core/committer/txvalidator/validator.go#TxValidator.Validate(block *common.Block) error 方法中完成，包括檢查交易格式、對應賬本是否存在、是否雙花、滿足 VSCC 和 Policy 等。核心邏輯如下。

  1. // core/committer/txvalidator/validator.go#TxValidator.Validate(block *common.Block) error
  2. // 併發驗證交易有效性
  3. go func() {
  4.     for tIdx, d := range block.Data.Data {
  5.         // ensure that we don't have too many concurrent validation workers
  6.         v.Support.Acquire(context.Background(), 1)
  7.         go func(index int, data []byte) {
  8.             defer v.Support.Release(1)
  9.             v.validateTx(&blockValidationRequest{
  10.                 d:     data,
  11.                 block: block,
  12.                 tIdx:  index,
  13.             }, results)
  14.         }(tIdx, d)
  15.     }
  16. }()
  17. // 處理檢查結果
  18. for i := 0; i < len(block.Data.Data); i++ {
  19.     res := <-results
  20.     if res.err != nil {
  21.         if err == nil || res.tIdx < errPos {
  22.             err = res.err
  23.             errPos = res.tIdx
  24.         }
  25.     } else { // 設定有效標記，記錄鏈碼名稱，更新鏈碼資訊
  26.         txsfltr.SetFlag(res.tIdx, res.validationCode)
  27.         if res.validationCode == peer.TxValidationCode_VALID {
  28.             if res.txsChaincodeName != nil {
  29.                 txsChaincodeNames[res.tIdx] = res.txsChaincodeName
  30.             }
  31.             if res.txsUpgradedChaincode != nil {
  32.                 txsUpgradedChaincodes[res.tIdx] = res.txsUpgradedChaincode
  33.             }
  34.             txidArray[res.tIdx] = res.txid
  35.         }
  36.     }
  37. }
  38. // 標記雙花交易
  39. if v.Support.Capabilities().ForbidDuplicateTXIdInBlock() {
  40.     markTXIdDuplicates(txidArray, txsfltr)
  41. }
  42. // 防止多次升級操作
  43. v.invalidTXsForUpgradeCC(txsChaincodeNames, txsUpgradedChaincodes, txsfltr)
  44. // 確認所有交易都完成檢查
  45. err = v.allValidated(txsfltr, block)
  46. if err != nil {
  47.     return err<

相關推薦

超級賬本 Fabric交易提交過程詳解

Peer 啟動後會在後臺執行 gossip 服務，包括若干 goroutine，實現位於 gossip/state/state.go#NewGossipStateProvi

Fabric網路環境啟動過程詳解

這篇文章對fabric的網路環境啟動過程進行講解,也就是我們上節講到的啟動測試fabric網路環境時執行network_setup.sh這個檔案的執行流程 fabric網路環境啟動過程詳解 上一節我們講到 fabric網路環境的啟動測試，主要是使用 ./network_setup.sh up 這個命令，所

Fabric網絡環境啟動過程詳解

nco fabric %20 狀態 pre fix sys 以及 mount 這篇文章對fabric的網絡環境啟動過程進行講解,也就是我們上節講到的啟動測試fabric網絡環境時運行network_setup.sh這個文件的執行流程 fabric網絡環境啟動過程詳解 上一節

Nginx實現集群的負載均衡配置過程詳解

post 發現 forward too strong eight glin 內容 請求 Nginx實現集群的負載均衡配置過程詳解 Nginx 的負載均衡功能，其實實際上和 nginx 的代理是同一個功能，只是把代理一臺機器改為多臺機器而已。 Nginx 的負載均衡

使用HeartBeat實現高可用HA的配置過程詳解

接口 dea ive for 64位 doc 主機名 停止 enforce 使用HeartBeat實現高可用HA的配置過程詳解 一、寫在前面 HA即(high available)高可用，又被叫做雙機熱備，用於關鍵性業務。簡單理解就是，有2臺機器 A 和 B，正常

OC學習小結之ios運行過程詳解

for cat 用戶 with res nbsp c學習 launch cati 1）ios核心類 UIView 視圖，屏幕上能看得見的東西都是視圖，例如：按鈕、文本標簽、和表格等 UIViewController：內部默認有個視圖（UIView），負責管理UIView的

storm集群部署和配置過程詳解

多少 帶來 進程 創建 使用 命令 介紹 aml 可能 ---恢復內容開始--- 先整體介紹一下搭建storm集群的步驟： 設置zookeeper集群 安裝依賴到所有nimbus和worker節點 下載並解壓storm發布版本到所有nimbus和worker節點 配置s

TCP協議的3次握手與4次揮手過程詳解

進行 發送數據 不存在 信息 隊列 協議 標識 方式 ar9 所謂三次握手(Three-Way Handshake)即建立TCP連接，就是指建立一個TCP連接時，需要客戶端和服務端總共發送3個包以確認連接的建立。所謂四次揮手(Four-Way Wavehand)即終止TCP

轉-Linux啟動過程詳解（inittab、rc.sysinit、rcX.d、rc.local）

dha mage 模塊 都是 交換 如何配置 mas 完全 打開 http://blog.chinaunix.net/space.php?uid=10167808&do=blog&id=26042 1)BIOS自檢2)啟動Grub/Lilo3)加載內

TCP數據傳輸過程詳解

握手 ron 布爾 位域 fcm 打開 數據段 2個 處理 在學習三次握手的時候，我們知道其中有seq、ack兩個序列號。 如果不仔細了解，那麽可能只知道發回去的時候要加一。 下文將著重介紹，關於序列號的傳輸過程。 最關鍵的一句話：序列號為當前端成功發送的數據位數，確認號為

嵌入式開發學習（2）<S5PV210啟動過程詳解>

nan ios eight img 啟動方式 margin 需要 外部 啟動 基本概念： 內存： 　　SRAM 靜態內存 特點：容量小、價格高，優點：不需要軟件初始化，上電就能用。 　　DRAM 動態內存 特點：容量大、價格低，缺點：上電不能用，需要軟件初始化。 　

linux--系統啟動及安裝過程詳解

linux啟動先通過一張圖來簡單了解下整個系統啟動的流程，整個過程基本可以分為POST-->BIOS-->MBR(GRUB)-->Kernel-->Init-->Runlevel本文出自 “運維自動化” 博客，請務必保留此出處http://shower.blog.51cto.co

HBase寫過程詳解

family region -s ont 流程 size 詳解 put 時機 1基本流程 （1）客戶端發起PUT請求 （2）Zookeeper返回hbase:meta所在的region server （3）去（2）返回的server上，根據rowkey查詢寫操作所在的reg

Mysql加鎖過程詳解

插入記錄 控制 uniq null 詳細 server 讀者 index 理論知識 1、背景 　　MySQL/InnoDB的加鎖分析，一直是一個比較困難的話題。我在工作過程中，經常會有同事咨詢這方面的問題。同時，微博上也經常會收到MySQL鎖相關的私信，讓我幫助解決一些死

Mysql加鎖過程詳解（4）-select for update/lock in share mode 對事務並發性影響

per inno targe 允許 evel transacti 修改 not null warn select for update/lock in share mode 對事務並發性影響 事務並發性理解 事務並發性，粗略的理解就是單位時間內能夠執行的事務數量，常見的單

CentOS 7系統KVM虛擬機安裝過程詳解

選項 安裝 svm roc 支持 linu 系統 kvm flags 一、如何安裝KVM 這裏我是在Windows系統中使用VMware Workstaion安裝了一臺Linux的虛擬機來進行KVM的安裝操作的。首先，我們需要了解我們安裝的Linux系統的CPU是否支持KV

Mysql加鎖過程詳解（9）-innodb下的記錄鎖，間隙鎖，next-key鎖

ans 唯一索引 crazy cimage -h insert tran 存在 gin Mysql加鎖過程詳解（1）-基本知識 Mysql加鎖過程詳解（2）-關於mysql 幻讀理解 Mysql加鎖過程詳解（3）-關於mysql 幻讀理解 Mysql加鎖過程詳解（4）-

SQL語句執行過程詳解

使用 錯誤信息 意思 排錯 表達 對象 data 才會 結果集 　　一、SQL語句執行原 第一步:客戶端把語句發給服務器端執行當我們在客戶端執行 select 語句時,客戶端會把這條 SQL 語句發送給服務器端,讓服務器端的進程來處理這語句。也就是說,Oracl

淺談Web緩存－緩存的實現過程詳解

根據 直觀 pre -i sha 轉載 align 緩存 請求轉發 在前端開發中，性能一直都是被大家所重視的一點，然而判斷一個網站的性能最直觀的就是看網頁打開的速度。其中提高網頁反應速度的一個方式就是使用緩存。一個優秀的緩存策略可以縮短網頁請求資源的距離，減少延遲，並且

OSPF鄰接關系建立過程詳解

拓撲 由於 ethernet 並且 interval fec 進入 根據 alt １.Down-OSPF路由器啟動後開始向外發Hello，但是沒有收到對方的Hello報文。２.Attempt-NBMA才會由Down進入此狀態，此狀態只在NBMA網絡上存在，手工指定鄰居後便會