mirror of https://bitbucket.org/ausocean/av.git
Ported RTMP_SetBufferMS and tested
This commit is contained in:
parent
cba28550e2
commit
5938dcf0d5
|
@ -370,7 +370,7 @@ func startSession(rtmp *C.RTMP, u string, timeout uint32) (*C.RTMP, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
rtmpEnableWrite(rtmp)
|
rtmpEnableWrite(rtmp)
|
||||||
C.RTMP_SetBufferMS(rtmp, 3600*1000)
|
rtmpSetBufferMS(rtmp, 3600*1000)
|
||||||
if C.RTMP_Connect(rtmp, nil) == 0 {
|
if C.RTMP_Connect(rtmp, nil) == 0 {
|
||||||
//C.RTMP_Close(rtmp)
|
//C.RTMP_Close(rtmp)
|
||||||
//C.RTMP_Free(rtmp)
|
//C.RTMP_Free(rtmp)
|
||||||
|
@ -559,6 +559,10 @@ func rtmpEnableWrite(r *C.RTMP) {
|
||||||
r.Link.protocol |= RTMP_FEATURE_WRITE
|
r.Link.protocol |= RTMP_FEATURE_WRITE
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func rtmpSetBufferMS(r *C.RTMP, size int32) {
|
||||||
|
r.m_nBufferMS = C.int(size)
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
func socksSetup(r *RTMP, sockshost *AVal) {
|
func socksSetup(r *RTMP, sockshost *AVal) {
|
||||||
if sockshost.av_len != 0 {
|
if sockshost.av_len != 0 {
|
||||||
|
|
Loading…
Reference in New Issue