diff --git a/src/gen_rpc_acceptor.erl b/src/gen_rpc_acceptor.erl index d5d94c6..bce4123 100644 --- a/src/gen_rpc_acceptor.erl +++ b/src/gen_rpc_acceptor.erl @@ -71,6 +71,7 @@ set_socket(Pid, Socket) when is_pid(Pid) -> %%% =================================================== init({Driver, Peer}) -> ok = gen_rpc_helper:set_optimal_process_flags(), + _ = erlang:process_flag(fullsweep_after, 20), {Control, ControlList} = gen_rpc_helper:get_rpc_module_control(), {DriverMod, _DriverPort, DriverClosed, DriverError} = gen_rpc_helper:get_server_driver_options(Driver), ?log(info, "event=start driver=~s peer=\"~s\"", [Driver, gen_rpc_helper:peer_to_string(Peer)]), diff --git a/src/gen_rpc_client.erl b/src/gen_rpc_client.erl index 867c7b4..5a6f046 100644 --- a/src/gen_rpc_client.erl +++ b/src/gen_rpc_client.erl @@ -237,6 +237,7 @@ init({{Node,_Key}}) -> init({Node}) -> ok = gen_rpc_helper:set_optimal_process_flags(), + _ = erlang:process_flag(fullsweep_after, 20), case gen_rpc_helper:get_client_config_per_node(Node) of {error, Reason} -> ?log(error, "event=external_source_error action=falling_back_to_local reason=\"~s\"", [Reason]),