net.ontopia.persistence.proxy
Class JGroupsCluster

java.lang.Object
  net.ontopia.persistence.proxy.JGroupsCluster

All Implemented Interfaces:

ClusterIF, org.jgroups.MessageListener

public class JGroupsCluster
extends java.lang.Object
implements ClusterIF, org.jgroups.MessageListener

INTERNAL: Class that represents a cluster of OKS instances.

Field Summary

protected java.lang.String	clusterId
protected java.lang.String	clusterProps
protected org.jgroups.JChannel	dchannel
protected org.jgroups.blocks.PullPushAdapter	ppadapter
protected EDU.oswego.cs.dl.util.concurrent.LinkedQueue	queue
protected StorageIF	storage

Fields inherited from interface net.ontopia.persistence.proxy.ClusterIF

DATA_CACHE_CLEAR, DATA_CACHE_FIELD_EVICT, DATA_CACHE_FIELDS_EVICT, DATA_CACHE_IDENTITY_EVICT, QUERY_CACHE_RT1_CLEAR, QUERY_CACHE_RT1_EVICT, QUERY_CACHE_RT2_CLEAR, QUERY_CACHE_RT2_EVICT, QUERY_CACHE_SRCLOC_CLEAR, QUERY_CACHE_SRCLOC_EVICT, QUERY_CACHE_SUBIND_CLEAR, QUERY_CACHE_SUBIND_EVICT, QUERY_CACHE_SUBLOC_CLEAR, QUERY_CACHE_SUBLOC_EVICT

Method Summary

void	clearCache(IdentityIF namespace, int cacheType)
void	clearDatacache()
void	evictCache(IdentityIF namespace, int cacheType, java.util.Collection keys)
void	evictCache(IdentityIF namespace, int cacheType, java.lang.Object key)
void	evictField(IdentityIF identity, int field)
void	evictFields(IdentityIF identity)
void	evictIdentity(IdentityIF identity)
void	flush()
byte[]	getState()
void	join()
void	leave()
protected void	processEvent(JGroupsEvent e)
void	receive(org.jgroups.Message msg)
void	setState(byte[] jgstate)

Methods inherited from class java.lang.Object

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

Field Detail

dchannel

protected org.jgroups.JChannel dchannel

ppadapter

protected org.jgroups.blocks.PullPushAdapter ppadapter

clusterId

protected java.lang.String clusterId

clusterProps

protected java.lang.String clusterProps

storage

protected StorageIF storage

queue

protected EDU.oswego.cs.dl.util.concurrent.LinkedQueue queue

Method Detail

join

public void join()

Specified by:

join in interface ClusterIF

leave

public void leave()

Specified by:

leave in interface ClusterIF

evictIdentity

public void evictIdentity(IdentityIF identity)

Specified by:

evictIdentity in interface ClusterIF

evictFields

public void evictFields(IdentityIF identity)

Specified by:

evictFields in interface ClusterIF

evictField

public void evictField(IdentityIF identity,
                       int field)

Specified by:

evictField in interface ClusterIF

clearDatacache

public void clearDatacache()

Specified by:

clearDatacache in interface ClusterIF

evictCache

public void evictCache(IdentityIF namespace,
                       int cacheType,
                       java.lang.Object key)

Specified by:

evictCache in interface ClusterIF

evictCache

public void evictCache(IdentityIF namespace,
                       int cacheType,
                       java.util.Collection keys)

Specified by:

evictCache in interface ClusterIF

clearCache

public void clearCache(IdentityIF namespace,
                       int cacheType)

Specified by:

clearCache in interface ClusterIF

flush

public void flush()

Specified by:

flush in interface ClusterIF

processEvent

protected void processEvent(JGroupsEvent e)

receive

public void receive(org.jgroups.Message msg)

Specified by:

receive in interface org.jgroups.MessageListener

getState

public byte[] getState()

Specified by:

getState in interface org.jgroups.MessageListener

setState

public void setState(byte[] jgstate)

Specified by:

setState in interface org.jgroups.MessageListener