public class DistHashTable<K,V> extends java.util.AbstractMap<K,V>
Modifier and Type | Field and Description |
---|---|
protected ChannelFactory |
cf |
protected SocketChannel |
channel |
protected edu.jas.util.DHTListener<K,V> |
listener |
protected java.util.SortedMap<K,V> |
theList |
Constructor and Description |
---|
DistHashTable(ChannelFactory cf,
java.lang.String host,
int port)
DistHashTable.
|
DistHashTable(SocketChannel sc)
DistHashTable.
|
DistHashTable(java.lang.String host)
Constructs a new DistHashTable.
|
DistHashTable(java.lang.String host,
int port)
DistHashTable.
|
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clear the List.
|
boolean |
containsKey(java.lang.Object o)
Contains key.
|
boolean |
containsValue(java.lang.Object o)
Contains value.
|
java.util.Set<java.util.Map.Entry<K,V>> |
entrySet()
Get the entries as Set.
|
boolean |
equals(java.lang.Object o)
Equals.
|
V |
get(java.lang.Object key)
Get value under key from DHT.
|
java.util.SortedMap<K,V> |
getList()
Get the internal sorted map.
|
java.util.List<V> |
getValueList()
Get the internal list, convert from Collection.
|
V |
getWait(K key)
Get value under key from DHT.
|
int |
hashCode()
Hash code.
|
void |
init()
Initialize and start the list thread.
|
boolean |
isEmpty()
Is the List empty?
|
java.util.Iterator<K> |
iterator()
List key iterator.
|
java.util.Set<K> |
keySet()
Get the keys as set.
|
V |
put(K key,
V value)
Put object to the distributed hash table.
|
void |
putWait(K key,
V value)
Put object to the distributed hash table.
|
int |
size()
Size of the (local) list.
|
void |
terminate()
Terminate the list thread.
|
java.util.Iterator<V> |
valueIterator()
List value iterator.
|
java.util.Collection<V> |
values()
Get the values as Collection.
|
protected final ChannelFactory cf
protected SocketChannel channel
public DistHashTable(java.lang.String host)
host
- name or IP of server host.public DistHashTable(java.lang.String host, int port)
host
- name or IP of server host.port
- on server.public DistHashTable(ChannelFactory cf, java.lang.String host, int port)
cf
- ChannelFactory to use.host
- name or IP of server host.port
- on server.public DistHashTable(SocketChannel sc)
sc
- SocketChannel to use.public int hashCode()
public boolean equals(java.lang.Object o)
public boolean containsKey(java.lang.Object o)
public boolean containsValue(java.lang.Object o)
public java.util.List<V> getValueList()
public java.util.SortedMap<K,V> getList()
public int size()
public boolean isEmpty()
public java.util.Iterator<V> valueIterator()
public void putWait(K key, V value)
key
- value
- public V put(K key, V value)
public V getWait(K key)
key
- public V get(java.lang.Object key)
public void clear()
public void init()
public void terminate()