Module: sip-router
Branch: master
Commit: de2c39a1857d74443c6b1fa4f06cbb18d3dd8026
URL:
http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=de2c39a1857d74443c6b1fa4f06cbb18d3dd8026
Author: Daniel-Constantin Mierla <mico...@gmail.com>
Committer: Daniel-Constantin Mierla <mico...@gmail.com>
Date: Fri Nov 15 09:52:29 2013 +0100
app_perl: added rpc commands to set/get the value for reset_cycles
---
modules/app_perl/app_perl_mod.c | 102 ++++++++++++++++++++++++++++++++++++++-
1 files changed, 101 insertions(+), 1 deletions(-)
diff --git a/modules/app_perl/app_perl_mod.c b/modules/app_perl/app_perl_mod.c
index c35ece4..3948bbe 100644
--- a/modules/app_perl/app_perl_mod.c
+++ b/modules/app_perl/app_perl_mod.c
@@ -40,6 +40,9 @@
#include "../../modules/rr/api.h"
#include "../../modules/sl/sl.h"
+#include "../../rpc.h"
+#include "../../rpc_lookup.h"
+
/* lock_ops.h defines union semun, perl does not need to redefine it */
#ifdef USE_SYSV_SEM
# define HAS_UNION_SEMUN
@@ -74,6 +77,8 @@ PerlInterpreter *my_perl = NULL;
/** SL API structure */
sl_api_t slb;
+static int ap_init_rpc(void);
+
/*
* Module destroy function prototype
*/
@@ -329,7 +334,6 @@ struct mi_root* perl_mi_reload(struct mi_root *cmd_tree,
void *param)
*/
static int mod_init(void) {
- int ret = 0;
int argc = 1;
char *argt[] = { MOD_NAME, NULL };
char **argv;
@@ -342,6 +346,12 @@ static int mod_init(void) {
return -1;
}
+ if(ap_init_rpc()<0)
+ {
+ LM_ERR("failed to register RPC commands\n");
+ return -1;
+ }
+
if (!filename) {
LM_ERR("insufficient module parameters. Module not loaded.\n");
return -1;
@@ -394,6 +404,10 @@ error:
*/
static void destroy(void)
{
+ if(_ap_reset_cycles!=NULL)
+ shm_free(_ap_reset_cycles);
+ _ap_reset_cycles = NULL;
+
if(my_perl==NULL)
return;
unload_perl(my_perl);
@@ -437,3 +451,89 @@ int app_perl_reset_interpreter(void)
return 0;
}
+
+/*** RPC implementation ***/
+
+static const char* app_perl_rpc_set_reset_cycles_doc[3] = {
+ "Set the value for reset_cycles",
+ "Has one parmeter with int value",
+ 0
+};
+
+
+/*
+ * RPC command to set the value for reset_cycles
+ */
+static void app_perl_rpc_set_reset_cycles(rpc_t* rpc, void* ctx)
+{
+ int rsv;
+
+ if(rpc->scan(ctx, "d", &rsv)<1)
+ {
+ rpc->fault(ctx, 500, "Invalid Parameters");
+ return;
+ }
+ if(rsv<=0)
+ rsv = 0;
+
+ LM_DBG("new reset cycle value is %d\n", rsv);
+
+ *_ap_reset_cycles = rsv;
+
+ return;
+}
+
+static const char* app_perl_rpc_get_reset_cycles_doc[2] = {
+ "Get the value for reset_cycles",
+ 0
+};
+
+
+/*
+ * RPC command to set the value for reset_cycles
+ */
+static void app_perl_rpc_get_reset_cycles(rpc_t* rpc, void* ctx)
+{
+ int rsv;
+ void* th;
+
+ rsv = *_ap_reset_cycles;
+
+ /* add entry node */
+ if (rpc->add(ctx, "{", &th) < 0)
+ {
+ rpc->fault(ctx, 500, "Internal error root reply");
+ return;
+ }
+
+ if(rpc->struct_add(th, "d", "reset_cycles", rsv)<0)
+ {
+ rpc->fault(ctx, 500, "Internal error adding reset cycles");
+ return;
+ }
+ LM_DBG("reset cycle value is %d\n", rsv);
+
+ return;
+}
+
+
+rpc_export_t app_perl_rpc_cmds[] = {
+ {"app_perl.set_reset_cycles", app_perl_rpc_set_reset_cycles,
+ app_perl_rpc_set_reset_cycles_doc, 0},
+ {"app_perl.get_reset_cycles", app_perl_rpc_get_reset_cycles,
+ app_perl_rpc_get_reset_cycles_doc, 0},
+ {0, 0, 0, 0}
+};
+
+/**
+ * register RPC commands
+ */
+static int ap_init_rpc(void)
+{
+ if (rpc_register_array(app_perl_rpc_cmds)!=0)
+ {
+ LM_ERR("failed to register RPC commands\n");
+ return -1;
+ }
+ return 0;
+}
_______________________________________________
sr-dev mailing list
sr-dev@lists.sip-router.org
http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev
