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 class AIOFileLockNodeManager
extends FileLockNodeManager

This is using the HornetQ Libaio Native to perform calls to flock on 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, SERVER_LOCK_NAME

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

nodeID, uuid

Constructor Summary

Constructors

Constructor and Description
AIOFileLockNodeManager(String directory)

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, getDirectory, interrupt, isAwaitingFailback, isBackupLive, isLiveLocked, newFile, pauseLiveServer, releaseBackup, start, startBackup, startLiveNode, stop, stopBackup

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

getNodeId, getUUID, isStarted

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)

Parameters:

directory -

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: