forked from TrueCloudLab/frostfs-node
[#1253] ir: Call UpdateStateIR method to remove dead storage node
Alphabet nodes in notary enabled environment cannot call `UpdateState` method to remove unwanted storage nodes from the network map, because this method checks witness of the storage node. To force storage node state update, alphabet nodes should invoke new method `UpdateStateIR` which is similar to `AddPeerIR`. State update initiated by the storage node itself is processed the same way as before -- alphabet nods resign such transaction. Signed-off-by: Alex Vanin <alexey@nspcc.ru>
This commit is contained in:
parent
e81081e0e0
commit
7e06d0aa69
1 changed files with 21 additions and 5 deletions
|
@ -25,13 +25,29 @@ func (np *Processor) processNetmapCleanupTick(ev netmapCleanupTick) {
|
||||||
|
|
||||||
np.log.Info("vote to remove node from netmap", zap.String("key", s))
|
np.log.Info("vote to remove node from netmap", zap.String("key", s))
|
||||||
|
|
||||||
prm := netmapclient.UpdatePeerPrm{}
|
// In notary environments we call UpdateStateIR method instead of UpdateState.
|
||||||
|
// It differs from UpdateState only by name, so we can do this in the same form.
|
||||||
|
// See https://github.com/nspcc-dev/neofs-contract/issues/225
|
||||||
|
const methodUpdateStateNotary = "updateStateIR"
|
||||||
|
|
||||||
prm.SetKey(key.Bytes())
|
if np.notaryDisabled {
|
||||||
prm.SetState(netmap.NodeStateOffline)
|
prm := netmapclient.UpdatePeerPrm{}
|
||||||
prm.SetHash(ev.TxHash())
|
|
||||||
|
|
||||||
err = np.netmapClient.UpdatePeerState(prm)
|
prm.SetKey(key.Bytes())
|
||||||
|
prm.SetState(netmap.NodeStateOffline)
|
||||||
|
prm.SetHash(ev.TxHash())
|
||||||
|
|
||||||
|
err = np.netmapClient.UpdatePeerState(prm)
|
||||||
|
} else {
|
||||||
|
err = np.netmapClient.Morph().NotaryInvoke(
|
||||||
|
np.netmapClient.ContractAddress(),
|
||||||
|
0,
|
||||||
|
uint32(ev.epoch),
|
||||||
|
nil,
|
||||||
|
methodUpdateStateNotary,
|
||||||
|
int64(netmap.NodeStateOffline.ToV2()), key.Bytes(),
|
||||||
|
)
|
||||||
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
np.log.Error("can't invoke netmap.UpdateState", zap.Error(err))
|
np.log.Error("can't invoke netmap.UpdateState", zap.Error(err))
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue