Threads: TODO: Sort the packets, to avoid NACK

ossrs · Apr 26, 2021 · 1a0456a · 1a0456a
1 parent b11f958
commit 1a0456a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/trunk/src/app/srs_app_hybrid.cpp b/trunk/src/app/srs_app_hybrid.cpp
@@ -183,12 +183,6 @@ srs_error_t SrsHybridServer::initialize()
     // A monitor to check the clock wall deviation, per clock tick.
     timer_->subscribe(20 * SRS_UTIME_MILLISECONDS, clock_monitor_);
 
-    // Consume the async UDP/SRTP packets.
-    if ((err = _srs_thread_pool->consume()) != srs_success) {
-        return srs_error_wrap(err, "srtp");
-    }
-    }
-
     vector<ISrsHybridServer*>::iterator it;
     for (it = servers.begin(); it != servers.end(); ++it) {
         ISrsHybridServer* server = *it;

diff --git a/trunk/src/app/srs_app_threads.cpp b/trunk/src/app/srs_app_threads.cpp
@@ -1181,6 +1181,7 @@ srs_error_t SrsAsyncSRTPManager::consume(SrsThreadEntry* entry, int* nn_consumed
     // How many messages to run a yield.
     uint32_t nn_msgs_for_yield = 0;
 
+    // TODO: FIXME: Sort the packets, to avoid NACK.
     vector<SrsAsyncSRTPPacket*> flying_cooked_packets;
     entry->cooked_packets_->swap(flying_cooked_packets);