前言
随着Filecoin/Lotus公链越来越接近启动,真实数据的处理也越来越重要了。根据官方的设计,真实数据的有效算力是自填自挖算力的10倍,鉴于真实数据的比重是如此之在,从今天起,我们就来了聊下真实的相关处理情况,今天为本部分的第一篇。
当前情况下官方的机器人会给存储矿工发送经过验证的真实数据,未来随着基础设施的完善,也会有其他方式来发送真实数据,比如客户端自己指定某个矿工来发送数据。接下来我们从客户端开始来研究下Lotus是怎么处理真实数据。
当客户端要存储真实数据时,他会调用lotusclientdealdataCidminerIdpriceduration命令发送数据到指定的矿工。
正文
当Lotusdaemon接收到这个请求之后就开始了交易处理。Lotusdaemon会调用go-file-markets类库的StorageClient对象对交易进行处理。
跨链协议Wormhole推出Cosmos生态应用链跨链桥:7月21日消息,跨链协议Wormhole宣布在Cosmos生态系统中启动应用链跨链桥,旨在让开发者和用户更容易地将代币接入任何Cosmos链,推动流动性以发展Cosmos生态系统。[2023/7/21 15:50:43]
因为StorageClient对象被LotusAPI对象所依赖,所以在启动Lotus的过程中,DI容器会调用StorageClient函数来创建它。
StorageClient函数流程如下:
调用NewFromLibp2pHost函数,生成StorageMarketNetwork对象。net?:=?smnet.NewFromLibp2pHost(h)
调用NewClient函数,生成Client对象。c,?err?:=?storageimpl.NewClient(net,?ibs,?dataTransfer,?discovery,?deals,?scn,?storageimpl.DealPollingInterval(time.Second))
Coinbase:DEX不能像交易所一样受到监管:金色财经报道,Coinbase周一向监管机构发送了一封新信,这次反对像集中式交易所一样监管去中心化交易所的提议。Coinbase首席法务官Paul Grewel表示,像Uniswap这样的去中心化交易所被称为DEX,不可能以与国家证券交易所相同的方式进行注册。这项提议在过程和实质上存在太多缺陷,无法推进。特别是,美国证券交易委员会试图通过将关于其加密货币管辖权的不受支持的假设纳入拟议规则来抢先国会行动。[2023/6/15 21:37:40]
scn即node对象,也是环境对象返回的节点对象,这个对象是ClientNodeAdapter对象由DI容器调用NewClientNodeAdapter函数而创建。
NewClient函数内容如下:
生成两个IO对象。carIO?:=?cario.NewCarIO()
数据:一地址以527ETH购买46枚MAYC NFT:4月23日消息,据
生成fsm状态组对象。statemachines,?err?:=?newClientStateMachine(
????ds,
????&clientDealEnvironment{c},
????c.dispatch,
)
c.statemachines?=?statemachines
fsm状态组对象使用的配置参数如下:return?fsm.New(ds,?fsm.Parameters{
????Environment:?????env,
????StateType:???????storagemarket.ClientDeal{},
????StateKeyField:???"State",
????Events:??????????clientstates.ClientEvents,
????StateEntryFuncs:?clientstates.ClientStateEntryFuncs,
????FinalityStates:??clientstates.ClientFinalityStates,
????Notifier:????????notifier,
})
环境对象为clientDealEnvironment。
状态对象为ClientDeal。
状态字段为State。
事件集合为ClientEvents,参考storagemarket/impl/clientstates/client_fsm.go文件。
状态处理函数集合为ClientStateEntryFuncs,状态机的状态处理器根据对应的状态获取到指定的函数进行处理。
终止状态集合为ClientFinalityStates。
通知对象为Client对象的dispatch方法。
使用配置选项,配置Client对象。c.Configure(options...)
设置数据传输监听对象。dataTransfer.SubscribeToEvents(dtutils.ClientDataTransferSubscriber(statemachines))
当传输结束、传输错误时会发送ClientEventDataTransferComplete、ClientEventDataTransferFailed等事件到fsm状态组。
返回Client对象。
在DI容器的OnStart钩子函数中调用Client对象的Start方法。Start方法调用自身的restartDeals方法开始进行重新交易。
返回Client对象。
郑重声明: 本文版权归原作者所有, 转载文章仅为传播更多信息之目的, 如作者信息标记有误, 请第一时间联系我们修改或删除, 多谢。