Fix bug of the node module

dobyte · Feb 19, 2025 · fc198d6 · fc198d6
1 parent d91e2e0
commit fc198d6
Showing 1 changed file with 13 additions and 9 deletions.
diff --git a/cluster/node/node.go b/cluster/node/node.go
@@ -66,17 +66,21 @@ func NewNode(opts ...Option) *Node {
 	n.state.Store(int32(cluster.Shut))
 	n.wg = &sync.WaitGroup{}
 	n.evtPool = &sync.Pool{New: func() interface{} {
-		return &event{
-			ctx:  context.Background(),
-			node: n,
-		}
+		evt := &event{}
+		evt.ctx = context.Background()
+		evt.node = n
+		evt.actor.Store((*Actor)(nil))
+
+		return evt
 	}}
 	n.reqPool = &sync.Pool{New: func() interface{} {
-		return &request{
-			ctx:     context.Background(),
-			node:    n,
-			message: &cluster.Message{},
-		}
+		req := &request{}
+		req.ctx = context.Background()
+		req.node = n
+		req.message = &cluster.Message{}
+		req.actor.Store((*Actor)(nil))
+
+		return req
 	}}
 
 	return n