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(datanode): fix print connection log panic.

Browse Source 
Signed-off-by: Victor1319 <834863182@qq.com>
This commit is contained in:
Victor1319 2023-11-03 18:13:01 +08:00 committed by leonrayang
parent 1437f1fb3e
commit 8cf8eb18c9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
repl/repl_protocol.go
View File

@ -402,7 +402,7 @@ func (rp *ReplProtocol) writeResponse(reply *Packet) {
defer func() {
reply.clean()
}()
log.LogDebugf("writeResponse.opcode %v reply %v conn(%v)", reply.Opcode, reply.GetUniqueLogId(), rp.sourceConn)
log.LogDebugf("writeResponse.opcode %v reply %v conn(%v)", reply.Opcode, reply.GetUniqueLogId(), rp.sourceConn.RemoteAddr().String())
if reply.IsErrPacket() {
err = fmt.Errorf(reply.LogMessage(ActionWriteToClient, rp.sourceConn.RemoteAddr().String(),
reply.StartT, fmt.Errorf(string(reply.Data[:reply.Size]))))
@ -413,7 +413,7 @@ func (rp *ReplProtocol) writeResponse(reply *Packet) {
}
rp.Stop()
}
log.LogDebugf("try rsp opcode %v %v %v", rp.replId, reply.Opcode, rp.sourceConn)
log.LogDebugf("try rsp opcode %v %v %v", rp.replId, reply.Opcode, rp.sourceConn.RemoteAddr().String())
// execute the post-processing function
rp.postFunc(reply)
if !reply.NeedReply {