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

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

net?:=?smnet.NewFromLibp2pHost(h)

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

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)},?nil

opt?:=?storageimpl.CustomDealDecisionLogic(func(ctx?context.Context,?deal?storagemarket.MinerDeal)?(bool,?string,?error)?{
})

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

carIO?:=?cario.NewCarIO()
pio?:=?pieceio.NewPieceIOWithStore(carIO,?fs,?bs)

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),
}

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

return?fsm.New(ds,?fsm.Parameters{Environment:env,StateType:storagemarket.MinerDeal{},StateKeyField:"State",Events:providerstates.ProviderEvents,StateEntryFuncs:?providerstates.ProviderStateEntryFuncs,FinalityStates:providerstates.ProviderFinalityStates,Notifier:notifier,
})

h.Configure(options...)

dataTransfer.SubscribeToEvents(dtutils.ProviderDataTransferSubscriber(deals))

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

Start 方法执行过程如下： 调用 StorageMarketNetwork 网络对象的 SetDelegate 设置代理/委托为自身。

err?:=?p.net.SetDelegate(p)

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

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)

var?deals?[]storagemarket.MinerDeal
err?:=?c.deals.List(&deals)

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

—-

编译者/作者：乔疯

玩币族申明：玩币族作为开放的资讯翻译/分享平台，所提供的所有资讯仅代表作者个人观点，与玩币族平台立场无关，且不构成任何投资理财建议。文章版权归原作者所有。