Package | Description |
---|---|
com.hazelcast.cluster | |
com.hazelcast.impl | |
com.hazelcast.impl.base | |
com.hazelcast.nio |
Modifier and Type | Method and Description |
---|---|
void |
ClusterService.enqueuePacket(Packet packet) |
Modifier and Type | Field and Description |
---|---|
protected Queue<Packet> |
BaseManager.qServiceThreadPacketCache |
Modifier and Type | Method and Description |
---|---|
Packet |
BaseManager.createRemotelyProcessablePacket(RemotelyProcessable rp) |
protected Packet |
BaseManager.TargetAwareOp.doObtainPacket() |
protected Packet |
BaseManager.obtainPacket() |
Packet |
BaseManager.obtainPacket(String name,
Object key,
Object value,
ClusterOperation operation,
long timeout) |
Modifier and Type | Method and Description |
---|---|
static Request |
Request.copyFromPacket(Packet packet) |
protected void |
BaseManager.TargetAwareOp.doReleasePacket(Packet packet) |
void |
ClientHandlerService.ClientOperationHandler.handle(Node node,
Packet packet) |
void |
ClientHandlerService.handle(Packet packet) |
protected void |
BaseManager.ResponseQueueCall.handleNoneRedoResponse(Packet packet) |
void |
BaseManager.handleResponse(Packet packetResponse) |
void |
BaseManager.ConnectionAwareOp.handleResponse(Packet packet) |
void |
BaseManager.TargetAwareOp.handleResponse(Packet packet) |
void |
BaseManager.ResponsiveOperationHandler.process(Packet packet) |
abstract void |
ClientHandlerService.ClientOperationHandler.processCall(Node node,
Packet packet) |
protected boolean |
BaseManager.releasePacket(Packet packet) |
protected boolean |
BaseManager.send(Packet packet,
Address address)
Do not forget to release packet if send fails.
|
protected boolean |
BaseManager.send(Packet packet,
Connection conn)
Do not forget to release packet if send fails.
|
protected boolean |
BaseManager.sendOrReleasePacket(Packet packet,
Address address) |
protected boolean |
BaseManager.sendOrReleasePacket(Packet packet,
Connection conn) |
protected void |
ClientHandlerService.ClientOperationHandler.sendResponse(Packet request) |
protected boolean |
BaseManager.sendResponse(Packet packet) |
protected boolean |
BaseManager.sendResponse(Packet packet,
Address address) |
protected boolean |
BaseManager.sendResponseFailure(Packet packet) |
void |
Request.setFromPacket(Packet packet) |
Constructor and Description |
---|
ClientRequestHandler(Node node,
Packet packet,
CallContext callContext,
ClientHandlerService.ClientOperationHandler clientOperationHandler,
Subject subject) |
Modifier and Type | Method and Description |
---|---|
void |
Call.handleResponse(Packet packet) |
void |
PacketProcessor.process(Packet packet) |
Modifier and Type | Method and Description |
---|---|
Packet |
Connection.obtainPacket() |
Modifier and Type | Method and Description |
---|---|
void |
IOService.handleClientPacket(Packet p) |
void |
NodeIOService.handleClientPacket(Packet p) |
void |
IOService.handleMemberPacket(Packet p) |
void |
NodeIOService.handleMemberPacket(Packet p) |
void |
Connection.releasePacket(Packet packet) |
boolean |
SocketPacketWriter.write(Packet socketWritable,
ByteBuffer socketBuffer) |
Copyright © 2013 Hazelcast, Inc.. All rights reserved.