Home
last modified time | relevance | path

Searched refs:streams_pos (Results 1 – 3 of 3) sorted by relevance

/dports/databases/redis5/redis-5.0.14/src/
H A Ddb.c1451 int streams_pos = -1; in xreadGetKeys() local
1463 streams_pos = i; in xreadGetKeys()
1469 if (streams_pos != -1) num = argc - streams_pos - 1; in xreadGetKeys()
1472 if (streams_pos == -1 || num == 0 || num % 2 != 0) { in xreadGetKeys()
1480 for (i = streams_pos+1; i < argc-num; i++) keys[i-streams_pos-1] = i; in xreadGetKeys()
/dports/databases/redis-devel/redis-0e5b813/src/
H A Ddb.c1889 int streams_pos = -1; in xreadGetKeys() local
1901 streams_pos = i; in xreadGetKeys()
1907 if (streams_pos != -1) num = argc - streams_pos - 1; in xreadGetKeys()
1910 if (streams_pos == -1 || num == 0 || num % 2 != 0) { in xreadGetKeys()
1918 for (i = streams_pos+1; i < argc-num; i++) keys[i-streams_pos-1] = i; in xreadGetKeys()
/dports/databases/redis6/redis-6.0.16/src/
H A Ddb.c1741 int streams_pos = -1; in xreadGetKeys() local
1753 streams_pos = i; in xreadGetKeys()
1759 if (streams_pos != -1) num = argc - streams_pos - 1; in xreadGetKeys()
1762 if (streams_pos == -1 || num == 0 || num % 2 != 0) { in xreadGetKeys()
1770 for (i = streams_pos+1; i < argc-num; i++) keys[i-streams_pos-1] = i; in xreadGetKeys()