git:master:f9dcffc4: htable: added rpc htable.dmqresync command - sr-dev

17 Aug 2023

Module: kamailio
Branch: master
Commit: f9dcffc42f10caa638ba3e2cbbe6ffb6206373b7
URL: https://github.com/kamailio/kamailio/commit/f9dcffc42f10caa638ba3e2cbbe6ffb6...
Author: Daniel-Constantin Mierla miconda@gmail.com
Committer: Daniel-Constantin Mierla miconda@gmail.com
Date: 2023-08-17T18:40:44+02:00
htable: added rpc htable.dmqresync command
- reset and dmq sync for a specific hash table
---
Modified: src/modules/htable/htable.c
---
Diff:  https://github.com/kamailio/kamailio/commit/f9dcffc42f10caa638ba3e2cbbe6ffb6...
Patch: https://github.com/kamailio/kamailio/commit/f9dcffc42f10caa638ba3e2cbbe6ffb6...
---

diff --git a/src/modules/htable/htable.c b/src/modules/htable/htable.c
index b12d44f0927..5c682972f0c 100644
--- a/src/modules/htable/htable.c
+++ b/src/modules/htable/htable.c
@@ -1516,6 +1516,10 @@ static const char *htable_dmqsync_doc[2] = {
    "Perform DMQ sync action.",
    0
 };
+static const char *htable_dmqresync_doc[2] = {
+	"Perform DMQ resync action (flush and sync).",
+	0
+};
 /* clang-format on */
static void htable_rpc_delete(rpc_t *rpc, void *c)
@@ -2119,6 +2123,32 @@ static void htable_rpc_dmqsync(rpc_t *rpc, void *c)
    rpc->rpl_printf(c, "Ok");
 }
+/*! \brief RPC htable.dmgresync command to empty a hash table and sync via dmq */
+static void htable_rpc_dmqresync(rpc_t *rpc, void *c)
+{
+	str htname;
+	ht_t *ht;
+
+	if(rpc->scan(c, "S", &htname) < 1) {
+		rpc->fault(c, 500, "No htable name given");
+		return;
+	}
+	ht = ht_get_table(&htname);
+	if(ht == NULL) {
+		rpc->fault(c, 500, "No such htable");
+		return;
+	}
+	if(ht_reset_content(ht) < 0) {
+		rpc->fault(c, 500, "Htable flush failed.");
+		return;
+	}
+	if(ht_dmq_request_sync(&htname) < 0) {
+		rpc->fault(c, 500, "HTable DMQ Sync Failed");
+		return;
+	}
+	rpc->rpl_printf(c, "Ok");
+}
+
 /* clang-format off */
 rpc_export_t htable_rpc[] = {
    {"htable.dump", htable_rpc_dump, htable_dump_doc, RET_ARRAY},
@@ -2135,6 +2165,7 @@ rpc_export_t htable_rpc[] = {
    {"htable.stats", htable_rpc_stats, htable_stats_doc, RET_ARRAY},
    {"htable.flush", htable_rpc_flush, htable_flush_doc, 0},
    {"htable.dmqsync", htable_rpc_dmqsync, htable_dmqsync_doc, 0},
+	{"htable.dmqresync", htable_rpc_dmqresync, htable_dmqresync_doc, 0},
    {0, 0, 0, 0}
 };
 /* clang-format on */

    