| java.lang.Object
 org.cougaar.core.persist.BlackboardPersistence
| discardSubscriberState | | public void discardSubscriberState(Subscriber subscriber)(Code) | | |
| getPersistenceData | | public List getPersistenceData()(Code) | | |
| getPersistenceTime | | public long getPersistenceTime()(Code) | | Gets the system time when persistence should be performed. We do
persistence periodically with a period such that all the plugins
will, on the average create persistence deltas with their
individual periods. The average frequence of persistence is the
sum of the individual media frequencies. Frequency is the
reciprocal of period. The computation is:
T = 1/(1/T1 + 1/T2 + ... + 1/Tn)
the time of the next persistence delta |
| getSubscriberStateKeys | | public Set getSubscriberStateKeys()(Code) | | Get a set of the Keys of the SubscriberStates in the rehydration info.
Used by the Distributor to track which subscribers have not
rehydrated.
|
| hasSubscriberStates | | public boolean hasSubscriberStates()(Code) | | |
| isDummyPersistence | | public boolean isDummyPersistence()(Code) | | true if persistence is disabled, except for"returnBytes" state-capture persistence |
| persist | | public PersistenceObject persist(List epochEnvelopes, List undistributedEnvelopes, List subscriberStates, boolean returnBytes, boolean full, MessageManager messageManager, Object quiescenceMonitorState)(Code) | | End a persistence epoch by generating a persistence delta.
Parameters:
epochEnvelopes - All envelopes from this epoch that havebeen distributed. The effect of these envelopes has already beencaptured in the subscriber inboxes or in the consequentialoutboxes which are in undistributedEnvelopes.
Parameters:
undistributedEnvelopes - Envelopes that have not yet been distributed
Parameters:
subscriberStates - The subscriber states to record |
| rehydrate | | public RehydrationResult rehydrate(PersistenceEnvelope oldObjects, Object state)(Code) | | Rehydrate a persisted agent. Reads all the deltas in
order keeping the latest (last encountered) values from
every object.
Parameters:
oldObjects - Changes recorded in all but the last delta. List of all envelopes that have not yet been distributed |
| releaseDatabaseConnection | | public void releaseDatabaseConnection(Object locker)(Code) | | |
|
|