Osmocom Open Build Service

osmo-epdg_0.0.0.126.e82c.202402272026.dsc -> osmo-epdg_0.0.0.128.5081.202402282026.dsc Changed

@@ -2,15 +2,15 @@
 Source: osmo-epdg
 Binary: osmo-epdg
 Architecture: any
-Version: 0.0.0.126.e82c.202402272026
+Version: 0.0.0.128.5081.202402282026
 Maintainer: Osmocom team <openbsc@lists.osmocom.org>
 Standards-Version: 4.5.0
 Build-Depends: erlang-nox, libpcap-dev, rebar3, debhelper (>= 10)
 Package-List:
  osmo-epdg deb net optional arch=any
 Checksums-Sha1:
- d19f3389d044e4bf0b1a64f9ec06fa4f88ae205e 9817556 osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz
+ 87ea1611be0805157967977979df9aadc9b45a51 9816848 osmo-epdg_0.0.0.128.5081.202402282026.tar.xz
 Checksums-Sha256:
- 6df645075807a45244eb06c0d124962f7f11c4b224befbc0d25216c446c5b6d1 9817556 osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz
+ 484d879af711447fdbd96aa482d00568ea4ec96f655e13cbd13ece014eb88d76 9816848 osmo-epdg_0.0.0.128.5081.202402282026.tar.xz
 Files:
- 8d50c8932fb5099f1c2cc978b804d374 9817556 osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz
+ 775fb212cf57e672f6ed13fc6bc8f02b 9816848 osmo-epdg_0.0.0.128.5081.202402282026.tar.xz

osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz/.tarball-version -> osmo-epdg_0.0.0.128.5081.202402282026.tar.xz/.tarball-version Changed

osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz/build_dep.tar.gz -> osmo-epdg_0.0.0.128.5081.202402282026.tar.xz/build_dep.tar.gz Changed

osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz/debian/changelog -> osmo-epdg_0.0.0.128.5081.202402282026.tar.xz/debian/changelog Changed

osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz/debian/control -> osmo-epdg_0.0.0.128.5081.202402282026.tar.xz/debian/control Changed

osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz/rebar.config -> osmo-epdg_0.0.0.128.5081.202402282026.tar.xz/rebar.config Changed

osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz/rebar.lock -> osmo-epdg_0.0.0.128.5081.202402282026.tar.xz/rebar.lock Changed

osmo-epdg_0.0.0.126.e82c.202402272026.tar.xz/src/epdg_gtpc_s2b.erl -> osmo-epdg_0.0.0.128.5081.202402282026.tar.xz/src/epdg_gtpc_s2b.erl Changed

@@ -179,10 +179,11 @@
 
 %% @callback gen_server
 handle_info({udp, _Socket, IP, InPortNo, RxMsg}, State) ->
-    lager:info("S2b: Rx from IP ~p port ~p: ~p~n", IP, InPortNo, RxMsg),
-    Req = gtp_packet:decode(RxMsg),
-    lager:info("S2b: Rx from IP ~p port ~p: ~p~n", IP, InPortNo, Req),
-    rx_gtp(Req, State);
+    lager:debug("S2b: Rx from IP ~p port ~p: ~p~n", IP, InPortNo, RxMsg),
+    spawn_wait_ret(fun() ->
+                        rx_udp(IP, InPortNo, RxMsg, State)
+                   end,
+                   {noreply, State});
 handle_info(Info, State) ->
     lager:info("S2b handle_info: ~p ~n", Info),
     {noreply, State}.
@@ -359,6 +360,27 @@
 connect(Address) ->
     connect(?SVC_NAME, Address).
 
+%% Calls Fun on a spawned monitored process and returns Fun ret.
+%% If spawned process crashes, return DefaultRet.
+spawn_wait_ret(Fun, DefaultRet) ->
+    MyPID=self(),
+    {Pid, MRef} = spawn_monitor(fun() ->
+                                    Ret = Fun(),
+                                    MyPID ! {self(), Ret}
+                                end),
+    receive
+    {'DOWN', MRef, process, _, _Reason} ->
+        DefaultRet;
+    {Pid, Ret} ->
+        erlang:demonitor(MRef, flush),
+        Ret
+    end.
+
+rx_udp(IP, InPortNo, RxMsg, State) ->
+    Req = gtp_packet:decode(RxMsg),
+    lager:debug("S2b: Rx from IP ~p port ~p: ~p~n", IP, InPortNo, Req),
+    rx_gtp(Req, State).
+
 rx_gtp(Resp = #gtp{version = v2, type = create_session_response}, State0) ->
     Sess0 = find_gtp_session_by_local_teic(Resp#gtp.tei, State0),
     case Sess0 of

Changes of Revision 146