From 5c7de275460a0ef3b994d39c52a2221e6526c1b7 Mon Sep 17 00:00:00 2001 From: Alex Vanin Date: Thu, 29 Oct 2020 19:07:31 +0300 Subject: [PATCH] [#132] Add netmap cleanup event processor Signed-off-by: Alex Vanin --- .../processors/netmap/process_cleanup.go | 42 +++++++++++++++++++ 1 file changed, 42 insertions(+) create mode 100644 pkg/innerring/processors/netmap/process_cleanup.go diff --git a/pkg/innerring/processors/netmap/process_cleanup.go b/pkg/innerring/processors/netmap/process_cleanup.go new file mode 100644 index 000000000..35a098729 --- /dev/null +++ b/pkg/innerring/processors/netmap/process_cleanup.go @@ -0,0 +1,42 @@ +package netmap + +import ( + "github.com/nspcc-dev/neo-go/pkg/crypto/keys" + "github.com/nspcc-dev/neofs-api-go/v2/netmap" + "github.com/nspcc-dev/neofs-node/pkg/innerring/invoke" + "go.uber.org/zap" +) + +func (np *Processor) processNetmapCleanupTick(epoch uint64) { + if !np.activeState.IsActive() { + np.log.Info("passive mode, ignore new netmap cleanup tick") + + return + } + + err := np.netmapSnapshot.forEachRemoveCandidate(epoch, func(s string) error { + key, err := keys.NewPublicKeyFromString(s) + if err != nil { + np.log.Warn("can't decode public key of netmap node", + zap.String("key", s)) + + return nil + } + + np.log.Info("vote to remove node from netmap", zap.String("key", s)) + + err = invoke.UpdatePeerState(np.morphClient, np.netmapContract, &invoke.UpdatePeerArgs{ + Key: key, + Status: uint32(netmap.Offline), + }) + if err != nil { + np.log.Error("can't invoke netmap.UpdateState", zap.Error(err)) + } + + return nil + }) + if err != nil { + np.log.Warn("can't iterate on netmap cleaner cache", + zap.String("error", err.Error())) + } +}