| 165 | } |
| 166 | |
| 167 | RefreshTaskPtr RefreshSet::tryGetTaskForInnerTable(const StorageID & inner_table_id) const |
| 168 | { |
| 169 | std::unique_lock lock(mutex); |
| 170 | auto it = inner_tables.find(inner_table_id); |
| 171 | if (it == inner_tables.end()) |
| 172 | return nullptr; |
| 173 | return *it->second.begin(); |
| 174 | } |
| 175 | |
| 176 | void RefreshSet::notifyDependents(const StorageID & id) const |
| 177 | { |
no test coverage detected