| 190 | } |
| 191 | |
| 192 | bool TabletNode::MayLoadNow() { |
| 193 | MutexLock lock(&mutex_); |
| 194 | if (recent_load_time_list_.size() < |
| 195 | static_cast<uint32_t>(FLAGS_tera_master_max_load_concurrency)) { |
| 196 | return true; |
| 197 | } |
| 198 | if (recent_load_time_list_.front() + FLAGS_tera_master_load_interval * 1000000 <= get_micros()) { |
| 199 | return true; |
| 200 | } |
| 201 | VLOG(16) << "MayLoadNow() " << addr_ |
| 202 | << " last load time: " << (get_micros() - recent_load_time_list_.front()) / 1000000 |
| 203 | << " seconds ago"; |
| 204 | return false; |
| 205 | } |
| 206 | |
| 207 | void TabletNode::UpdateSize(TabletPtr tablet) { |
| 208 | MutexLock lock(&mutex_); |
no test coverage detected