SHS/pip
4
3
Fork 0
Code Issues 67 Pull Requests 1 Actions Releases Wiki Activity

git-svn-id: svn://db.shs.com.ru/pip@798 12ceb7fc-bf1f-11e4-8940-5bc7170c53b5

Browse Source
This commit is contained in:
Пелипенко Иван
2019-05-29 06:26:22 +00:00
parent 607246d6a2
commit 35a19403d6
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src_main/io_utils/piconnection.cpp
View File

@@ -1119,13 +1119,14 @@ void PIConnection::DevicePool::run() {
void __DevicePool_threadReadDP(void * ddp) { void __DevicePool_threadReadDP(void * ddp) {
PIConnection::DevicePool::DeviceData * dd((PIConnection::DevicePool::DeviceData * )ddp); PIConnection::DevicePool::DeviceData * dd((PIConnection::DevicePool::DeviceData * )ddp);
if (dd->dev == 0) {piMSleep(100); return;} if (dd->dev == 0) {piMSleep(100); return;}
if (dd->dev->isClosed()) PIIODevice * dev = dd->dev;
if (!dd->dev->open()) {piMSleep(dd->dev->reopenTimeout()); return;} if (dev->isClosed())
if (!dev->open()) {piMSleep(dev->reopenTimeout()); return;}
PIByteArray ba; PIByteArray ba;
ba = dd->dev->read(dd->dev->threadedReadBufferSize()); ba = dev->read(dev->threadedReadBufferSize());
// dd->dev->threadedRead(ba.data(), ba.size()); // dd->dev->threadedRead(ba.data(), ba.size());
if (ba.isEmpty()) {piMSleep(10); return;} if (ba.isEmpty()) {piMSleep(10); return;}
dd->dev->threadedRead(ba.data(), ba.size_s()); dev->threadedRead(ba.data(), ba.size_s());
//piCout << "Readed from" << dd->dev->path() << Hex << ba; //piCout << "Readed from" << dd->dev->path() << Hex << ba;
__device_pool__->deviceReaded(dd, ba); __device_pool__->deviceReaded(dd, ba);
} }