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

comment some piCout in pipeer.cpp

Browse Source 
git-svn-id: svn://db.shs.com.ru/pip@109 12ceb7fc-bf1f-11e4-8940-5bc7170c53b5
This commit is contained in:
Бычков Андрей
2015-04-18 19:41:28 +00:00
parent 78efb444f4
commit 929338a4d7
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/io/pipeer.cpp
View File

@@ -57,7 +57,7 @@ void PIPeer::PeerData::dtThread() {
bool PIPeer::PeerData::send(const PIByteArray & d) { bool PIPeer::PeerData::send(const PIByteArray & d) {
piCout << "send ..." << t.isRunning(); //piCout << "send ..." << t.isRunning();
if (t.isRunning()) return false; if (t.isRunning()) return false;
data = d; data = d;
t.startOnce(); t.startOnce();
@@ -338,7 +338,7 @@ bool PIPeer::sendInternal(const PIString & to, const PIByteArray & data) {
} }
PIByteArray ba; PIByteArray ba;
ba << int(4) << self_info.name << to << int(0) << data; ba << int(4) << self_info.name << to << int(0) << data;
piCoutObj << "sendInternal to" << to << data.size_s() << int(data.front()); //piCoutObj << "sendInternal to" << to << data.size_s() << int(data.front());
if (!sendToNeighbour(dp, ba)) return false; if (!sendToNeighbour(dp, ba)) return false;
return true; return true;
} }
@@ -358,7 +358,7 @@ bool PIPeer::dataRead(uchar * readed, int size) {
PIString from, to; PIString from, to;
ba >> type; ba >> type;
PIMutexLocker locker(eth_mutex); PIMutexLocker locker(eth_mutex);
piCoutObj << "received data from" << from << "packet" << type; //piCoutObj << "received data from" << from << "packet" << type;
if (type == 5) { // ping request if (type == 5) { // ping request
PIString addr; PIString addr;
PISystemTime time; PISystemTime time;
@@ -445,7 +445,7 @@ bool PIPeer::dataRead(uchar * readed, int size) {
cnt++; cnt++;
if (cnt > _PIPEER_MSG_TTL || from == dp->name) return true; if (cnt > _PIPEER_MSG_TTL || from == dp->name) return true;
sba << type << from << to << cnt << pba; sba << type << from << to << cnt << pba;
piCout << "translate packet" << from << "->" << to << ", ttl =" << cnt; //piCout << "translate packet" << from << "->" << to << ", ttl =" << cnt;
sendToNeighbour(dp, sba); sendToNeighbour(dp, sba);
} }
return true; return true;
@@ -461,7 +461,7 @@ bool PIPeer::mbcastRead(uchar * data, int size) {
if (type <= 0 || type >= 4) return true; if (type <= 0 || type >= 4) return true;
PeerInfo pi; PeerInfo pi;
ba >> pi.name; ba >> pi.name;
piCoutObj << "received mb from" << pi.name << "packet" << type; //piCoutObj << "received mb from" << pi.name << "packet" << type;
if (pi.name == self_info.name) return true; if (pi.name == self_info.name) return true;
PIMutexLocker locker(mc_mutex); PIMutexLocker locker(mc_mutex);
diag_s.received(size); diag_s.received(size);