Free a stream, including the listpacks stored inside the radix tree. */
| 76 | |
| 77 | /* Free a stream, including the listpacks stored inside the radix tree. */ |
| 78 | void freeStream(stream *s) { |
| 79 | raxFreeWithCallback(s->rax,(void(*)(void*))lpFree); |
| 80 | if (s->cgroups) |
| 81 | raxFreeWithCallback(s->cgroups,(void(*)(void*))streamFreeCG); |
| 82 | zfree(s); |
| 83 | } |
| 84 | |
| 85 | /* Return the length of a stream. */ |
| 86 | unsigned long streamLength(robj_roptr subject) { |
no test coverage detected