apps/gb28181
1
0
Fork 0
mirror of https://github.com/gowvp/gb28181.git synced 2026-04-22 23:17:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

远程地址防止 panic

Browse Source
This commit is contained in:
xugo
2025-04-13 18:30:55 +08:00
parent fc21e6baf1
commit fd4a36cf7d
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/gbs/sip/connection.go
+8 -4
View File
@@ -107,7 +107,8 @@ func (conn *connection) Read(buf []byte) (int, error) {
num, err = conn.baseConn.Read(buf)
if err != nil {
return num, NewError(err, conn.logKey, "read", conn.baseConn.LocalAddr().String())
return num, err
// NewError(err, conn.logKey, "read", conn.baseConn.LocalAddr().String())
}
return num, err
}
@@ -115,7 +116,8 @@ func (conn *connection) Read(buf []byte) (int, error) {
func (conn *connection) ReadFrom(buf []byte) (num int, raddr net.Addr, err error) {
num, raddr, err = conn.baseConn.(net.PacketConn).ReadFrom(buf)
if err != nil {
return num, raddr, NewError(err, conn.logKey, "readfrom", conn.baseConn.LocalAddr().String(), raddr.String())
return num, raddr, err
// NewError(err, conn.logKey, "readfrom", conn.baseConn.LocalAddr().String(), raddr.String())
}
// logrus.Tracef("readFrom %d , %s -> %s \n %s", num, raddr, conn.LocalAddr(), string(buf[:num]))
return num, raddr, err
@@ -129,7 +131,8 @@ func (conn *connection) Write(buf []byte) (int, error) {
num, err = conn.baseConn.Write(buf)
if err != nil {
return num, NewError(err, conn.logKey, "write", conn.baseConn.LocalAddr().String())
return num, err
// NewError(err, conn.logKey, "write", conn.baseConn.LocalAddr().String())
}
return num, err
}
@@ -141,7 +144,8 @@ func (conn *connection) WriteTo(buf []byte, raddr net.Addr) (num int, err error)
num, err = conn.baseConn.(net.PacketConn).WriteTo(buf, raddr)
}
if err != nil {
return num, NewError(err, conn.logKey, "writeTo", conn.baseConn.LocalAddr().String(), raddr.String())
return num, err
// NewError(err, conn.logKey, "writeTo", conn.baseConn.LocalAddr().String(), raddr.String())
}
// logrus.Tracef("writeTo %d , %s -> %s \n %s", num, conn.baseConn.LocalAddr(), raddr.String(), string(buf[:num]))
return num, err