diff --git a/cs654/proj1/KaZaServer.java b/cs654/proj1/KaZaServer.java index ef232da..9635b9b 100644 --- a/cs654/proj1/KaZaServer.java +++ b/cs654/proj1/KaZaServer.java @@ -30,6 +30,25 @@ public class KaZaServer implements Runnable } } + public void connectToPeerGroupLeader(String peerName) + { + Socket s; + try + { + s = new Socket(peerName, LISTEN_PORT); + DataOutputStream os = new DataOutputStream(s.getOutputStream()); + os.writeBytes("USER KaZaServer\n"); + } + catch (Exception e) + { + return; + } + synchronized (m_peerGroupLeaders) + { + m_peerGroupLeaders.add(s); + } + } + public void close() { }