cvs commit: incubator-geronimo/modules/network/src/java/org/apache/geronimo/network/protocol SocketProtocol.java

[adc]

adc         2004/08/01 20:53:31

  Modified:    modules/network/src/java/org/apache/geronimo/network/protocol
                        SocketProtocol.java
  Log:
  Log timeout error.
  
  Revision  Changes    Path
  1.16      +7 -4      
incubator-geronimo/modules/network/src/java/org/apache/geronimo/network/protocol/SocketProtocol.java
  
  Index: SocketProtocol.java
  ===================================================================
  RCS file: 
/home/cvs/incubator-geronimo/modules/network/src/java/org/apache/geronimo/network/protocol/SocketProtocol.java,v
  retrieving revision 1.15
  retrieving revision 1.16
  diff -u -r1.15 -r1.16
  --- SocketProtocol.java       1 Aug 2004 13:03:44 -0000       1.15
  +++ SocketProtocol.java       2 Aug 2004 03:53:30 -0000       1.16
  @@ -242,7 +242,10 @@
   
           try {
               log.trace("AQUIRING " + sendMutex);
  -            if (!sendMutex.attempt(timeout)) throw new 
ProtocolException("Send timeout.");
  +            if (!sendMutex.attempt(timeout)) {
  +                log.error("TIMEOUT " + sendMutex);
  +                throw new ProtocolException("Send timeout.");
  +            }
               log.trace("AQUIRED " + sendMutex);
   
   
  @@ -265,7 +268,7 @@
               selectorManager.addInterestOps(selectionKey, 
SelectionKey.OP_WRITE);
   
           } catch (InterruptedException e) {
  -            log.trace("Communications error, closing connection: ", e);
  +            log.error("Communications error, closing connection: ", e);
               close();
               throw new ProtocolException(e);
           }
  @@ -280,7 +283,7 @@
               sendMutex.release();
               log.trace("flush RELEASED " + sendMutex);
           } catch (InterruptedException e) {
  -            log.trace("Communications error, closing connection: ", e);
  +            log.error("Communications error, closing connection: ", e);
               close();
               throw new ProtocolException(e);
           }