From 890329f352bd5b6413cec85002fe803b04b28456 Mon Sep 17 00:00:00 2001 From: Xin Hao Date: Thu, 29 Aug 2024 23:02:56 +0800 Subject: [PATCH] change SessionPool's List as List ref --- session_pool.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/session_pool.go b/session_pool.go index 7ba45f9a..758d04fd 100644 --- a/session_pool.go +++ b/session_pool.go @@ -36,8 +36,8 @@ import ( // // Notice that all queries will be executed in the default space specified in the pool config. type SessionPool struct { - idleSessions list.List - activeSessions list.List + idleSessions *list.List + activeSessions *list.List conf SessionPoolConf tz timezoneInfo log Logger @@ -654,7 +654,7 @@ func parseParams(params map[string]interface{}) (map[string]*nebula.Value, error func (pool *SessionPool) removeSessionFromActive(session *pureSession) { pool.rwLock.Lock() defer pool.rwLock.Unlock() - l := &pool.activeSessions + l := pool.activeSessions for ele := l.Front(); ele != nil; ele = ele.Next() { if ele.Value.(*pureSession) == session { l.Remove(ele) @@ -665,14 +665,14 @@ func (pool *SessionPool) removeSessionFromActive(session *pureSession) { func (pool *SessionPool) addSessionToActive(session *pureSession) { pool.rwLock.Lock() defer pool.rwLock.Unlock() - l := &pool.activeSessions + l := pool.activeSessions l.PushBack(session) } func (pool *SessionPool) removeSessionFromIdle(session *pureSession) { pool.rwLock.Lock() defer pool.rwLock.Unlock() - l := &pool.idleSessions + l := pool.idleSessions for ele := l.Front(); ele != nil; ele = ele.Next() { if ele.Value.(*pureSession) == session { l.Remove(ele) @@ -683,7 +683,7 @@ func (pool *SessionPool) removeSessionFromIdle(session *pureSession) { func (pool *SessionPool) addSessionToIdle(session *pureSession) { pool.rwLock.Lock() defer pool.rwLock.Unlock() - l := &pool.idleSessions + l := pool.idleSessions l.PushBack(session) } @@ -691,13 +691,13 @@ func (pool *SessionPool) addSessionToIdle(session *pureSession) { func (pool *SessionPool) returnSession(session *pureSession) { pool.rwLock.Lock() defer pool.rwLock.Unlock() - l := &pool.activeSessions + l := pool.activeSessions for ele := l.Front(); ele != nil; ele = ele.Next() { if ele.Value.(*pureSession) == session { l.Remove(ele) } } - l = &pool.idleSessions + l = pool.idleSessions l.PushBack(session) session.returnedAt = time.Now() }