org.hornetq.core.server.impl

Class AIOFileLockNodeManager

java.lang.Object

org.hornetq.core.server.NodeManager

org.hornetq.core.server.impl.FileLockNodeManager

org.hornetq.core.server.impl.AIOFileLockNodeManager

All Implemented Interfaces:

HornetQComponent

public final class AIOFileLockNodeManager
extends FileLockNodeManager

This is using the HornetQ Libaio Native to perform calls to flock on a Linux system. At the current version of RHEL there's a bug on GFS2 and because of that fctl is not functional what will cause issues on Failover over Shared Storage.

This will provide an alternative to perform locks through our native module until fctl is fixed on Linux.

https://bugzilla.redhat.com/show_bug.cgi?id=678585

Author:

clebertsuconic

Field Summary

Fields inherited from class org.hornetq.core.server.impl.FileLockNodeManager

interrupted

Fields inherited from class org.hornetq.core.server.NodeManager

channel, FIRST_TIME_START, replicatedBackup

Constructor Summary

Constructors

Constructor and Description
AIOFileLockNodeManager(String directory, boolean replicatingBackup)

Method Summary

Methods

Modifier and Type	Method and Description
protected FileLock	lock(int liveLockPos)
protected File	newFileForRegionLock(int liveLockPos)
protected FileLock	tryLock(int lockPos)

Methods inherited from class org.hornetq.core.server.impl.FileLockNodeManager

awaitLiveNode, crashLiveServer, interrupt, isAwaitingFailback, isBackupLive, isLiveLocked, pauseLiveServer, readNodeId, releaseBackup, start, startBackup, startLiveNode

Methods inherited from class org.hornetq.core.server.NodeManager

createNodeId, getNodeGroupName, getNodeId, getUUID, isStarted, newFile, setNodeGroupName, setNodeID, setUpServerLockFile, setUUID, stop, stopBackup

Methods inherited from class java.lang.Object

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

Constructor Detail

AIOFileLockNodeManager

public AIOFileLockNodeManager(String directory,
                      boolean replicatingBackup)

Parameters:

directory -

replicatingBackup -

Method Detail

tryLock

protected FileLock tryLock(int lockPos)
                    throws Exception

Overrides:

tryLock in class FileLockNodeManager

Throws:

Exception

lock

protected FileLock lock(int liveLockPos)
                 throws IOException

Overrides:

lock in class FileLockNodeManager

Throws:

IOException

newFileForRegionLock

protected File newFileForRegionLock(int liveLockPos)

Parameters:

liveLockPos -

Returns: