erlang
/
osmo_ss7
mirror of https://gerrit.osmocom.org/erlang/osmo_ss7
4
0
Fork 0
Code Issues Projects Releases Wiki Activity

sctp_core: register process name and listen to SCTP socket in passive mode

This commit is contained in:
Harald Welte 2013-07-27 14:13:37 +08:00
parent 43ceb09099
commit dd03995ea2
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/sctp_core.erl
View File

@ -68,7 +68,9 @@ behaviour_info(Other) ->
}). }).
start_link(InitOpts) -> start_link(InitOpts) ->
gen_fsm:start_link(?MODULE, InitOpts, [{debug, [trace]}]). LocalPort = proplists:get_value(sctp_local_port, InitOpts),
Name = list_to_atom("sctp_core_" ++ integer_to_list(LocalPort)),
gen_fsm:start_link({local, Name}, ?MODULE, InitOpts, [{debug, [trace]}]).
reconnect_sctp(L = #sctp_state{sctp_remote_ip = Ip, sctp_remote_port = Port, sctp_sock = Sock}) -> reconnect_sctp(L = #sctp_state{sctp_remote_ip = Ip, sctp_remote_port = Port, sctp_sock = Sock}) ->
io:format("SCTP Reconnect ~p:~p~n", [Ip, Port]), io:format("SCTP Reconnect ~p:~p~n", [Ip, Port]),
@ -108,7 +110,7 @@ init(InitOpts) ->
active -> active ->
gen_fsm:send_event(self(), osmo_util:make_prim('M','SCTP_ESTABLISH',request)); gen_fsm:send_event(self(), osmo_util:make_prim('M','SCTP_ESTABLISH',request));
_ -> _ ->
ok ok = gen_sctp:listen(SctpSock, true)
end, end,
{ok, idle, LoopDat}; {ok, idle, LoopDat};
Default -> Default ->
@ -174,6 +176,9 @@ handle_info({sctp, Socket, _RemoteIp, _RemotePort, {ANC, SAC}},
associating -> associating ->
NewState = established, NewState = established,
Spec = confirm; Spec = confirm;
idle ->
NewState = established,
Spec = indication;
_ -> _ ->
NewState = State, NewState = State,
Spec = indication Spec = indication