Searched refs:streams_arg (Results 1 – 1 of 1) sorted by relevance
1332 int streams_arg = 0; in xreadCommand() local1356 streams_arg = i+1; in xreadCommand()1357 streams_count = (c->argc-streams_arg); in xreadCommand()1389 if (streams_arg == 0) { 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()1470 robj *o = lookupKeyRead(c->db,c->argv[streams_arg+i]); in xreadCommand()1518 addReplyBulk(c,c->argv[streams_arg+i]); in xreadCommand()1522 streamPropInfo spi = {c->argv[i+streams_arg],groupname}; in xreadCommand()1547 blockForKeys(c, BLOCKED_STREAM, c->argv+streams_arg, streams_count, in xreadCommand()