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

Finished writing httpPost - need to build and test

This commit is contained in:
saxon 2018-07-18 12:21:31 +09:30
parent f7c9719d5b
commit 2dd7b344f8
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
rtmp/rtmp.go
View File

@ -52,7 +52,7 @@ import "C"
import (
"errors"
_ "fmt"
"fmt"
"log"
"math"
"reflect"
@ -605,6 +605,29 @@ func writeN(r *C.RTMP, buffer unsafe.Pointer, n int) int {
return 0
}
func httpPost(r *C.RTMP, cmd RTMPTCmd, buf *byte, len int) int {
length := 512
var hbuf [length]byte
fString := fmt.Sprintf("POST /%s%s/%d HTTP/1.1\r\n"
"Host: %.*s:%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],
r->m_clientID.av_val ? r->m_clientID.av_val : "",
r->m_msgCounter, r->Link.hostname.av_len, r->Link.hostname.av_val,
r->Link.port, len)
hlen := len(fString)
hbuf = (*byte)(unsafe.Pointer(&(([]byte{fString})[0])))
// TODO: port this
C.RTMPSockBuf_Send(&r.m_sb, (*C.char)(hbuf), hlen)
hlen = c.RTMPSockBuf_Send(&r.m_sb, buf, len)
r.m_msgCounter++
r.m_unackd++
return hlen
}
// TODO: port RTMP_METHOD
func avQueue(vals **C.RTMP_METHOD, num *int, av *C.AVal, txn int ) {