Method ObserverFetchBlock

worker/observer.go:29–33

ObserverFetchBlock handles observer fetch block logic.

(req *ObserverFetchBlockReq, resp *ObserverFetchBlockResp)

// ObserverFetchBlock handles observer fetch block logic.
func (rpc *DBMSRPCService) ObserverFetchBlock(req *ObserverFetchBlockReq, resp *ObserverFetchBlockResp) (err error) {
	subscriberID := req.GetNodeID().ToNodeID()
	resp.Block, resp.Count, err = rpc.dbms.observerFetchBlock(req.DatabaseID, subscriberID, req.Count)
	return
}

func (dbms *DBMS) observerFetchBlock(dbID proto.DatabaseID, nodeID proto.NodeID, count int32) (
	block *types.Block, realCount int32, err error) {