server_common/q5
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-04-26 11:18:12 +08:00
parent 75b0c72d72
commit 0ec6d9a142
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
timer.go
View File

@ -345,6 +345,11 @@ func (this *XTimer) internalDelete(timer *XTimerList, isDestory bool, toFreeList
if !timer.attachEntry.Empty() { if !timer.attachEntry.Empty() {
timer.attachEntry.DelInit() timer.attachEntry.DelInit()
} }
for !timer.destoryHandleList.Empty() {
handle := timer.destoryHandleList.FirstEntry().(XTimerDestoryHandleNode)
handle.entry.DelInit()
handle.cb()
}
if isDestory { if isDestory {
timer.cb(TIMER_DESTORY_EVENT, nil) timer.cb(TIMER_DESTORY_EVENT, nil)
} else { } else {
@ -355,11 +360,6 @@ func (this *XTimer) internalDelete(timer *XTimerList, isDestory bool, toFreeList
timer.wp.timer = nil timer.wp.timer = nil
timer.wp = nil timer.wp = nil
} }
for !timer.destoryHandleList.Empty() {
handle := timer.destoryHandleList.FirstEntry().(XTimerDestoryHandleNode)
handle.entry.DelInit()
handle.cb()
}
if toFreeList { if toFreeList {
this.addToFreeList(timer) this.addToFreeList(timer)
} }