8000 feat(socket): implement `esockd_socket` connection module by keynslug · Pull Request #15451 · emqx/emqx · GitHub
[go: up one dir, main page]
Skip to content

feat(socket): implement esockd_socket connection module #15451

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 31 commits into from
Jul 24, 2025
Merged

feat(socket): implement esockd_socket connection module #15451

Changes from 1 commit
Commits
Show all changes
31 commits
Select commit Hold shift + click to select a range
0630af6
feat(parser): tell how much more bytes are expected when incomplete
keynslug Jun 30, 2025
7cf8259
chore: update `esockd` to 5.15.0 with `esockd_socket` backend
keynslug Jul 23, 2025
be4b994
feat(socket): implement `esockd_socket` connection module
keynslug Jun 30, 2025
28bc810
test(emqx): make peeking into connection state module-aware
keynslug Jun 30, 2025
3a6b020
test(emqx): adapt PP2 mocks to `esockd_socket` listeners
keynslug Jul 1, 2025
aad4e5a
fix(sessds): make `get_session_state/1` connmod-aware
keynslug Jul 1, 2025
e6edd25
fix(eviction): make aware of new connection module
keynslug Jul 1, 2025
0761af5
test(emqx): cleanup `emqx_client_SUITE` and unbreak 2 testcases
keynslug Jul 2, 2025
1f9dc79
feat(congestion): make module generic and connmod-aware
keynslug Jul 2, 2025
280ac5a
feat(socket): use async send APIs and respect `send_timeout` option
keynslug Jul 2, 2025
a43ee50
chore(conn): make `esockd_transport` connection emit `send_timeout` e…
keynslug Jul 2, 2025
63f64ec
test(conn): verify congestion and send timeout logic
keynslug Jul 2, 2025
e1312b6
feat(emqx): support `esockd_socket` backend through listener config
keynslug Jun 30, 2025
960f9fb
test(conn): verify connmods work well with socket close and keepalive
keynslug Jul 10, 2025
f69c877
perf(frame): optimize away and inline few serialization routines
keynslug Jul 10, 2025
13a081b
chore(socket): fix dialyzer complaints
keynslug Jul 10, 2025
3a3ce16
chore: add changelog entry
keynslug Jul 10, 2025
242148f
chore(socket): drop unnecessary directive
keynslug Jul 16, 2025
6dcae1c
fix(socket): avoid closing already closed socket
keynslug Jul 17, 2025
3a81374
fix(socket): anticipate > 1 socket `abort`s on socket close
keynslug Jul 18, 2025
3430943
chore(socket): correct typespec
keynslug Jul 18, 2025
b3d1f5e
fix(socket): preserve select handle + handle decongestion correctly
keynslug Jul 18, 2025
a724a65
test(client): add congested-then-decongested client testcase
keynslug Jul 18, 2025
8bb14d9
chore(socket): annotate log events with connmod for observability
keynslug Jul 18, 2025
7b8dcbc
chore(frame): avoid using 0 to signal "some more" bytes expected
keynslug Jul 22, 2025
e66c98c
chore(socket): drop dead copy-paste artifacts
keynslug Jul 22, 2025
9a26fb3
chore(conn): mention related `emqx_socket_connection` in header
keynslug Jul 22, 2025
8cf1ee0
chore(schema): mention `tcp_backend` change requires listener restart
keynslug Jul 22, 2025
b255ddd
fix(schema): do not announce `socket` TCP backend under Windows
keynslug Jul 22, 2025
367fd4b
chore(socket): address dialyzer concerns
keynslug Jul 22, 2025
80429fa
test(telemetry): fix testcase timeout due to dirty server state
keynslug Jul 23, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
chore(socket): fix dialyzer complaints
  • Loading branch information
@keynslug
keynslug committed Jul 23, 2025
commit 13a081b2e0293f6e2bf4dfdd24d83a20a4dd5168
6 changes: 3 additions & 3 deletions apps/emqx/src/emqx_socket_connection.erl
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@
-record(congested, {
handle :: reference(),
deadline :: _TimestampMs :: integer(),
sendq :: [erlang:iovec()]
sendq :: [erlang:iodata()]
}).

-type congested() :: #congested{}.
Expand Down Expand Up @@ -941,7 +941,7 @@ serialize_and_inc_stats(#state{serialize = Serialize}, Packet) ->
send(Num, IoData, #state{socket = Socket, sockstate = idle} = State) ->
Oct = iolist_size(IoData),
Handle = make_ref(),
case socket:send(Socket, IoData, Handle) of
case socket:send(Socket, IoData, [], Handle) of
ok ->
sent(Num, Oct, State);
{select, {_Info, Rest}} ->
Expand Down Expand Up @@ -969,7 +969,7 @@ send(_Num, _IoVec, #state{sockstate = closed} = State) ->
handle_send_ready(Socket, SS = #congested{sendq = SQ}, State) ->
IoData = sendq_to_iodata(SQ, []),
Handle = make_ref(),
case socket:send(Socket, IoData, Handle) of
case socket:send(Socket, IoData, [], Handle) of
ok ->
{ok, State};
{select, {_Info, Rest}} ->
Expand Down
0