diff --git a/cmd/neofs-node/config.go b/cmd/neofs-node/config.go index 6c38b806..88746cad 100644 --- a/cmd/neofs-node/config.go +++ b/cmd/neofs-node/config.go @@ -443,3 +443,8 @@ func (c *cfg) bootstrap() error { return c.cfgNetmap.wrapper.AddPeer(&ni) } + +// needBootstrap checks if local node should be registered in network on bootup. +func (c *cfg) needBootstrap() bool { + return c.cfgNetmap.needBootstrap +} diff --git a/cmd/neofs-node/netmap.go b/cmd/neofs-node/netmap.go index c5d3504a..038a059d 100644 --- a/cmd/neofs-node/netmap.go +++ b/cmd/neofs-node/netmap.go @@ -2,6 +2,7 @@ package main import ( "bytes" + "errors" netmapSDK "github.com/nspcc-dev/neofs-api-go/pkg/netmap" netmapV2 "github.com/nspcc-dev/neofs-api-go/v2/netmap" @@ -113,7 +114,7 @@ func initNetmapService(c *cfg) { }) addNewEpochAsyncNotificationHandler(c, func(ev event.Event) { - if c.cfgNetmap.reBoostrapTurnedOff.Load() { // fixes #470 + if !c.needBootstrap() || c.cfgNetmap.reBoostrapTurnedOff.Load() { // fixes #470 return } @@ -149,8 +150,10 @@ func initNetmapService(c *cfg) { func bootstrapNode(c *cfg) { initState(c) - err := c.bootstrap() - fatalOnErrDetails("bootstrap error", err) + if c.needBootstrap() { + err := c.bootstrap() + fatalOnErrDetails("bootstrap error", err) + } } func addNetmapNotificationHandler(c *cfg, sTyp string, h event.Handler) { @@ -228,7 +231,13 @@ func addNewEpochAsyncNotificationHandler(c *cfg, h event.Handler) { ) } +var errRelayBootstrap = errors.New("setting netmap status is forbidden in relay mode") + func (c *cfg) SetNetmapStatus(st control.NetmapStatus) error { + if !c.needBootstrap() { + return errRelayBootstrap + } + if st == control.NetmapStatus_ONLINE { c.cfgNetmap.reBoostrapTurnedOff.Store(false) return c.bootstrap()