diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-03-02 14:32:01 +0100 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-03-02 14:35:52 +0100 |
commit | 0ac19e55b447e9bc966282e1ba9cae9f23ae4f91 (patch) | |
tree | 4aaab6159bb0ace904af76f3d797aec6b273cd6f /directory/src/main/java/com/orbekk/same/directory/DirectoryServiceImpl.java | |
parent | 5fb1fa01e75b2d47aad321f00fb28ea2c4478a8f (diff) |
Rename Discovery* => Directory*.
Diffstat (limited to 'directory/src/main/java/com/orbekk/same/directory/DirectoryServiceImpl.java')
-rw-r--r-- | directory/src/main/java/com/orbekk/same/directory/DirectoryServiceImpl.java | 43 |
1 files changed, 43 insertions, 0 deletions
diff --git a/directory/src/main/java/com/orbekk/same/directory/DirectoryServiceImpl.java b/directory/src/main/java/com/orbekk/same/directory/DirectoryServiceImpl.java new file mode 100644 index 0000000..8c6c6b9 --- /dev/null +++ b/directory/src/main/java/com/orbekk/same/directory/DirectoryServiceImpl.java @@ -0,0 +1,43 @@ +package com.orbekk.same.directory; + +import java.util.ArrayList; +import java.util.Iterator; +import java.util.List; + +import com.orbekk.same.discovery.DirectoryService; + +public class DirectoryServiceImpl implements DirectoryService { + public final static long EXPIRE_TIME = 15 * 60l * 1000; // 15 minutes + List<NetworkEntry> networkList = new ArrayList<NetworkEntry>(); + + synchronized void cleanNetworkList() { + long expiredTime = System.currentTimeMillis() - EXPIRE_TIME; + for (Iterator<NetworkEntry> it = networkList.iterator(); it.hasNext();) { + NetworkEntry e = it.next(); + if (e.hasExpired(expiredTime)) { + it.remove(); + } + } + } + + @Override + public List<String> getNetworks() throws Exception { + cleanNetworkList(); + List<String> networks = new ArrayList<String>(); + for (NetworkEntry e : networkList) { + networks.add(e.networkName); + networks.add(e.masterUrl); + } + return networks; + } + + @Override + public void registerNetwork(String networkName, String masterUrl) + throws Exception { + cleanNetworkList(); + NetworkEntry entry = new NetworkEntry(networkName, masterUrl); + entry.register(System.currentTimeMillis()); + networkList.remove(entry); + networkList.add(entry); + } +} |