Rice Pastry API

rice.p2p.aggregation
Class AggregateList

java.lang.Object
  extended by rice.p2p.aggregation.AggregateList

public class AggregateList
extends java.lang.Object


Field Summary
protected  java.util.Hashtable aggregateList
           
protected  java.lang.String configFileName
           
protected  Environment environment
           
protected  IdFactory factory
           
protected  java.lang.String instance
           
protected  java.lang.String label
           
protected  java.io.PrintStream logFile
           
protected  java.lang.String logFileName
           
protected  Logger logger
           
protected  boolean loggingEnabled
           
protected  long nextSerial
           
protected  Id rootKey
           
protected  boolean wasReadOK
           
 
Constructor Summary
AggregateList(java.lang.String configFileName, java.lang.String label, IdFactory factory, boolean loggingEnabled, java.lang.String instance, Environment env)
           
 
Method Summary
 void addAggregateDescriptor(rice.p2p.aggregation.AggregateDescriptor aggr)
           
 void clear()
           
 java.util.Enumeration elements()
           
 rice.p2p.aggregation.AggregateDescriptor getADC(Id id)
           
 Id getRoot()
           
 Id[] getSomePointers(int referenceThreshold, int max, Id[] excludes)
           
 AggregationStatistics getStatistics(long granularity, long range, int nominalReferenceCount)
           
 boolean isEmpty()
           
 void logEntry(java.lang.String entry)
           
 boolean readFromDisk()
           
 boolean readOK()
           
 void recalculateReferenceCounts(Id[] excludes)
           
 void recoverLog()
           
 void refreshAggregate(rice.p2p.aggregation.AggregateDescriptor adc, long lifetime)
           
 void removeAggregateDescriptor(rice.p2p.aggregation.AggregateDescriptor aggr)
           
 void resetMarkers()
           
 void setAggregateLifetime(rice.p2p.aggregation.AggregateDescriptor adc, long lifetime)
           
 void setObjectCurrentLifetime(rice.p2p.aggregation.AggregateDescriptor adc, int index, long lifetime)
           
 void setObjectRefreshedLifetime(rice.p2p.aggregation.AggregateDescriptor adc, int index, long lifetime)
           
 void setRoot(Id root)
           
 void writeToDisk()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

aggregateList

protected final java.util.Hashtable aggregateList

configFileName

protected final java.lang.String configFileName

logFileName

protected final java.lang.String logFileName

label

protected final java.lang.String label

factory

protected final IdFactory factory

logFile

protected final java.io.PrintStream logFile

loggingEnabled

protected final boolean loggingEnabled

rootKey

protected Id rootKey

wasReadOK

protected boolean wasReadOK

nextSerial

protected long nextSerial

instance

protected java.lang.String instance

environment

protected Environment environment

logger

protected Logger logger
Constructor Detail

AggregateList

public AggregateList(java.lang.String configFileName,
                     java.lang.String label,
                     IdFactory factory,
                     boolean loggingEnabled,
                     java.lang.String instance,
                     Environment env)
              throws java.io.IOException
Throws:
java.io.IOException
Method Detail

readOK

public boolean readOK()

elements

public java.util.Enumeration elements()

recoverLog

public void recoverLog()

getRoot

public Id getRoot()

logEntry

public void logEntry(java.lang.String entry)

setRoot

public void setRoot(Id root)

isEmpty

public boolean isEmpty()

clear

public void clear()

getADC

public rice.p2p.aggregation.AggregateDescriptor getADC(Id id)

setAggregateLifetime

public void setAggregateLifetime(rice.p2p.aggregation.AggregateDescriptor adc,
                                 long lifetime)

setObjectCurrentLifetime

public void setObjectCurrentLifetime(rice.p2p.aggregation.AggregateDescriptor adc,
                                     int index,
                                     long lifetime)

setObjectRefreshedLifetime

public void setObjectRefreshedLifetime(rice.p2p.aggregation.AggregateDescriptor adc,
                                       int index,
                                       long lifetime)

resetMarkers

public void resetMarkers()

refreshAggregate

public void refreshAggregate(rice.p2p.aggregation.AggregateDescriptor adc,
                             long lifetime)

addAggregateDescriptor

public void addAggregateDescriptor(rice.p2p.aggregation.AggregateDescriptor aggr)

removeAggregateDescriptor

public void removeAggregateDescriptor(rice.p2p.aggregation.AggregateDescriptor aggr)

recalculateReferenceCounts

public void recalculateReferenceCounts(Id[] excludes)

readFromDisk

public boolean readFromDisk()

writeToDisk

public void writeToDisk()

getSomePointers

public Id[] getSomePointers(int referenceThreshold,
                            int max,
                            Id[] excludes)

getStatistics

public AggregationStatistics getStatistics(long granularity,
                                           long range,
                                           int nominalReferenceCount)

Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection