beepcore-java-commits

[Huston F. <hu...@us...>]

Update of /cvsroot/beepcore-java/beepcore-java/src/org/beepcore/beep/transport/tcp
In directory usw-pr-cvs1:/tmp/cvs-serv8875

Modified Files:
	TCPSession.java 
Log Message:
Cleanup erroneous message on session close

Index: TCPSession.java
===================================================================
RCS file: /cvsroot/beepcore-java/beepcore-java/src/org/beepcore/beep/transport/tcp/TCPSession.java,v
retrieving revision 1.11
retrieving revision 1.12
diff -C2 -r1.11 -r1.12
*** TCPSession.java	2001/07/29 03:52:57	1.11
--- TCPSession.java	2001/07/30 13:09:00	1.12
***************
*** 405,415 ****
  
          while (true) {
!             int b = is.read();
  
!             if (b == -1) {
!                 throw new SessionAbortedException();
!             }
  
!             headerBuffer[length] = (byte) b;
  
              if (headerBuffer[length] == '\n') {
--- 405,425 ----
  
          while (true) {
!             try {
!                 int b = is.read();
  
!                 if (b == -1) {
!                     throw new SessionAbortedException();
!                 }
! 
!                 headerBuffer[length] = (byte) b;
  
!             } catch (java.net.SocketException e) {
!                 if (getState() == SESSION_STATE_ACTIVE) {
!                     throw e;
!                 }
! 
!                 // socket closed intentionally (session closing) so just return
!                 return;
!             }
  
              if (headerBuffer[length] == '\n') {