dockerfile/openalpr-base
1
0
Fork 0
mirror of https://github.com/kerberos-io/openalpr-base.git synced 2025-10-06 22:02:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

Improved robustness of videobuffer

Browse Source
This commit is contained in:
Matt Hill
2014-07-03 15:34:12 -04:00
parent 8af784840e
commit cf7addab56
1 changed files with 52 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

87
src/videobuffer.cpp
View File

@@ -21,6 +21,7 @@
void imageCollectionThread(void* arg);
void getALPRImages(cv::VideoCapture cap, VideoDispatcher* dispatcher);
VideoBuffer::VideoBuffer()
@@ -102,42 +103,8 @@ void imageCollectionThread(void* arg)
cv::VideoCapture cap=cv::VideoCapture();
cap.open(dispatcher->mjpeg_url);
cv::Mat frame;
getALPRImages(cap, dispatcher);
while (dispatcher->active)
{
while (dispatcher->active)
{
dispatcher->mMutex.lock();
bool hasImage = false;
try
{
hasImage = cap.read(frame);
dispatcher->setLatestFrame(&frame);
}
catch (int e)
{
// Error occured while trying to gather image. Retry, don't exit.
std::cerr << "Exception happened " << e << std::endl;
}
// Double check the image to make sure it's valid.
if (frame.cols == 0 || frame.rows == 0)
hasImage = false;
dispatcher->mMutex.unlock();
if (hasImage == false)
break;
// Delay 15ms
usleep(15000);
}
// Delay 100ms
usleep(100000);
}
}
catch (const std::runtime_error& error)
{
@@ -151,3 +118,53 @@ void imageCollectionThread(void* arg)
}
// Continuously grabs images from the video capture. If there is an error,
// it returns so that the video capture can be recreated.
void getALPRImages(cv::VideoCapture cap, VideoDispatcher* dispatcher)
{
cv::Mat frame;
while (dispatcher->active)
{
while (dispatcher->active)
{
dispatcher->mMutex.lock();
bool hasImage = false;
try
{
hasImage = cap.read(frame);
// Double check the image to make sure it's valid.
if (frame.cols == 0 || frame.rows == 0)
{
dispatcher->mMutex.unlock();
return;
}
dispatcher->setLatestFrame(&frame);
}
catch (const std::runtime_error& error)
{
// Error occured while trying to gather image. Retry, don't exit.
std::cerr << "Exception happened " << error.what() << std::endl;
dispatcher->mMutex.unlock();
return;
}
dispatcher->mMutex.unlock();
if (hasImage == false)
break;
// Delay 15ms
usleep(15000);
}
// Delay 100ms
usleep(100000);
}
}