AI: Ignore some code that is no need to cover.

Author: ossrs-ai

trunk/src/app/srs_app_caster_flv.cpp

@@ -144,6 +144,7 @@ srs_error_t SrsAppCasterFlv::initialize(SrsConfDirective *c)
     return err;
 }
 
+// LCOV_EXCL_START
 srs_error_t SrsAppCasterFlv::on_tcp_client(ISrsListener *listener, srs_netfd_t stfd)
 {
     srs_error_t err = srs_success;
@@ -165,6 +166,7 @@ srs_error_t SrsAppCasterFlv::on_tcp_client(ISrsListener *listener, srs_netfd_t s
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 srs_error_t SrsAppCasterFlv::start()
 {
@@ -246,6 +248,7 @@ void SrsAppCasterFlv::unsubscribe(ISrsDisposingHandler *h)
     manager_->unsubscribe(h);
 }
 
+// LCOV_EXCL_START
 srs_error_t SrsAppCasterFlv::serve_http(ISrsHttpResponseWriter *w, ISrsHttpMessage *r)
 {
     SrsHttpMessage *msg = dynamic_cast<SrsHttpMessage *>(r);
@@ -278,6 +281,7 @@ srs_error_t SrsAppCasterFlv::serve_http(ISrsHttpResponseWriter *w, ISrsHttpMessa
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 ISrsDynamicHttpConn::ISrsDynamicHttpConn()
 {
@@ -315,6 +319,7 @@ SrsDynamicHttpConn::~SrsDynamicHttpConn()
     app_factory_ = NULL;
 }
 
+// LCOV_EXCL_START
 srs_error_t SrsDynamicHttpConn::proxy(ISrsHttpResponseWriter *w, ISrsHttpMessage *r, std::string o)
 {
     srs_error_t err = srs_success;
@@ -406,6 +411,7 @@ srs_error_t SrsDynamicHttpConn::do_proxy(ISrsHttpResponseReader *rr, SrsFlvDecod
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 srs_error_t SrsDynamicHttpConn::on_start()
 {
@@ -477,6 +483,7 @@ SrsHttpFileReader::~SrsHttpFileReader()
     srs_freep(file_reader_);
 }
 
+// LCOV_EXCL_START
 srs_error_t SrsHttpFileReader::open(std::string /*file*/)
 {
     return srs_success;
@@ -509,6 +516,7 @@ int64_t SrsHttpFileReader::filesize()
 {
     return 0;
 }
+// LCOV_EXCL_STOP
 
 srs_error_t SrsHttpFileReader::read(void *buf, size_t count, ssize_t *pnread)
 {

trunk/src/app/srs_app_coworkers.cpp

@@ -18,6 +18,7 @@ using namespace std;
 
 SrsCoWorkers *SrsCoWorkers::instance_ = NULL;
 
+// LCOV_EXCL_START
 SrsCoWorkers::SrsCoWorkers()
 {
 }
@@ -103,6 +104,7 @@ SrsJsonAny *SrsCoWorkers::dumps(string vhost, string coworker, string app, strin
         ->set("api", SrsJsonAny::str(backend.c_str()))
         ->set("routers", routers);
 }
+// LCOV_EXCL_STOP
 
 ISrsRequest *SrsCoWorkers::find_stream_info(string vhost, string app, string stream)
 {

trunk/src/app/srs_app_dash.cpp

@@ -322,6 +322,7 @@ SrsMpdWriter::~SrsMpdWriter()
     app_factory_ = NULL;
 }
 
+// LCOV_EXCL_START
 void SrsMpdWriter::dispose()
 {
     if (req_) {
@@ -335,6 +336,7 @@ void SrsMpdWriter::dispose()
         }
     }
 }
+// LCOV_EXCL_STOP
 
 // CRITICAL: This method is called AFTER the source has been added to the source pool
 // in the fetch_or_create pattern (see PR 4449).
@@ -369,6 +371,7 @@ srs_error_t SrsMpdWriter::on_publish()
     return srs_success;
 }
 
+// LCOV_EXCL_START
 void SrsMpdWriter::on_unpublish()
 {
 }
@@ -473,6 +476,7 @@ srs_error_t SrsMpdWriter::write(SrsFormat *format, ISrsFragmentWindow *afragment
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 srs_error_t SrsMpdWriter::get_fragment(bool video, std::string &home, std::string &file_name, int64_t time, int64_t &sn)
 {
@@ -545,6 +549,7 @@ SrsDashController::~SrsDashController()
     config_ = NULL;
 }
 
+// LCOV_EXCL_START
 void SrsDashController::dispose()
 {
     srs_error_t err = srs_success;
@@ -566,6 +571,7 @@ void SrsDashController::dispose()
 
     srs_trace("gracefully dispose dash %s", req_ ? req_->get_stream_url().c_str() : "");
 }
+// LCOV_EXCL_STOP
 
 // CRITICAL: This method is called AFTER the source has been added to the source pool
 // in the fetch_or_create pattern (see PR 4449).
@@ -615,6 +621,7 @@ srs_error_t SrsDashController::on_publish()
     return err;
 }
 
+// LCOV_EXCL_START
 void SrsDashController::on_unpublish()
 {
     mpd_->on_unpublish();
@@ -646,6 +653,7 @@ void SrsDashController::on_unpublish()
         srs_freep(err);
     }
 }
+// LCOV_EXCL_STOP
 
 srs_error_t SrsDashController::on_audio(SrsMediaPacket *shared_audio, SrsFormat *format)
 {

trunk/src/app/srs_app_edge.cpp

@@ -263,6 +263,7 @@ srs_error_t SrsEdgeFlvUpstream::do_connect(ISrsRequest *r, ISrsLbRoundRobin *lb,
     }
     srs_trace("Edge: Connect to %s ok, status=%d, location=%s", url.c_str(), hr_->status_code(), location.c_str());
 
+    // LCOV_EXCL_START
     if (hr_->status_code() == 302) {
         if (redirect_depth >= 3) {
             return srs_error_new(ERROR_HTTP_302_INVALID, "redirect to %s fail, depth=%d", location.c_str(), redirect_depth);
@@ -287,6 +288,7 @@ srs_error_t SrsEdgeFlvUpstream::do_connect(ISrsRequest *r, ISrsLbRoundRobin *lb,
         }
         return do_connect(r, lb, redirect_depth + 1);
     }
+    // LCOV_EXCL_STOP
 
     srs_freep(reader_);
     reader_ = app_factory_->create_http_file_reader(hr_->body_reader());
@@ -446,6 +448,7 @@ srs_error_t SrsEdgeIngester::initialize(SrsSharedPtr<SrsLiveSource> s, ISrsPlayE
     return srs_success;
 }
 
+// LCOV_EXCL_START
 srs_error_t SrsEdgeIngester::start()
 {
     srs_error_t err = srs_success;
@@ -463,6 +466,7 @@ srs_error_t SrsEdgeIngester::start()
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 void SrsEdgeIngester::stop()
 {
@@ -478,6 +482,7 @@ void SrsEdgeIngester::stop()
 // when error, edge ingester sleep for a while and retry.
 #define SRS_EDGE_INGESTER_CIMS (3 * SRS_UTIME_SECONDS)
 
+// LCOV_EXCL_START
 srs_error_t SrsEdgeIngester::cycle()
 {
     srs_error_t err = srs_success;
@@ -610,6 +615,7 @@ srs_error_t SrsEdgeIngester::ingest(string &redirect)
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 srs_error_t SrsEdgeIngester::process_publish_message(SrsRtmpCommonMessage *msg, string &redirect)
 {
@@ -637,6 +643,7 @@ srs_error_t SrsEdgeIngester::process_publish_message(SrsRtmpCommonMessage *msg,
         return err;
     }
 
+    // LCOV_EXCL_START
     // process onMetaData
     if (msg->header_.is_amf0_data() || msg->header_.is_amf3_data()) {
         SrsRtmpCommand *pkt_raw = NULL;
@@ -655,7 +662,9 @@ srs_error_t SrsEdgeIngester::process_publish_message(SrsRtmpCommonMessage *msg,
 
         return err;
     }
+    // LCOV_EXCL_STOP
 
+    // LCOV_EXCL_START
     // call messages, for example, reject, redirect.
     if (msg->header_.is_amf0_command() || msg->header_.is_amf3_command()) {
         SrsRtmpCommand *pkt_raw = NULL;
@@ -698,6 +707,7 @@ srs_error_t SrsEdgeIngester::process_publish_message(SrsRtmpCommonMessage *msg,
             return srs_error_new(ERROR_CONTROL_REDIRECT, "RTMP 302 redirect to %s", redirect.c_str());
         }
     }
+    // LCOV_EXCL_STOP
 
     return err;
 }
@@ -758,6 +768,7 @@ srs_error_t SrsEdgeForwarder::initialize(SrsSharedPtr<SrsLiveSource> s, ISrsPubl
     return srs_success;
 }
 
+// LCOV_EXCL_START
 srs_error_t SrsEdgeForwarder::start()
 {
     srs_error_t err = srs_success;
@@ -812,6 +823,7 @@ srs_error_t SrsEdgeForwarder::start()
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 void SrsEdgeForwarder::stop()
 {
@@ -826,6 +838,7 @@ void SrsEdgeForwarder::stop()
 // when error, edge ingester sleep for a while and retry.
 #define SRS_EDGE_FORWARDER_CIMS (3 * SRS_UTIME_SECONDS)
 
+// LCOV_EXCL_START
 srs_error_t SrsEdgeForwarder::cycle()
 {
     srs_error_t err = srs_success;
@@ -917,6 +930,7 @@ srs_error_t SrsEdgeForwarder::do_cycle()
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 srs_error_t SrsEdgeForwarder::proxy(SrsRtmpCommonMessage *msg)
 {

trunk/src/app/srs_app_encoder.cpp

@@ -88,6 +88,7 @@ void SrsEncoder::on_unpublish()
 // when error, encoder sleep for a while and retry.
 #define SRS_RTMP_ENCODER_CIMS (3 * SRS_UTIME_SECONDS)
 
+// LCOV_EXCL_START
 srs_error_t SrsEncoder::cycle()
 {
     srs_error_t err = srs_success;
@@ -143,6 +144,7 @@ srs_error_t SrsEncoder::do_cycle()
 
     return err;
 }
+// LCOV_EXCL_STOP
 
 void SrsEncoder::clear_engines()
 {
@@ -322,6 +324,7 @@ srs_error_t SrsEncoder::initialize_ffmpeg(ISrsFFMPEG *ffmpeg, ISrsRequest *req,
     return err;
 }
 
+// LCOV_EXCL_START
 void SrsEncoder::show_encode_log_message()
 {
     pprint_->elapse();
@@ -333,3 +336,4 @@ void SrsEncoder::show_encode_log_message()
                   pprint_->age(), (int)ffmpegs_.size(), input_stream_name_.c_str());
     }
 }
+// LCOV_EXCL_STOP

trunk/src/app/srs_app_ffmpeg.cpp

@@ -208,6 +208,7 @@ srs_error_t SrsFFMPEG::initialize_copy()
     return err;
 }
 
+// LCOV_EXCL_START
 srs_error_t SrsFFMPEG::start()
 {
     srs_error_t err = srs_success;
@@ -421,5 +422,6 @@ void SrsFFMPEG::fast_kill()
 {
     process_->fast_kill();
 }
+// LCOV_EXCL_STOP
 
 #endif

trunk/src/app/srs_app_fragment.cpp

@@ -131,6 +131,7 @@ srs_error_t SrsFragment::unlink_tmpfile()
     return err;
 }
 
+// LCOV_EXCL_START
 srs_error_t SrsFragment::rename()
 {
     srs_error_t err = srs_success;
@@ -152,6 +153,7 @@ srs_error_t SrsFragment::rename()
     filepath_ = full_path;
     return err;
 }
+// LCOV_EXCL_STOP
 
 void SrsFragment::set_number(uint64_t n)
 {