[Beepcore-java-commits] CVS: beepcore-java/src/org/beepcore/beep/core Channel.java,1.26,1.27

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

Update of /cvsroot/beepcore-java/beepcore-java/src/org/beepcore/beep/core
In directory usw-pr-cvs1:/tmp/cvs-serv2021/src/org/beepcore/beep/core

Modified Files:
	Channel.java 
Log Message:
making send async

Index: Channel.java
===================================================================
RCS file: /cvsroot/beepcore-java/beepcore-java/src/org/beepcore/beep/core/Channel.java,v
retrieving revision 1.26
retrieving revision 1.27
diff -C2 -r1.26 -r1.27
*** Channel.java	2 Sep 2002 13:44:39 -0000	1.26
--- Channel.java	4 Sep 2002 14:42:50 -0000	1.27
***************
*** 891,906 ****
                  // make sure the other peer can accept something
                  if (peerWindowSize == 0) {
!                     try {
!                         wait();
!                     } catch (InterruptedException e) {
!                         throw new RuntimeException("caught InterruptedException");
!                     }
! 
!                     // wait until there is something to send up to
!                     // our timeout
!                     if (peerWindowSize == 0) {
!                         throw new BEEPException("Time expired waiting " +
!                                                 "for peer.");
!                     }
                  }
  
--- 891,895 ----
                  // make sure the other peer can accept something
                  if (peerWindowSize == 0) {
!                     return;
                  }
  
***************
*** 1010,1014 ****
  
          if ((previousPeerWindowSize == 0) && (peerWindowSize > 0)) {
!             notify();    // unblock if we're waiting to send
          }
      }
--- 999,1006 ----
  
          if ((previousPeerWindowSize == 0) && (peerWindowSize > 0)) {
!             try {
!                 sendQueuedMessages();
!             } catch (BEEPException e) {
!             }
          }
      }