Commit 49a4799f authored by Dave Cridland's avatar Dave Cridland

Merge pull request #219 from guusdk/OF-883

OF-883: Compensate for new half-duplex close of TCP channel in MINA
parents bc19c579 be6ee20f
...@@ -107,6 +107,14 @@ public abstract class ConnectionHandler extends IoHandlerAdapter { ...@@ -107,6 +107,14 @@ public abstract class ConnectionHandler extends IoHandlerAdapter {
} }
} }
@Override
public void inputClosed( IoSession session ) throws Exception {
// Get the connection for this session
Connection connection = (Connection) session.getAttribute(CONNECTION);
// Inform the connection that it was closed
connection.close();
}
@Override @Override
public void sessionClosed(IoSession session) throws Exception { public void sessionClosed(IoSession session) throws Exception {
// Get the connection for this session // Get the connection for this session
......
...@@ -222,7 +222,7 @@ public class NIOConnection implements Connection { ...@@ -222,7 +222,7 @@ public class NIOConnection implements Connection {
return; return;
} }
try { try {
deliverRawText(flashClient ? "</flash:stream>" : "</stream:stream>", false); deliverRawText(flashClient ? "</flash:stream>" : "</stream:stream>", true);
} catch (Exception e) { } catch (Exception e) {
// Ignore // Ignore
} }
...@@ -235,7 +235,7 @@ public class NIOConnection implements Connection { ...@@ -235,7 +235,7 @@ public class NIOConnection implements Connection {
// OF-881: Notify any close listeners after the synchronized block has completed. // OF-881: Notify any close listeners after the synchronized block has completed.
notifyCloseListeners(); // clean up session, etc. notifyCloseListeners(); // clean up session, etc.
ioSession.close(false); // async via MINA ioSession.close(true); // sync via MINA
} }
public void systemShutdown() { public void systemShutdown() {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment