精通 Filecoin:Lotus真实数据处理之Provider初始化

因为 StorageProvider 对象被存储矿工 API 对象所依赖,所以在启动存储矿工的过程中,DI 容器会调用 StorageProvider 函数(node/modules/storageminer.go)来创建它。StorageProvider 函数流程如下:
  1. 调用 NewFromLibp2pHost 函数,生成 StorageMarketNetwork 对象。

    net := smnet.NewFromLibp2pHost(h)
  2. 调用 NewLocalFileStore 函数,生成 FileStore 存储对象。

    store, err := piecefilestore.NewLocalFileStore(piecefilestore.OsPath(r.Path()))

    NewLocalFileStore 函数(go-fil-markets 类库 filestore/filestore.go)流程如下:

    base := filepath.Clean(string(basedirectory))
    info, err := os.Stat(string(base))

if !info.IsDir() {     return nil, fmt.Errorf("%s is not a directory", base) }

return &fileStore{string(base)}, nilNewLocalFileStore 函数使用的路径为仓库目录。即碎片的临时目录就是仓库目录。

  • 调用 CustomDealDecisionLogic 函数,返回一个函数对象。在函数对象中调用我们提供的回调函数,进行自定义交易逻辑判断。

    opt := storageimpl.CustomDealDecisionLogic(func(ctx context.Context, deal storagemarket.MinerDeal) (bool, string, error) {})
  • 生成并返回 StorageProvider 对象。

    p, err := storageimpl.NewProvider(net, namespace.Wrap(ds, datastore.NewKey("/deals/provider")), ibs, store, pieceStore, dataTransfer, spn, address.Address(minerAddress), ffiConfig.SealProofType, storedAsk, opt)return p, nil

    NewProvider 函数处理如下:

    • 环境对象为 providerDealEnvironment

    • 状态对象为 MinerDeal

    • 状态字段为 State

    • 事件集合为 ProviderEvents,参考 storagemarket/impl/providerstates/provider_fsm.go 文件。

    • 状态处理函数集合 为 ProviderStateEntryFuncs,状态机的状态处理器根据对应的状态获取到指定的函数进行处理。

    • 终止状态集合为 ProviderFinalityStates

    • 通知对象为 Provider 对象的 dispatch 方法。

    • 生成 PieceIOWithStore 对象。

      carIO := cario.NewCarIO()
      pio := pieceio.NewPieceIOWithStore(carIO, fs, bs)
    • 生成 Provider 对象。

      h := &Provider{
          net:                  net,
          proofType:            rt,
          spn:                  spn,
          fs:                   fs,
          pio:                  pio,
          pieceStore:           pieceStore,
          conns:                connmanager.NewConnManager(),
          storedAsk:            storedAsk,
          actor:                minerAddress,
          dataTransfer:         dataTransfer,
          dealAcceptanceBuffer: DefaultDealAcceptanceBuffer,
          pubSub:               pubsub.New(providerDispatcher),
      }
    • 生成 fsm 状态组对象。

      deals, err := NewProviderStateMachine(
          ds,
          &providerDealEnvironment{h},
          h.dispatch,
      )h.deals = deals

      fsm 状态组对象使用的配置参数如下:

      return fsm.New(ds, fsm.Parameters{
          Environment:     env,
          StateType:       storagemarket.MinerDeal{},
          StateKeyField:   "State",
          Events:          providerstates.ProviderEvents,
          StateEntryFuncs: providerstates.ProviderStateEntryFuncs,
          FinalityStates:  providerstates.ProviderFinalityStates,
          Notifier:        notifier,
      })
    • 使用配置选项,配置 Provider 对象。

      h.Configure(options...)
    • 设置数据传输监听对象。

      dataTransfer.SubscribeToEvents(dtutils.ProviderDataTransferSubscriber(deals))

      当开始数据传输、传输结束、传输错误时会发送 ProviderEventDataTransferInitiatedProviderEventDataTransferCompletedProviderEventDataTransferFailed 等事件到 fsm 状态组。

    • 返回 Provider 对象。






      在存储矿工启动过程自动调用 HandleDeals 函数(node/modules/storageminer.go)。在这个函数中,调用 StorageProvider 对象的 Start 方法,从而启动这个对象。

      Start 方法执行过程如下:

      1. 调用 StorageMarketNetwork 网络对象的 SetDelegate 设置代理/委托为自身。

        err := p.net.SetDelegate(p)

        网络对象的实现为 libp2pStorageMarketNetwork 结构体(storagemarket/network/libp2p_impl.go)。它的 SetDelegate 方法内容如下:

        impl.receiver = r
        impl.host.SetStreamHandler(storagemarket.DealProtocolID, impl.handleNewDealStream)
        impl.host.SetStreamHandler(storagemarket.AskProtocolID, impl.handleNewAskStream)
        return nil

        上面分别设置网络对象的 handleNewDealStream 方法处理 DealProtocolID 协议,表示存储;handleNewAskStream 方法 处理 AskProtocolID 协议,表示 ask。

        handleNewDealStream 方法内容如下:

        // 客户端 peer id
        remotePID := s.Conn().RemotePeer()  buffered := bufio.NewReaderSize(s, 16)// 对流进行包装
        ds := &dealStream{remotePID, impl.host, s, buffered}// 调用 StorageProvider 对象的 HandleDealStream 方法,处理客户端存储请求
        impl.receiver.HandleDealStream(ds)
      2. 在协程中调用 StorageProvider 对象的 restartDeals 方法,重新进行交易处理。restartDeals 方法流程如下:

        • 如果当前交易对象已经终止,则进行下一个处理。

        • 如果当前交易对象的连接已经关闭,则进行下一个处理。

        • 发送初始交易事件给 fsm 状态组。

          err = c.deals.Send(deal.ProposalCid, storagemarket.ProviderEventRestart)

          交易提案的 Cid 表示了状态机的名称/编号。

        • 从 fsm 状态组对象中获取所有的交易对象。

          var deals []storagemarket.MinerDeal
          err := c.deals.List(&deals)
        • 遍历所有的交易对象,进行下面的处理:

      3. 返回空值。







      本文链接:https://www.8btc.com/article/630375
      转载请注明文章出处

    声明:此文出于传递更多信息之目的,并不意味着赞同其观点或证实其描述。本网站所提供的信息,只供参考之用。

    本文转载自互联网,如有侵权,联系删除

    相关推荐

    能用家用电脑来挖矿吗?是可以拿来挖矿的?

    能用家用电脑来挖矿吗?是可以拿来挖矿的?

    说到比特币,相信大家都不陌生。毕竟,它是前几年最流行的虚拟货币,可以说是 风靡全球。其实所谓的比特币是一种虚拟的加密数字货币 怎么用电脑挖矿比特币 ,它与普通的虚拟货

    2021-09-12 100

    2018年,你还没有听说过“挖矿”你真的OUT了

    2018年,你还没有听说过“挖矿”你真的OUT了

    没听过“挖矿”的2018你真的OUT了! 2009年,改变世界的神秘人物中本聪发布2100万比特币后,一大批“挖矿”矿工出现。截至 2018 年 2 月,比特币的 80% 已经被“开采”出来,而由于其稀

    2021-09-12 154

    挖矿衍生品的几种玩法和介绍

    挖矿衍生品的几种玩法和介绍

    对于绝大多数熟悉数字货币的人来说,挖矿自然也是必备的基础知识之一,挖矿产业自从比特币诞生以来,一直到现在,已经发展成为了一个庞大的产业。最近比特大陆的各种纷争,其

    2021-09-06 51

    精通 Filecoin:Lotus真实数据处理之Provider初始化

    精通 Filecoin:Lotus真实数据处理之Provider初始化

    因为 StorageProvider 对象被存储矿工 API 对象所依赖,所以在启动存储矿工的过程中,DI 容器会调用 StorageProvider 函数(node/modules/storageminer.go)来创建它。 StorageProvider 函数流程如下: 调用

    2021-09-06 114

    Filecoin主网上线在即,如何评估矿工的挖矿效率?

    Filecoin主网上线在即,如何评估矿工的挖矿效率?

    随着Filecoin测试网第二阶段的启动,Filecoin的市场热度持续高涨,技术圈、币圈、矿圈、投资圈、媒体圈等各个群体都疯狂涌入。 各路矿工也都在摩拳擦掌,为将在8月25日开始的测试网

    2021-09-05 178

    发布评论

    点击我更换图片