external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-02-12 11:21:52 +00:00
Code Issues Releases Wiki Activity

For #2311, Refine the update to update_auth

Browse source
This commit is contained in:
winlin 2021-05-12 21:26:04 +08:00
parent 71dda68f62
commit e076300cd8
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
trunk/src/app/srs_app_http_stream.cpp
View file

@ -75,7 +75,7 @@ SrsBufferCache::~SrsBufferCache()
srs_freep(req); srs_freep(req);
} }
srs_error_t SrsBufferCache::update(SrsSource* s, SrsRequest* r) srs_error_t SrsBufferCache::update_auth(SrsSource* s, SrsRequest* r)
{ {
srs_freep(req); srs_freep(req);
req = r->copy(); req = r->copy();
@ -523,7 +523,7 @@ SrsLiveStream::~SrsLiveStream()
srs_freep(req); srs_freep(req);
} }
srs_error_t SrsLiveStream::update(SrsSource* s, SrsRequest* r) srs_error_t SrsLiveStream::update_auth(SrsSource* s, SrsRequest* r)
{ {
source = s; source = s;
@ -940,8 +940,8 @@ srs_error_t SrsHttpStreamServer::http_mount(SrsSource* s, SrsRequest* r)
} else { } else {
// The entry exists, we reuse it and update the request of stream and cache. // The entry exists, we reuse it and update the request of stream and cache.
entry = sflvs[sid]; entry = sflvs[sid];
entry->stream->update(s, r); entry->stream->update_auth(s, r);
entry->cache->update(s, r); entry->cache->update_auth(s, r);
} }
if (entry->stream) { if (entry->stream) {

4
trunk/src/app/srs_app_http_stream.hpp
View file

@ -46,7 +46,7 @@ private:
public: public:
SrsBufferCache(SrsSource* s, SrsRequest* r); SrsBufferCache(SrsSource* s, SrsRequest* r);
virtual ~SrsBufferCache(); virtual ~SrsBufferCache();
virtual srs_error_t update(SrsSource* s, SrsRequest* r); virtual srs_error_t update_auth(SrsSource* s, SrsRequest* r);
public: public:
virtual srs_error_t start(); virtual srs_error_t start();
virtual srs_error_t dump_cache(SrsConsumer* consumer, SrsRtmpJitterAlgorithm jitter); virtual srs_error_t dump_cache(SrsConsumer* consumer, SrsRtmpJitterAlgorithm jitter);
@ -188,7 +188,7 @@ private:
public: public:
SrsLiveStream(SrsSource* s, SrsRequest* r, SrsBufferCache* c); SrsLiveStream(SrsSource* s, SrsRequest* r, SrsBufferCache* c);
virtual ~SrsLiveStream(); virtual ~SrsLiveStream();
virtual srs_error_t update(SrsSource* s, SrsRequest* r); virtual srs_error_t update_auth(SrsSource* s, SrsRequest* r);
public: public:
virtual srs_error_t serve_http(ISrsHttpResponseWriter* w, ISrsHttpMessage* r); virtual srs_error_t serve_http(ISrsHttpResponseWriter* w, ISrsHttpMessage* r);
private: private: