From 9c70a8054e60010ad69699ad8532d4a3be06ea41 Mon Sep 17 00:00:00 2001 From: Sergey Matveev Date: Thu, 8 Jul 2021 13:07:58 +0300 Subject: [PATCH] Do not process job if sender is clearly unknown --- src/toss.go | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/src/toss.go b/src/toss.go index e5e3487..3fc4865 100644 --- a/src/toss.go +++ b/src/toss.go @@ -917,6 +917,18 @@ func (ctx *Ctx) Toss( isBad = true continue } + sender := ctx.Neigh[*job.PktEnc.Sender] + if sender == nil { + err := errors.New("unknown node") + ctx.LogE("rx-open", les, err, func(les LEs) string { + return fmt.Sprintf( + "Tossing %s/%s", + ctx.NodeName(job.PktEnc.Sender), pktName, + ) + }) + isBad = true + continue + } errs := make(chan error, 1) var sharedKey []byte Retry: @@ -927,7 +939,7 @@ func (ctx *Ctx) Toss( pipeR, pktName, les, - ctx.Neigh[*job.PktEnc.Sender], + sender, job.PktEnc.Nice, uint64(pktSizeWithoutEnc(job.Size)), job.Path, -- 2.44.0