| 186 | } |
| 187 | |
| 188 | inline void table_data::force_refresh() |
| 189 | { |
| 190 | if (pg::use_shared_mem_for_refresh) { |
| 191 | return; |
| 192 | } |
| 193 | if (refresh_promise_ && !refresh_promise_.cancel()) { |
| 194 | refresh_promise_.get_future().get(); |
| 195 | } |
| 196 | ASSERT(refreshing_dataset_ != nullptr); |
| 197 | refresh_promise_ = async::run_on_main([d = refreshing_dataset_]() { |
| 198 | return d->refresh(); |
| 199 | }); |
| 200 | } |
| 201 | |
| 202 | inline const std::string& table_data::get_table_name() const noexcept |
| 203 | { |
nothing calls this directly
no test coverage detected