diff --git a/src/server/acl/acl_family.cc b/src/server/acl/acl_family.cc index 0228d5c58..385363878 100644 --- a/src/server/acl/acl_family.cc +++ b/src/server/acl/acl_family.cc @@ -87,7 +87,8 @@ void AclFamily::StreamUpdatesToAllProactorConnections(const std::string& user, u auto update_cb = [&]([[maybe_unused]] size_t id, util::Connection* conn) { DCHECK(conn); auto connection = static_cast(conn); - if (!connection->IsHttp() && connection->cntx()) { + if (connection->protocol() == facade::Protocol::REDIS && !connection->IsHttp() && + connection->cntx()) { connection->SendAclUpdateAsync( facade::Connection::AclUpdateMessage{user, update_cat, update_commands, update_keys}); } diff --git a/src/server/dfly_main.cc b/src/server/dfly_main.cc index 3e7dcc366..87b3c4095 100644 --- a/src/server/dfly_main.cc +++ b/src/server/dfly_main.cc @@ -288,7 +288,8 @@ bool RunEngine(ProactorPool* pool, AcceptServer* acceptor) { if (mc_port > 0 && !tcp_disabled) { auto listener = MakeListener(Protocol::MEMCACHE, &service); - acceptor->AddListener(mc_port, listener.release()); + acceptor->AddListener(mc_port, listener.get()); + listeners.push_back(listener.release()); } service.Init(acceptor, listeners, opts);