diff --git a/src_main/io/pipeer.cpp b/src_main/io/pipeer.cpp index b1333b99..dc8164a3 100755 --- a/src_main/io/pipeer.cpp +++ b/src_main/io/pipeer.cpp @@ -446,6 +446,7 @@ bool PIPeer::dataRead(uchar * readed, int size) { PIString from, to; ba >> type; PIMutexLocker locker(eth_mutex); + piCout << "dataRead lock"; if (type == 5) { // ping request PIString addr; PISystemTime time; @@ -703,7 +704,7 @@ bool PIPeer::sendToNeighbour(PIPeer::PeerInfo * peer, const PIByteArray & ba) { void PIPeer::sendMBcast(const PIByteArray & ba) { send_mc_mutex.lock(); - piCoutObj << "sendMBcast" << ba.size() << "bytes ..."; + piCout << "sendMBcast" << ba.size() << "bytes ..."; piForeach (PIEthernet * e, eths_mcast) { //errorClear(); //piCout << "send to" << e->path() << e->sendAddress();// << e->send(ba); @@ -735,7 +736,7 @@ void PIPeer::sendMBcast(const PIByteArray & ba) { if (eth_tcp_cli.send(ba)) diag_s.sended(ba.size_s()); } - piCoutObj << "sendMBcast ok"; + piCout << "sendMBcast ok"; send_mc_mutex.unlock(); } @@ -838,6 +839,7 @@ bool PIPeer::closeDevice() { void PIPeer::syncPeers() { //piCout << "[PIPeer \"" + self_info.name + "\"] sync " << peers.size_s() << " peers"; PIMutexLocker locker(eth_mutex); + piCout << "syncPeers lock"; PIString pn; bool change = false; PIStringList dpeers; @@ -893,6 +895,7 @@ void PIPeer::reinit() { // timer.clearDelimiters(); PIMutexLocker mbl(mc_mutex); PIMutexLocker ethl(eth_mutex); + piCout << "reinit lock"; PIMutexLocker pl(peers_mutex); PIMutexLocker sl(send_mutex); initNetwork();