From 048d38e506cad749a55c1ce7d41f0d3c44621d78 Mon Sep 17 00:00:00 2001 From: BartolomeyKant Date: Mon, 31 Mar 2025 13:05:06 +0500 Subject: [PATCH 1/2] make default socket init --- aether/transport/low_level/tcp/win_tcp.cpp | 1 + 1 file changed, 1 insertion(+) diff --git a/aether/transport/low_level/tcp/win_tcp.cpp b/aether/transport/low_level/tcp/win_tcp.cpp index 6fa3c032..881b3a03 100644 --- a/aether/transport/low_level/tcp/win_tcp.cpp +++ b/aether/transport/low_level/tcp/win_tcp.cpp @@ -389,6 +389,7 @@ WinTcpTransport::WinTcpTransport(ActionContext action_context, : action_context_{action_context}, poller_{std::move(poller)}, endpoint_{endpoint}, + socket_{INVALID_SOCKET}, socket_packet_queue_manager_{action_context_}, read_overlapped_{{}, EventType::kRead}, write_overlapped_{{}, EventType::kWrite} { From 935ac6f577262487269afb3674bcc31594eff513 Mon Sep 17 00:00:00 2001 From: BartolomeyKant Date: Mon, 31 Mar 2025 13:05:14 +0500 Subject: [PATCH 2/2] remove split update event --- aether/stream_api/unidirectional_gate.h | 3 --- 1 file changed, 3 deletions(-) diff --git a/aether/stream_api/unidirectional_gate.h b/aether/stream_api/unidirectional_gate.h index dc6abd57..02c7f4cf 100644 --- a/aether/stream_api/unidirectional_gate.h +++ b/aether/stream_api/unidirectional_gate.h @@ -45,8 +45,6 @@ class ParallelGate final : public ByteIGate { : write_gate_{std::move(write_gate)}, read_gate_{std::move(read_gate)}, write_gate_update_{write_gate_.gate_update_event().Subscribe( - gate_update_event_, MethodPtr<&GateUpdateEvent::Emit>{})}, - read_gate_update_{read_gate_.gate_update_event().Subscribe( gate_update_event_, MethodPtr<&GateUpdateEvent::Emit>{})} {} ActionView Write(DataBuffer&& data, @@ -72,7 +70,6 @@ class ParallelGate final : public ByteIGate { TReadGate read_gate_; GateUpdateEvent gate_update_event_; Subscription write_gate_update_; - Subscription read_gate_update_; }; } // namespace ae