[sr-dev] git:4.3:da6e5258: erlang: fix where is registered pseudo process

Module: kamailio Branch: 4.3 Commit: da6e5258a5897a6793e8a7f0ff4ee32233323d6b URL: https://github.com/kamailio/kamailio/commit/da6e5258a5897a6793e8a7f0ff4ee32… Author: Seudin Kasumovic &lt;seudin.kasumovic(a)gmail.com&gt; Committer: Seudin Kasumovic &lt;seudin.kasumovic(a)gmail.com&gt; Date: 2016-04-26T16:00:16+02:00 erlang: fix where is registered pseudo process - check is event route exist for queried registered process - check argument type and function arity - ensure error message proper formatted (cherry picked from commit 0f52906f28fdf38e56fd37e6ed34155b2deee505) --- Modified: modules/erlang/handle_emsg.c --- Diff: https://github.com/kamailio/kamailio/commit/da6e5258a5897a6793e8a7f0ff4ee32… Patch: https://github.com/kamailio/kamailio/commit/da6e5258a5897a6793e8a7f0ff4ee32… --- diff --git a/modules/erlang/handle_emsg.c b/modules/erlang/handle_emsg.c index 4dbb0a2..e1aa51f 100644 --- a/modules/erlang/handle_emsg.c +++ b/modules/erlang/handle_emsg.c @@ -415,6 +415,36 @@ int handle_net_kernel(cnode_handler_t *phandler, erlang_msg * msg) int erlang_whereis(cnode_handler_t *phandler,erlang_ref_ex_t *ref, erlang_pid *pid) { ei_x_buff *response = &phandler->response; + ei_x_buff *request = &phandler->request; + char route[sizeof("erlang:")+MAXATOMLEN] = "erlang:"; + int arity; + int type; + int rt; + + ei_decode_list_header(request->buff,&request->index,&arity); + + if (arity != 1) { + response->index = 1; + encode_error_msg(response, ref, "badarith", "undefined function erlang:whereis/%d",arity); + return 0; + } + + ei_get_type(request->buff,&request->index,&type,&arity); + + if (type != ERL_ATOM_EXT) { + response->index = 1; + encode_error_msg(response, ref, "badarg", "bad argument"); + return 0; + } + + ei_decode_atom(request->buff,&request->index,route+sizeof("erlang:")-1); + + rt = route_get(&event_rt, route); + if (rt < 0 || event_rt.rlist[rt] == NULL) { + LM_WARN("can't find pseudo process %s\n", route); + ei_x_encode_atom(response,"undefined"); + return 0; + } ei_x_encode_pid(response,&phandler->ec.self); @@ -430,6 +460,7 @@ static int handle_erlang_calls(cnode_handler_t *phandler,erlang_ref_ex_t *ref, e return erlang_whereis(phandler,ref,pid); } else { + response->index = 1; encode_error_msg(response, ref, "badrpc", "Method Not Found"); }