We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f497ffc commit c8876fcCopy full SHA for c8876fc
1 file changed
src/defrag.c
@@ -871,7 +871,7 @@ void* defragStreamConsumerPendingEntry(raxIterator *ri, void *privdata) {
871
PendingEntryContext *ctx = privdata;
872
streamNACK *nack = ri->data, *newnack;
873
nack->consumer = ctx->c; /* update nack pointer to consumer */
874
- nack->cgroup_ref_node->value = ctx->cg; /* Update the value of cgroups_ref node to the consumer group. */
+ // nack->cgroup_ref_node->value = ctx->cg; /* Update the value of cgroups_ref node to the consumer group. */
875
newnack = activeDefragAlloc(nack);
876
if (newnack) {
877
/* update consumer group pointer to the nack */
0 commit comments