Skip to content

Commit b6a8b04

Browse files
committed
v0.23.1
Fix SCATTER double-tracking each peer: connection_added appended to @connections and then called add_round_robin_send_connection, which appends again. connection_removed deleted only one entry on disconnect, leaving a stale one behind.
1 parent c58eacc commit b6a8b04

3 files changed

Lines changed: 12 additions & 2 deletions

File tree

CHANGELOG.md

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,16 @@
11
# Changelog
22

3+
## 0.23.1 — 2026-04-18
4+
5+
### Fixed
6+
7+
- **SCATTER double-tracked each peer.** `Routing::Scatter#connection_added`
8+
appended to `@connections` and then called `add_round_robin_send_connection`,
9+
which appends again — so every connected peer had two entries in the list.
10+
`#connection_removed` deleted only one on disconnect, leaving a stale entry
11+
behind. Fixed by dropping the duplicate append.
12+
13+
314
## 0.23.0 — 2026-04-17
415

516
### Added

lib/omq/routing/scatter.rb

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@ def unblock_recv
3636
# @param connection [Protocol::ZMTP::Connection]
3737
#
3838
def connection_added(connection)
39-
@connections << connection
4039
add_round_robin_send_connection(connection)
4140
start_reaper(connection)
4241
end

lib/omq/version.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
# frozen_string_literal: true
22

33
module OMQ
4-
VERSION = "0.23.0"
4+
VERSION = "0.23.1"
55
end

0 commit comments

Comments
 (0)