peer update

git-svn-id: svn://db.shs.com.ru/pip@32 12ceb7fc-bf1f-11e4-8940-5bc7170c53b5
This commit is contained in:
2015-03-16 15:38:24 +00:00
parent 31fbfe65a4
commit f2e85a736d
2 changed files with 4 additions and 1 deletions

View File

@@ -406,6 +406,7 @@ bool PIPeer::mbcastRead(uchar * data, int size) {
case 2: // remove peer
//piCout << "remove peer packet ..." << pi.name;
peers_mutex.lock();
removeNeighbour(pi.name);
rpi = getPeerByName(pi.name);
if (rpi) {
dist = rpi->dist;
@@ -465,6 +466,7 @@ bool PIPeer::mbcastRead(uchar * data, int size) {
peer.addNeighbours(rpeer.neighbours);
rpeer.neighbours = peer.neighbours;
if (peer.name == pi.name) peer.sync = 0;
ch = true;
}
piBreak;
}
@@ -543,7 +545,6 @@ void PIPeer::removeNeighbour(const PIString & name) {
bool PIPeer::removePeer(const PIString & name) {
removeNeighbour(name);
for (int i = 0; i < peers.size_s(); ++i)
if (peers[i].name == name) {
peers.remove(i);