com.hazelcast.nio
Class NodeIOService

java.lang.Object
  extended by com.hazelcast.nio.NodeIOService
All Implemented Interfaces:
IOService

public class NodeIOService
extends Object
implements IOService


Field Summary
 
Fields inherited from interface com.hazelcast.nio.IOService
KILO_BYTE
 
Constructor Summary
NodeIOService(Node node)
           
 
Method Summary
 PacketReader createPacketReader(TcpIpConnection connection)
           
 PacketWriter createPacketWriter(TcpIpConnection connection)
           
 void executeAsync(Runnable runnable)
           
 long getConnectionMonitorInterval()
           
 int getConnectionMonitorMaxFaults()
           
 EventService getEventService()
           
 ILogger getLogger(String name)
           
 MemberSocketInterceptor getMemberSocketInterceptor()
           
 Collection<Integer> getOutboundPorts()
           
 PortableContext getPortableContext()
           
 int getSelectorThreadCount()
           
 SerializationService getSerializationService()
           
 SocketChannelWrapperFactory getSocketChannelWrapperFactory()
           
 int getSocketConnectTimeoutSeconds()
           
 SocketInterceptorConfig getSocketInterceptorConfig()
           
 boolean getSocketKeepAlive()
           
 int getSocketLingerSeconds()
           
 boolean getSocketNoDelay()
           
 int getSocketReceiveBufferSize()
           
 int getSocketSendBufferSize()
           
 SSLConfig getSSLConfig()
           
 SymmetricEncryptionConfig getSymmetricEncryptionConfig()
           
 TextCommandService getTextCommandService()
           
 Address getThisAddress()
           
 ThreadGroup getThreadGroup()
           
 String getThreadPrefix()
           
 void handleClientPacket(Packet p)
           
 void handleMemberPacket(Packet packet)
           
 boolean isActive()
           
 boolean isClient()
           
 boolean isMemcacheEnabled()
           
 boolean isRestEnabled()
           
 boolean isSocketBind()
           
 boolean isSocketBindAny()
           
 void onDisconnect(Address endpoint)
           
 void onFailedConnection(Address address)
           
 void onFatalError(Exception e)
           
 void onOutOfMemory(OutOfMemoryError oom)
           
 void onSuccessfulConnection(Address address)
           
 void removeEndpoint(Address endPoint)
           
 void shouldConnectTo(Address address)
           
 Data toData(Object obj)
           
 Object toObject(Data data)
           
 
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

onOutOfMemory

public void onOutOfMemory(OutOfMemoryError oom)
Specified by:
onOutOfMemory 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

getSSLConfig

public SSLConfig getSSLConfig()
Specified by:
getSSLConfig in interface IOService

handleMemberPacket

public void handleMemberPacket(Packet packet)
Specified by:
handleMemberPacket in interface IOService

handleClientPacket

public void handleClientPacket(Packet p)
Specified by:
handleClientPacket 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

onSuccessfulConnection

public void onSuccessfulConnection(Address address)
Specified by:
onSuccessfulConnection 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

isSocketBind

public boolean isSocketBind()
Specified by:
isSocketBind in interface IOService

isSocketBindAny

public boolean isSocketBindAny()
Specified by:
isSocketBindAny 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

getSocketConnectTimeoutSeconds

public int getSocketConnectTimeoutSeconds()
Specified by:
getSocketConnectTimeoutSeconds 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

onDisconnect

public void onDisconnect(Address endpoint)
Specified by:
onDisconnect 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

executeAsync

public void executeAsync(Runnable runnable)
Specified by:
executeAsync in interface IOService

getEventService

public EventService getEventService()
Specified by:
getEventService in interface IOService

toData

public Data toData(Object obj)
Specified by:
toData in interface IOService

toObject

public Object toObject(Data data)
Specified by:
toObject in interface IOService

getSerializationService

public SerializationService getSerializationService()
Specified by:
getSerializationService in interface IOService

getPortableContext

public PortableContext getPortableContext()
Specified by:
getPortableContext in interface IOService

getSocketChannelWrapperFactory

public SocketChannelWrapperFactory getSocketChannelWrapperFactory()
Specified by:
getSocketChannelWrapperFactory in interface IOService

getMemberSocketInterceptor

public MemberSocketInterceptor getMemberSocketInterceptor()
Specified by:
getMemberSocketInterceptor in interface IOService

createPacketReader

public PacketReader createPacketReader(TcpIpConnection connection)
Specified by:
createPacketReader in interface IOService

createPacketWriter

public PacketWriter createPacketWriter(TcpIpConnection connection)
Specified by:
createPacketWriter in interface IOService

getOutboundPorts

public Collection<Integer> getOutboundPorts()
Specified by:
getOutboundPorts in interface IOService


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.