|
|
@@ -1,7 +1,9 @@
|
|
|
package ruleEngine
|
|
|
|
|
|
import (
|
|
|
+ "context"
|
|
|
"github.com/gogf/gf/container/gqueue"
|
|
|
+ "github.com/gogf/gf/v2/os/glog"
|
|
|
"sparrow/pkg/protocol"
|
|
|
"sparrow/pkg/server"
|
|
|
"sync"
|
|
|
@@ -213,7 +215,7 @@ func (m *MailBox) BroadcastChildren(msg protocol.ActorMsg) error {
|
|
|
}
|
|
|
|
|
|
func (m *MailBox) destroy() error {
|
|
|
- server.Log.Errorf("Going to destroy mailbox:%s", m.id)
|
|
|
+ glog.Error(context.Background(), "Going to destroy mailbox:%s", m.id)
|
|
|
m.mu.Lock()
|
|
|
defer m.mu.Unlock()
|
|
|
if m.closed {
|
lijian