github-forks
/
lal
mirror of https://github.com/q191201771/lal.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

comment

Browse Source
pull/358/head
q191201771 7 months ago
parent f31e75b52f
commit 592dc3e2e8
5 changed files with 75 additions and 19 deletions
Show Stats Download Patch File Download Diff File

10
pkg/httpflv/client_pull_session.go
Unescape Escape View File

@ -106,6 +106,8 @@ func (session *PullSession) WaitChan() <-chan error {
return session.conn.Done() return session.conn.Done()
} }
// ---------------------------------------------------------------------------------------------------------------------
// ISessionUrlContext interface
// --------------------------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// Url 文档请参考： interface ISessionUrlContext // Url 文档请参考： interface ISessionUrlContext
@ -128,12 +130,18 @@ func (session *PullSession) RawQuery() string {
return session.urlCtx.RawQuery return session.urlCtx.RawQuery
} }
// ---------------------------------------------------------------------------------------------------------------------
// IObject interface
// ---------------------------------------------------------------------------------------------------------------------
// UniqueKey 文档请参考： interface IObject // UniqueKey 文档请参考： interface IObject
func (session *PullSession) UniqueKey() string { func (session *PullSession) UniqueKey() string {
return session.sessionStat.UniqueKey() return session.sessionStat.UniqueKey()
} }
// ----- ISessionStat -------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// ISessionStat interface
// ---------------------------------------------------------------------------------------------------------------------
// UpdateStat 文档请参考： interface ISessionStat // UpdateStat 文档请参考： interface ISessionStat
func (session *PullSession) UpdateStat(intervalSec uint32) { func (session *PullSession) UpdateStat(intervalSec uint32) {

10
pkg/rtmp/client_pull_session.go
Unescape Escape View File

@ -115,6 +115,8 @@ func (s *PullSession) WaitChan() <-chan error {
return s.core.WaitChan() return s.core.WaitChan()
} }
// ---------------------------------------------------------------------------------------------------------------------
// ISessionUrlContext interface
// --------------------------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// Url 文档请参考： interface ISessionUrlContext // Url 文档请参考： interface ISessionUrlContext
@ -137,12 +139,18 @@ func (s *PullSession) RawQuery() string {
return s.core.RawQuery() return s.core.RawQuery()
} }
// ---------------------------------------------------------------------------------------------------------------------
// IObject interface
// ---------------------------------------------------------------------------------------------------------------------
// UniqueKey 文档请参考： interface IObject // UniqueKey 文档请参考： interface IObject
func (s *PullSession) UniqueKey() string { func (s *PullSession) UniqueKey() string {
return s.core.UniqueKey() return s.core.UniqueKey()
} }
// ----- ISessionStat -------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// ISessionStat interface
// ---------------------------------------------------------------------------------------------------------------------
// GetStat 文档请参考： interface ISessionStat // GetStat 文档请参考： interface ISessionStat
func (s *PullSession) GetStat() base.StatSession { func (s *PullSession) GetStat() base.StatSession {

10
pkg/rtmp/client_push_session.go
Unescape Escape View File

@ -109,6 +109,8 @@ func (s *PushSession) WaitChan() <-chan error {
return s.core.WaitChan() return s.core.WaitChan()
} }
// ---------------------------------------------------------------------------------------------------------------------
// ISessionUrlContext interface
// --------------------------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// Url 文档请参考： interface ISessionUrlContext // Url 文档请参考： interface ISessionUrlContext
@ -131,12 +133,18 @@ func (s *PushSession) RawQuery() string {
return s.core.RawQuery() return s.core.RawQuery()
} }
// ---------------------------------------------------------------------------------------------------------------------
// IObject interface
// ---------------------------------------------------------------------------------------------------------------------
// UniqueKey 文档请参考： interface IObject // UniqueKey 文档请参考： interface IObject
func (s *PushSession) UniqueKey() string { func (s *PushSession) UniqueKey() string {
return s.core.UniqueKey() return s.core.UniqueKey()
} }
// ----- ISessionStat -------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// ISessionStat interface
// ---------------------------------------------------------------------------------------------------------------------
// GetStat 文档请参考： interface ISessionStat // GetStat 文档请参考： interface ISessionStat
func (s *PushSession) GetStat() base.StatSession { func (s *PushSession) GetStat() base.StatSession {

32
pkg/rtsp/client_pull_session.go
Unescape Escape View File

@ -145,6 +145,8 @@ func (session *PullSession) WaitChan() <-chan error {
return session.waitChan return session.waitChan
} }
// ---------------------------------------------------------------------------------------------------------------------
// ISessionUrlContext interface
// --------------------------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// Url 文档请参考： interface ISessionUrlContext // Url 文档请参考： interface ISessionUrlContext
@ -167,12 +169,18 @@ func (session *PullSession) RawQuery() string {
return session.cmdSession.RawQuery() return session.cmdSession.RawQuery()
} }
// ---------------------------------------------------------------------------------------------------------------------
// IObject interface
// ---------------------------------------------------------------------------------------------------------------------
// UniqueKey 文档请参考： interface IObject // UniqueKey 文档请参考： interface IObject
func (session *PullSession) UniqueKey() string { func (session *PullSession) UniqueKey() string {
return session.baseInSession.UniqueKey() return session.baseInSession.UniqueKey()
} }
// ----- ISessionStat -------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// ISessionStat interface
// ---------------------------------------------------------------------------------------------------------------------
// GetStat 文档请参考： interface ISessionStat // GetStat 文档请参考： interface ISessionStat
func (session *PullSession) GetStat() base.StatSession { func (session *PullSession) GetStat() base.StatSession {
@ -191,44 +199,52 @@ func (session *PullSession) IsAlive() (readAlive, writeAlive bool) {
return session.baseInSession.IsAlive() return session.baseInSession.IsAlive()
} }
// ---------------------------------------------------------------------------------------------------------------------
// IClientCommandSessionObserver interface
// --------------------------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// OnConnectResult IClientCommandSessionObserver, callback by ClientCommandSession // OnConnectResult callback by ClientCommandSession
func (session *PullSession) OnConnectResult() { func (session *PullSession) OnConnectResult() {
// noop // noop
} }
// OnDescribeResponse IClientCommandSessionObserver, callback by ClientCommandSession // OnDescribeResponse callback by ClientCommandSession
func (session *PullSession) OnDescribeResponse(sdpCtx sdp.LogicContext) { func (session *PullSession) OnDescribeResponse(sdpCtx sdp.LogicContext) {
session.onDescribeResponse() session.onDescribeResponse()
session.baseInSession.InitWithSdp(sdpCtx) session.baseInSession.InitWithSdp(sdpCtx)
} }
// OnSetupWithConn IClientCommandSessionObserver, callback by ClientCommandSession // OnSetupWithConn callback by ClientCommandSession
func (session *PullSession) OnSetupWithConn(uri string, rtpConn, rtcpConn *nazanet.UdpConnection) { func (session *PullSession) OnSetupWithConn(uri string, rtpConn, rtcpConn *nazanet.UdpConnection) {
_ = session.baseInSession.SetupWithConn(uri, rtpConn, rtcpConn) _ = session.baseInSession.SetupWithConn(uri, rtpConn, rtcpConn)
} }
// OnSetupWithChannel IClientCommandSessionObserver, callback by ClientCommandSession // OnSetupWithChannel callback by ClientCommandSession
func (session *PullSession) OnSetupWithChannel(uri string, rtpChannel, rtcpChannel int) { func (session *PullSession) OnSetupWithChannel(uri string, rtpChannel, rtcpChannel int) {
_ = session.baseInSession.SetupWithChannel(uri, rtpChannel, rtcpChannel) _ = session.baseInSession.SetupWithChannel(uri, rtpChannel, rtcpChannel)
} }
// OnSetupResult IClientCommandSessionObserver, callback by ClientCommandSession // OnSetupResult callback by ClientCommandSession
func (session *PullSession) OnSetupResult() { func (session *PullSession) OnSetupResult() {
session.baseInSession.WriteRtpRtcpDummy() session.baseInSession.WriteRtpRtcpDummy()
} }
// OnInterleavedPacket IClientCommandSessionObserver, callback by ClientCommandSession // OnInterleavedPacket callback by ClientCommandSession
func (session *PullSession) OnInterleavedPacket(packet []byte, channel int) { func (session *PullSession) OnInterleavedPacket(packet []byte, channel int) {
session.baseInSession.HandleInterleavedPacket(packet, channel) session.baseInSession.HandleInterleavedPacket(packet, channel)
} }
// WriteInterleavedPacket IInterleavedPacketWriter, callback by BaseInSession // ---------------------------------------------------------------------------------------------------------------------
// IInterleavedPacketWriter interface
// ---------------------------------------------------------------------------------------------------------------------
// WriteInterleavedPacket callback by BaseInSession
func (session *PullSession) WriteInterleavedPacket(packet []byte, channel int) error { func (session *PullSession) WriteInterleavedPacket(packet []byte, channel int) error {
return session.cmdSession.WriteInterleavedPacket(packet, channel) return session.cmdSession.WriteInterleavedPacket(packet, channel)
} }
// ---------------------------------------------------------------------------------------------------------------------
func (session *PullSession) dispose(err error) error { func (session *PullSession) dispose(err error) error {
var retErr error var retErr error
session.disposeOnce.Do(func() { session.disposeOnce.Do(func() {

32
pkg/rtsp/client_push_session.go
Unescape Escape View File

@ -128,6 +128,8 @@ func (session *PushSession) WaitChan() <-chan error {
return session.waitChan return session.waitChan
} }
// ---------------------------------------------------------------------------------------------------------------------
// ISessionUrlContext interface
// --------------------------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// Url 文档请参考： interface ISessionUrlContext // Url 文档请参考： interface ISessionUrlContext
@ -150,12 +152,18 @@ func (session *PushSession) RawQuery() string {
return session.cmdSession.RawQuery() return session.cmdSession.RawQuery()
} }
// ---------------------------------------------------------------------------------------------------------------------
// ISessionUrlContext IObject
// ---------------------------------------------------------------------------------------------------------------------
// UniqueKey 文档请参考： interface IObject // UniqueKey 文档请参考： interface IObject
func (session *PushSession) UniqueKey() string { func (session *PushSession) UniqueKey() string {
return session.baseOutSession.UniqueKey() return session.baseOutSession.UniqueKey()
} }
// ----- ISessionStat -------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// ISessionStat IObject
// ---------------------------------------------------------------------------------------------------------------------
// GetStat 文档请参考： interface ISessionStat // GetStat 文档请参考： interface ISessionStat
func (session *PushSession) GetStat() base.StatSession { func (session *PushSession) GetStat() base.StatSession {
@ -174,43 +182,51 @@ func (session *PushSession) IsAlive() (readAlive, writeAlive bool) {
return session.baseOutSession.IsAlive() return session.baseOutSession.IsAlive()
} }
// ---------------------------------------------------------------------------------------------------------------------
// ISessionStat IClientCommandSessionObserver
// --------------------------------------------------------------------------------------------------------------------- // ---------------------------------------------------------------------------------------------------------------------
// OnConnectResult IClientCommandSessionObserver, callback by ClientCommandSession // OnConnectResult callback by ClientCommandSession
func (session *PushSession) OnConnectResult() { func (session *PushSession) OnConnectResult() {
// noop // noop
} }
// OnDescribeResponse IClientCommandSessionObserver, callback by ClientCommandSession // OnDescribeResponse callback by ClientCommandSession
func (session *PushSession) OnDescribeResponse(sdpCtx sdp.LogicContext) { func (session *PushSession) OnDescribeResponse(sdpCtx sdp.LogicContext) {
// noop // noop
} }
// OnSetupWithConn IClientCommandSessionObserver, callback by ClientCommandSession // OnSetupWithConn callback by ClientCommandSession
func (session *PushSession) OnSetupWithConn(uri string, rtpConn, rtcpConn *nazanet.UdpConnection) { func (session *PushSession) OnSetupWithConn(uri string, rtpConn, rtcpConn *nazanet.UdpConnection) {
_ = session.baseOutSession.SetupWithConn(uri, rtpConn, rtcpConn) _ = session.baseOutSession.SetupWithConn(uri, rtpConn, rtcpConn)
} }
// OnSetupWithChannel IClientCommandSessionObserver, callback by ClientCommandSession // OnSetupWithChannel callback by ClientCommandSession
func (session *PushSession) OnSetupWithChannel(uri string, rtpChannel, rtcpChannel int) { func (session *PushSession) OnSetupWithChannel(uri string, rtpChannel, rtcpChannel int) {
_ = session.baseOutSession.SetupWithChannel(uri, rtpChannel, rtcpChannel) _ = session.baseOutSession.SetupWithChannel(uri, rtpChannel, rtcpChannel)
} }
// OnSetupResult IClientCommandSessionObserver, callback by ClientCommandSession // OnSetupResult callback by ClientCommandSession
func (session *PushSession) OnSetupResult() { func (session *PushSession) OnSetupResult() {
// noop // noop
} }
// OnInterleavedPacket IClientCommandSessionObserver, callback by ClientCommandSession // OnInterleavedPacket callback by ClientCommandSession
func (session *PushSession) OnInterleavedPacket(packet []byte, channel int) { func (session *PushSession) OnInterleavedPacket(packet []byte, channel int) {
session.baseOutSession.HandleInterleavedPacket(packet, channel) session.baseOutSession.HandleInterleavedPacket(packet, channel)
} }
// WriteInterleavedPacket IInterleavedPacketWriter, callback by BaseOutSession // ---------------------------------------------------------------------------------------------------------------------
// ISessionStat IInterleavedPacketWriter
// ---------------------------------------------------------------------------------------------------------------------
// WriteInterleavedPacket callback by BaseOutSession
func (session *PushSession) WriteInterleavedPacket(packet []byte, channel int) error { func (session *PushSession) WriteInterleavedPacket(packet []byte, channel int) error {
return session.cmdSession.WriteInterleavedPacket(packet, channel) return session.cmdSession.WriteInterleavedPacket(packet, channel)
} }
// ---------------------------------------------------------------------------------------------------------------------
func (session *PushSession) dispose(err error) error { func (session *PushSession) dispose(err error) error {
var retErr error var retErr error
session.disposeOnce.Do(func() { session.disposeOnce.Do(func() {

Write Preview
Loading…
Cancel
Save