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(flash): Avoid printing garbled characters

Browse Source 
with: #1000371716

Signed-off-by: clinx <chenlin1@oppo.com>
This commit is contained in:
clinx 2025-10-11 16:45:50 +08:00 committed by 曾雪伟
parent 8a0b0e5b67
commit 31e326f36d
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
remotecache/flashnode/flashnode_op.go
View File

@ -469,9 +469,14 @@ func (f *FlashNode) opCachePutBlock(conn net.Conn, p *proto.Packet) (err error)
}
func (f *FlashNode) replyPutDataOk(ch *proto.CoonHandler, conn net.Conn, p *proto.Packet, logPrefix string) {
close(ch.Completed)
defer close(ch.Completed)
replyPacket := proto.NewPacket()
replyPacket.ReqID = p.ReqID
replyPacket.Opcode = p.Opcode
replyPacket.StartT = p.StartT
replyPacket.PacketOkReply()
for range ch.WaitAckChan {
if ch.RemoteError = p.WriteToConn(conn); ch.RemoteError != nil {
if ch.RemoteError = replyPacket.WriteToConn(conn); ch.RemoteError != nil {
log.LogWarnf(logPrefix+" reply to conn %v for write data", ch.RemoteError)
return
}