Module: kamailio Branch: master Commit: f1278a20bb37b29285c9d7cac298a3b1905f1c88 URL: https://github.com/kamailio/kamailio/commit/f1278a20bb37b29285c9d7cac298a3b… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2020-09-17T13:19:13+02:00 corex: added rpc command shm.info --- Added: src/modules/corex/corex_rpc_shm.c Added: src/modules/corex/corex_rpc_shm.h Modified: src/modules/corex/corex_mod.c --- Diff: https://github.com/kamailio/kamailio/commit/f1278a20bb37b29285c9d7cac298a3b… Patch: https://github.com/kamailio/kamailio/commit/f1278a20bb37b29285c9d7cac298a3b… --- diff --git a/src/modules/corex/corex_mod.c b/src/modules/corex/corex_mod.c index 8d0e649548..194efcdb8e 100644 --- a/src/modules/corex/corex_mod.c +++ b/src/modules/corex/corex_mod.c @@ -39,6 +39,7 @@ #include "corex_lib.h" #include "corex_rpc.h" +#include "corex_rpc_shm.h" #include "corex_var.h" #include "corex_nio.h" @@ -188,6 +189,12 @@ static int mod_init(void) return -1; } + if(corex_init_rpc_shm()<0) + { + LM_ERR("failed to register RPC shm commands\n"); + return -1; + } + if(corex_register_check_self()<0) { LM_ERR("failed to register check self callback\n"); diff --git a/src/modules/corex/corex_rpc_shm.c b/src/modules/corex/corex_rpc_shm.c new file mode 100644 index 0000000000..5316cdc7bc --- /dev/null +++ b/src/modules/corex/corex_rpc_shm.c @@ -0,0 +1,72 @@ +/** + * Copyright (C) 2020 Daniel-Constantin Mierla (asipto.com) + * + * This file is part of Kamailio, a free SIP server. + * + * Permission to use, copy, modify, and distribute this software for any + * purpose with or without fee is hereby granted, provided that the above + * copyright notice and this permission notice appear in all copies. + * + * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES + * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR + * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES + * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN + * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF + * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. + * + */ + +#include <stdio.h> +#include <unistd.h> +#include <stdlib.h> +#include <string.h> + +#include "../../core/dprint.h" +#include "../../core/ut.h" +#include "../../core/mem/shm.h" +#include "../../core/globals.h" +#include "../../core/rpc.h" +#include "../../core/rpc_lookup.h" + +static const char* corex_rpc_shm_info_doc[2] = { + "Return details of the shared memory manager", + 0 +}; + + +/* + * RPC command to list the listening sockets + */ +static void corex_rpc_shm_info(rpc_t* rpc, void* ctx) +{ + void* th; + + if (rpc->add(ctx, "{", &th) < 0) { + rpc->fault(ctx, 500, "Internal error creating rpc"); + return; + } + if(rpc->struct_add(th, "su", + "name", (_shm_root.mname)?_shm_root.mname:"unknown", + "size", (unsigned int)shm_mem_size) <0) { + rpc->fault(ctx, 500, "Internal error adding fields"); + return; + } +} + +rpc_export_t corex_rpc_shm_cmds[] = { + {"shm.info", corex_rpc_shm_info, corex_rpc_shm_info_doc, 0}, + {0, 0, 0, 0} +}; + +/** + * register RPC shm commands + */ +int corex_init_rpc_shm(void) +{ + if (rpc_register_array(corex_rpc_shm_cmds)!=0) { + LM_ERR("failed to register RPC shm commands\n"); + return -1; + } + return 0; +} diff --git a/src/modules/corex/corex_rpc_shm.h b/src/modules/corex/corex_rpc_shm.h new file mode 100644 index 0000000000..392dcafc08 --- /dev/null +++ b/src/modules/corex/corex_rpc_shm.h @@ -0,0 +1,25 @@ +/** + * Copyright (C) 2020 Daniel-Constantin Mierla (asipto.com) + * + * This file is part of Kamailio, a free SIP server. + * + * Permission to use, copy, modify, and distribute this software for any + * purpose with or without fee is hereby granted, provided that the above + * copyright notice and this permission notice appear in all copies. + * + * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES + * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR + * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES + * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN + * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF + * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. + * + */ + +#ifndef _COREX_RPC_SHM_H_ +#define _COREX_RPC_SHM_H_ + +int corex_init_rpc_shm(void); + +#endif