|
Lightweight Bartering Grid | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectlbg.peer.register.learning.consumption.PeerConsumptionDataTracker
public class PeerConsumptionDataTracker
A PeerConsumptionDataTracker tracks the data that are known to have been donwloaded by Supplier Peers for recent Consumption Tasks.
The tracked data were required by successfully completed Consumption Tasks.
To each data id is associated the set of Supplier Peers which have downloaded the data.
The tracked data can be searched to locate, and rank Peers that may still have some Resources holding the data in their data cache.
Constructor Summary | |
---|---|
PeerConsumptionDataTracker(int capacity)
|
Method Summary | |
---|---|
int |
countTrackedData()
Returns the number of tracked data. |
java.util.Map<java.lang.Long,java.util.Set<java.lang.String>> |
rankPeers(Task t)
Return data-aware ranking of Supplier Peers, sorted by decreasing Storage Affinity, where input data of target Task may be present. |
java.lang.String |
toString()
|
void |
trackData(java.lang.String supplier_peer,
Task t)
Tracks target data, i.e. |
java.util.Iterator<java.lang.String> |
trackedSuppliers(java.lang.String data_id)
Returns an Iterator of the suppliers that presumably store target tracked data, i.e. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public PeerConsumptionDataTracker(int capacity) throws GridException
GridException
Method Detail |
---|
public java.lang.String toString()
toString
in class java.lang.Object
public void trackData(java.lang.String supplier_peer, Task t) throws GridException
trackData
in interface ConsumptionDataTracker
supplier_peer
- target Supplier Peert
- target Task
GridException
- if a parameter is illegalpublic java.util.Map<java.lang.Long,java.util.Set<java.lang.String>> rankPeers(Task t) throws GridException
Note that Peers with no Storage Affinity are not ranked.
Note that input data of target Task may have been ejected from the data caches of the Suppliers Resources that once held it.
rankPeers
in interface ConsumptionDataTracker
t
- target Task
GridException
- if a parameter is illegalpublic int countTrackedData()
countTrackedData
in interface ConsumptionDataTracker
public java.util.Iterator<java.lang.String> trackedSuppliers(java.lang.String data_id) throws GridException
trackedSuppliers
in interface ConsumptionDataTracker
data_id
- tracked data id
GridException
|
Lightweight Bartering Grid | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Copyright (c) 2005-2008, Cyril Briquet, parts Xavier Dalem.