[filter] Added 'open' phase to connect() filter

flomesh-io · Jun 19, 2024 · cae1935 · cae1935
1 parent aa1d5c4
commit cae1935
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/outbound.cpp b/src/outbound.cpp
@@ -260,6 +260,7 @@ OutboundTCP::OutboundTCP(EventTarget::Input *output, const Outbound::Options &op
   , SocketTCP(false, Outbound::m_options)
   , m_resolver(Net::context())
 {
+  state(Outbound::State::open);
 }
 
 OutboundTCP::~OutboundTCP() {
@@ -513,6 +514,7 @@ OutboundUDP::OutboundUDP(EventTarget::Input *output, const Outbound::Options &op
   , SocketUDP(false, Outbound::m_options)
   , m_resolver(Net::context())
 {
+  state(Outbound::State::open);
 }
 
 OutboundUDP::~OutboundUDP() {
@@ -866,6 +868,7 @@ template<> void EnumDef<Outbound::Protocol>::init() {
 
 template<> void EnumDef<Outbound::State>::init() {
   define(Outbound::State::idle, "idle");
+  define(Outbound::State::open, "open");
   define(Outbound::State::resolving, "resolving");
   define(Outbound::State::connecting, "connecting");
   define(Outbound::State::connected, "connected");

diff --git a/src/outbound.hpp b/src/outbound.hpp
@@ -58,6 +58,7 @@ class Outbound :
 
   enum class State {
     idle,
+    open,
     resolving,
     connecting,
     connected,