org.nuxeo.ecm.core.storage.sql

Class Invalidations

java.lang.Object

org.nuxeo.ecm.core.storage.sql.Invalidations

All Implemented Interfaces:

Serializable, SerializableAccumulableInvalidations, SerializableMessage

public class Invalidations
extends Object
implements SerializableAccumulableInvalidations

A set of invalidations.

Records both modified and deleted fragments, as well as "parents modified" fragments.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
boolean	all Used locally when invalidating everything, or when too many invalidations have been received.
Set<RowId>	deleted null when empty
static int	DELETED
static int	MAX_SIZE Maximum number of invalidations kept, after which only all is set.
Set<RowId>	modified null when empty
static int	MODIFIED
static String	PARENT Pseudo-table for children invalidation.
static String	SERIES_PROXIES Pseudo-table for series proxies invalidation.
static String	TARGET_PROXIES Pseudo-table for target proxies invalidation.

Constructor Summary

Constructors

Constructor and Description
Invalidations()
Invalidations(boolean all)

Method Summary

Modifier and Type	Method and Description
void	add(SerializableAccumulableInvalidations o) Adds other invalidations to this one.
void	add(Serializable id, String[] tableNames, int kind)
void	addDeleted(RowId rowId)
void	addModified(RowId rowId)
protected void	checkMaxSize()
void	clear()
static Invalidations	deserialize(InputStream in)
Set<RowId>	getKindSet(int kind) only call this if it's to add at least one element in the set
boolean	isEmpty() Checks if this contains no invalidations.
void	serialize(OutputStream out) Serializes this to an output stream.
protected void	setAll()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

PARENT

public static final String PARENT

Pseudo-table for children invalidation.

See Also:

Constant Field Values

SERIES_PROXIES

public static final String SERIES_PROXIES

Pseudo-table for series proxies invalidation.

See Also:

Constant Field Values

TARGET_PROXIES

public static final String TARGET_PROXIES

Pseudo-table for target proxies invalidation.

See Also:

Constant Field Values

MODIFIED

public static final int MODIFIED

See Also:

Constant Field Values

DELETED

public static final int DELETED

See Also:

Constant Field Values

MAX_SIZE

public static final int MAX_SIZE

Maximum number of invalidations kept, after which only all is set. This avoids accumulating too many invalidations in memory, at the expense of more coarse-grained invalidations.

See Also:

Constant Field Values

all

public boolean all

Used locally when invalidating everything, or when too many invalidations have been received.

modified

public Set<RowId> modified

null when empty

deleted

public Set<RowId> deleted

null when empty

Constructor Detail

Invalidations

public Invalidations()

Invalidations

public Invalidations(boolean all)

Method Detail

isEmpty

public boolean isEmpty()

Description copied from interface: SerializableAccumulableInvalidations

Checks if this contains no invalidations.

Specified by:

isEmpty in interface SerializableAccumulableInvalidations

clear

public void clear()

setAll

protected void setAll()

checkMaxSize

protected void checkMaxSize()

getKindSet

public Set<RowId> getKindSet(int kind)

only call this if it's to add at least one element in the set

add

public void add(SerializableAccumulableInvalidations o)

Description copied from interface: SerializableAccumulableInvalidations

Adds other invalidations to this one.

Specified by:

add in interface SerializableAccumulableInvalidations

addModified

public void addModified(RowId rowId)

addDeleted

public void addDeleted(RowId rowId)

add

public void add(Serializable id,
                String[] tableNames,
                int kind)

serialize

public void serialize(OutputStream out)
               throws IOException

Description copied from interface: SerializableMessage

Serializes this to an output stream. The deserialization is handled by AbstractPubSubBroker.deserialize(java.io.InputStream).

Specified by:

serialize in interface SerializableMessage

Throws:

IOException

deserialize

public static Invalidations deserialize(InputStream in)
                                 throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object