| | |
| | | #include <zconf.h> |
| | | #include <opencv2/opencv.hpp> |
| | | #include "FFmpegDecoderJPG.h" |
| | | #include <cstring> |
| | | |
| | | void BASICGB28181::initFFmpeg() { |
| | | av_register_all(); |
| | |
| | | dst.data, dst.linesize); |
| | | sws_freeContext(convert_ctx); |
| | | |
| | | DBG("m.size is " << m.size()); |
| | | // DBG("m.size is " << m.size()); |
| | | // LOG_IF(); |
| | | |
| | | return m; |
| | |
| | | } |
| | | |
| | | BASICGB28181::FFmpegDecoderJPG::~FFmpegDecoderJPG() { |
| | | //清空队列 |
| | | while (m_rtpQueue.count_queue()) { |
| | | //#todo delete frameBuffInfo* |
| | | m_rtpQueue.popNotWait(); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | #ifdef TestCode |
| | | DBG(" m_rtpQueue.push before "); |
| | | DBG(" m_rtpQueue.push befores "); |
| | | #endif |
| | | m_rtpQueue. |
| | | push(info); |
| | | m_rtpQueue.push(info); |
| | | #ifdef TestCode |
| | | DBG(" m_rtpQueue.push after "); |
| | | #endif |
| | |
| | | do { |
| | | |
| | | // DBG(" m_rtpQueue.pop before "); |
| | | //从缓存中获取buffinfo |
| | | frameBuffInfo *buffinfo = fFmpegDecoderJPG->m_rtpQueue.pop(); |
| | | // DBG(" m_rtpQueue.pop after "); |
| | | diff = len - buffinfo->buffLen; |
| | | // printf("bufsize is :%ld,len is :%ld, datalen:%d \n", bufsize, len, buffinfo->buffLen); |
| | | |
| | | //帧长大于bufsize |
| | | if (diff < 0) { |
| | | // DBG("/帧长大于bufsize" << diff); |
| | |
| | | delete[] buffinfo->buff; |
| | | delete buffinfo; |
| | | } while (diff > 0); |
| | | //#todo 触发信号 |
| | | |
| | | // DBG("emitSigal(\"read_dataOk\") begin"); |
| | | // gSignalLock.emitSigal("read_dataOk"); |
| | | fFmpegDecoderJPG->m_readData = true; |
| | |
| | | * @param p_this |
| | | */ |
| | | void BASICGB28181::FFmpegDecoderJPG::BareFlowDecoderThd(FFmpegDecoderJPG *p_this) { |
| | | DBG(p_this->m_camIdx << " BareFlowDecoderThd ok ... gpuIdx is " << p_this->m_gpuIdx); |
| | | DBG(p_this->m_camIdx << " BareFlowDecoderThd ok ... gpuIdx is " << p_this->m_gpuIdx); |
| | | DBG("p_thisADDR:" << p_this << "p_this->m_running" << p_this->m_running); |
| | | while (!p_this->m_running) { |
| | | |
| | | p_this->m_running = true; |
| | |
| | | // avformat_network_init(); |
| | | p_this->ic = avformat_alloc_context(); |
| | | |
| | | //创建ffmpeg使用的内存空间 |
| | | p_this->iobuffer = (unsigned char *) av_malloc(p_this->m_buf_size); |
| | | if (!p_this->iobuffer) { |
| | | ERR("av_malloc: err======" << p_this->m_camIdx); |
| | | p_this->m_running = false; |
| | | continue; |
| | | } |
| | | // 使用回调函数和内存块创建 AVIOContext |
| | | p_this->avio = avio_alloc_context(p_this->iobuffer, p_this->m_buf_size, 0, p_this, p_this->read_data, NULL, |
| | | NULL); |
| | | if (!p_this->avio) { |
| | |
| | | vi = i; |
| | | break; |
| | | } |
| | | } |
| | | if(vi == -1)//无视频包 |
| | | { |
| | | ERR("no video packet!!"); |
| | | p_this->m_running = false; |
| | | continue; |
| | | } |
| | | p_this->stream = p_this->ic->streams[vi]; |
| | | p_this->video_st = p_this->stream; |
| | |
| | | |
| | | // BASICGB28181::avframe_to_cvmat(frame).copyTo(p_this->m_image); |
| | | p_this->m_image = std::move(BASICGB28181::avframe_to_cvmat(p_this->frame)); |
| | | |
| | | if(p_this->m_image.empty()) { |
| | | ERR("camID:" << p_this->m_camIdx << " frameW:" << p_this->frame->width << "frame.data.len" << strlen(p_this->frame->data[0])); |
| | | continue; |
| | | } |
| | | // else { |
| | | // static int count =0; |
| | | // count ++; |
| | | // if(count > 100){ |
| | | // ERR("camID:" << p_this->m_camIdx << " cols:" << p_this->m_image.cols <<\ |
| | | // " rows:" << p_this->m_image.rows << " channels:" << p_this->m_image.channels()); |
| | | // count = 0; |
| | | // } |
| | | // |
| | | // } |
| | | // 将i帧保存为快照 |
| | | if (p_this->m_SnapshotNotSaveRet && (p_this->pkt.flags & AV_PKT_FLAG_KEY)) { |
| | | try { |
| | | std::string strNewName = "./"; |
| | |
| | | #ifdef TestCode |
| | | DBG("emitSigal(\"DecoderImageOK\") begin"); |
| | | #endif |
| | | //触发信号 |
| | | //触发上层信号 |
| | | gSignalLock.emitSigal(p_this->m_camIdx + "DecoderImageOK"); |
| | | // DBG("emitSigal: " << p_this->m_camIdx); |
| | | //#ifdef TestCode |
| | | // DBG("emitSigal(\"DecoderImageOK\") after"); |
| | | //#endif |
| | |
| | | } |
| | | m_camIdx = camIdx; |
| | | DBG("BareFlowDecoderThd camIdx : " << camIdx); |
| | | // 启动解码线程 |
| | | std::thread t_BareFlowDecoder(BareFlowDecoderThd, this); |
| | | t_BareFlowDecoder.detach(); |
| | | ); |
| | |
| | | delete iter->m_packet.data; |
| | | iter = m_packetsVec.erase(iter); |
| | | while (!(iter->m_packet.flags & AV_PKT_FLAG_KEY)) { |
| | | INFO("DropFrame: " << iter->m_frameId); |
| | | // INFO("DropFrame: " << iter->m_frameId); |
| | | delete iter->m_packet.data; |
| | | iter = m_packetsVec.erase(iter); |
| | | } |
| | |
| | | m_frameIndex++; |
| | | m_packetsVec.push_back({m_frameIndex, newPacket}); |
| | | if (newPacket.flags & AV_PKT_FLAG_KEY) { |
| | | DBG("newPacket.flags & AV_PKT_FLAG_KEY "); |
| | | // DBG("newPacket.flags & AV_PKT_FLAG_KEY "); |
| | | m_last_I_FrameId = m_frameIndex; |
| | | } |
| | | } |