November 2024 - gerrit-log - lists.osmocom.org

[M] Change in ...osmo-s1gw[master]: erab_fsm: add fetch_info/1 for state introspection

by pespin

Attention is currently required from: fixeria. pespin has posted comments on this change by fixeria. ( https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38781?usp=email ) Change subject: erab_fsm: add fetch_info/1 for state introspection ...................................................................... Patch Set 2: Code-Review+1 -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38781?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: comment Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I02d5d043d6eda67c5bf2a6cf6ec1b863030a05a9 Gerrit-Change-Number: 38781 Gerrit-PatchSet: 2 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-Attention: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Comment-Date: Sun, 17 Nov 2024 17:30:16 +0000 Gerrit-HasComments: No Gerrit-Has-Labels: Yes

7 months, 1 week

1
0
0 0

[M] Change in ...osmo-s1gw[master]: sctp_server: make it abstract from sctp_proxy logic

by fixeria

Attention is currently required from: fixeria. Hello Jenkins Builder, I'd like you to reexamine a change. Please visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38790?usp=email to look at the new patch set (#2). The following approvals got outdated and were removed: Verified-1 by Jenkins Builder Change subject: sctp_server: make it abstract from sctp_proxy logic ...................................................................... sctp_server: make it abstract from sctp_proxy logic Instead of using the sctp_proxy API directly, let the caller pass a module name (handler), which implements the sctp_client behavior. This makes the interaction between modules cleaner, allows to reuse the sctp_server module in other places, and makes testing easier. Change-Id: Iee4202dd4d4e9762fe74ead985aa43343ebdc524 --- M src/osmo_s1gw_sup.erl M src/sctp_client.erl M src/sctp_proxy.erl M src/sctp_server.erl 4 files changed, 53 insertions(+), 23 deletions(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/90/38790/2 -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38790?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newpatchset Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: Iee4202dd4d4e9762fe74ead985aa43343ebdc524 Gerrit-Change-Number: 38790 Gerrit-PatchSet: 2 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Attention: fixeria <vyanitskiy(a)sysmocom.de>

7 months, 1 week

1
0
0 0

[S] Change in ...osmo-s1gw[master]: sctp_server: add type hints

by fixeria

fixeria has uploaded this change for review. ( https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38784?usp=email ) Change subject: sctp_server: add type hints ...................................................................... sctp_server: add type hints Change-Id: I0ddeccb81c52f1769fa0754c5628b53b1c9feb81 --- M src/sctp_server.erl 1 file changed, 12 insertions(+), 2 deletions(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/84/38784/1 diff --git a/src/sctp_server.erl b/src/sctp_server.erl index 58d91ca..9de56f1 100644 --- a/src/sctp_server.erl +++ b/src/sctp_server.erl @@ -51,8 +51,18 @@ -include("s1gw_metrics.hrl"). -include("s1ap.hrl"). --record(server_state, {sock, clients, mme_addr_port}). --record(client_state, {addr_port, pid}). +-type addr_port() :: {inet:ip_address(), + inet:port_number()}. + +-record(server_state, {sock :: gen_sctp:sctp_socket(), + clients :: dict:dict(), + mme_addr_port :: term() + }). + +-record(client_state, {addr_port :: addr_port(), + pid :: pid() + }). + %% ------------------------------------------------------------------ %% public API -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38784?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I0ddeccb81c52f1769fa0754c5628b53b1c9feb81 Gerrit-Change-Number: 38784 Gerrit-PatchSet: 1 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de>

7 months, 2 weeks

1
0
0 0

[S] Change in ...osmo-s1gw[master]: erab_fsm: add all-state event handler

by fixeria

Hello Jenkins Builder, I'd like you to reexamine a change. Please visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38780?usp=email to look at the new patch set (#2). The following approvals got outdated and were removed: Verified+1 by Jenkins Builder Change subject: erab_fsm: add all-state event handler ...................................................................... erab_fsm: add all-state event handler This patch prepares for a follow-up commit adding a request (fetch_info) that must be handled in any state. Change-Id: I2673f18ddee0f1eee27bb0ed71ca9073d6dea3f2 --- M src/erab_fsm.erl 1 file changed, 12 insertions(+), 16 deletions(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/80/38780/2 -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38780?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newpatchset Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I2673f18ddee0f1eee27bb0ed71ca9073d6dea3f2 Gerrit-Change-Number: 38780 Gerrit-PatchSet: 2 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder

7 months, 2 weeks

1
0
0 0

[M] Change in ...osmo-s1gw[master]: erab_fsm: add fetch_info/1 for state introspection

by fixeria

Attention is currently required from: fixeria, pespin. Hello Jenkins Builder, pespin, I'd like you to reexamine a change. Please visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38781?usp=email to look at the new patch set (#2). The following approvals got outdated and were removed: Code-Review+1 by pespin, Verified+1 by Jenkins Builder Change subject: erab_fsm: add fetch_info/1 for state introspection ...................................................................... erab_fsm: add fetch_info/1 for state introspection This API will be used by the upcoming interactive VTY interface. Change-Id: I02d5d043d6eda67c5bf2a6cf6ec1b863030a05a9 Related: SYS#7066 --- M src/erab_fsm.erl M test/erab_fsm_test.erl 2 files changed, 58 insertions(+), 3 deletions(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/81/38781/2 -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38781?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newpatchset Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I02d5d043d6eda67c5bf2a6cf6ec1b863030a05a9 Gerrit-Change-Number: 38781 Gerrit-PatchSet: 2 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-Attention: fixeria <vyanitskiy(a)sysmocom.de>

7 months, 2 weeks

1
0
0 0

[XS] Change in ...osmo-s1gw[master]: sctp_server: cosmetic: use ?FUNCTION_NAME in send_data/2

by fixeria

fixeria has uploaded this change for review. ( https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38785?usp=email ) Change subject: sctp_server: cosmetic: use ?FUNCTION_NAME in send_data/2 ...................................................................... sctp_server: cosmetic: use ?FUNCTION_NAME in send_data/2 Change-Id: Ifd646ba1383840f656df5a798299a5ed116731ae --- M src/sctp_server.erl 1 file changed, 1 insertion(+), 1 deletion(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/85/38785/1 diff --git a/src/sctp_server.erl b/src/sctp_server.erl index 9de56f1..0b741ad 100644 --- a/src/sctp_server.erl +++ b/src/sctp_server.erl @@ -75,7 +75,7 @@ send_data(Aid, Data) -> - gen_server:cast(?MODULE, {send_data, Aid, Data}). + gen_server:cast(?MODULE, {?FUNCTION_NAME, Aid, Data}). shutdown() -> -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38785?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: Ifd646ba1383840f656df5a798299a5ed116731ae Gerrit-Change-Number: 38785 Gerrit-PatchSet: 1 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de>

7 months, 2 weeks

1
0
0 0

[S] Change in ...osmo-s1gw[master]: sctp_server: pass MME addr/port to sctp_proxy as opaque data

by fixeria

fixeria has uploaded this change for review. ( https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38786?usp=email ) Change subject: sctp_server: pass MME addr/port to sctp_proxy as opaque data ...................................................................... sctp_server: pass MME addr/port to sctp_proxy as opaque data This is the first step towards the goal of making the sctp_server module more generic and abstract from the client module's API. Change-Id: I1bd5f17d940173c4ec2d8d7a1d48778098008c84 --- M src/sctp_proxy.erl M src/sctp_server.erl 2 files changed, 25 insertions(+), 14 deletions(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/86/38786/1 diff --git a/src/sctp_proxy.erl b/src/sctp_proxy.erl index 6503a9e..72f7980 100644 --- a/src/sctp_proxy.erl +++ b/src/sctp_proxy.erl @@ -41,7 +41,8 @@ connected/3, code_change/4, terminate/3]). --export([start_link/3, +-export([start_link/2, + start_link/3, send_data/2, shutdown/1]). @@ -55,9 +56,19 @@ %% public API %% ------------------------------------------------------------------ --spec start_link(gen_sctp:assoc_id(), - sctp_client:loc_rem_addr(), - inet:port_number()) -> gen_statem:start_ret(). +-spec start_link(Aid, {MmeAddr, MmePort}) -> Result + when Aid :: gen_sctp:assoc_id(), + MmeAddr :: sctp_client:loc_rem_addr(), + MmePort :: inet:port_number(), + Result :: gen_statem:start_ret(). +start_link(Aid, {MmeAddr, MmePort}) -> + start_link(Aid, MmeAddr, MmePort). + +-spec start_link(Aid, MmeAddr, MmePort) -> Result + when Aid :: gen_sctp:assoc_id(), + MmeAddr :: sctp_client:loc_rem_addr(), + MmePort :: inet:port_number(), + Result :: gen_statem:start_ret(). start_link(Aid, MmeAddr, MmePort) -> gen_statem:start_link(?MODULE, [Aid, MmeAddr, MmePort], []). diff --git a/src/sctp_server.erl b/src/sctp_server.erl index 0b741ad..7722436 100644 --- a/src/sctp_server.erl +++ b/src/sctp_server.erl @@ -56,7 +56,7 @@ -record(server_state, {sock :: gen_sctp:sctp_socket(), clients :: dict:dict(), - mme_addr_port :: term() + priv :: term() }). -record(client_state, {addr_port :: addr_port(), @@ -68,9 +68,9 @@ %% public API %% ------------------------------------------------------------------ -start_link(BindAddr, BindPort, MmeAddrPort) -> +start_link(BindAddr, BindPort, Priv) -> gen_server:start_link({local, ?MODULE}, ?MODULE, - [BindAddr, BindPort, MmeAddrPort], + [BindAddr, BindPort, Priv], []). @@ -86,11 +86,11 @@ %% gen_server API %% ------------------------------------------------------------------ -init([BindAddrStr, BindPort, MmeAddrPort]) when is_list(BindAddrStr) -> +init([BindAddrStr, BindPort, Priv]) when is_list(BindAddrStr) -> {ok, BindAddr} = inet:parse_address(BindAddrStr), - init([BindAddr, BindPort, MmeAddrPort]); + init([BindAddr, BindPort, Priv]); -init([BindAddr, BindPort, MmeAddrPort]) -> +init([BindAddr, BindPort, Priv]) -> process_flag(trap_exit, true), {ok, Sock} = gen_sctp:open([{ip, BindAddr}, {port, BindPort}, @@ -101,7 +101,7 @@ ok = gen_sctp:listen(Sock, true), {ok, #server_state{sock = Sock, clients = dict:new(), - mme_addr_port = MmeAddrPort}}. + priv = Priv}}. handle_call(Info, From, State) -> @@ -163,7 +163,7 @@ comm_up -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) established", [Aid, FromAddr, FromPort]), Clients = client_add(State#server_state.clients, Aid, FromAddr, FromPort, - State#server_state.mme_addr_port); + State#server_state.priv); shutdown_comp -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) closed", [Aid, FromAddr, FromPort]), Clients = client_del(State#server_state.clients, Aid); @@ -200,8 +200,8 @@ %% Add a new client to the list, spawning a proxy process -client_add(Clients, Aid, FromAddr, FromPort, {MmeAddr, MmePort}) -> - {ok, Pid} = sctp_proxy:start_link(Aid, MmeAddr, MmePort), +client_add(Clients, Aid, FromAddr, FromPort, Priv) -> + {ok, Pid} = sctp_proxy:start_link(Aid, Priv), NewClient = #client_state{addr_port = {FromAddr, FromPort}, pid = Pid}, s1gw_metrics:gauge_inc(?S1GW_GAUGE_S1AP_ENB_NUM_SCTP_CONNECTIONS), dict:store(Aid, NewClient, Clients). -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38786?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I1bd5f17d940173c4ec2d8d7a1d48778098008c84 Gerrit-Change-Number: 38786 Gerrit-PatchSet: 1 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de>

7 months, 2 weeks

1
0
0 0

[M] Change in ...osmo-s1gw[master]: sctp_server: cosmetic: rename State -> S

by fixeria

fixeria has uploaded this change for review. ( https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38787?usp=email ) Change subject: sctp_server: cosmetic: rename State -> S ...................................................................... sctp_server: cosmetic: rename State -> S Using a shorter name makes the code more compact and beings it in consistency with other modules. Change-Id: I8dde744ac8b8798cdeed5d4eac47d4f650fe03f9 --- M src/sctp_server.erl 1 file changed, 35 insertions(+), 34 deletions(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/87/38787/1 diff --git a/src/sctp_server.erl b/src/sctp_server.erl index 7722436..3c7917e 100644 --- a/src/sctp_server.erl +++ b/src/sctp_server.erl @@ -104,51 +104,52 @@ priv = Priv}}. -handle_call(Info, From, State) -> +handle_call(Info, From, S) -> ?LOG_ERROR("unknown ~p() from ~p: ~p", [?FUNCTION_NAME, From, Info]), - {reply, {error, not_implemented}, State}. + {reply, {error, not_implemented}, S}. -handle_cast({send_data, Aid, Data}, State) -> - gen_sctp:send(State#server_state.sock, +handle_cast({send_data, Aid, Data}, S) -> + gen_sctp:send(S#server_state.sock, #sctp_sndrcvinfo{stream = ?S1AP_SCTP_STREAM, ppid = ?S1AP_SCTP_PPID, assoc_id = Aid}, Data), - {noreply, State}; + {noreply, S}; -handle_cast(Info, State) -> +handle_cast(Info, S) -> ?LOG_ERROR("unknown ~p(): ~p", [?FUNCTION_NAME, Info]), - {noreply, State}. + {noreply, S}. %% Handle SCTP events coming from gen_sctp module -handle_info({sctp, _Socket, FromAddr, FromPort, {AncData, Data}}, State) -> - NewState = sctp_recv(State, {FromAddr, FromPort, AncData, Data}), - {noreply, NewState}; +handle_info({sctp, _Socket, FromAddr, FromPort, {AncData, Data}}, S0) -> + S1 = sctp_recv(S0, {FromAddr, FromPort, AncData, Data}), + {noreply, S1}; %% Handle termination events of the child processes handle_info({'EXIT', Pid, Reason}, - #server_state{sock = Sock, clients = Clients} = State) -> + #server_state{sock = Sock, clients = Clients} = S0) -> ?LOG_DEBUG("Child process ~p terminated with reason ~p", [Pid, Reason]), - case client_find(State, Pid) of + case client_find(S0, Pid) of {ok, {Aid, _Client}} -> %% gracefully close the eNB connection gen_sctp:eof(Sock, #sctp_assoc_change{assoc_id = Aid}), - {noreply, State#server_state{clients = dict:erase(Aid, Clients)}}; + S1 = S0#server_state{clients = dict:erase(Aid, Clients)}, + {noreply, S1}; error -> - {noreply, State} + {noreply, S0} end; %% Catch-all for unknown messages -handle_info(Info, State) -> +handle_info(Info, S) -> ?LOG_ERROR("unknown ~p(): ~p", [?FUNCTION_NAME, Info]), - {noreply, State}. + {noreply, S}. -terminate(Reason, State) -> +terminate(Reason, S) -> ?LOG_NOTICE("Terminating, reason ~p", [Reason]), - close_conns(State), - gen_sctp:close(State#server_state.sock), + close_conns(S), + gen_sctp:close(S#server_state.sock), ok. %% ------------------------------------------------------------------ @@ -156,33 +157,33 @@ %% ------------------------------------------------------------------ %% Handle an #sctp_assoc_change event (connection state) -sctp_recv(State, {FromAddr, FromPort, [], - #sctp_assoc_change{state = ConnState, - assoc_id = Aid}}) -> +sctp_recv(S, {FromAddr, FromPort, [], + #sctp_assoc_change{state = ConnState, + assoc_id = Aid}}) -> case ConnState of comm_up -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) established", [Aid, FromAddr, FromPort]), - Clients = client_add(State#server_state.clients, Aid, FromAddr, FromPort, - State#server_state.priv); + Clients = client_add(S#server_state.clients, Aid, FromAddr, FromPort, + S#server_state.priv); shutdown_comp -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) closed", [Aid, FromAddr, FromPort]), - Clients = client_del(State#server_state.clients, Aid); + Clients = client_del(S#server_state.clients, Aid); comm_lost -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) lost", [Aid, FromAddr, FromPort]), - Clients = client_del(State#server_state.clients, Aid); + Clients = client_del(S#server_state.clients, Aid); _ -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) state ~p", [Aid, FromAddr, FromPort, ConnState]), - Clients = State#server_state.clients + Clients = S#server_state.clients end, - State#server_state{clients = Clients}; + S#server_state{clients = Clients}; %% Handle an #sctp_sndrcvinfo event (incoming data) -sctp_recv(State, {FromAddr, FromPort, - [#sctp_sndrcvinfo{assoc_id = Aid}], Data}) -> +sctp_recv(S, {FromAddr, FromPort, + [#sctp_sndrcvinfo{assoc_id = Aid}], Data}) -> ?LOG_DEBUG("eNB connection (id=~p, ~p:~p) -> MME: ~p", [Aid, FromAddr, FromPort, Data]), s1gw_metrics:ctr_inc(?S1GW_CTR_S1AP_ENB_ALL_RX), - case dict:find(Aid, State#server_state.clients) of + case dict:find(Aid, S#server_state.clients) of {ok, #client_state{pid = Pid}} -> sctp_proxy:send_data(Pid, Data); error -> @@ -190,13 +191,13 @@ [Aid, FromAddr, FromPort]), s1gw_metrics:ctr_inc(?S1GW_CTR_S1AP_ENB_ALL_RX_UNKNOWN_ENB) end, - State; + S; %% Catch-all for other kinds of SCTP events -sctp_recv(State, {FromAddr, FromPort, AncData, Data}) -> +sctp_recv(S, {FromAddr, FromPort, AncData, Data}) -> ?LOG_DEBUG("Unhandled SCTP event (~p:~p): ~p, ~p", [FromAddr, FromPort, AncData, Data]), - State. + S. %% Add a new client to the list, spawning a proxy process -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38787?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I8dde744ac8b8798cdeed5d4eac47d4f650fe03f9 Gerrit-Change-Number: 38787 Gerrit-PatchSet: 1 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de>

7 months, 2 weeks

1
0
0 0

[S] Change in ...osmo-s1gw[master]: sctp_server: cosmetic: make #server_state last argument

by fixeria

fixeria has uploaded this change for review. ( https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38788?usp=email ) Change subject: sctp_server: cosmetic: make #server_state last argument ...................................................................... sctp_server: cosmetic: make #server_state last argument Make it consistent with the gen_server and gen_statem API. Change-Id: I34bcdb818f58ccfa045d9fe17743523480e785f2 --- M src/sctp_server.erl 1 file changed, 18 insertions(+), 16 deletions(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/88/38788/1 diff --git a/src/sctp_server.erl b/src/sctp_server.erl index 3c7917e..938b02a 100644 --- a/src/sctp_server.erl +++ b/src/sctp_server.erl @@ -123,14 +123,14 @@ %% Handle SCTP events coming from gen_sctp module handle_info({sctp, _Socket, FromAddr, FromPort, {AncData, Data}}, S0) -> - S1 = sctp_recv(S0, {FromAddr, FromPort, AncData, Data}), + S1 = sctp_recv({FromAddr, FromPort, AncData, Data}, S0), {noreply, S1}; %% Handle termination events of the child processes handle_info({'EXIT', Pid, Reason}, #server_state{sock = Sock, clients = Clients} = S0) -> ?LOG_DEBUG("Child process ~p terminated with reason ~p", [Pid, Reason]), - case client_find(S0, Pid) of + case client_find(Pid, S0) of {ok, {Aid, _Client}} -> %% gracefully close the eNB connection gen_sctp:eof(Sock, #sctp_assoc_change{assoc_id = Aid}), @@ -157,14 +157,14 @@ %% ------------------------------------------------------------------ %% Handle an #sctp_assoc_change event (connection state) -sctp_recv(S, {FromAddr, FromPort, [], - #sctp_assoc_change{state = ConnState, - assoc_id = Aid}}) -> +sctp_recv({FromAddr, FromPort, [], + #sctp_assoc_change{state = ConnState, + assoc_id = Aid}}, + #server_state{priv = Priv} = S) -> case ConnState of comm_up -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) established", [Aid, FromAddr, FromPort]), - Clients = client_add(S#server_state.clients, Aid, FromAddr, FromPort, - S#server_state.priv); + Clients = client_add(S#server_state.clients, Aid, FromAddr, FromPort, Priv); shutdown_comp -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) closed", [Aid, FromAddr, FromPort]), Clients = client_del(S#server_state.clients, Aid); @@ -179,11 +179,12 @@ S#server_state{clients = Clients}; %% Handle an #sctp_sndrcvinfo event (incoming data) -sctp_recv(S, {FromAddr, FromPort, - [#sctp_sndrcvinfo{assoc_id = Aid}], Data}) -> +sctp_recv({FromAddr, FromPort, + [#sctp_sndrcvinfo{assoc_id = Aid}], Data}, + #server_state{clients = Clients} = S) -> ?LOG_DEBUG("eNB connection (id=~p, ~p:~p) -> MME: ~p", [Aid, FromAddr, FromPort, Data]), s1gw_metrics:ctr_inc(?S1GW_CTR_S1AP_ENB_ALL_RX), - case dict:find(Aid, S#server_state.clients) of + case dict:find(Aid, Clients) of {ok, #client_state{pid = Pid}} -> sctp_proxy:send_data(Pid, Data); error -> @@ -194,7 +195,8 @@ S; %% Catch-all for other kinds of SCTP events -sctp_recv(S, {FromAddr, FromPort, AncData, Data}) -> +sctp_recv({FromAddr, FromPort, AncData, Data}, + #server_state{} = S) -> ?LOG_DEBUG("Unhandled SCTP event (~p:~p): ~p, ~p", [FromAddr, FromPort, AncData, Data]), S. @@ -223,18 +225,18 @@ %% Find a client by process ID -client_find(#server_state{clients = Clients}, Pid) -> - client_find(dict:to_list(Clients), Pid); +client_find(Pid, #server_state{clients = Clients}) -> + client_find(Pid, dict:to_list(Clients)); -client_find([{Aid, Client} | Clients], Pid) -> +client_find(Pid, [{Aid, Client} | Clients]) -> case Client of #client_state{pid = Pid} -> {ok, {Aid, Client}}; _ -> - client_find(Clients, Pid) + client_find(Pid, Clients) end; -client_find([], _Pid) -> +client_find(_Pid, []) -> error. -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38788?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I34bcdb818f58ccfa045d9fe17743523480e785f2 Gerrit-Change-Number: 38788 Gerrit-PatchSet: 1 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de>

7 months, 2 weeks

1
0
0 0

[S] Change in ...osmo-s1gw[master]: sctp_server: pass #server_state to client_{add,del}()

by fixeria

fixeria has uploaded this change for review. ( https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38789?usp=email ) Change subject: sctp_server: pass #server_state to client_{add,del}() ...................................................................... sctp_server: pass #server_state to client_{add,del}() Prepare for a follow-up patch, in which functions client_{add,del}() will need to access more fields from the #server_state. Change-Id: I5f784617745a9ecec2cfa998dc70e176311d24b1 --- M src/sctp_server.erl 1 file changed, 15 insertions(+), 13 deletions(-) git pull ssh://gerrit.osmocom.org:29418/erlang/osmo-s1gw refs/changes/89/38789/1 diff --git a/src/sctp_server.erl b/src/sctp_server.erl index 938b02a..2617375 100644 --- a/src/sctp_server.erl +++ b/src/sctp_server.erl @@ -160,23 +160,22 @@ sctp_recv({FromAddr, FromPort, [], #sctp_assoc_change{state = ConnState, assoc_id = Aid}}, - #server_state{priv = Priv} = S) -> + #server_state{} = S) -> case ConnState of comm_up -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) established", [Aid, FromAddr, FromPort]), - Clients = client_add(S#server_state.clients, Aid, FromAddr, FromPort, Priv); + client_add(Aid, FromAddr, FromPort, S); shutdown_comp -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) closed", [Aid, FromAddr, FromPort]), - Clients = client_del(S#server_state.clients, Aid); + client_del(Aid, S); comm_lost -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) lost", [Aid, FromAddr, FromPort]), - Clients = client_del(S#server_state.clients, Aid); + client_del(Aid, S); _ -> ?LOG_NOTICE("eNB connection (id=~p, ~p:~p) state ~p", [Aid, FromAddr, FromPort, ConnState]), - Clients = S#server_state.clients - end, - S#server_state{clients = Clients}; + S + end; %% Handle an #sctp_sndrcvinfo event (incoming data) sctp_recv({FromAddr, FromPort, @@ -203,24 +202,27 @@ %% Add a new client to the list, spawning a proxy process -client_add(Clients, Aid, FromAddr, FromPort, Priv) -> +client_add(Aid, FromAddr, FromPort, + #server_state{clients = Clients, + priv = Priv} = S) -> {ok, Pid} = sctp_proxy:start_link(Aid, Priv), - NewClient = #client_state{addr_port = {FromAddr, FromPort}, pid = Pid}, s1gw_metrics:gauge_inc(?S1GW_GAUGE_S1AP_ENB_NUM_SCTP_CONNECTIONS), - dict:store(Aid, NewClient, Clients). + NewClient = #client_state{addr_port = {FromAddr, FromPort}, pid = Pid}, + S#server_state{clients = dict:store(Aid, NewClient, Clients)}. %% Delete an existing client from the list, stopping the proxy process -client_del(Clients, Aid) -> +client_del(Aid, + #server_state{clients = Clients} = S) -> case dict:find(Aid, Clients) of {ok, Client} -> %% the proxy process might be already dead, so we guard %% against exceptions like noproc or {nodedown,Node}. catch sctp_proxy:shutdown(Client#client_state.pid), s1gw_metrics:gauge_dec(?S1GW_GAUGE_S1AP_ENB_NUM_SCTP_CONNECTIONS), - dict:erase(Aid, Clients); + S#server_state{clients = dict:erase(Aid, Clients)}; error -> - Clients + S end. -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/38789?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I5f784617745a9ecec2cfa998dc70e176311d24b1 Gerrit-Change-Number: 38789 Gerrit-PatchSet: 1 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de>

7 months, 2 weeks

1
0
0 0

2025

2024

2023

2022

gerrit-log November 2024