Searched refs:consumer_inserted (Results 1 – 3 of 3) sorted by relevance
1030 int consumer_inserted = in streamReplyWithRange() local1047 } else if (group_inserted == 1 && consumer_inserted == 0) { in streamReplyWithRange()
1035 int consumer_inserted = in streamReplyWithRange() local1052 } else if (group_inserted == 1 && consumer_inserted == 0) { in streamReplyWithRange()
1572 int consumer_inserted = in streamReplyWithRange() local1589 } else if (group_inserted == 1 && consumer_inserted == 0) { in streamReplyWithRange()