apps/lkm
1
0
Fork 0
mirror of https://github.com/lkmio/lkm.git synced 2025-10-04 14:52:44 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

rtmp推拉流回调结果, 不再使用管道传递

Browse Source
This commit is contained in:
yangjiechina
2024-08-11 13:09:53 +08:00
parent efded1d4db
commit e19a8708bd
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
rtmp/rtmp_session.go
View File

@@ -28,7 +28,7 @@ func (s *Session) generateSourceId(app, stream_ string) string {
} }
} }
func (s *Session) OnPublish(app, stream_ string, response chan utils.HookState) { func (s *Session) OnPublish(app, stream_ string) utils.HookState {
log.Sugar.Infof("rtmp onpublish app:%s stream:%s conn:%s", app, stream_, s.conn.RemoteAddr().String()) log.Sugar.Infof("rtmp onpublish app:%s stream:%s conn:%s", app, stream_, s.conn.RemoteAddr().String())
streamName, values := stream.ParseUrl(stream_) streamName, values := stream.ParseUrl(stream_)
@@ -54,10 +54,10 @@ func (s *Session) OnPublish(app, stream_ string, response chan utils.HookState)
go source.LoopEvent() go source.LoopEvent()
} }
response <- state return state
} }
func (s *Session) OnPlay(app, stream_ string, response chan utils.HookState) { func (s *Session) OnPlay(app, stream_ string) utils.HookState {
streamName, values := stream.ParseUrl(stream_) streamName, values := stream.ParseUrl(stream_)
sourceId := s.generateSourceId(app, streamName) sourceId := s.generateSourceId(app, streamName)
@@ -73,7 +73,7 @@ func (s *Session) OnPlay(app, stream_ string, response chan utils.HookState) {
s.handle = sink s.handle = sink
} }
response <- state return state
} }
func (s *Session) Input(conn net.Conn, data []byte) error { func (s *Session) Input(conn net.Conn, data []byte) error {