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

fix(client): write meta conflict

Browse Source 
with: #1000451308

Signed-off-by: clinx <chenlin1@oppo.com>
This commit is contained in:
clinx 2025-12-01 14:07:51 +08:00 committed by 贺迟
parent 09adcf3912
commit 2f6568e81c
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sdk/data/stream/extent_handler.go
View File

@ -185,6 +185,8 @@ type ExtentHandler struct {
storageClass uint32
isMigration bool
flushMu sync.Mutex
}
// NewExtentHandler returns a new extent handler.
@ -848,6 +850,9 @@ func (eh *ExtentHandler) createExtent(dp *wrapper.DataPartition) (extID int, err
// Handler lock is held by the caller.
func (eh *ExtentHandler) flushPacket() {
eh.flushMu.Lock()
defer eh.flushMu.Unlock()
if eh.packet == nil {
log.LogDebugf("ExtentHandler flushPacket nil, return: eh(%v)", eh)
return