Skip to content
This repository was archived by the owner on Aug 2, 2021. It is now read-only.

Commit f73157b

Browse files
committed
pss: changed comment match actual behaviour
1 parent a6036b6 commit f73157b

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

pss/pss.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -565,7 +565,7 @@ func (p *Pss) enqueue(msg *PssMsg, pending bool) error {
565565
p.outboxMutex.Lock()
566566
defer p.outboxMutex.Unlock()
567567
pendingSize := p.getPending()
568-
// Only allow defaultOutboxCapacity messages at most processed (both enqueued or being forwarded)
568+
// Only allow capacity of outbox messages at most processed (both enqueued or being forwarded)
569569
if pending || pendingSize < cap(p.outbox) { //If pending there is already a slot booked for this message
570570
if !pending {
571571
// We book a slot in the queue increasing pending messages and release it after successfully sending the message

0 commit comments

Comments
 (0)