public abstract class AbstractChannel extends Object implements Channel
Modifier and Type | Field and Description |
---|---|
protected CloseFuture |
closeFuture |
protected boolean |
closing |
static int |
DEFAULT_PACKET_SIZE |
static int |
DEFAULT_WINDOW_SIZE |
protected boolean |
eof |
protected int |
id |
protected Window |
localWindow |
protected Object |
lock |
protected org.slf4j.Logger |
log |
protected int |
recipient |
protected Window |
remoteWindow |
protected Session |
session |
Constructor and Description |
---|
AbstractChannel() |
Modifier and Type | Method and Description |
---|---|
CloseFuture |
close(boolean immediately) |
protected void |
configureWindow() |
protected void |
doClose() |
protected abstract void |
doWriteData(byte[] data,
int off,
int len) |
protected abstract void |
doWriteExtendedData(byte[] data,
int off,
int len) |
int |
getId() |
Window |
getLocalWindow() |
int |
getRecipient() |
Session |
getSession() |
void |
handleClose() |
void |
handleData(Buffer buffer) |
void |
handleEof() |
void |
handleExtendedData(Buffer buffer) |
void |
handleFailure() |
void |
handleRequest(Buffer buffer) |
void |
handleWindowAdjust(Buffer buffer) |
void |
init(Session session,
int id) |
protected void |
sendEof() |
protected void |
sendWindowAdjust(int len) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handleOpenFailure, handleOpenSuccess, open
public static final int DEFAULT_WINDOW_SIZE
public static final int DEFAULT_PACKET_SIZE
protected final org.slf4j.Logger log
protected final Object lock
protected final Window localWindow
protected final Window remoteWindow
protected Session session
protected int id
protected int recipient
protected boolean eof
protected final CloseFuture closeFuture
protected boolean closing
public int getRecipient()
public Window getLocalWindow()
getLocalWindow
in interface Channel
public Session getSession()
getSession
in interface Channel
public void handleRequest(Buffer buffer) throws IOException
handleRequest
in interface Channel
IOException
public CloseFuture close(boolean immediately)
public void handleClose() throws IOException
handleClose
in interface Channel
IOException
protected void doClose()
public void handleData(Buffer buffer) throws IOException
handleData
in interface Channel
IOException
public void handleExtendedData(Buffer buffer) throws IOException
handleExtendedData
in interface Channel
IOException
public void handleEof() throws IOException
handleEof
in interface Channel
IOException
public void handleWindowAdjust(Buffer buffer) throws IOException
handleWindowAdjust
in interface Channel
IOException
public void handleFailure() throws IOException
handleFailure
in interface Channel
IOException
protected abstract void doWriteData(byte[] data, int off, int len) throws IOException
IOException
protected abstract void doWriteExtendedData(byte[] data, int off, int len) throws IOException
IOException
protected void sendEof() throws IOException
IOException
protected void configureWindow()
protected void sendWindowAdjust(int len) throws IOException
IOException
Copyright © 2008-2013 The Apache Software Foundation. All Rights Reserved.