public abstract class ClusterBase extends java.lang.Object implements ClusterInterface
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DefaultClusterName |
static long |
DefaultLowPriorityQueueInterval |
Constructor and Description |
---|
ClusterBase(ClusterFileStateCache stateCache,
java.lang.String clusterName,
ThreadRequestPool threadPool)
Class constructor
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getClusterName()
Return the cluster name
|
ClusterNode |
getLocalNode()
Return the local node details
|
ClusterNodeList |
getNodeList()
Return the list of nodes
|
NotifyChangeHandler |
getNotifyChangeHandler()
Return the change notification handler, if configured for the filesystem
|
OpLockManager |
getOpLockManager()
Return the oplock manager
|
ClusterFileStateCache |
getStateCache()
Return the associated cluster state cache
|
ThreadRequestPool |
getThreadPool()
Return the thread pool
|
boolean |
hasDebug()
Check if debug output is enabled
|
boolean |
hasSendNotExistStates()
Check if none existent file/folder states should be sent to the cluster
|
abstract void |
requestOplockBreak(ClusterNode clNode,
ClusterFileState clState)
Request an oplock break
|
void |
setLocalNode(ClusterNode localNode)
Set the local cluster node
|
void |
setNodeList(ClusterNodeList nodeList)
Set the cluster node list
|
void |
setNotifyChangeHandler(NotifyChangeHandler notifyHandler)
Set the change notification handler
|
void |
setOpLockManager(OpLockManager oplockMgr)
Set the oplock manager
|
void |
setSendNotExistStates(boolean notExist)
Set the send none existent file/folder states to the cluster
|
abstract void |
shutdownCluster()
Shutdown the cluster
|
abstract void |
startCluster()
Start the cluster
|
public static final java.lang.String DefaultClusterName
public static final long DefaultLowPriorityQueueInterval
public ClusterBase(ClusterFileStateCache stateCache, java.lang.String clusterName, ThreadRequestPool threadPool)
stateCache
- ClusterFileStateCacheclusterName
- StringthreadPool
- ThreadRequestPoolpublic abstract void startCluster() throws java.lang.Exception
startCluster
in interface ClusterInterface
java.lang.Exception
public abstract void shutdownCluster() throws java.lang.Exception
shutdownCluster
in interface ClusterInterface
java.lang.Exception
public final java.lang.String getClusterName()
getClusterName
in interface ClusterInterface
public final ClusterNodeList getNodeList()
getNodeList
in interface ClusterInterface
public final ClusterNode getLocalNode()
getLocalNode
in interface ClusterInterface
public final ClusterFileStateCache getStateCache()
getStateCache
in interface ClusterInterface
public final ThreadRequestPool getThreadPool()
getThreadPool
in interface ClusterInterface
public final boolean hasDebug()
hasDebug
in interface ClusterInterface
public final boolean hasSendNotExistStates()
hasSendNotExistStates
in interface ClusterInterface
public final OpLockManager getOpLockManager()
getOpLockManager
in interface ClusterInterface
public final NotifyChangeHandler getNotifyChangeHandler()
getNotifyChangeHandler
in interface ClusterInterface
public final void setSendNotExistStates(boolean notExist)
setSendNotExistStates
in interface ClusterInterface
notExist
- booleanpublic final void setOpLockManager(OpLockManager oplockMgr)
setOpLockManager
in interface ClusterInterface
oplockMgr
- OpLockManagerpublic final void setNotifyChangeHandler(NotifyChangeHandler notifyHandler)
setNotifyChangeHandler
in interface ClusterInterface
notifyHandler
- NotifyChangeHandlerpublic final void setNodeList(ClusterNodeList nodeList)
setNodeList
in interface ClusterInterface
nodeList
- ClusterNodeListpublic final void setLocalNode(ClusterNode localNode)
setLocalNode
in interface ClusterInterface
localNode
- ClusterNodepublic abstract void requestOplockBreak(ClusterNode clNode, ClusterFileState clState) throws java.io.IOException
clNode
- ClusterNodeclState
- ClusterFileStatejava.io.IOException
Copyright © 2005 - 2010 Alfresco Software, Inc. All Rights Reserved.