[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting/transport/multiplex ...

[Ron Sigal]

  User: rsigal  
  Date: 06/07/20 03:26:13

  Modified:    src/main/org/jboss/remoting/transport/multiplex 
                        OutputMultiplexor.java
  Log:
  JBREM-551:  Check for IOException("Broken pipe") in doRun().  Also, call MultiplexingManager.setWriteException() in doRun().
  
  Revision  Changes    Path
  1.27      +8 -4      JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/OutputMultiplexor.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: OutputMultiplexor.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/OutputMultiplexor.java,v
  retrieving revision 1.26
  retrieving revision 1.27
  diff -u -b -r1.26 -r1.27
  --- OutputMultiplexor.java	19 Jul 2006 23:22:28 -0000	1.26
  +++ OutputMultiplexor.java	20 Jul 2006 07:26:13 -0000	1.27
  @@ -446,21 +446,25 @@
                        {
                           log.info(e);
                           writeQueue.clear();
  +                        manager.setWriteException(e);
                           break;
                        }
                        catch (IOException e)
                        {
                           String message = e.getMessage();
                           if ("An existing connection was forcibly closed by the remote host".equals(message) ||
  -                            "An established connection was aborted by the software in your host machine".equals(message))
  +                            "An established connection was aborted by the software in your host machine".equals(message) ||
  +                            "Broken pipe".equals(message))
                           {
                              log.debug(e);
                              writeQueue.clear();
  +                           manager.setWriteException(e);
                              break;
                           }
                           else
                           {
                              log.error(e);
  +                           manager.setWriteException(e);
                              throw e;
                           }
                        }
  @@ -530,10 +534,10 @@
         /**
          *
          * @param bytes
  -       * @param start TODO
  -       * @param length TODO
  +       * @param start
  +       * @param length
          * @param os
  -       * @param channel TODO
  +       * @param channel
          * @throws IOException
          */
         protected void encode(SocketId destination, byte[] bytes,  int start,