started porting rtmpWrite func

This commit is contained in:
Saxon Milton 2018-06-28 03:32:16 +09:30
parent 6b4ece57e5
commit 9d186f51bb
1 changed files with 6 additions and 1 deletions

View File

@ -86,11 +86,16 @@ func (s *session) Open() error {
return nil
}
func (s *session) rtmpWrite(rtmp *C.RTMP, data []byte, dataLength uint ) bool {
}
func (s *session) writeFrame(data []byte, dataLength uint) uint {
if !C.RTMP_IsConnected(rtmp) {
return 1
}
if !C.RTMP_Write(s.rtmp, (const char*)(*C.char)(unsafe.Pointer(&data[0])), C.uint(dataLength)) {
// !C.RTMP_Write(s.rtmp, (const char*)(*C.char)(unsafe.Pointer(&data[0])), C.uint(dataLength))
if rtmpWrite(s.rtmp, data, dataLength) {
return 2
}
return 0