This commit is contained in:
andrew (from workstation) 2020-05-22 12:11:56 +02:00
parent cfb731231a
commit 6e05d300dc
3 changed files with 11 additions and 11 deletions

View File

@ -4084,6 +4084,8 @@ class CliClient final : public Actor {
}
#endif
on_cmd("v0");
while (!cmd_queue_.empty() && !close_flag_) {
auto cmd = std::move(cmd_queue_.front());
cmd_queue_.pop();

View File

@ -3743,7 +3743,7 @@ void FileManager::memory_cleanup() {
if (main_node_id != 0) {
auto &node = file_nodes_[main_node_id];
if (node != nullptr && ((int32) i) == node->main_file_id_.fast_get()) {
if (time - node->main_file_id_.get_time() > 60 * 5 /* MAIN FILE TTL */) {
if (time - node->main_file_id_.get_time() > 20 /* MAIN FILE TTL */) {
node->main_file_id_.reset_time();
for (auto &file_id : node->file_ids_) {
@ -3838,9 +3838,9 @@ void FileManager::memory_cleanup() {
while (it != file_hash_to_file_id_.end()) {
auto &file = file_id_info_[it->second.fast_get()];
if (file_nodes_[file.node_id_] == nullptr) {
file_hash_to_file_id_.erase(it);
file_hash_to_file_id_.erase(it++);
} else {
it++;
++it;
}
}
}
@ -3851,9 +3851,9 @@ void FileManager::memory_cleanup() {
while (it != local_location_to_file_id_.end()) {
auto &file = file_id_info_[it->second.fast_get()];
if (file_nodes_[file.node_id_] == nullptr) {
it = local_location_to_file_id_.erase(it);
it = local_location_to_file_id_.erase(it++);
} else {
it++;
++it;
}
}
}
@ -3864,9 +3864,9 @@ void FileManager::memory_cleanup() {
while (it != generate_location_to_file_id_.end()) {
auto &file = file_id_info_[it->second.fast_get()];
if (file_nodes_[file.node_id_] == nullptr) {
it = generate_location_to_file_id_.erase(it);
it = generate_location_to_file_id_.erase(it++);
} else {
it++;
++it;
}
}
}
@ -3878,10 +3878,10 @@ void FileManager::memory_cleanup() {
while (it != map.end()) {
auto &file = file_id_info_[it->first.file_id_.fast_get()];
if (file_nodes_[file.node_id_] == nullptr) {
map.erase(it);
remote_location_info_.erase(it->second);
map.erase(it++);
} else {
it++;
++it;
}
}
}

View File

@ -34,9 +34,7 @@ class Enumerator {
}
void erase(Key key_y) {
auto pos_y = static_cast<Key>(key_y - 1);
empty_id_.push_back(key_y);
arr_[pos_y] = nullptr;
}
Key add(ValueT v) {