external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

RTC: Hook beofore publish event

Browse source
This commit is contained in:
winlin 2020-08-17 14:05:01 +08:00
parent d5e1116eb7
commit ecc5f73c54
2 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

6
trunk/src/app/srs_app_rtc_conn.cpp
View file

@ -3126,6 +3126,12 @@ srs_error_t SrsRtcConnection::create_publisher(SrsRequest* req, SrsRtcStreamDesc
} }
} }
if (_srs_rtc_hijacker) {
if ((err = _srs_rtc_hijacker->on_before_publish(this, publisher, req)) != srs_success) {
return srs_error_wrap(err, "on before publish");
}
}
// If DLTS done, start the publisher. Because maybe create some publishers after DTLS done. // If DLTS done, start the publisher. Because maybe create some publishers after DTLS done.
if(ESTABLISHED == state()) { if(ESTABLISHED == state()) {
if(srs_success != (err = publisher->start())) { if(srs_success != (err = publisher->start())) {

2
trunk/src/app/srs_app_rtc_conn.hpp
View file

@ -497,6 +497,8 @@ public:
public: public:
// Initialize the hijacker. // Initialize the hijacker.
virtual srs_error_t initialize() = 0; virtual srs_error_t initialize() = 0;
// When create publisher.
virtual srs_error_t on_before_publish(SrsRtcConnection* session, SrsRtcPublishStream* publisher, SrsRequest* req) = 0;
// When start publisher by RTC. // When start publisher by RTC.
virtual srs_error_t on_start_publish(SrsRtcConnection* session, SrsRtcPublishStream* publisher, SrsRequest* req) = 0; virtual srs_error_t on_start_publish(SrsRtcConnection* session, SrsRtcPublishStream* publisher, SrsRequest* req) = 0;
// When stop publish by RTC. // When stop publish by RTC.