Searched refs:streamParseStrictIDOrReply (Results 1 – 1 of 1) sorted by relevance
| /f-stack/app/redis-5.0.5/src/ |
| H A D | t_stream.c | 1149 int streamParseStrictIDOrReply(client *c, robj *o, streamID *id, uint64_t missing_seq) { in streamParseStrictIDOrReply() function
1206 if (streamParseStrictIDOrReply(c,c->argv[i],&id,0) != C_OK) return; in xaddCommand()
1462 if (streamParseStrictIDOrReply(c,c->argv[i],ids+id_idx,0) != C_OK) in xreadCommand()
1775 } else if (streamParseStrictIDOrReply(c,c->argv[4],&id,0) != C_OK) { in xgroupCommand()
1843 if (streamParseStrictIDOrReply(c,c->argv[2],&id,0) != C_OK) return; in xsetidCommand()
1895 if (streamParseStrictIDOrReply(c,c->argv[j],&id,0) != C_OK) return; in xackCommand()
2162 if (streamParseStrictIDOrReply(NULL,c->argv[j],&id,0) != C_OK) break; in xclaimCommand()
2196 if (streamParseStrictIDOrReply(c,c->argv[j],&last_id,0) != C_OK) return; in xclaimCommand()
2231 if (streamParseStrictIDOrReply(c,c->argv[j],&id,0) != C_OK) in xclaimCommand()
2330 if (streamParseStrictIDOrReply(c,c->argv[j],&id,0) != C_OK) return; in xdelCommand()
[all …]
|