|
@ -1742,14 +1742,14 @@ void DBImpl::GarbageCollect() { |
|
|
valuelog_set.emplace(filename); |
|
|
valuelog_set.emplace(filename); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
bool tmp_judge=false;//only clean one file
|
|
|
|
|
|
|
|
|
//bool tmp_judge=false;//only clean one file
|
|
|
for (std::string valuelog_name : valuelog_set) { |
|
|
for (std::string valuelog_name : valuelog_set) { |
|
|
if(tmp_judge){ |
|
|
|
|
|
break; |
|
|
|
|
|
} |
|
|
|
|
|
else{ |
|
|
|
|
|
tmp_judge=true; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
// if(tmp_judge){
|
|
|
|
|
|
// break;
|
|
|
|
|
|
// }
|
|
|
|
|
|
// else{
|
|
|
|
|
|
// tmp_judge=true;
|
|
|
|
|
|
// }
|
|
|
uint64_t cur_log_number = GetValueLogID(valuelog_name); |
|
|
uint64_t cur_log_number = GetValueLogID(valuelog_name); |
|
|
valuelog_name = ValueLogFileName(dbname_, cur_log_number); |
|
|
valuelog_name = ValueLogFileName(dbname_, cur_log_number); |
|
|
if (cur_log_number == valuelogfile_number_) { |
|
|
if (cur_log_number == valuelogfile_number_) { |
|
|