mirror
/
av
mirror of https://bitbucket.org/ausocean/av.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

rtmp: removed debug prints

This commit is contained in:
saxon 2019-01-02 21:55:43 +10:30
parent cec95cd652
commit e340c9b9be
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
rtmp/socket.go
View File

@ -55,13 +55,10 @@ func C_RTMP_Connect(r *C_RTMP, cp *C_RTMPPacket) (ok bool) {
} }
addr, err := net.ResolveTCPAddr("tcp4", hostname) addr, err := net.ResolveTCPAddr("tcp4", hostname)
if err != nil { if err != nil {
fmt.Println(err)
fmt.Println("socket.go:58")
return false return false
} }
r.m_sb.conn, err = net.DialTCP("tcp4", nil, addr) r.m_sb.conn, err = net.DialTCP("tcp4", nil, addr)
if err != nil { if err != nil {
fmt.Println("socket.go:63")
return false return false
} }
if r.Link.socksport != 0 { if r.Link.socksport != 0 {
@ -109,7 +106,6 @@ func C_RTMPSockBuf_Fill(sb *C_RTMPSockBuf) int {
} }
err := sb.conn.SetReadDeadline(time.Now().Local().Add(time.Second * time.Duration(sb.timeout))) err := sb.conn.SetReadDeadline(time.Now().Local().Add(time.Second * time.Duration(sb.timeout)))
if err != nil { if err != nil {
fmt.Println("socket.go:111")
return -1 return -1
} }
n, err := sb.conn.Read(sb.sb_buf[sb.sb_start+sb.sb_size:]) n, err := sb.conn.Read(sb.sb_buf[sb.sb_start+sb.sb_size:])
@ -126,7 +122,6 @@ func C_RTMPSockBuf_Fill(sb *C_RTMPSockBuf) int {
func C_RTMPSockBuf_Send(sb *C_RTMPSockBuf, buf []byte) int32 { func C_RTMPSockBuf_Send(sb *C_RTMPSockBuf, buf []byte) int32 {
err := sb.conn.SetWriteDeadline(time.Now().Local().Add(time.Second * time.Duration(sb.timeout))) err := sb.conn.SetWriteDeadline(time.Now().Local().Add(time.Second * time.Duration(sb.timeout)))
if err != nil { if err != nil {
fmt.Println("socket.go:128")
return -1 return -1
} }
n, err := sb.conn.Write(buf) n, err := sb.conn.Write(buf)