| | |
| | | import org.apache.mina.core.buffer.IoBuffer; |
| | | |
| | | import com.dy.common.mw.channel.tcp.PrefixedDataAvailableStatus; |
| | | import org.apache.mina.core.session.IoSession; |
| | | |
| | | public interface PrefixedDataAvailable { |
| | | |
| | |
| | | * @return 不时本协议数据时返回空 |
| | | * @throws Exception 异常 |
| | | */ |
| | | PrefixedDataAvailableStatus forOnLine(IoBuffer in, |
| | | int remain, |
| | | int minDataLength, |
| | | int maxDataLength) throws Exception ; |
| | | PrefixedDataAvailableStatus forOnLine(IoSession ioSession, |
| | | IoBuffer in, |
| | | int remain, |
| | | int minDataLength, |
| | | int maxDataLength) throws Exception ; |
| | | |
| | | /** |
| | | * 分析上线后(网络连接后非第一包数据)是否可获得 |
| | |
| | | * @return PrefixedDataAvailableStatus |
| | | * @throws Exception 异常 |
| | | */ |
| | | PrefixedDataAvailableStatus forUpData(IoBuffer in, |
| | | int remain, |
| | | int minDataLength, |
| | | int maxDataLength) throws Exception; |
| | | PrefixedDataAvailableStatus forUpData(IoSession ioSession, |
| | | IoBuffer in, |
| | | int remain, |
| | | int minDataLength, |
| | | int maxDataLength) throws Exception; |
| | | |
| | | } |