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

Added some test cases for helper functions

This commit is contained in:
saxon 2018-07-20 17:40:37 +09:30
parent cf8568bf40
commit 1d1ff01681
1 changed files with 3 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
rtmp/rtmp.go
View File

@ -991,13 +991,8 @@ func writeN(r *C.RTMP, buffer unsafe.Pointer, n int) int {
for n > 0 { for n > 0 {
var nBytes int var nBytes int
if (r.Link.protocol & RTMP_FEATURE_HTTP) != 0 {
// TODO: port HTTP_POST
nBytes = httpPost(r, RTMPT_SEND, (*byte)(ptr), n)
} else {
// TODO: port this if necessary // TODO: port this if necessary
nBytes = int(sockBufSend(&r.m_sb, (*byte)(ptr), int32(n))) nBytes = int(sockBufSend(&r.m_sb, (*byte)(ptr), int32(n)))
}
if nBytes < 0 { if nBytes < 0 {
if debugMode { if debugMode {
@ -1033,31 +1028,6 @@ var RTMPT_cmds = []string{
"close", "close",
} }
func httpPost(r *C.RTMP, cmd C.RTMPTCmd, buf *byte, l int) int {
res := ""
if r.m_clientID.av_val != nil {
res = string(ptrToSlice(unsafe.Pointer(r.m_clientID.av_val),
int(r.m_clientID.av_len)))
}
fString := fmt.Sprintf("POST /%s%s/%d HTTP/1.1\r\n"+
"Host: %v:%d\r\n"+
"Accept: */*\r\n"+
"User-Agent: Shockwave Flash\r\n"+
"Connection: Keep-Alive\r\n"+
"Cache-Control: no-cache\r\n"+
"Content-type: application/x-fcs\r\n"+
"Content-length: %d\r\n\r\n", RTMPT_cmds[cmd], res, r.m_msgCounter,
r.Link.hostname.av_len, r.Link.hostname.av_val, r.Link.port, l)
hlen := len(fString)
hbuf := (*byte)(unsafe.Pointer(&(([]byte(fString))[0])))
// TODO: port this
sockBufSend(&r.m_sb, (*byte)(unsafe.Pointer(hbuf)), int32(hlen))
hlen = int(sockBufSend(&r.m_sb, (*byte)(unsafe.Pointer(buf)), int32(l)))
r.m_msgCounter++
r.m_unackd++
return hlen
}
func sockBufSend(sb *C.RTMPSockBuf, buf *byte, l int32) int32 { func sockBufSend(sb *C.RTMPSockBuf, buf *byte, l int32) int32 {
return int32(C.send(sb.sb_socket, unsafe.Pointer(buf), C.size_t(l), 0)) return int32(C.send(sb.sb_socket, unsafe.Pointer(buf), C.size_t(l), 0))
} }
@ -1091,7 +1061,7 @@ func sToUP(b []byte) unsafe.Pointer {
return unsafe.Pointer(&b[0]) return unsafe.Pointer(&b[0])
} }
// Creates a new C string from a go string // Creates a new C style string from a go string
func goStrToCStr(str string) *byte { func goStrToCStr(str string) *byte {
l := len(str) l := len(str)
slice := make([]byte, l+1) slice := make([]byte, l+1)