ulfgebhardt/college
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

modified leave method. all nodes are linked circularly.

Browse Source
This commit is contained in:
lutz 2012-11-25 18:47:40 +01:00
parent 64b1e0dc04
commit 6a2215a491
1 changed files with 7 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
ws2012/P2P/uebungen/4/src/node/Node.java
View File

@ -100,31 +100,13 @@ public class Node {
try {
if (neighbors.size() > 2) {
if (i == 0) {
putAddrInBuf(buf, neighbors.get(1));
channel.send(buf, neighbors.get(i));
putAddrInBuf(buf, neighbors.get(neighbors.size() - 1));
channel.send(buf, neighbors.get(i));
} else if (i == neighbors.size() - 1) {
putAddrInBuf(buf, neighbors.get(0));
channel.send(buf, neighbors.get(i));
putAddrInBuf(buf, neighbors.get(i - 1));
channel.send(buf, neighbors.get(i));
} else {
putAddrInBuf(buf, neighbors.get(i - 1));
channel.send(buf, neighbors.get(i));
putAddrInBuf(buf, neighbors.get(i + 1));
channel.send(buf, neighbors.get(i));
}
int pred = ((i - 1) + neighbors.size()) % neighbors.size();
int succ = (i + 1) % neighbors.size();
putAddrInBuf(buf, neighbors.get(succ));
channel.send(buf, neighbors.get(i));
putAddrInBuf(buf, neighbors.get(pred));
channel.send(buf, neighbors.get(i));
} else if (neighbors.size() == 2) {
putAddrInBuf(buf, neighbors.get(Math.abs(i - 1)));
channel.send(buf, neighbors.get(i));
@ -261,4 +243,4 @@ public class Node {
running = false;
}
}
}
}