[sr-dev] git:kamailio_3.0: sctp rpc: core.sctp_options debugging version

Module: sip-router Branch: kamailio_3.0 Commit: d0f78f622c9223f58a037c6f0dc827240ab68c6a URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=d0f78f6… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Thu Nov 12 16:29:40 2009 +0100 sctp rpc: core.sctp_options debugging version core.sctp_options can now have 1 optional parameter. If the parameter is missing it works as before: displays ser's idea of all the sctp config options. If the parameter is present it should have one of the following values: "default" (default send socket), "first" (first sctp socket) or addr[:port]. In this case the kernel sctp options for that particular socket will be displayed, with 0 used for the options that are userspace only. E.g.: sercmd core.sctp_options 127.0.0.1 (cherry picked from commit 44226358e60f5b69a4c383c892003ad2226c9089) --- core_cmd.c | 57 ++++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 54 insertions(+), 3 deletions(-) diff --git a/core_cmd.c b/core_cmd.c index ca06bf4..8533802 100644 --- a/core_cmd.c +++ b/core_cmd.c @@ -680,7 +680,13 @@ static void core_tcp_options(rpc_t* rpc, void* c) static const char* core_sctp_options_doc[] = { - "Returns active sctp options.", /* Documentation string */ + "Returns active sctp options. With one parameter" + " it returns the sctp options set in the kernel for a specific socket" + "(debugging), with 0 filled in for non-kernel related options." + " The parameter can be: \"default\" | \"first\" | address[:port] ." + " With no parameters it returns ser's idea of the current sctp options" + " (intended non-debugging use).", + /* Documentation string */ 0 /* Method signature(s) */ }; @@ -689,9 +695,54 @@ static void core_sctp_options(rpc_t* rpc, void* c) #ifdef USE_SCTP void *handle; struct cfg_group_sctp t; - + char* param; + struct socket_info* si; + char* host; + str hs; + int hlen; + int port; + int proto; + + param=0; if (!sctp_disable){ - sctp_options_get(&t); + /* look for optional socket parameter */ + if (rpc->scan(c, "*s", &param)>0){ + si=0; + if (strcasecmp(param, "default")==0){ + si=sendipv4_sctp?sendipv4_sctp:sendipv6_sctp; + }else if (strcasecmp(param, "first")==0){ + si=sctp_listen; + }else{ + if (parse_phostport(param, &host, &hlen, &port, &proto)!=0){ + rpc->fault(c, 500, "bad param (use address, address:port," + " default or first)"); + return; + } + if (proto && proto!=PROTO_SCTP){ + rpc->fault(c, 500, "bad protocol in param (only SCTP" + " allowed)"); + return; + } + hs.s=host; + hs.len=hlen; + si=grep_sock_info(&hs, port, PROTO_SCTP); + if (si==0){ + rpc->fault(c, 500, "not listening on sctp %s", param); + return; + } + } + if (si==0 || si->socket==-1){ + rpc->fault(c, 500, "could not find a sctp socket"); + return; + } + memset(&t, 0, sizeof(t)); + if (sctp_get_cfg_from_sock(si->socket, &t)!=0){ + rpc->fault(c, 500, "failed to get socket options"); + return; + } + }else{ + sctp_options_get(&t); + } rpc->add(c, "{", &handle); rpc->struct_add(handle, "ddddddddddddddddddd", "sctp_socket_rcvbuf", t.so_rcvbuf,