com.hazelcast.nio

Class NodeIOService

java.lang.Object

com.hazelcast.nio.NodeIOService

All Implemented Interfaces:

IOService

public class NodeIOService
extends Object
implements IOService

Constructor Summary

Constructors

Constructor and Description
NodeIOService(Node node)

Method Summary

Methods

Modifier and Type	Method and Description
void	disconnectExistingCalls(Address deadEndpoint)
void	executeAsync(Runnable runnable)
AsymmetricEncryptionConfig	getAsymmetricEncryptionConfig()
long	getConnectionMonitorInterval()
int	getConnectionMonitorMaxFaults()
ILogger	getLogger(String name)
Collection<Integer>	getOutboundPorts()
int	getSelectorThreadCount()
SocketInterceptorConfig	getSocketInterceptorConfig()
boolean	getSocketKeepAlive()
int	getSocketLingerSeconds()
boolean	getSocketNoDelay()
int	getSocketPort()
int	getSocketReceiveBufferSize()
int	getSocketSendBufferSize()
SSLConfig	getSSLConfig()
SymmetricEncryptionConfig	getSymmetricEncryptionConfig()
SystemLogService	getSystemLogService()
TextCommandService	getTextCommandService()
Address	getThisAddress()
ThreadGroup	getThreadGroup()
String	getThreadPrefix()
void	handleClientPacket(Packet p)
void	handleInterruptedException(Thread thread, RuntimeException e)
void	handleMemberPacket(Packet p)
boolean	isActive()
boolean	isClient()
boolean	isMemcacheEnabled()
boolean	isRestEnabled()
boolean	isReuseSocketAddress()
boolean	isSocketBindAny()
boolean	isSocketPortAutoIncrement()
void	onFailedConnection(Address address)
void	onFatalError(Exception e)
void	onIOThreadStart()
void	onOutOfMemory(OutOfMemoryError oom)
void	onShutdown()
void	removeEndpoint(Address endPoint)
void	shouldConnectTo(Address address)

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeIOService

public NodeIOService(Node node)

Method Detail

isActive

public boolean isActive()

Specified by:

isActive in interface IOService

getLogger

public ILogger getLogger(String name)

Specified by:

getLogger in interface IOService

getSystemLogService

public SystemLogService getSystemLogService()

Specified by:

getSystemLogService in interface IOService

onOutOfMemory

public void onOutOfMemory(OutOfMemoryError oom)

Specified by:

onOutOfMemory in interface IOService

handleInterruptedException

public void handleInterruptedException(Thread thread,
                              RuntimeException e)

Specified by:

handleInterruptedException in interface IOService

onIOThreadStart

public void onIOThreadStart()

Specified by:

onIOThreadStart in interface IOService

getThisAddress

public Address getThisAddress()

Specified by:

getThisAddress in interface IOService

onFatalError

public void onFatalError(Exception e)

Specified by:

onFatalError in interface IOService

getSocketInterceptorConfig

public SocketInterceptorConfig getSocketInterceptorConfig()

Specified by:

getSocketInterceptorConfig in interface IOService

getSymmetricEncryptionConfig

public SymmetricEncryptionConfig getSymmetricEncryptionConfig()

Specified by:

getSymmetricEncryptionConfig in interface IOService

getAsymmetricEncryptionConfig

public AsymmetricEncryptionConfig getAsymmetricEncryptionConfig()

Specified by:

getAsymmetricEncryptionConfig in interface IOService

getSSLConfig

public SSLConfig getSSLConfig()

Specified by:

getSSLConfig in interface IOService

handleClientPacket

public void handleClientPacket(Packet p)

Specified by:

handleClientPacket in interface IOService

handleMemberPacket

public void handleMemberPacket(Packet p)

Specified by:

handleMemberPacket in interface IOService

getTextCommandService

public TextCommandService getTextCommandService()

Specified by:

getTextCommandService in interface IOService

isMemcacheEnabled

public boolean isMemcacheEnabled()

Specified by:

isMemcacheEnabled in interface IOService

isRestEnabled

public boolean isRestEnabled()

Specified by:

isRestEnabled in interface IOService

removeEndpoint

public void removeEndpoint(Address endPoint)

Specified by:

removeEndpoint in interface IOService

getThreadPrefix

public String getThreadPrefix()

Specified by:

getThreadPrefix in interface IOService

getThreadGroup

public ThreadGroup getThreadGroup()

Specified by:

getThreadGroup in interface IOService

onFailedConnection

public void onFailedConnection(Address address)

Specified by:

onFailedConnection in interface IOService

shouldConnectTo

public void shouldConnectTo(Address address)

Specified by:

shouldConnectTo in interface IOService

isReuseSocketAddress

public boolean isReuseSocketAddress()

Specified by:

isReuseSocketAddress in interface IOService

getSocketPort

public int getSocketPort()

Specified by:

getSocketPort in interface IOService

isSocketBindAny

public boolean isSocketBindAny()

Specified by:

isSocketBindAny in interface IOService

isSocketPortAutoIncrement

public boolean isSocketPortAutoIncrement()

Specified by:

isSocketPortAutoIncrement in interface IOService

getSocketReceiveBufferSize

public int getSocketReceiveBufferSize()

Specified by:

getSocketReceiveBufferSize in interface IOService

getSocketSendBufferSize

public int getSocketSendBufferSize()

Specified by:

getSocketSendBufferSize in interface IOService

getSocketLingerSeconds

public int getSocketLingerSeconds()

Specified by:

getSocketLingerSeconds in interface IOService

getSocketKeepAlive

public boolean getSocketKeepAlive()

Specified by:

getSocketKeepAlive in interface IOService

getSocketNoDelay

public boolean getSocketNoDelay()

Specified by:

getSocketNoDelay in interface IOService

getSelectorThreadCount

public int getSelectorThreadCount()

Specified by:

getSelectorThreadCount in interface IOService

disconnectExistingCalls

public void disconnectExistingCalls(Address deadEndpoint)

Specified by:

disconnectExistingCalls in interface IOService

isClient

public boolean isClient()

Specified by:

isClient in interface IOService

getConnectionMonitorInterval

public long getConnectionMonitorInterval()

Specified by:

getConnectionMonitorInterval in interface IOService

getConnectionMonitorMaxFaults

public int getConnectionMonitorMaxFaults()

Specified by:

getConnectionMonitorMaxFaults in interface IOService

onShutdown

public void onShutdown()

Specified by:

onShutdown in interface IOService

executeAsync

public void executeAsync(Runnable runnable)

Specified by:

executeAsync in interface IOService

getOutboundPorts

public Collection<Integer> getOutboundPorts()

Specified by:

getOutboundPorts in interface IOService