Free a consumer group and all its associated data. */
| 2279 | |
| 2280 | /* Free a consumer group and all its associated data. */ |
| 2281 | void streamFreeCG(streamCG *cg) { |
| 2282 | raxFreeWithCallback(cg->pel,(void(*)(void*))streamFreeNACK); |
| 2283 | raxFreeWithCallback(cg->consumers,(void(*)(void*))streamFreeConsumer); |
| 2284 | zfree(cg); |
| 2285 | } |
| 2286 | |
| 2287 | /* Lookup the consumer group in the specified stream and returns its |
| 2288 | * pointer, otherwise if there is no such group, NULL is returned. */ |
no test coverage detected