| | |
| | | printf("GB28181API end!\n"); |
| | | // m_rtpQueue.clearAll(); |
| | | m_rtpQueue.clearAll([](frameBuffInfo *info){ |
| | | delete[] info->buff; |
| | | delete info; |
| | | if (info){ |
| | | delete[] info->buff; |
| | | delete info; |
| | | } |
| | | }); |
| | | deleteCamera(); |
| | | } |
| | | |
| | | bool pushInfo(unsigned char *data, int datalen) { |
| | | |
| | | while(m_rtpQueue.count_queue() > 120){ |
| | | auto p = m_rtpQueue.popNotWait(); |
| | | if (p){ |
| | | delete[] p->buff; |
| | | delete p; |
| | | } |
| | | } |
| | | |
| | | frameBuffInfo *info = new frameBuffInfo(); |
| | | info->buff = new unsigned char[datalen]; |
| | |
| | | info->buff = new unsigned char[buffinfo->buffLen - len]{}; |
| | | memcpy(info->buff, buffinfo->buff + len, buffinfo->buffLen - len); |
| | | |
| | | while(_this->m_rtpQueue.count_queue() > 120){ |
| | | auto p = _this->m_rtpQueue.popNotWait(); |
| | | if (p){ |
| | | delete[] p->buff; |
| | | delete p; |
| | | } |
| | | } |
| | | // printf("/帧长大于info->buffLen:%d\n", info->buffLen); |
| | | _this->m_rtpQueue.push_front_one(info); |
| | | // printf("/帧长大于info->buffLen\n"); |