csrc/worker/stream.cpp
@@ -30,8 +30,11 @@ std::lock_guard<std::mutex> locker(mutex_avpkt_); list_pkt_.push_back(pkt); while(list_pkt_.size() > max_size_/2*3){ CPacket &tmpkt = list_pkt_.front(); if (tmpkt.data->getAVPacket().flags & AV_PKT_FLAG_KEY){ break; } list_pkt_.pop_front(); }