Don't start our writer thread until we know our socket is connected and ready
to send data. git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@5544 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
@@ -62,10 +62,9 @@ public class Communicator
|
|||||||
_outStream = new ObjectOutputStream(_outBuffer);
|
_outStream = new ObjectOutputStream(_outBuffer);
|
||||||
_inStream = new ObjectInputStream();
|
_inStream = new ObjectInputStream();
|
||||||
|
|
||||||
// start up our message writer
|
// create our message writer
|
||||||
_writer = new Timer(1);
|
_writer = new Timer(1);
|
||||||
_writer.addEventListener(TimerEvent.TIMER, sendPendingMessages);
|
_writer.addEventListener(TimerEvent.TIMER, sendPendingMessages);
|
||||||
_writer.start();
|
|
||||||
|
|
||||||
_portIdx = 0;
|
_portIdx = 0;
|
||||||
logonToPort();
|
logonToPort();
|
||||||
@@ -276,9 +275,13 @@ public class Communicator
|
|||||||
protected function socketOpened (event :Event) :void
|
protected function socketOpened (event :Event) :void
|
||||||
{
|
{
|
||||||
logonToPort(true);
|
logonToPort(true);
|
||||||
|
|
||||||
// well that's great! let's logon
|
// well that's great! let's logon
|
||||||
postMessage(new AuthRequest(_client.getCredentials(), _client.getVersion(),
|
postMessage(new AuthRequest(_client.getCredentials(), _client.getVersion(),
|
||||||
_client.getBootGroups()));
|
_client.getBootGroups()));
|
||||||
|
|
||||||
|
// start up our writer thread now that we know we're ready to write
|
||||||
|
_writer.start();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
Reference in New Issue
Block a user