| | |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | protected boolean doDecode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) { |
|---|
| | | String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrRtuAddr) ; |
|---|
| | | String rtuAddr = (String)session.getAttribute(TcpIoSessionAttrKeys.sessionAttrRtuAddr) ; |
|---|
| | | if(rtuAddr == null){ |
|---|
| | | //会话未被管理 |
|---|
| | | //会话管理器中不存在此会话，说明刚建立网络连接， |
|---|
| | |
|---|
| | | PrefixedDataAvailableStatus dataStatus = this.pdaHandle.forOnLine(session, in) ; |
|---|
| | | |
|---|
| | | if(dataStatus.protocolName != null && dataStatus.protocolVersion != null){ |
|---|
| | | session.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolName, dataStatus.protocolName) ; |
|---|
| | | session.setAttribute(TcpIoSessionAttrIdIsRtuAddr.sessionArrProtocolVersion, dataStatus.protocolVersion) ; |
|---|
| | | session.setAttribute(TcpIoSessionAttrKeys.sessionAttrProtocolName, dataStatus.protocolName) ; |
|---|
| | | session.setAttribute(TcpIoSessionAttrKeys.sessionAttrProtocolVersion, dataStatus.protocolVersion) ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(dataStatus.isCompleted() || dataStatus.isAdjoined()){ |
|---|
