X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Ftoss.go;h=3fc4865538e7133c0a39300539dd285d847e6c3e;hb=9c70a8054e60010ad69699ad8532d4a3be06ea41;hp=e5e3487c8bba60aceabad445ea2b913fccb460c1;hpb=f8d9aac9b7c0a822972b7230edf25b7af287892a;p=nncp.git

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,