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

add PIBinaryLog::threadedReadRecord event (with full info)

Browse Source
This commit is contained in:
Пелипенко Иван
2025-03-04 20:20:09 +03:00
parent 4340f5444d
commit 8e18ec15c9
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
libs/main/io_devices/pibinarylog.cpp
View File

@@ -181,6 +181,7 @@ bool PIBinaryLog::threadedRead(const uchar * readed, ssize_t size) {
is_thread_ok = false; is_thread_ok = false;
logmutex.lock(); logmutex.lock();
const PISystemTime lastrec_timestamp = lastrecord.timestamp; const PISystemTime lastrec_timestamp = lastrecord.timestamp;
const int lastrec_id = lastrecord.id;
logmutex.unlock(); logmutex.unlock();
PISystemTime pt; PISystemTime pt;
double delay; double delay;
@@ -248,7 +249,8 @@ bool PIBinaryLog::threadedRead(const uchar * readed, ssize_t size) {
break; break;
default: return false; default: return false;
} }
bool res = PIIODevice::threadedRead(readed, size); bool res = PIIODevice::threadedRead(readed, size);
threadedReadRecord(PIByteArray(readed, size), lastrec_id, lastrec_timestamp);
is_thread_ok = true; is_thread_ok = true;
return res; return res;
} }

1
libs/main/io_devices/pibinarylog.h
View File

@@ -327,6 +327,7 @@ public:
EVENT(fileError); EVENT(fileError);
EVENT1(newFile, const PIString &, filename); EVENT1(newFile, const PIString &, filename);
EVENT1(posChanged, int, pos); EVENT1(posChanged, int, pos);
EVENT3(threadedReadRecord, PIByteArray, data, int, id, PISystemTime, time);
//! Get binlog info and statistic //! Get binlog info and statistic
static BinLogInfo getLogInfo(const PIString & path); static BinLogInfo getLogInfo(const PIString & path);