lxy/zhub
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

鏂板锛歞elay銆乼imer 鍙戦€佹棩蹇?

Browse Source 
git-svn-id: svn://47.119.165.148/zhub@143 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
This commit is contained in:
lxy
2021-11-17 07:55:05 +00:00
parent b99fd65a55
commit 55ef98d1bd
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
zsub/ztimer.go
View File

@@ -53,6 +53,7 @@ func (s *ZSub) timer(rcmd []string, c *ZConn) {
var timerFun = func() { var timerFun = func() {
for _, conn := range timer.conns { for _, conn := range timer.conns {
log.Println("timer send:", rcmd[1], rcmd[2])
err := conn.send("timer", timer.topic) err := conn.send("timer", timer.topic)
if timer.single && err == nil { if timer.single && err == nil {
break break
@@ -242,6 +243,7 @@ func (s *ZSub) delay(rcmd []string, c *ZConn) {
go func() { go func() {
select { select {
case <-delay.timer.C: case <-delay.timer.C:
log.Println("delay send:", rcmd[1], rcmd[2])
zsub.Publish(rcmd[1], rcmd[2]) zsub.Publish(rcmd[1], rcmd[2])
funChan <- func() { funChan <- func() {
delete(s.delays, rcmd[1]+"-"+rcmd[2]) delete(s.delays, rcmd[1]+"-"+rcmd[2])