Osmocom Open Build Service

osmo-s1gw_0.2.0.92.a7e0.202411112026.dsc -> osmo-s1gw_0.2.0.96.a530.202411122026.dsc Changed

osmo-s1gw_0.2.0.92.a7e0.202411112026.tar.xz/.tarball-version -> osmo-s1gw_0.2.0.96.a530.202411122026.tar.xz/.tarball-version Changed

osmo-s1gw_0.2.0.92.a7e0.202411112026.tar.xz/build_dep.tar.gz -> osmo-s1gw_0.2.0.96.a530.202411122026.tar.xz/build_dep.tar.gz Changed

osmo-s1gw_0.2.0.92.a7e0.202411112026.tar.xz/debian/changelog -> osmo-s1gw_0.2.0.96.a530.202411122026.tar.xz/debian/changelog Changed

osmo-s1gw_0.2.0.92.a7e0.202411112026.tar.xz/debian/control -> osmo-s1gw_0.2.0.96.a530.202411122026.tar.xz/debian/control Changed

osmo-s1gw_0.2.0.92.a7e0.202411112026.tar.xz/src/s1ap_proxy.erl -> osmo-s1gw_0.2.0.96.a530.202411122026.tar.xz/src/s1ap_proxy.erl Changed

@@ -33,14 +33,18 @@
 %% that of the covered work.
 
 -module(s1ap_proxy).
+-behaviour(gen_server).
 
--export(init/0,
-         deinit/1,
+-export(init/1,
+         handle_info/2,
+         handle_call/3,
+         handle_cast/2,
+         terminate/2).
+-export(start_link/0,
          process_pdu/2,
-         process_pdu_safe/2,
-         handle_exit/2,
-         encode_pdu/1,
-         decode_pdu/1).
+         fetch_erab/2,
+         fetch_erab_list/1,
+         shutdown/1).
 
 -include_lib("kernel/include/logger.hrl").
 
@@ -74,28 +78,117 @@
 
 -export_type(proxy_action/0).
 
+
 %% ------------------------------------------------------------------
 %% public API
 %% ------------------------------------------------------------------
 
-%% Initialize per-connection data
--spec init() -> proxy_state().
-init() ->
-    #proxy_state{erabs = dict:new()}.
+-spec start_link() -> gen_server:start_ret().
+start_link() ->
+    gen_server:start_link(?MODULE, , ).
+
+
+-type process_pdu_result() :: {proxy_action(), binary()}.
+-spec process_pdu(pid(), binary()) -> process_pdu_result().
+process_pdu(Pid, PDU) ->
+    gen_server:call(Pid, {?FUNCTION_NAME, PDU}).
+
+
+%% Fetch a single E-RAB from the registry (by UID)
+-spec fetch_erab(pid(), erab_uid()) -> {ok, pid()} | error.
+fetch_erab(Pid, UID) ->
+    gen_server:call(Pid, {?FUNCTION_NAME, UID}).
+
+
+%% Fetch all E-RABs from the registry in form of a list
+-spec fetch_erab_list(pid()) -> {erab_uid(), pid()}.
+fetch_erab_list(Pid) ->
+    gen_server:call(Pid, ?FUNCTION_NAME).
+
+
+-spec shutdown(pid()) -> ok.
+shutdown(Pid) ->
+    gen_server:stop(Pid).
+
+
+%% ------------------------------------------------------------------
+%% gen_server API
+%% ------------------------------------------------------------------
+
+init() ->
+    process_flag(trap_exit, true),
+    {ok, #proxy_state{erabs = dict:new()}}.
+
+
+handle_call({process_pdu, OrigData}, _From,
+            #proxy_state{} = S0) ->
+    {Reply, S1} = handle_pdu_bin(OrigData, S0),
+    {reply, Reply, S1};
+
+handle_call({fetch_erab, UID}, _From,
+            #proxy_state{erabs = ERABs} = S) ->
+    {reply, dict:find(UID, ERABs), S};
+
+handle_call(fetch_erab_list, _From,
+            #proxy_state{erabs = ERABs} = S) ->
+    {reply, dict:to_list(ERABs), S};
+
+handle_call(Info, From,
+            #proxy_state{} = S) ->
+    ?LOG_ERROR("unknown ~p() from ~p: ~p", ?FUNCTION_NAME, From, Info),
+    {reply, {error, not_implemented}, S}.
+
 
+handle_cast(Info, #proxy_state{} = S) ->
+    ?LOG_ERROR("unknown ~p(): ~p", ?FUNCTION_NAME, Info),
+    {noreply, S}.
 
-%% De-initialize per-connection data
--spec deinit(proxy_state()) -> ok.
-deinit(_S) ->
+
+handle_info({'EXIT', Pid, Reason},
+            #proxy_state{erabs = ERABs} = S) ->
+    ?LOG_DEBUG("Child process ~p terminated with reason ~p", Pid, Reason),
+    Fun = fun(_Key, Val) -> Val =/= Pid end,
+    {noreply, S#proxy_state{erabs = dict:filter(Fun, ERABs)}};
+
+handle_info(Info, #proxy_state{} = S) ->
+    ?LOG_ERROR("unknown ~p(): ~p", ?FUNCTION_NAME, Info),
+    {noreply, S}.
+
+
+terminate(Reason, #proxy_state{}) ->
+    ?LOG_NOTICE("Terminating, reason ~p", Reason),
     ok.
 
 
-%% Process an S1AP PDU
--type process_pdu_result() :: {{proxy_action(), binary()}, proxy_state()}.
--spec process_pdu(binary(), proxy_state()) -> process_pdu_result().
-process_pdu(OrigData, S0) ->
+%% ------------------------------------------------------------------
+%% private API
+%% ------------------------------------------------------------------
+
+-spec erab_uid(erab_id(), proxy_state()) -> erab_uid().
+erab_uid(ERABId, #proxy_state{mme_ue_id = MmeUeId,
+                              enb_ue_id = EnbUeId}) ->
+    {MmeUeId, EnbUeId, ERABId}.
+
+
+%% Encode an S1AP PDU
+-spec encode_pdu(s1ap_pdu()) -> {ok, binary()} |
+                                {error, {asn1, tuple()}}.
+encode_pdu(Pdu) ->
+    'S1AP-PDU-Descriptions':encode('S1AP-PDU', Pdu).
+
+
+%% Decode an S1AP PDU
+-spec decode_pdu(binary()) -> {ok, s1ap_pdu()} |
+                              {error, {asn1, tuple()}}.
+decode_pdu(Data) ->
+    'S1AP-PDU-Descriptions':decode('S1AP-PDU', Data).
+
+
+%% Process an S1AP PDU (binary)
+-spec handle_pdu_bin(binary(), proxy_state()) -> {process_pdu_result(), proxy_state()}.
+handle_pdu_bin(OrigData, S0) ->
     s1gw_metrics:ctr_inc(?S1GW_CTR_S1AP_PROXY_IN_PKT_ALL),
-    case decode_pdu(OrigData) of
+    try decode_pdu(OrigData) of
         {ok, PDU} ->
             ?LOG_DEBUG("Rx S1AP PDU: ~p", PDU),
             case handle_pdu(PDU, S0) of
@@ -121,55 +214,16 @@
             s1gw_metrics:ctr_inc(?S1GW_CTR_S1AP_PROXY_IN_PKT_DECODE_ERROR),
             s1gw_metrics:ctr_inc(?S1GW_CTR_S1AP_PROXY_OUT_PKT_FWD_UNMODIFIED),
             {{forward, OrigData}, S0} %% XXX: forward as-is or drop?
-    end.
-
-
-%% A safe wrapper for proc/2
--spec process_pdu_safe(binary(), proxy_state()) -> process_pdu_result().
-process_pdu_safe(OrigData, S) ->
-    try process_pdu(OrigData, S) of
-        Result -> Result
     catch
         Exception:Reason:StackTrace ->
             ?LOG_ERROR("An exception occurred: ~p, ~p, ~p", Exception, Reason, StackTrace),
             s1gw_metrics:ctr_inc(?S1GW_CTR_S1AP_PROXY_EXCEPTION),
             s1gw_metrics:ctr_inc(?S1GW_CTR_S1AP_PROXY_OUT_PKT_FWD_UNMODIFIED),
-            {{forward, OrigData}, S} %% XXX: proxy as-is or drop?
+            {{forward, OrigData}, S0} %% XXX: proxy as-is or drop?
     end.
 
 
-%% Handle an exit event
--spec handle_exit(pid(), proxy_state()) -> proxy_state().
-handle_exit(Pid, #proxy_state{erabs = ERABs} = S) ->
-    Fun = fun(_Key, Val) -> Val =/= Pid end,
-    S#proxy_state{erabs = dict:filter(Fun, ERABs)}.
-
-
-%% ------------------------------------------------------------------
-%% private API
-%% ------------------------------------------------------------------
-
--spec erab_uid(erab_id(), proxy_state()) -> erab_uid().
-erab_uid(ERABId, #proxy_state{mme_ue_id = MmeUeId,
-                              enb_ue_id = EnbUeId}) ->
-    {MmeUeId, EnbUeId, ERABId}.
-
-
-%% Encode an S1AP PDU
--spec encode_pdu(s1ap_pdu()) -> {ok, binary()} |
-                                {error, {asn1, tuple()}}.
-encode_pdu(Pdu) ->
-    'S1AP-PDU-Descriptions':encode('S1AP-PDU', Pdu).
-

osmo-s1gw_0.2.0.92.a7e0.202411112026.tar.xz/src/sctp_proxy.erl -> osmo-s1gw_0.2.0.96.a530.202411122026.tar.xz/src/sctp_proxy.erl Changed

@@ -77,13 +77,13 @@
 %% ------------------------------------------------------------------
 
 init(Aid, MmeAddr, MmePort) ->
-    process_flag(trap_exit, true),
+    {ok, Pid} = s1ap_proxy:start_link(),
     {ok, connecting,
      #{enb_aid => Aid,
        mme_addr => MmeAddr,
        mme_port => MmePort,
        tx_queue => ,
-       priv => s1ap_proxy:init()}}.
+       handler => Pid}}.
 
 
 callback_mode() ->
@@ -145,8 +145,8 @@
 
 %% Handle an eNB -> MME data forwarding request (forward)
 connected(cast, {send_data, Data}, S0) ->
-    S1 = sctp_send(Data, S0),
-    {keep_state, S1};
+    sctp_send(Data, S0),
+    {keep_state, S0};
 
 %% Handle an #sctp_assoc_change event (MME connection state)
 connected(info, {sctp, _Socket, MmeAddr, MmePort,
@@ -168,24 +168,16 @@
           #{sock := Sock,
             enb_aid := EnbAid,
             mme_aid := Aid,
-            priv := Priv} = S) ->
+            handler := Pid} = S) ->
     ?LOG_DEBUG("MME connection (id=~p, ~p:~p) -> eNB: ~p",
                Aid, MmeAddr, MmePort, Data),
-    {Action, NewPriv} = s1ap_proxy:process_pdu_safe(Data, Priv),
-    case Action of
+    case s1ap_proxy:process_pdu(Pid, Data) of
         {forward, FwdData} ->
             sctp_server:send_data(EnbAid, FwdData);
         {reply, ReData} ->
             ok = sctp_client:send_data({Sock, Aid}, ReData)
     end,
-    {keep_state, S#{priv := NewPriv}};
-
-%% Handle termination events of the child processes
-connected(info, {'EXIT', Pid, Reason},
-          #{priv := Priv} = S) ->
-    ?LOG_DEBUG("Child process ~p terminated with reason ~p", Pid, Reason),
-    NewPriv = s1ap_proxy:handle_exit(Pid, Priv),
-    {keep_state, S#{priv := NewPriv}};
+    {keep_state, S};
 
 %% Catch-all for other kinds of SCTP events
 connected(info, {sctp, _Socket, MmeAddr, MmePort,
@@ -205,13 +197,12 @@
     {ok, State, S}.
 
 
-terminate(Reason, State, S) ->
+terminate(Reason, State, #{handler := Pid} = S) ->
     ?LOG_NOTICE("Terminating in state ~p, reason ~p", State, Reason),
+    s1ap_proxy:shutdown(Pid),
     case S of
         #{sock := Sock,
-          mme_aid := Aid,
-          priv := Priv} ->
-            s1ap_proxy:deinit(Priv),
+          mme_aid := Aid} ->
             sctp_client:disconnect({Sock, Aid}),
             gen_sctp:close(Sock);
         #{sock := Sock} ->
@@ -229,25 +220,23 @@
           #{sock := Sock,
             enb_aid := EnbAid,
             mme_aid := Aid,
-            priv := Priv} = S) ->
-    {Action, NewPriv} = s1ap_proxy:process_pdu_safe(Data, Priv),
-    case Action of
+            handler := Pid}) ->
+    case s1ap_proxy:process_pdu(Pid, Data) of
         {forward, FwdData} ->
             ok = sctp_client:send_data({Sock, Aid}, FwdData);
         {reply, ReData} ->
             sctp_server:send_data(EnbAid, ReData)
-    end,
-    S#{priv := NewPriv}.
+    end.
 
 
 %% Send pending messages to the MME
 sctp_send_pending(#{tx_queue := Pending} = S) ->
     sctp_send_pending(lists:reverse(Pending), S).
 
-sctp_send_pending(Data | Pending, S0) ->
-    S1 = sctp_send(Data, S0),
+sctp_send_pending(Data | Pending, S) ->
+    sctp_send(Data, S),
     s1gw_metrics:gauge_dec(?S1GW_GAUGE_S1AP_PROXY_UPLINK_PACKETS_QUEUED),
-    sctp_send_pending(Pending, S1);
+    sctp_send_pending(Pending, S);
 
 sctp_send_pending(, S) ->
     S#{tx_queue := }.

osmo-s1gw_0.2.0.92.a7e0.202411112026.tar.xz/test/s1ap_proxy_test.erl -> osmo-s1gw_0.2.0.96.a530.202411122026.tar.xz/test/s1ap_proxy_test.erl Changed

@@ -3,6 +3,7 @@
 -include_lib("eunit/include/eunit.hrl").
 -include("pfcp_mock.hrl").
 
+
 %% ------------------------------------------------------------------
 %% setup functions
 %% ------------------------------------------------------------------
@@ -16,13 +17,14 @@
 start() ->
     pfcp_mock:mock_all(),
     exometer_mock:mock_all(),
-    s1ap_proxy:init().
+    {ok, Pid} = s1ap_proxy:start_link(),
+    #{handler => Pid}.
 
 
-stop(S) ->
+stop(#{handler := Pid}) ->
+    s1ap_proxy:shutdown(Pid),
     exometer_mock:unmock_all(),
-    pfcp_mock:unmock_all(),
-    s1ap_proxy:deinit(S).
+    pfcp_mock:unmock_all().
 
 
 %% ------------------------------------------------------------------
@@ -50,107 +52,93 @@
 %% actual testcases
 %% ------------------------------------------------------------------
 
-test_s1_setup_req(S0) ->
+test_s1_setup_req(#{handler := Pid}) ->
     SetupReq = s1_setup_req_pdu(),
     %% Expect the PDU to be proxied unmodified
-    ?_assertEqual({{forward, SetupReq}, S0}, s1ap_proxy:process_pdu(SetupReq, S0)).
+    ?_assertEqual({forward, SetupReq}, s1ap_proxy:process_pdu(Pid, SetupReq)).
 
 
-test_e_rab_setup(S0) ->
+test_e_rab_setup(#{handler := Pid}) ->
     %% eNB <- MME E-RAB SETUP REQUEST
     SetupReqIn = e_rab_setup_req_pdu(?ADDR_U2C, ?TEID_U2C),
     SetupReqExp = e_rab_setup_req_pdu(?ADDR_A2U, ?TEID_A2U),
-    {{forward, SetupReqOut}, S1} = s1ap_proxy:process_pdu(SetupReqIn, S0),
-
     %% eNB -> MME E-RAB SETUP RESPONSE
     SetupRspIn = e_rab_setup_rsp_pdu(?ADDR_U2A, ?TEID_U2A),
     SetupRspExp = e_rab_setup_rsp_pdu(?ADDR_C2U, ?TEID_C2U),
-    {{forward, SetupRspOut}, _S2} = s1ap_proxy:process_pdu(SetupRspIn, S1),
 
-    ?_assertEqual(SetupReqExp, SetupReqOut),
-     ?_assertEqual(SetupRspExp, SetupRspOut).
+    ?_assertEqual({forward, SetupReqExp}, s1ap_proxy:process_pdu(Pid, SetupReqIn)),
+     ?_assertEqual({forward, SetupRspExp}, s1ap_proxy:process_pdu(Pid, SetupRspIn)),
+     ?_assertMatch({ok, _}, s1ap_proxy:fetch_erab(Pid, {7, 9, 6})),
+     ?_assertMatch(_, s1ap_proxy:fetch_erab_list(Pid)).
 
 
-test_e_rab_setup_req_fail(S0) ->
+test_e_rab_setup_req_fail(#{handler := Pid}) ->
     %% pfcp_peer:session_establish_req/3 responds with a reject
     PDU = pfcp_mock:pdu_rsp_reject(session_establishment_response, ?SEID_Loc),
     pfcp_mock:mock_req(session_establish_req, PDU),
-    %% the linked erab_fsm will terminate abnormally, so trap this
-    process_flag(trap_exit, true),
     %% eNB <- S1GW <- MME E-RAB SETUP REQUEST
     %% eNB -- S1GW -> MME E-RAB SETUP RESPONSE (failure)
     SetupReqIn = e_rab_setup_req_pdu(?ADDR_U2C, ?TEID_U2C),
     SetupRspExp = e_rab_setup_rsp_fail_pdu(),
-    {{reply, SetupRspOut}, _S1} = s1ap_proxy:process_pdu(SetupReqIn, S0),
 
-    %% TODO: make sure that the E-RAB FSM has been terminated
+    ?_assertEqual({reply, SetupRspExp}, s1ap_proxy:process_pdu(Pid, SetupReqIn)),
+     ?_assertEqual(, s1ap_proxy:fetch_erab_list(Pid)).
 
-    ?_assertEqual(SetupRspExp, SetupRspOut).
 
-
-test_e_rab_release_cmd(S0) ->
+test_e_rab_release_cmd(#{handler := Pid}) ->
     %% eNB <- MME E-RAB SETUP REQUEST
-    SetupReqIn = e_rab_setup_req_pdu(?ADDR_U2C, ?TEID_U2C),
-    {_, S1} = s1ap_proxy:process_pdu(SetupReqIn, S0),
-
+    SetupReq = e_rab_setup_req_pdu(?ADDR_U2C, ?TEID_U2C),
     %% eNB -> MME E-RAB SETUP RESPONSE
-    SetupRspIn = e_rab_setup_rsp_pdu(?ADDR_U2A, ?TEID_U2A),
-    {_, S2} = s1ap_proxy:process_pdu(SetupRspIn, S1),
-
+    SetupRsp = e_rab_setup_rsp_pdu(?ADDR_U2A, ?TEID_U2A),
     %% eNB <- MME E-RAB RELEASE COMMAND
     ReleaseCmd = e_rab_release_cmd_pdu(),
-    {{forward, ReleaseCmdOut}, S3} = s1ap_proxy:process_pdu(ReleaseCmd, S2),
-
     %% eNB -> MME E-RAB RELEASE RESPONSE
     ReleaseRsp = e_rab_release_rsp_pdu(),
-    {{forward, ReleaseRspOut}, _S4} = s1ap_proxy:process_pdu(ReleaseRsp, S3),
 
-    %% TODO: make sure that the E-RAB FSM has been terminated
-
-    ?_assertEqual(ReleaseCmd, ReleaseCmdOut),
-     ?_assertEqual(ReleaseRsp, ReleaseRspOut).
+    ?_assertMatch({forward, _}, s1ap_proxy:process_pdu(Pid, SetupReq)),
+     ?_assertMatch({forward, _}, s1ap_proxy:process_pdu(Pid, SetupRsp)),
+     ?_assertMatch(_, s1ap_proxy:fetch_erab_list(Pid)),
+     ?_assertEqual({forward, ReleaseCmd}, s1ap_proxy:process_pdu(Pid, ReleaseCmd)),
+     ?_assertEqual({forward, ReleaseRsp}, s1ap_proxy:process_pdu(Pid, ReleaseRsp)),
+     ?_assertEqual(, s1ap_proxy:fetch_erab_list(Pid)).
 
 
-test_e_rab_release_ind(S0) ->
+test_e_rab_release_ind(#{handler := Pid}) ->
     %% eNB <- MME E-RAB SETUP REQUEST
-    SetupReqIn = e_rab_setup_req_pdu(?ADDR_U2C, ?TEID_U2C),
-    {_, S1} = s1ap_proxy:process_pdu(SetupReqIn, S0),
-
+    SetupReq = e_rab_setup_req_pdu(?ADDR_U2C, ?TEID_U2C),
     %% eNB -> MME E-RAB SETUP RESPONSE
-    SetupRspIn = e_rab_setup_rsp_pdu(?ADDR_U2A, ?TEID_U2A),
-    {_, S2} = s1ap_proxy:process_pdu(SetupRspIn, S1),
-
+    SetupRsp = e_rab_setup_rsp_pdu(?ADDR_U2A, ?TEID_U2A),
     %% eNB -> MME E-RAB RELEASE INDICATION
     ReleaseInd = e_rab_release_ind_pdu(),
-    {{forward, ReleaseIndOut}, _S3} = s1ap_proxy:process_pdu(ReleaseInd, S2),
 
     %% TODO: make sure that the E-RAB FSM has been terminated
+    %% FIXME: erab_fsm does not tear down immediately, but after a timeout
 
-    ?_assertEqual(ReleaseInd, ReleaseIndOut).
+    ?_assertMatch({forward, _}, s1ap_proxy:process_pdu(Pid, SetupReq)),
+     ?_assertMatch({forward, _}, s1ap_proxy:process_pdu(Pid, SetupRsp)),
+     ?_assertEqual({forward, ReleaseInd}, s1ap_proxy:process_pdu(Pid, ReleaseInd)).
 
 
-test_e_rab_modify_ind(S0) ->
+test_e_rab_modify_ind(#{handler := Pid}) ->
     %% eNB -> MME E-RAB MODIFICATION INDICATION
     ModifyIndIn = e_rab_modify_ind_pdu(?ADDR_U2A, ?TEID_U2A),
     %% XXX: not implemented, we should actually expect ?ADDR_C2U, ?TEID_C2U
     ModifyIndExp = e_rab_modify_ind_pdu(?ADDR_U2A, ?TEID_U2A),
-    {{forward, ModifyIndOut}, _S1} = s1ap_proxy:process_pdu(ModifyIndIn, S0),
 
-    ?_assertEqual(ModifyIndExp, ModifyIndOut).
+    ?_assertEqual({forward, ModifyIndExp}, s1ap_proxy:process_pdu(Pid, ModifyIndIn)).
 
-test_initial_context_setup(S0) ->
+
+test_initial_context_setup(#{handler := Pid}) ->
     %% eNB <- MME INITIAL CONTEXT SETUP REQUEST
     InitCtxSetupReqIn = initial_context_setup_req_pdu(?ADDR_U2C, ?TEID_U2C),
     InitCtxSetupReqExp = initial_context_setup_req_pdu(?ADDR_A2U, ?TEID_A2U),
-    {{forward, InitCtxSetupReqOut}, S1} = s1ap_proxy:process_pdu(InitCtxSetupReqIn, S0),
-
     %% eNB -> MME INITIAL CONTEXT SETUP RESPONSE
     InitCtxSetupRspIn = initial_context_setup_rsp_pdu(?ADDR_U2A, ?TEID_U2A),
     InitCtxSetupRspExp = initial_context_setup_rsp_pdu(?ADDR_C2U, ?TEID_C2U),
-    {{forward, InitCtxSetupRspOut}, _S2} = s1ap_proxy:process_pdu(InitCtxSetupRspIn, S1),
 
-    ?_assertEqual(InitCtxSetupReqExp, InitCtxSetupReqOut),
-     ?_assertEqual(InitCtxSetupRspExp, InitCtxSetupRspOut).
+    ?_assertEqual({forward, InitCtxSetupReqExp}, s1ap_proxy:process_pdu(Pid, InitCtxSetupReqIn)),
+     ?_assertEqual({forward, InitCtxSetupRspExp}, s1ap_proxy:process_pdu(Pid, InitCtxSetupRspIn)),
+     ?_assertMatch(_, s1ap_proxy:fetch_erab_list(Pid)).
 
 
 %% ------------------------------------------------------------------

Changes of Revision 98