Searched refs:CONSUMED (Results 1 – 2 of 2) sorted by relevance
28 if (version->status == DataStatus::CONSUMED) { in BuildConsumeRelationship()35 if (preVersion->status != DataStatus::CONSUMED) { in BuildProducerProducerRelationship()76 if (last == nullptr || last->status == DataStatus::CONSUMED) { in onProduced()79 status = DataStatus::CONSUMED; in onProduced()99 status = DataStatus::CONSUMED; in onConsumed()
64 CONSUMED, // 同时也是RELEASE，当前版本的所有消费者已经执行完成，标志着下一个版本的生产者可以执行 enumerator