blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-11-05 11:52:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: debug info.

Browse Source
This commit is contained in:
Gordon 2024-04-17 15:11:26 +08:00
parent ae4417fc3c
commit ef96c70100
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
go.mod
View File

@ -15,7 +15,7 @@ require (
github.com/mitchellh/mapstructure v1.5.0
github.com/openimsdk/localcache v0.0.1
github.com/openimsdk/protocol v0.0.63
github.com/openimsdk/tools v0.0.47-alpha.35
github.com/openimsdk/tools v0.0.47-alpha.36
github.com/pkg/errors v0.9.1 // indirect
github.com/prometheus/client_golang v1.18.0
github.com/stretchr/testify v1.9.0

4
go.sum
View File

@ -270,8 +270,8 @@ github.com/openimsdk/gomake v0.0.5 h1:MxKVvhQRPBRhh7rzeu4+bBnqNjEEiX8gn0ojdfplW0
github.com/openimsdk/gomake v0.0.5/go.mod h1:PndCozNc2IsQIciyn9mvEblYWZwJmAI+06z94EY+csI=
github.com/openimsdk/protocol v0.0.63 h1:9DnweZe9nEYDFa4fGTbC9Cqi0gLUdtBhRo1NRP2X3WQ=
github.com/openimsdk/protocol v0.0.63/go.mod h1:OZQA9FR55lseYoN2Ql1XAHYKHJGu7OMNkUbuekrKCM8=
github.com/openimsdk/tools v0.0.47-alpha.35 h1:uR5GBZqpR7tltXa8pfjwWlXTgNYqIt/90bR7ygeGT/k=
github.com/openimsdk/tools v0.0.47-alpha.35/go.mod h1:P4oGP1Pd+d4ctbLD5U/XQTgl8yu8Hd3skx640Fr69ko=
github.com/openimsdk/tools v0.0.47-alpha.36 h1:r3WmAObA/UcAvJwtuuJZwcKAyFjwzEQVNt0dh/TD7bY=
github.com/openimsdk/tools v0.0.47-alpha.36/go.mod h1:P4oGP1Pd+d4ctbLD5U/XQTgl8yu8Hd3skx640Fr69ko=
github.com/pelletier/go-toml/v2 v2.1.0 h1:FnwAJ4oYMvbT/34k9zzHuZNrhlz48GB3/s6at6/MHO4=
github.com/pelletier/go-toml/v2 v2.1.0/go.mod h1:tJU2Z3ZkXwnxa4DPO899bsyIoywizdUvyaeZurnPPDc=
github.com/pierrec/lz4/v4 v4.1.21 h1:yOVMLb6qSIDP67pl/5F7RepeKYu/VmTyEXvuMI5d9mQ=

1
internal/msgtransfer/online_history_msg_handler.go
View File

@ -415,6 +415,7 @@ func (och *OnlineHistoryRedisConsumerHandler) ConsumeClaim(
for {
select {
case <-ticker.C:
log.ZDebug(context.Background(), "ticker update", "length", len(messages))
// if the buffer is empty and running is false, return loop.
if len(messages) == 0 {
if !running.Load() {