From 16f608730ee63ca6bf2141da37992616989c4fc3 Mon Sep 17 00:00:00 2001 From: fuxiao <576101059@qq.com> Date: Mon, 4 Nov 2024 15:02:40 +0800 Subject: [PATCH] fixed bug --- cluster/node/request.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/cluster/node/request.go b/cluster/node/request.go index 347dad6..44a622c 100644 --- a/cluster/node/request.go +++ b/cluster/node/request.go @@ -281,11 +281,10 @@ func (r *request) Reply(message *cluster.Message) error { }) case r.pid != "": // 来源于Actor if actor, ok := r.node.scheduler.doLoad(r.pid); ok { - actor.Deliver(r.uid, message) - return nil - } else { - return errors.ErrIllegalOperation + return actor.Deliver(r.uid, message) } + + return nil case r.nid != "": // 来源于其他Node if r.nid == r.node.opts.id { return nil