From fef6436759f5f9e1c472df34c8ef16eb5fe87221 Mon Sep 17 00:00:00 2001 From: yedf2 <120050102@qq.com> Date: Sat, 1 Jul 2023 09:34:01 +0800 Subject: [PATCH] fix comments --- dtmsvr/cron.go | 1 + dtmsvr/storage/boltdb/boltdb.go | 1 + dtmsvr/storage/redis/redis.go | 1 + dtmsvr/storage/sql/sql.go | 2 +- 4 files changed, 4 insertions(+), 1 deletion(-) diff --git a/dtmsvr/cron.go b/dtmsvr/cron.go index 4f7179e..21e22df 100644 --- a/dtmsvr/cron.go +++ b/dtmsvr/cron.go @@ -57,6 +57,7 @@ func CronUpdateTopicsMap() { } } +// CronUpdateTopicsMap cron updates topics map once func CronUpdateTopicsMapOnce() { defer handlePanic(nil) updateTopicsMap() diff --git a/dtmsvr/storage/boltdb/boltdb.go b/dtmsvr/storage/boltdb/boltdb.go index eea3a5d..e6b6b51 100644 --- a/dtmsvr/storage/boltdb/boltdb.go +++ b/dtmsvr/storage/boltdb/boltdb.go @@ -483,6 +483,7 @@ func (s *Store) ResetCronTime(after time.Duration, limit int64) (succeedCount in return } +// ResetTransGlobalCronTime reset nextCronTime of one global trans. func (s *Store) ResetTransGlobalCronTime(g *storage.TransGlobalStore) error { old := g.UpdateTime err := s.boltDb.Update(func(t *bolt.Tx) error { diff --git a/dtmsvr/storage/redis/redis.go b/dtmsvr/storage/redis/redis.go index 7a91682..090ab59 100644 --- a/dtmsvr/storage/redis/redis.go +++ b/dtmsvr/storage/redis/redis.go @@ -330,6 +330,7 @@ return tostring(i) return } +// ResetTransGlobalCronTime reset nextCronTime of one global trans. func (s *Store) ResetTransGlobalCronTime(global *storage.TransGlobalStore) error { now := dtmutil.GetNextTime(0) global.NextCronTime = now diff --git a/dtmsvr/storage/sql/sql.go b/dtmsvr/storage/sql/sql.go index 98a4501..28f9c9c 100644 --- a/dtmsvr/storage/sql/sql.go +++ b/dtmsvr/storage/sql/sql.go @@ -204,7 +204,7 @@ func (s *Store) ResetCronTime(after time.Duration, limit int64) (succeedCount in return affected, affected == limit, err } -// reset nextCronTime of one global trans. +// ResetTransGlobalCronTime reset nextCronTime of one global trans. func (s *Store) ResetTransGlobalCronTime(global *storage.TransGlobalStore) error { now := getTimeStr(0) where := map[string]string{