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

rtmp: clean up C_SocksNegotiate

This commit is contained in:
Dan Kortschak 2018-09-19 11:25:52 +09:30
parent d1f870223c
commit 5f3f50373b
1 changed files with 20 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
rtmp/rtmp.go
View File

@ -455,35 +455,30 @@ func C_SocksNegotiate(r *C_RTMP) (ok bool) {
var addr int32 var addr int32
var service C.sockaddr_in var service C.sockaddr_in
memset((*byte)(unsafe.Pointer(&service)), 0, int(unsafe.Sizeof(service)))
C_add_addr_info(&service, r.Link.hostname, r.Link.port) C_add_addr_info(&service, r.Link.hostname, r.Link.port)
addr = int32(inet.Htonl(uint32(service.sin_addr.s_addr))) addr = int32(inet.Htonl(uint32(service.sin_addr.s_addr)))
{ packet := []byte{
packet := []byte{ 4, 1,
4, 1, byte((r.Link.port >> 8) & 0xFF),
byte((r.Link.port >> 8) & 0xFF), byte((r.Link.port) & 0xFF),
byte((r.Link.port) & 0xFF), byte(addr>>24) & 0xFF, byte(addr>>16) & 0xFF,
byte(addr>>24) & 0xFF, byte(addr>>16) & 0xFF, byte(addr>>8) & 0xFF, byte(addr) & 0xFF,
byte(addr>>8) & 0xFF, byte(addr) & 0xFF, 0,
0,
}
C_WriteN(r, packet)
if C_ReadN(r, &packet[0], 8) != 8 {
return false
}
if packet[0] == 0 && packet[1] == 90 {
return true
} else {
// TODO: use new logger here
log.Println("C_SocksNegotitate: SOCKS returned error code!")
return false
}
} }
C_WriteN(r, packet)
if C_ReadN(r, &packet[0], 8) != 8 {
return false
}
if packet[0] == 0 && packet[1] == 90 {
return true
}
// TODO: use new logger here
log.Println("C_SocksNegotitate: SOCKS returned error code!")
return false
} }
// int RTMP_ConnectStream(RTMP* r, int seekTime); // int RTMP_ConnectStream(RTMP* r, int seekTime);