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

@formatter:off

Browse Source 
chore(rdma): format the codes to pass jenkins test.

Signed-off-by: 80329100 <wuhuocheng@oppo.com>
This commit is contained in:
80329100 2024-11-12 14:20:52 +08:00
parent 9dff00dd5a
commit c47a9ebe2f
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
proto/packet.go
View File

@ -1021,7 +1021,6 @@ func (p *Packet) WriteToRdmaConn(conn *rdma.Connection) (err error) {
if p.Data != nil && p.Size != 0 {
copy(dataBuffer[offset:offset+p.Size], p.Data)
offset += p.Size
}
if _, err = conn.WriteBuffer(rdmaBuffer); err != nil {
return
@ -1103,9 +1102,6 @@ func (p *Packet) ReadFromRdmaConnWithVer(c *rdma.Connection, timeoutSec int) (er
offset += util.RdmaPacketArgSize
}
if p.Size < 0 {
return syscall.EBADMSG
}
size := p.Size
if (p.Opcode == OpRead || p.Opcode == OpStreamRead || p.Opcode == OpExtentRepairRead || p.Opcode == OpStreamFollowerRead) && p.ResultCode == OpInitResultCode {
size = 0