mod_hash: add realm filter to hash_dump db command so that you can quickly dump all entries that belong only to a specific realm without getting the whole db
This commit is contained in:
parent
0315d32076
commit
8134712627
|
@ -531,16 +531,33 @@ SWITCH_STANDARD_API(hash_api_function)
|
||||||
return SWITCH_STATUS_SUCCESS;
|
return SWITCH_STATUS_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
#define HASH_DUMP_SYNTAX "all|limit|db"
|
#define HASH_DUMP_SYNTAX "all|limit|db [<realm>]"
|
||||||
SWITCH_STANDARD_API(hash_dump_function)
|
SWITCH_STANDARD_API(hash_dump_function)
|
||||||
{
|
{
|
||||||
int mode;
|
int mode;
|
||||||
switch_hash_index_t *hi;
|
switch_hash_index_t *hi;
|
||||||
|
int argc = 0;
|
||||||
|
char *argv[4] = { 0 };
|
||||||
|
char *mydata = NULL;
|
||||||
|
int realm = 0;
|
||||||
|
char *realmvalue = NULL;
|
||||||
|
|
||||||
if (zstr(cmd)) {
|
if (!zstr(cmd)) {
|
||||||
|
mydata = strdup(cmd);
|
||||||
|
switch_assert(mydata);
|
||||||
|
argc = switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0])));
|
||||||
|
} else {
|
||||||
|
realmvalue = "test";
|
||||||
|
realm = 0;
|
||||||
stream->write_function(stream, "Usage: "HASH_DUMP_SYNTAX"\n");
|
stream->write_function(stream, "Usage: "HASH_DUMP_SYNTAX"\n");
|
||||||
return SWITCH_STATUS_SUCCESS;
|
return SWITCH_STATUS_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
cmd = strdup(argv[0]);
|
||||||
|
if (argc == 2) {
|
||||||
|
realm = 1;
|
||||||
|
realmvalue = switch_mprintf("%s_", argv[1]);
|
||||||
|
}
|
||||||
|
|
||||||
if (!strcmp(cmd, "all")) {
|
if (!strcmp(cmd, "all")) {
|
||||||
mode = 3;
|
mode = 3;
|
||||||
|
@ -553,7 +570,6 @@ SWITCH_STANDARD_API(hash_dump_function)
|
||||||
return SWITCH_STATUS_SUCCESS;
|
return SWITCH_STATUS_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
if (mode & 1) {
|
if (mode & 1) {
|
||||||
switch_thread_rwlock_rdlock(globals.limit_hash_rwlock);
|
switch_thread_rwlock_rdlock(globals.limit_hash_rwlock);
|
||||||
for (hi = switch_hash_first(NULL, globals.limit_hash); hi; hi = switch_hash_next(hi)) {
|
for (hi = switch_hash_first(NULL, globals.limit_hash); hi; hi = switch_hash_next(hi)) {
|
||||||
|
@ -577,8 +593,13 @@ SWITCH_STANDARD_API(hash_dump_function)
|
||||||
const void *key;
|
const void *key;
|
||||||
switch_ssize_t keylen;
|
switch_ssize_t keylen;
|
||||||
switch_hash_this(hi, &key, &keylen, &val);
|
switch_hash_this(hi, &key, &keylen, &val);
|
||||||
|
if (realm) {
|
||||||
stream->write_function(stream, "D/%s/%s\n", key, (char*)val);
|
if (strstr(key, realmvalue)) {
|
||||||
|
stream->write_function(stream, "D/%s/%s\n", key, (char*)val);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
stream->write_function(stream, "D/%s/%s\n", key, (char*)val);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
switch_thread_rwlock_unlock(globals.db_hash_rwlock);
|
switch_thread_rwlock_unlock(globals.db_hash_rwlock);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue