mirror of https://bitbucket.org/ausocean/av.git
Started porting sendPacket
This commit is contained in:
parent
8ab61598a9
commit
c3bd4b5e0b
14
rtmp/rtmp.go
14
rtmp/rtmp.go
|
@ -229,14 +229,20 @@ func rtmpWrite(r *C.RTMP, data []byte) int {
|
||||||
return size + s2
|
return size + s2
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
|
||||||
func sendPacket(r *C.RTMP, pkt *C.RTMPPacket, queue int) int {
|
func sendPacket(r *C.RTMP, pkt *C.RTMPPacket, queue int) int {
|
||||||
const prevPacket *C.RTMPPacket
|
const prevPacket *C.RTMPPacket
|
||||||
last := 0
|
last := 0
|
||||||
var nSize, hSize, cSize int
|
var nSize, hSize, cSize, nChunkSize, tlen int
|
||||||
var
|
var header, hptr, hend, buffer *C.char
|
||||||
|
var goHbuf [RTMP_MAX_HEADER_SIZE]byte
|
||||||
|
var hbuf = (*C.char)(unsafe.Pointer(&goHbuf[0]))
|
||||||
|
var c C.char
|
||||||
|
var t int32
|
||||||
|
var tbuf *C.char = nil
|
||||||
|
var toff *C.char = nil
|
||||||
}
|
}
|
||||||
*/
|
|
||||||
|
|
||||||
// Close terminates the rtmp connection
|
// Close terminates the rtmp connection
|
||||||
func (s *session) Close() error {
|
func (s *session) Close() error {
|
||||||
|
|
Loading…
Reference in New Issue