test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-11-29 18:38:44 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

fix: crash when startup if the milvus volume is on-operation concurrently (#37312)

Browse Source 
issue: #37311

Signed-off-by: chyezh <chyezh@outlook.com>
This commit is contained in:
Zhen Ye 2024-11-04 14:50:23 +08:00 committed by GitHub
parent ba9f36ba33
commit 0c4321cf57
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
internal/core/src/storage/LocalChunkManager.cpp
View File

@ -15,6 +15,7 @@
// limitations under the License.
#include "LocalChunkManager.h"
#include "log/Log.h"
#include <boost/filesystem.hpp>
#include <boost/system/error_code.hpp>
@ -232,7 +233,17 @@ LocalChunkManager::GetSizeOfDir(const std::string& dir) {
it != v.end();
++it) {
if (boost::filesystem::is_regular_file(it->path())) {
total_file_size += boost::filesystem::file_size(it->path());
boost::system::error_code ec;
auto file_size = boost::filesystem::file_size(it->path(), ec);
if (ec) {
// The file may be removed concurrently by other threads.
// So the file size cannot be obtained, just ignore it.
LOG_INFO("size of file {} cannot be obtained with error: {}",
it->path().string(),
ec.message());
continue;
}
total_file_size += file_size;
}
if (boost::filesystem::is_directory(it->path())) {
total_file_size += GetSizeOfDir(it->path().string());