Searched refs:cgroups (Results 1 – 7 of 7) sorted by relevance
| /f-stack/app/redis-5.0.5/src/ |
| H A D | t_stream.c | 58 s->cgroups = NULL; /* Created on demand to save memory when not used. */ in streamNew()
65 if (s->cgroups) in freeStream()
66 raxFreeWithCallback(s->cgroups,(void(*)(void*))streamFreeCG); in freeStream()
1622 if (s->cgroups == NULL) s->cgroups = raxNew(); in streamCreateCG()
1630 raxInsert(s->cgroups,(unsigned char*)name,namelen,cg,NULL); in streamCreateCG()
1644 if (s->cgroups == NULL) return NULL; in streamLookupCG()
1645 streamCG *cg = raxFind(s->cgroups,(unsigned char*)groupname, in streamLookupCG()
2494 if (s->cgroups == NULL) { in xinfoCommand()
2499 addReplyMultiBulkLen(c,raxSize(s->cgroups)); in xinfoCommand()
2501 raxStart(&ri,s->cgroups); in xinfoCommand()
[all …]
|
| H A D | stream.h | 20 rax *cgroups; /* Consumer groups dictionary: name -> streamCG */ member
|
| H A D | defrag.c | 755 if (s->cgroups) in defragStream()
756 defragged += defragRadixTree(&s->cgroups, 1, defragStreamConsumerGroup, NULL); in defragStream()
|
| H A D | object.c | 902 if (s->cgroups) { in objectComputeSize()
903 raxStart(&ri,s->cgroups); in objectComputeSize()
|
| H A D | rdb.c | 932 size_t num_cgroups = s->cgroups ? raxSize(s->cgroups) : 0; in rdbSaveObject()
938 raxStart(&ri,s->cgroups); in rdbSaveObject()
|
| H A D | aof.c | 1211 if (s->cgroups) { in rewriteStreamObject()
1213 raxStart(&ri,s->cgroups); in rewriteStreamObject()
|
| /f-stack/dpdk/doc/guides/rel_notes/ |
| H A D | release_2_2.rst | 183 models: pthreads, cgroups, or lightweight threads. The example includes
|