cml/libcw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cwSpScQueueTmpl.cpp : _consumer() now reads all available records.

Browse Source
This commit is contained in:
kevin.larke 2020-04-19 15:43:07 -04:00
parent 85d7098061
commit 642904fe3a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cwSpScQueueTmpl.cpp
View File

@ -77,7 +77,7 @@ namespace cw
c->share->readyFl.store(true,std::memory_order_release);
}
if((m = c->share->q->pop()) != nullptr )
while((m = c->share->q->pop()) != nullptr )
{
uint8_t curCheckSum = 0;
for(unsigned i=0; i<kDataByteN; ++i)
@ -163,7 +163,7 @@ cw::rc_t cw::testSpScQueueTmpl()
goto errLabel;
}
sleepMs(5000);
sleepMs(60 * 1000);
errLabel:
if((rc0 = thread_mach::destroy(h)) != kOkRC )