| | |
| | | auto imageCount = m_redisTool.getSize(m_camId); |
| | | //保证Redis中的图片不要过多 |
| | | if (imageCount > M_CAM_PIC_MAX_COUNT) { |
| | | ERR("Too Much Pics In Cam " << m_camId << "Redis"); |
| | | ERR("Too Much Pics In Cam " << m_camId << " Redis ImageCount: " << imageCount ); |
| | | return; |
| | | } |
| | | auto item = m_imageQueue.front(); |
| | | m_redisTool.setKeyImage(item.m_imgName,item.m_image); |
| | | m_redisTool.listLpush(m_camId, item.m_imgName); |
| | | m_imageQueue.pop(); |
| | | INFO("SaveImage To Redis Succeed CamID:"<<m_camId<<" ImageName:"<<item.m_imgName); |
| | | } |
| | | } |
| | | |
| | | |
| | | //继承自父类,线程初始化的一些工作 |
| | | void RtspImageRedisElement::threadInitial() |
| | | { |
| | | |
| | | INFO("MYH DEBUG HERE"); |
| | | } |
| | | |
| | | //继承自父类,线程结束的时候调用 |
| | | void RtspImageRedisElement::threadClosing() |
| | | { |
| | | INFO("MYH DEBUG HERE"); |
| | | } |
| | | |
| | | //保存图片到队列中, |
| | |
| | | //保证队列中的图片不要过多 |
| | | if(m_imageQueue.size() < M_CAM_PIC_MAX_COUNT) |
| | | { |
| | | INFO("SaveImage Succeed ImgName:"<<imageName); |
| | | m_imageQueue.push(NameImagePair_s_t(imageName,img)); |
| | | } |
| | | else{ |
| | | ERR("SaveImage Failed ImgName:"<<imageName); |
| | | } |
| | | return true; |
| | | } |