diff options
| author | antirez <antirez@gmail.com> | 2018-01-19 09:52:34 +0100 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2018-03-15 12:54:10 +0100 |
| commit | 1fafe7def15de73bd66271c9632584c456ea41e2 (patch) | |
| tree | d952eef2a7b6210b88a926f98362d10c4b2f0542 | |
| parent | 58f0c000a5630d22c221bc4291b46f2fc1654ead (diff) | |
| download | redis-1fafe7def15de73bd66271c9632584c456ea41e2.tar.gz | |
CG: fix raxFind() retval check in streamCreateCG().
| -rw-r--r-- | src/t_stream.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index b9c0c4bd7..ffa5130d8 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -1076,7 +1076,8 @@ void streamConsumerFree(streamConsumer *sc) { * group is returned. */ streamCG *streamCreateCG(stream *s, char *name, size_t namelen, streamID id) { if (s->cgroups == NULL) s->cgroups = raxNew(); - if (raxFind(s->cgroups,(unsigned char*)name,namelen)) return NULL; + if (raxFind(s->cgroups,(unsigned char*)name,namelen) != raxNotFound) + return NULL; streamCG *cg = zmalloc(sizeof(*cg)); cg->pel = raxNew(); |