Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEugene Tarassov2013-10-28 11:07:27 +0000
committerEugene Tarassov2013-10-28 11:07:27 +0000
commit79ac0352734056583c3c0c7dab93225fa9defdc8 (patch)
tree787756a5324d3870af96fc7f3c276ab9716aafb9 /plugins
parentca447ce47f242e4d0742d113133af260062f0b21 (diff)
downloadorg.eclipse.tcf-79ac0352734056583c3c0c7dab93225fa9defdc8.tar.gz
org.eclipse.tcf-79ac0352734056583c3c0c7dab93225fa9defdc8.tar.xz
org.eclipse.tcf-79ac0352734056583c3c0c7dab93225fa9defdc8.zip
TCF Core: code cleanup
Diffstat (limited to 'plugins')
-rw-r--r--plugins/org.eclipse.tcf.core/src/org/eclipse/tcf/internal/services/local/LocatorService.java38
1 files changed, 23 insertions, 15 deletions
diff --git a/plugins/org.eclipse.tcf.core/src/org/eclipse/tcf/internal/services/local/LocatorService.java b/plugins/org.eclipse.tcf.core/src/org/eclipse/tcf/internal/services/local/LocatorService.java
index c3f93d46d..084dd8a05 100644
--- a/plugins/org.eclipse.tcf.core/src/org/eclipse/tcf/internal/services/local/LocatorService.java
+++ b/plugins/org.eclipse.tcf.core/src/org/eclipse/tcf/internal/services/local/LocatorService.java
@@ -248,26 +248,35 @@ public class LocatorService implements ILocator {
* Wrapper for final class DatagramPacket so its toString() can present
* the value in the debugger in a readable fashion.
*/
- private class InputPacket {
- private DatagramPacket p;
- protected InputPacket(DatagramPacket dgPacket) {
- p = dgPacket;
+ private static class InputPacket {
+
+ final DatagramPacket p;
+
+ InputPacket(DatagramPacket p) {
+ this.p = p;
}
- protected DatagramPacket getPacket() {
+
+ DatagramPacket getPacket() {
return p;
}
- protected int getLength() {
+
+ int getLength() {
return p.getLength();
}
- protected byte[] getData() {
+
+ byte[] getData() {
return p.getData();
}
- public int getPort() {
+
+ int getPort() {
return p.getPort();
}
- public InetAddress getAddress() {
+
+ InetAddress getAddress() {
return p.getAddress();
}
+
+ @Override
public String toString() {
return "[address=" + p.getAddress().toString()
+ ",port=" + p.getPort()
@@ -281,8 +290,7 @@ public class LocatorService implements ILocator {
for (;;) {
DatagramSocket socket = LocatorService.this.socket;
try {
- final InputPacket p
- = new InputPacket(new DatagramPacket(inp_buf, inp_buf.length));
+ final InputPacket p = new InputPacket(new DatagramPacket(inp_buf, inp_buf.length));
socket.receive(p.getPacket());
Protocol.invokeAndWait(new Runnable() {
public void run() {
@@ -393,18 +401,18 @@ public class LocatorService implements ILocator {
}
});
listeners.add(new LocatorListener() {
-
+ @Override
public void peerAdded(IPeer peer) {
sendPeerInfo(peer, null, 0);
}
-
+ @Override
public void peerChanged(IPeer peer) {
sendPeerInfo(peer, null, 0);
}
-
+ @Override
public void peerHeartBeat(String id) {
}
-
+ @Override
public void peerRemoved(String id) {
}
});

Back to the top