Searched refs:streams_count (Results 1 – 1 of 1) sorted by relevance
1331 int streams_count = 0; in xreadCommand() local1357 streams_count = (c->argc-streams_arg); in xreadCommand()1358 if ((streams_count % 2) != 0) { in xreadCommand()1402 if (streams_count > STREAMID_STATIC_VECTOR_LEN) in xreadCommand()1403 ids = zmalloc(sizeof(streamID)*streams_count); in xreadCommand()1404 if (groupname) groups = zmalloc(sizeof(streamCG*)*streams_count); in xreadCommand()1406 for (int i = streams_arg + streams_count; i < c->argc; i++) { in xreadCommand()1410 int id_idx = i - streams_arg - streams_count; in xreadCommand()1411 robj *key = c->argv[i-streams_count]; in xreadCommand()1469 for (int i = 0; i < streams_count; i++) { in xreadCommand()[all …]