| Modifier and Type | Field and Description |
|---|---|
| protected final AtomicBoolean |
| Access | Constructor and Description |
|---|---|
| protected | |
| protected | AbstractServerChannel(String discriminator, Collection<? extends RequestHandler<Channel>> handlers, CloseableExecutorService executor)
|
| Modifier and Type | Method and Description |
|---|---|
| protected OpenFuture | |
| public void | handleOpenFailure(Buffer
Incoming buffer)Buffer that triggered the callNote the buffer's read position is exactly after the information that read to this call was decoded Implements org. For a client channel, this method will be called internally by the session when the server has rejected this channel opening. |
| public void | handleOpenSuccess(long
Recipient identifier (UINT32 represented as a recipient, long long)Read/Write window size ( rwSize, long uint32)Preferred maximum packet size ( packetSize, Buffer uint32)Incoming buffer)Buffer that triggered the callNote the buffer's read position is exactly after the information that read to this call was decoded Implements org. For a client channel, this method will be called internally by the session when the confirmation has been received. |
| public OpenFuture | open(long
Recipient identifier (UINT32 represented as a recipient, long long)Read/Write window size ( rwSize, long uint32)Preferred maximum packet size ( packetSize, Buffer uint32)Incoming buffer)Buffer that triggered the callNote the buffer's read position is exactly after the information that read to this call was decoded Implements org. For a server channel, this method will actually open the channel |
| protected void |
| exitStatusSent | back to summary |
|---|---|
| protected final AtomicBoolean exitStatusSent | |
| AbstractServerChannel | back to summary |
|---|---|
| protected AbstractServerChannel(CloseableExecutorService executor) | |
| AbstractServerChannel | back to summary |
|---|---|
| protected AbstractServerChannel(String discriminator, Collection<? extends RequestHandler<Channel>> handlers, CloseableExecutorService executor) | |
| doInit | back to summary |
|---|---|
| protected OpenFuture doInit(Buffer buffer) | |
| handleOpenFailure | back to summary |
|---|---|
| public void handleOpenFailure(Buffer buffer) Implements org. Doc from org. For a client channel, this method will be called internally by the session when the server has rejected this channel opening. | |
| handleOpenSuccess | back to summary |
|---|---|
| public void handleOpenSuccess(long recipient, long rwSize, long packetSize, Buffer buffer) throws IOException Implements org. Doc from org. For a client channel, this method will be called internally by the session when the confirmation has been received.
| |
| open | back to summary |
|---|---|
| public OpenFuture open(long recipient, long rwSize, long packetSize, Buffer buffer) Implements org. Doc from org. For a server channel, this method will actually open the channel
| |
| sendExitStatus | back to summary |
|---|---|
| protected void sendExitStatus(int v) throws IOException | |