octoleo/s3fs-fuse
1
0
Fork 0
mirror of https://github.com/s3fs-fuse/s3fs-fuse.git synced 2024-11-15 16:57:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed the truncation bug of stat file for cache file

Browse Source
This commit is contained in:
Takeshi Nakatani 2020-04-14 14:43:41 +00:00
parent 538fbed302
commit 811ea0cb85
1 changed files with 36 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/fdcache.cpp
View File

@ -62,6 +62,33 @@ static const int MAX_MULTIPART_CNT = 10 * 1000; // S3 multipart max count
#define TMPFILE_DIR_0PATH "/tmp" #define TMPFILE_DIR_0PATH "/tmp"
#endif #endif
//------------------------------------------------
// Local utility function
//------------------------------------------------
// Wrapped s3fs_strtoofft()
//
// PageList::Serialize method uses s3fs_strtoofft function,
// but s3fs_strtoofft throws an exception, so wrap it in
// this function.
// PageList::Serialize works as 0 when the read data is invalid.
//
static off_t wrap_strtoofft(const char* str)
{
off_t result;
if(str){
try{
result = s3fs_strtoofft(str);
}catch(std::exception &e){
S3FS_PRN_WARN("something error is occurred in convert string to off_t, so return 0 as default.");
result = 0;
}
}else{
S3FS_PRN_WARN("parameter is null, so return 0 as default.");
result = 0;
}
return result;
}
//------------------------------------------------ //------------------------------------------------
// CacheFileStat class methods // CacheFileStat class methods
//------------------------------------------------ //------------------------------------------------
@ -842,6 +869,10 @@ bool PageList::Serialize(CacheFileStat& file, bool is_output)
ssall << "\n" << iter->offset << ":" << iter->bytes << ":" << (iter->loaded ? "1" : "0") << ":" << (iter->modified ? "1" : "0"); ssall << "\n" << iter->offset << ":" << iter->bytes << ":" << (iter->loaded ? "1" : "0") << ":" << (iter->modified ? "1" : "0");
} }
if(-1 == ftruncate(file.GetFd(), 0)){
S3FS_PRN_ERR("failed to truncate file(to 0) for stats(%d)", errno);
return false;
}
string strall = ssall.str(); string strall = ssall.str();
if(0 >= pwrite(file.GetFd(), strall.c_str(), strall.length(), 0)){ if(0 >= pwrite(file.GetFd(), strall.c_str(), strall.length(), 0)){
S3FS_PRN_ERR("failed to write stats(%d)", errno); S3FS_PRN_ERR("failed to write stats(%d)", errno);
@ -883,7 +914,7 @@ bool PageList::Serialize(CacheFileStat& file, bool is_output)
delete[] ptmp; delete[] ptmp;
return false; return false;
} }
off_t total = s3fs_strtoofft(oneline.c_str()); off_t total = wrap_strtoofft(oneline.c_str());
// load each part // load each part
bool is_err = false; bool is_err = false;
@ -895,24 +926,24 @@ bool PageList::Serialize(CacheFileStat& file, bool is_output)
is_err = true; is_err = true;
break; break;
} }
off_t offset = s3fs_strtoofft(part.c_str()); off_t offset = wrap_strtoofft(part.c_str());
// size // size
if(!getline(ssparts, part, ':')){ if(!getline(ssparts, part, ':')){
is_err = true; is_err = true;
break; break;
} }
off_t size = s3fs_strtoofft(part.c_str()); off_t size = wrap_strtoofft(part.c_str());
// loaded // loaded
if(!getline(ssparts, part, ':')){ if(!getline(ssparts, part, ':')){
is_err = true; is_err = true;
break; break;
} }
bool is_loaded = (1 == s3fs_strtoofft(part.c_str()) ? true : false); bool is_loaded = (1 == wrap_strtoofft(part.c_str()) ? true : false);
bool is_modified; bool is_modified;
if(!getline(ssparts, part, ':')){ if(!getline(ssparts, part, ':')){
is_modified = false; // old version does not have this part. is_modified = false; // old version does not have this part.
}else{ }else{
is_modified = (1 == s3fs_strtoofft(part.c_str()) ? true : false); is_modified = (1 == wrap_strtoofft(part.c_str()) ? true : false);
} }
// add new area // add new area
PageList::page_status pstatus = PageList::page_status pstatus =