AfflictionNetworks/narya
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Resort to adding some temporary logging printouts to BlockingCommunicator to figure out what's keeping the reader thread from being shut down.

Browse Source 
git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@4964 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
Mike Thomas
2008-03-07 23:53:19 +00:00
parent 7480630c3b
commit 4fabfcf0f3
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/java/com/threerings/presents/client/BlockingCommunicator.java
+13
View File
@@ -475,19 +475,29 @@ public class BlockingCommunicator extends Communicator
// somebody set up us the bomb! we've been interrupted which means that we're being // somebody set up us the bomb! we've been interrupted which means that we're being
// shut down, so we just report it and return from iterate() like a good monkey // shut down, so we just report it and return from iterate() like a good monkey
Log.debug("Reader thread woken up in time to die."); Log.debug("Reader thread woken up in time to die.");
// TEMP
Log.info("Blocking Communicator: Caught a ClosedByInterruptException: " + cbie);
} catch (InterruptedIOException iioe) { } catch (InterruptedIOException iioe) {
// somebody set up us the bomb! we've been interrupted which means that we're being // somebody set up us the bomb! we've been interrupted which means that we're being
// shut down, so we just report it and return from iterate() like a good monkey // shut down, so we just report it and return from iterate() like a good monkey
Log.debug("Reader thread woken up in time to die."); Log.debug("Reader thread woken up in time to die.");
// TEMP
Log.info("Blocking Communicator: Caught a InterruptedIOException: " + iioe);
} catch (EOFException eofe) { } catch (EOFException eofe) {
// TEMP
Log.info("Blocking Communicator: Caught an EOFException: " + eofe);
// let the communicator know that our connection was closed // let the communicator know that our connection was closed
connectionClosed(); connectionClosed();
// and shut ourselves down // and shut ourselves down
shutdown(); shutdown();
} catch (IOException ioe) { } catch (IOException ioe) {
// TEMP
Log.info("Blocking Communicator: Caught an IOException: " + ioe);
// let the communicator know that our connection failed // let the communicator know that our connection failed
connectionFailed(ioe); connectionFailed(ioe);
// and shut ourselves down // and shut ourselves down
@@ -518,7 +528,10 @@ public class BlockingCommunicator extends Communicator
// Note that we're the ones in control of the interruption, and then do it to get our // Note that we're the ones in control of the interruption, and then do it to get our
// reader out of waiting for the rest of a readFrame if necessary. // reader out of waiting for the rest of a readFrame if necessary.
_interrupted = true; _interrupted = true;
Log.info("BlockingCommunicator: about to call interrupt");
interrupt(); interrupt();
// TEMP
Log.info("BlockingCommunicator: called interrupt");
} }
} }