Searched refs:generation_list_t (Results 1 – 6 of 6) sorted by relevance
57 class generation_list_t {59 generation_list_t() = default;94 void set_min_from(topic_t topic, const generation_list_t &other) { in set_min_from()112 bool operator==(const generation_list_t &rhs) const {123 static generation_list_t invalids() { in invalids()181 generation_list_t current{};214 generation_list_t updated_gens_in_data(acquired_lock<data_t> &data);227 generation_list_t await_gens(const generation_list_t &input_gens);230 generation_list_t updated_gens();252 generation_list_t current_generations() { return updated_gens(); } in current_generations()[all …]
13 wcstring generation_list_t::describe() const { in describe()151 generation_list_t topic_monitor_t::updated_gens_in_data(acquired_lock<data_t> &data) { in updated_gens_in_data()180 generation_list_t topic_monitor_t::updated_gens() { in updated_gens()185 bool topic_monitor_t::try_update_gens_maybe_becoming_reader(generation_list_t *gens) { in try_update_gens_maybe_becoming_reader()227 generation_list_t topic_monitor_t::await_gens(const generation_list_t &input_gens) { in await_gens()228 generation_list_t gens = input_gens; in await_gens()254 bool topic_monitor_t::check(generation_list_t *gens, bool wait) { in check()257 generation_list_t current = updated_gens(); in check()
426 generation_list_t gens = generation_list_t::invalids(); in wait()
260 generation_list_t gens_{};
394 generation_list_t reapgens = generation_list_t::invalids(); in process_mark_finished_children()
6300 generation_list_t gens{}; in test_topic_monitor()6327 std::vector<generation_list_t> gens; in test_topic_monitor_torture()6328 gens.resize(thread_count, generation_list_t::invalids()); in test_topic_monitor_torture()