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

peer update

Browse Source 
git-svn-id: svn://db.shs.com.ru/pip@30 12ceb7fc-bf1f-11e4-8940-5bc7170c53b5
This commit is contained in:
Пелипенко Иван
2015-03-16 15:21:04 +00:00
parent 66e54cf585
commit dee3f36b95
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/io/pipeer.cpp
View File

@@ -428,6 +428,15 @@ bool PIPeer::mbcastRead(uchar * data, int size) {
rpeers << pi; rpeers << pi;
//piCoutObj << "rec sync " << rpeers.size_s() << " peers"; //piCoutObj << "rec sync " << rpeers.size_s() << " peers";
peers_mutex.lock(); peers_mutex.lock();
if (!self_info.neighbours.contains(pi.name)) {
self_info.addNeighbour(pi.name);
PeerInfo * np = peers_map.value(pi.name);
if (np) {
np->addNeighbour(self_info.name);
np->dist = 0;
}
ch = true;
}
piForeach (PeerInfo & rpeer, rpeers) { piForeach (PeerInfo & rpeer, rpeers) {
//piCout << " to sync " << rpeer.name; //piCout << " to sync " << rpeer.name;
if (rpeer.name == self_info.name) continue; if (rpeer.name == self_info.name) continue;