forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

beacon/blsync: fix lifecycle methods signature

Browse source
This commit is contained in:
Felix Lange 2024-03-14 23:12:38 +01:00
parent dfd8dcee68
commit 90151aef67
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
beacon/blsync/client.go
View file

@ -93,7 +93,7 @@ func (c *Client) SetEngineRPC(engine *rpc.Client) {
c.engineRPC = engine c.engineRPC = engine
} }
func (c *Client) Start() { func (c *Client) Start() error {
headCh := make(chan types.ChainHeadEvent, 16) headCh := make(chan types.ChainHeadEvent, 16)
c.blockSync.SubscribeChainHead(headCh) c.blockSync.SubscribeChainHead(headCh)
c.engineClient = startEngineClient(c.chainConfig, c.engineRPC, headCh) c.engineClient = startEngineClient(c.chainConfig, c.engineRPC, headCh)
@ -103,10 +103,12 @@ func (c *Client) Start() {
beaconApi := api.NewBeaconLightApi(url, c.customHeader) beaconApi := api.NewBeaconLightApi(url, c.customHeader)
c.scheduler.RegisterServer(request.NewServer(api.NewApiServer(beaconApi), &mclock.System{})) c.scheduler.RegisterServer(request.NewServer(api.NewApiServer(beaconApi), &mclock.System{}))
} }
return nil
} }
func (c *Client) Stop() { func (c *Client) Stop() error {
c.engineClient.stop() c.engineClient.stop()
c.chainHeadSub.Unsubscribe() c.chainHeadSub.Unsubscribe()
c.scheduler.Stop() c.scheduler.Stop()
return nil
} }