gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 10:06:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(data): when extent is mark delete, write op not failed.

Browse Source 
Signed-off-by: Victor1319 <834863182@qq.com>
This commit is contained in:
Victor1319 2024-01-30 09:42:12 +08:00 committed by longerfly
parent f6861102e0
commit 45b6896c46
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
storage/extent_store.go
View File

@ -387,7 +387,7 @@ func (s *ExtentStore) Write(extentID uint64, offset, size int64, data []byte, cr
)
s.eiMutex.Lock()
ei, _ = s.extentInfoMap[extentID]
ei = s.extentInfoMap[extentID]
e, err = s.extentWithHeader(ei)
s.eiMutex.Unlock()
if err != nil {
@ -405,10 +405,10 @@ func (s *ExtentStore) Write(extentID uint64, offset, size int64, data []byte, cr
} else {
if s.extentLock {
if _, ok := s.extentLockMap[extentID]; ok {
s.elMutex.RUnlock()
err = fmt.Errorf("extent(%v) is locked", extentID)
log.LogErrorf("[Write] gc_extent[%d] is locked", extentID)
return
// s.elMutex.RUnlock()
// err = fmt.Errorf("extent(%v) is locked", extentID)
log.LogErrorf("[Write] gc_extent[%d] is locked, path %s", extentID, s.dataPath)
// return
}
}
}