cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Ignore, not regect, indexer messages from self.

Browse Source
This commit is contained in:
gammazero 2022-02-10 08:44:40 -08:00
parent 3f3d61b043
commit 1e37185d74
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
chain/sub/incoming.go
View File

@ -481,15 +481,15 @@ func (v *IndexerMessageValidator) Validate(ctx context.Context, pid peer.ID, msg
// This chain-node should not be publishing its own messages. These are // This chain-node should not be publishing its own messages. These are
// relayed from market-nodes. If a node appears to be local, reject it. // relayed from market-nodes. If a node appears to be local, reject it.
if pid == v.self { if pid == v.self {
log.Warnf("refusing to relay indexer message from self") log.Debug("ignoring indexer message from self")
stats.Record(ctx, metrics.IndexerMessageValidationFailure.M(1)) stats.Record(ctx, metrics.IndexerMessageValidationFailure.M(1))
return pubsub.ValidationReject return pubsub.ValidationIgnore
} }
originPeer := msg.GetFrom() originPeer := msg.GetFrom()
if originPeer == v.self { if originPeer == v.self {
log.Warnf("refusing to relay indexer message originating from self") log.Debug("ignoring indexer message originating from self")
stats.Record(ctx, metrics.IndexerMessageValidationFailure.M(1)) stats.Record(ctx, metrics.IndexerMessageValidationFailure.M(1))
return pubsub.ValidationReject return pubsub.ValidationIgnore
} }
idxrMsg := dtsync.Message{} idxrMsg := dtsync.Message{}