fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-25 10:32:14 +00:00
Code Issues Projects Releases Wiki Activity

LCS: MINMATCHLEN and WITHMATCHLEN options.

Browse Source
This commit is contained in:
antirez 2020-04-02 13:37:35 +02:00
parent 88e66ecf94
commit 3f96e1623d
1 changed files with 24 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/t_string.c
View File

@ -482,11 +482,13 @@ void strlenCommand(client *c) {
/* LCS -- Longest common subsequence. /* LCS -- Longest common subsequence.
* *
* LCS [IDX] [STOREIDX <key>] STRINGS <string> <string> | KEYS <keya> <keyb> */ * LCS [IDX] [STOREIDX <key>] [MINMATCHLEN <len>]
* STRINGS <string> <string> | KEYS <keya> <keyb> */
void lcsCommand(client *c) { void lcsCommand(client *c) {
uint32_t i, j; uint32_t i, j;
long long minmatchlen = 0;
sds a = NULL, b = NULL; sds a = NULL, b = NULL;
int getlen = 0, getidx = 0; int getlen = 0, getidx = 0, withmatchlen = 0;
robj *idxkey = NULL; /* STOREIDX will set this and getidx to 1. */ robj *idxkey = NULL; /* STOREIDX will set this and getidx to 1. */
robj *obja = NULL, *objb = NULL; robj *obja = NULL, *objb = NULL;
@ -498,10 +500,17 @@ void lcsCommand(client *c) {
getidx = 1; getidx = 1;
} else if (!strcasecmp(opt,"LEN")) { } else if (!strcasecmp(opt,"LEN")) {
getlen = 1; getlen = 1;
} else if (!strcasecmp(opt,"WITHMATCHLEN")) {
withmatchlen = 1;
} else if (!strcasecmp(opt,"STOREIDX") && moreargs) { } else if (!strcasecmp(opt,"STOREIDX") && moreargs) {
getidx = 1; getidx = 1;
idxkey = c->argv[j+1]; idxkey = c->argv[j+1];
j++; j++;
} else if (!strcasecmp(opt,"MINMATCHLEN") && moreargs) {
if (getLongLongFromObjectOrReply(c,c->argv[j+1],&minmatchlen,NULL)
!= C_OK) return;
if (minmatchlen < 0) minmatchlen = 0;
j++;
} else if (!strcasecmp(opt,"STRINGS")) { } else if (!strcasecmp(opt,"STRINGS")) {
if (moreargs != 2) { if (moreargs != 2) {
addReplyError(c,"LCS requires exactly two strings"); addReplyError(c,"LCS requires exactly two strings");
@ -637,18 +646,22 @@ void lcsCommand(client *c) {
} }
/* Emit the current range if needed. */ /* Emit the current range if needed. */
uint32_t match_len = arange_end - arange_start + 1;
if (emit_range) { if (emit_range) {
if (minmatchlen == 0 || match_len >= minmatchlen) {
if (arraylenptr) { if (arraylenptr) {
addReplyArrayLen(c,2); addReplyArrayLen(c,2+withmatchlen);
addReplyArrayLen(c,2); addReplyArrayLen(c,2);
addReplyLongLong(c,arange_start); addReplyLongLong(c,arange_start);
addReplyLongLong(c,arange_end); addReplyLongLong(c,arange_end);
addReplyArrayLen(c,2); addReplyArrayLen(c,2);
addReplyLongLong(c,brange_start); addReplyLongLong(c,brange_start);
addReplyLongLong(c,brange_end); addReplyLongLong(c,brange_end);
if (withmatchlen) addReplyLongLong(c,match_len);
arraylen++;
}
} }
arange_start = alen; /* Restart at the next match. */ arange_start = alen; /* Restart at the next match. */
arraylen++;
} }
} }