From c05ed4c365b793c6fc7e703e4583ca6d2ba8c995 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 4 Nov 2021 20:51:10 +0800 Subject: [PATCH] [skip ci]Add rmq_imple seek comments (#11273) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index a24944122..d252faba4 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -648,6 +648,7 @@ func (rmq *rocksmq) Consume(topicName string, groupName string, n int) ([]Consum return consumerMessage, nil } +// seek is used for internal call without the topicMu func (rmq *rocksmq) seek(topicName string, groupName string, msgID UniqueID) error { rmq.storeMu.Lock() defer rmq.storeMu.Unlock() -- GitLab