MCPcopy Create free account
hub / github.com/F-Stack/f-stack / streamFreeConsumer

Function streamFreeConsumer

app/redis-6.2.6/src/t_stream.c:2256–2261  ·  view source on GitHub ↗

Free a consumer and associated data structures. Note that this function * will not reassign the pending messages associated with this consumer * nor will delete them from the stream, so when this function is called * to delete a consumer, and not when the whole stream is destroyed, the caller * should do some work before. */

Source from the content-addressed store, hash-verified

2254 * to delete a consumer, and not when the whole stream is destroyed, the caller
2255 * should do some work before. */
2256void streamFreeConsumer(streamConsumer *sc) {
2257 raxFree(sc->pel); /* No value free callback: the PEL entries are shared
2258 between the consumer and the main stream PEL. */
2259 sdsfree(sc->name);
2260 zfree(sc);
2261}
2262
2263/* Create a new consumer group in the context of the stream 's', having the
2264 * specified name and last server ID. If a consumer group with the same name

Callers 1

streamDelConsumerFunction · 0.85

Calls 3

raxFreeFunction · 0.85
sdsfreeFunction · 0.85
zfreeFunction · 0.70

Tested by

no test coverage detected