org.apache.activemq.artemis.core.server.impl

Class AIOFileLockNodeManager

java.lang.Object

org.apache.activemq.artemis.core.server.NodeManager

org.apache.activemq.artemis.core.server.impl.FileLockNodeManager

org.apache.activemq.artemis.core.server.impl.AIOFileLockNodeManager

All Implemented Interfaces:

ActiveMQComponent

public final class AIOFileLockNodeManager
extends FileLockNodeManager

This is using the ActiveMQ Artemis 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

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.server.impl.FileLockNodeManager

interrupted, lockAcquisitionTimeout

Fields inherited from class org.apache.activemq.artemis.core.server.NodeManager

channel, FIRST_TIME_START, replicatedBackup

Constructor Summary

Constructors

Constructor and Description
AIOFileLockNodeManager(File directory, boolean replicatingBackup)
AIOFileLockNodeManager(File directory, boolean replicatingBackup, long lockAcquisitionTimeout)

Method Summary

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.apache.activemq.artemis.core.server.impl.FileLockNodeManager

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

Methods inherited from class org.apache.activemq.artemis.core.server.NodeManager

createNodeId, getNodeId, getUUID, isStarted, newFile, 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(File directory,
                              boolean replicatingBackup)

Parameters:

directory -

replicatingBackup -

AIOFileLockNodeManager

public AIOFileLockNodeManager(File directory,
                              boolean replicatingBackup,
                              long lockAcquisitionTimeout)

Method Detail

tryLock

protected FileLock tryLock(int lockPos)
                    throws Exception

Overrides:

tryLock in class FileLockNodeManager

Throws:

Exception

lock

protected FileLock lock(int liveLockPos)
                 throws Exception

Overrides:

lock in class FileLockNodeManager

Throws:

Exception

newFileForRegionLock

protected File newFileForRegionLock(int liveLockPos)

Parameters:

liveLockPos -

Returns: