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

PIBroadcast fix

Browse Source
This commit is contained in:
Пелипенко Иван
2024-07-10 16:56:40 +03:00
parent a16e0b7659
commit b781bd5148
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
libs/io_utils/pibroadcast.cpp
View File

@@ -58,7 +58,7 @@ PIBroadcast::PIBroadcast(bool send_only): PIThread(), PIEthUtilBase() {
PIBroadcast::~PIBroadcast() { PIBroadcast::~PIBroadcast() {
PIThread::stopAndWait(); PIThread::stopAndWait();
mcast_mutex.unlock(); // mcast_mutex.unlock();
destroyAll(); destroyAll();
} }
@@ -202,10 +202,10 @@ void PIBroadcast::initAll(PIVector<PINetworkAddress> al) {
void PIBroadcast::send(const PIByteArray & data) { void PIBroadcast::send(const PIByteArray & data) {
if (!isRunning()) { /*if (!isRunning()) {
reinit(); reinit();
PIThread::start(3000); PIThread::start(3000);
} }*/
PIByteArray cd = cryptData(data); PIByteArray cd = cryptData(data);
if (cd.isEmpty()) return; if (cd.isEmpty()) return;
PIMutexLocker ml(mcast_mutex); PIMutexLocker ml(mcast_mutex);

1
libs/main/thread/pithread.cpp
View File

@@ -635,6 +635,7 @@ bool PIThread::startOnce() {
void PIThread::terminate() { void PIThread::terminate() {
piCoutObj << "Warning, terminate!";
// PICout(PICoutManipulators::DefaultControls) << "thread" << this << "terminate ..." << running_; // PICout(PICoutManipulators::DefaultControls) << "thread" << this << "terminate ..." << running_;
#ifdef FREERTOS #ifdef FREERTOS
PICout(PICoutManipulators::DefaultControls) << "FreeRTOS can't terminate pthreads! waiting for stop"; PICout(PICoutManipulators::DefaultControls) << "FreeRTOS can't terminate pthreads! waiting for stop";