sven/libicsneo
1
0
Fork 0
mirror of https://github.com/intrepidcs/libicsneo.git synced 2026-08-05 01:18:36 +02:00
Code Issues Projects Releases Wiki Activity

API: Add icsneoc2

Browse Source
This commit is contained in:
Thomas Stoddard
2026-03-24 21:08:40 -04:00
committed by Kyle Schwarz
parent 294e707924
commit 682299cb8c
40 changed files with 9015 additions and 369 deletions
Download Patch File Download Diff File Expand all files Collapse all files
device/device.cpp
+5 -6
View File
@@ -181,12 +181,11 @@ bool Device::getMessages(std::vector<std::shared_ptr<Message>>& container, size_
if(container.size() < limit)
container.resize(limit);
size_t actuallyRead;
if(timeout != std::chrono::milliseconds(0))
actuallyRead = pollingContainer.wait_dequeue_bulk_timed(container.data(), limit, timeout);
else
actuallyRead = pollingContainer.try_dequeue_bulk(container.data(), limit);
size_t actuallyRead = 0;
if(pollingContainer.wait_dequeue_timed(container.front(), timeout)) {
actuallyRead = 1; // Account for the first message we already dequeued
actuallyRead += pollingContainer.try_dequeue_bulk(container.data() + 1, limit - 1);
}
if(container.size() > actuallyRead)
container.resize(actuallyRead);