Bugfix for something that may never be needed in the wild: when an
AuthingConnection is replaced by a RunningConnection we need to transfer over any associated overflow queue to the new connection object. git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@3989 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
@@ -404,6 +404,12 @@ public class ConnectionManager extends LoopingThread
|
||||
// connection with the new one
|
||||
_handlers.put(selkey, rconn);
|
||||
|
||||
// transfer any overflow queue for that connection
|
||||
Object oflowHandler = _oflowqs.remove(conn);
|
||||
if (oflowHandler != null) {
|
||||
_oflowqs.put(rconn, oflowHandler);
|
||||
}
|
||||
|
||||
// and let our observers know about our new connection
|
||||
notifyObservers(CONNECTION_ESTABLISHED, rconn,
|
||||
conn.getAuthRequest(), conn.getAuthResponse());
|
||||
|
||||
Reference in New Issue
Block a user