Package | Description |
---|---|
com.hazelcast.nio |
This package contains classes related to New IO
|
com.hazelcast.nio.tcp |
Contains functionality for the TCP/IP Networking for cluster members
This whole package is internal and no compatibility will be provided. |
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.eventservice.impl |
Contains the code for the
InternalEventService implementation. |
com.hazelcast.spi.impl.operationexecutor |
Contains the
OperationRunner code. |
com.hazelcast.spi.impl.operationexecutor.impl |
Contains the
OperationExecutorImpl code. |
com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
InternalOperationService implementation. |
Modifier and Type | Method and Description |
---|---|
Packet |
Packet.raiseFlags(int flagsToRaise)
Raises all the flags raised in the argument.
|
Packet |
PacketIOHelper.readFrom(ByteBuffer src)
Reads the packet data from the supplied
ByteBuffer . |
Packet |
Packet.resetFlagsTo(int flagsToSet)
Resets the entire
flags bitfield to the supplied value. |
Packet |
Packet.setConn(Connection conn)
Sets the Connection this Packet is send with.
|
Packet |
Packet.setPacketType(Packet.Type type)
Sets the packet type by updating the packet type bits in the
flags bitfield. |
Modifier and Type | Method and Description |
---|---|
boolean |
ConnectionManager.transmit(Packet packet,
Address target)
Transmits a packet to a certain address.
|
boolean |
ConnectionManager.transmit(Packet packet,
Connection connection)
Transmits a packet to a certain connection.
|
boolean |
PacketIOHelper.writeTo(Packet packet,
ByteBuffer dst)
Writes the packet data to the supplied
ByteBuffer , up to the buffer's limit. |
Modifier and Type | Method and Description |
---|---|
void |
TcpIpConnectionManager.accept(Packet packet) |
protected void |
PacketDecoder.onPacketComplete(Packet packet) |
boolean |
TcpIpConnectionManager.transmit(Packet packet,
Address target)
Retries sending packet maximum 5 times until connection to target becomes available.
|
boolean |
TcpIpConnectionManager.transmit(Packet packet,
Connection connection) |
Constructor and Description |
---|
PacketDecoder(TcpIpConnection connection,
Consumer<Packet> dst) |
Modifier and Type | Method and Description |
---|---|
Consumer<Packet> |
NodeEngineImpl.getPacketDispatcher() |
Modifier and Type | Method and Description |
---|---|
void |
PacketDispatcher.accept(Packet packet) |
Constructor and Description |
---|
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
PacketDispatcher(ILogger logger,
Consumer<Packet> operationExecutor,
Consumer<Packet> responseHandler,
Consumer<Packet> invocationMonitor,
Consumer<Packet> eventService,
Consumer<Packet> connectionManager,
Consumer<Packet> jetService) |
Modifier and Type | Method and Description |
---|---|
void |
EventServiceImpl.accept(Packet packet)
Performs this operation on the given argument.
|
Constructor and Description |
---|
RemoteEventProcessor(EventServiceImpl eventService,
Packet packet) |
Modifier and Type | Method and Description |
---|---|
abstract void |
OperationRunner.run(Packet packet) |
Modifier and Type | Method and Description |
---|---|
void |
OperationExecutorImpl.accept(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Consumer<Packet> |
InboundResponseHandlerSupplier.get() |
Modifier and Type | Method and Description |
---|---|
void |
InvocationMonitor.accept(Packet packet) |
void |
InboundResponseHandler.accept(Packet packet) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.