feat(socket): implement `esockd_socket` connection module#15451

Merged

keynslug merged 31 commits intoemqx:release-60from

keynslug:perf/EMQX-14333/fanout-part-iv

Jul 24, 2025

Commits on Jul 23, 2025

feat(parser): tell how much more bytes are expected when incomplete
keynslug
committed
chore: update `esockd` to 5.15.0 with `esockd_socket` backend
keynslug
committed
feat(socket): implement `esockd_socket` connection module
keynslug
committed
test(emqx): make peeking into connection state module-aware
keynslug
committed
test(emqx): adapt PP2 mocks to `esockd_socket` listeners
keynslug
committed
fix(sessds): make `get_session_state/1` connmod-aware
keynslug
committed
fix(eviction): make aware of new connection module
keynslug
committed
test(emqx): cleanup `emqx_client_SUITE` and unbreak 2 testcases
keynslug
committed
feat(congestion): make module generic and connmod-aware
keynslug
committed
feat(socket): use async send APIs and respect `send_timeout` option
keynslug
committed
chore(conn): make `esockd_transport` connection emit `send_timeout` error
keynslug
committed
test(conn): verify congestion and send timeout logic
keynslug
committed
feat(emqx): support `esockd_socket` backend through listener config
keynslug
committed
test(conn): verify connmods work well with socket close and keepalive
keynslug
committed
perf(frame): optimize away and inline few serialization routines
keynslug
committed
chore(socket): fix dialyzer complaints
keynslug
committed
chore: add changelog entry
keynslug
committed
chore(socket): drop unnecessary directive
keynslug
committed
fix(socket): avoid closing already closed socket
keynslug
committed
fix(socket): anticipate > 1 socket `abort`s on socket close
keynslug
committed
chore(socket): correct typespec
keynslug
committed
fix(socket): preserve select handle + handle decongestion correctly
keynslug
committed
test(client): add congested-then-decongested client testcase
keynslug
committed
chore(socket): annotate log events with connmod for observability
keynslug
committed
chore(frame): avoid using 0 to signal "some more" bytes expected
keynslug
committed
chore(socket): drop dead copy-paste artifacts

keynslug
and
zmstone
committed
chore(conn): mention related `emqx_socket_connection` in header
keynslug
committed
chore(schema): mention `tcp_backend` change requires listener restart
keynslug
committed
fix(schema): do not announce `socket` TCP backend under Windows
keynslug
committed
chore(socket): address dialyzer concerns
keynslug
committed
test(telemetry): fix testcase timeout due to dirty server state
keynslug
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

feat(socket): implement `esockd_socket` connection module#15451

feat(socket): implement `esockd_socket` connection module#15451
keynslug merged 31 commits intoemqx:release-60from
keynslug:perf/EMQX-14333/fanout-part-iv

Commits on Jul 23, 2025

feat(parser): tell how much more bytes are expected when incomplete

chore: update `esockd` to 5.15.0 with `esockd_socket` backend

feat(socket): implement `esockd_socket` connection module

test(emqx): make peeking into connection state module-aware

test(emqx): adapt PP2 mocks to `esockd_socket` listeners

fix(sessds): make `get_session_state/1` connmod-aware

fix(eviction): make aware of new connection module

test(emqx): cleanup `emqx_client_SUITE` and unbreak 2 testcases

feat(congestion): make module generic and connmod-aware

feat(socket): use async send APIs and respect `send_timeout` option

chore(conn): make `esockd_transport` connection emit `send_timeout` error

test(conn): verify congestion and send timeout logic

feat(emqx): support `esockd_socket` backend through listener config

test(conn): verify connmods work well with socket close and keepalive

perf(frame): optimize away and inline few serialization routines

chore(socket): fix dialyzer complaints

chore: add changelog entry

chore(socket): drop unnecessary directive

fix(socket): avoid closing already closed socket

fix(socket): anticipate > 1 socket `abort`s on socket close

chore(socket): correct typespec

fix(socket): preserve select handle + handle decongestion correctly

test(client): add congested-then-decongested client testcase

chore(socket): annotate log events with connmod for observability

chore(frame): avoid using 0 to signal "some more" bytes expected

chore(socket): drop dead copy-paste artifacts

chore(conn): mention related `emqx_socket_connection` in header

chore(schema): mention `tcp_backend` change requires listener restart

fix(schema): do not announce `socket` TCP backend under Windows

chore(socket): address dialyzer concerns

test(telemetry): fix testcase timeout due to dirty server state

feat(socket): implement `esockd_socket` connection module#15451keynslug merged 31 commits intoemqx:release-60emqx/emqx:release-60from keynslug:perf/EMQX-14333/fanout-part-ivkeynslug/emqx:perf/EMQX-14333/fanout-part-ivCopy head branch name to clipboard

Commits

Commits on Jul 23, 2025

feat(socket): implement `esockd_socket` connection module#15451
keynslug merged 31 commits intoemqx:release-60from
keynslug:perf/EMQX-14333/fanout-part-iv