From c35df33c205dc33375f281f83e671de066846fa9 Mon Sep 17 00:00:00 2001 From: qydysky Date: Tue, 9 Jan 2024 22:34:17 +0800 Subject: [PATCH] Fix panic #99 --- Reply/stream.go | 40 ++++++++++++++++++++-------------------- 1 file changed, 20 insertions(+), 20 deletions(-) diff --git a/Reply/stream.go b/Reply/stream.go index 7436a68..5c657ca 100644 --- a/Reply/stream.go +++ b/Reply/stream.go @@ -121,26 +121,6 @@ func (t *m4s_link_item) getNo() (int, error) { } func (t *M4SStream) getM4s() (p *m4s_link_item) { - if t.m4s_pool == nil { - t.m4s_pool = pool.New( - func() *m4s_link_item { - return &m4s_link_item{ - data: slice.New[byte](), - } - }, - func(t *m4s_link_item) bool { - return t.createdTime.After(t.pooledTime) || time.Now().Before(t.pooledTime.Add(time.Second*10)) - }, - func(t *m4s_link_item) *m4s_link_item { - return t.reset() - }, - func(t *m4s_link_item) *m4s_link_item { - t.pooledTime = time.Now() - return t - }, - 50, - ) - } return t.m4s_pool.Get() } @@ -1206,6 +1186,26 @@ func (t *M4SStream) Start() bool { // 初始化请求池 t.reqPool = t.common.ReqPool + // 初始化池 + t.m4s_pool = pool.New( + func() *m4s_link_item { + return &m4s_link_item{ + data: slice.New[byte](), + } + }, + func(t *m4s_link_item) bool { + return t.createdTime.After(t.pooledTime) || time.Now().Before(t.pooledTime.Add(time.Second*10)) + }, + func(t *m4s_link_item) *m4s_link_item { + return t.reset() + }, + func(t *m4s_link_item) *m4s_link_item { + t.pooledTime = time.Now() + return t + }, + 50, + ) + // 初始化切片消息 t.Stream_msg = msgq.NewType[[]byte]() -- 2.39.2