Skip to content

Commit

Permalink
fixed bug
Browse files Browse the repository at this point in the history
  • Loading branch information
dobyte committed Nov 4, 2024
1 parent b892e39 commit 16f6087
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions cluster/node/request.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 16f6087

Please sign in to comment.