From 17532cb729d8d83ec0986bf94d0e394d530df67c Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Sat, 28 Feb 2026 22:35:24 +0800 Subject: [PATCH] fix redis --- apps/sdlan/src/policy/maxwell_redis_channel.erl | 3 ++- apps/sdlan/src/policy/maxwell_redis_server.erl | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/apps/sdlan/src/policy/maxwell_redis_channel.erl b/apps/sdlan/src/policy/maxwell_redis_channel.erl index 5fca8ef..d43874c 100644 --- a/apps/sdlan/src/policy/maxwell_redis_channel.erl +++ b/apps/sdlan/src/policy/maxwell_redis_channel.erl @@ -29,12 +29,13 @@ %%-------------------------------------------------------------------- start(Socket) -> - spawn_link(?MODULE, loop, [#state{socket = Socket, command = #command{}}]). + spawn(?MODULE, loop, [#state{socket = Socket, command = #command{}}]). loop(State=#state{socket = Socket, command = Command = #command{data = Data}}) -> inet:setopts(Socket, [{active, once}]), receive {tcp, _, Packet} -> + logger:debug("channel rec: ~p", [Packet]), NData = <>, case parse(Command#command{data = NData}) of {ok, #command{args = Args}} -> diff --git a/apps/sdlan/src/policy/maxwell_redis_server.erl b/apps/sdlan/src/policy/maxwell_redis_server.erl index c6b2526..ad994e5 100644 --- a/apps/sdlan/src/policy/maxwell_redis_server.erl +++ b/apps/sdlan/src/policy/maxwell_redis_server.erl @@ -32,8 +32,9 @@ init(Port) -> accept_loop(LSocket) -> case gen_tcp:accept(LSocket) of {ok, Socket} -> + logger:debug("accept socket: ~p", [Socket]), %% 每个连接一个进程 - Pid = spawn(fun() -> maxwell_redis_channel:start(Socket) end), + Pid = maxwell_redis_channel:start(Socket), ok = gen_tcp:controlling_process(Socket, Pid), accept_loop(LSocket); {error, closed} ->