Fix PinnedTS

It represented the deadline, while it should reflect the moment when a client was pinned. Signed-off-by: Tomasz Pietrek <[email protected]>
nats-io · Nov 11, 2024 · 05820ab · 05820ab
1 parent 30a0fcd
commit 05820ab
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/consumer.go b/server/consumer.go
@@ -3532,7 +3532,7 @@ func (o *consumer) setPinnedTimer(priorityGroup string) {
 	} else {
 		o.pinnedTtl = time.AfterFunc(o.cfg.PinnedTTL, func() {
 			o.mu.Lock()
-			o.pinnedTS = time.Now().Add(o.cfg.PinnedTTL)
+			o.pinnedTS = time.Now()
 			o.currentPinId = _EMPTY_
 			o.sendUnpinnedAdvisoryLocked(priorityGroup, "timeout")
 			o.mu.Unlock()