Issue 66: closing browser results into "SocketException: Broken pipe"

plugins/org.chromium.sdk.wipbackend.dev/src/org/chromium/sdk/internal/websocket/AbstractWsConnection.java

 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package org.chromium.sdk.internal.websocket;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.nio.CharBuffer;
 import java.nio.charset.Charset;
@@ skipping 52 matching lines @@
     INPUT_STREAM_PROBLEM,
 
     /**
      * Closed as requested by {@link WsConnection#close()}.
      */
     USER_REQUEST,
 
     /**
      * Connection close has been requested from remote side.
      */
-    REMOTE_CLOSE_REQUEST
+    REMOTE_CLOSE_REQUEST,
+
+    /**
+     * Remote side silently closed connection (without breaking a message).
+     */
+    REMOTE_SILENTLY_CLOSED,
   }
 
   @Override
   public RelayOk runInDispatchThread(final Runnable runnable, final SyncCallback syncCallback) {
     MessageDispatcher messageDispatcher = new MessageDispatcher() {
       @Override
       boolean dispatch(Listener userListener) {
         RuntimeException ex = null;
         try {
           runnable.run();
@@ skipping 18 matching lines @@
   @Override
   public void startListening(final Listener listener) {
     final INPUT loggableReader = socketWrapper.getLoggableInput();
     Runnable listenRunnable = new Runnable() {
       @Override
       public void run() {
         Exception closeCause = null;
         CloseReason closeReason = null;
         try {
           closeReason = runListenLoop(loggableReader);
+          if (closeReason == CloseReason.REMOTE_SILENTLY_CLOSED) {
+            LOGGER.log(Level.INFO,
+                "Remote side silently closed connection without 'close' message");
+          }
         } catch (IOException e) {
           closeCause = e;
           LOGGER.log(Level.SEVERE, "Connection read failure", e);
         } catch (InterruptedException e) {
           closeCause = e;
           closeReason = CloseReason.USER_REQUEST;
           LOGGER.log(Level.SEVERE, "Thread interruption", e);
         } finally {
           synchronized (dispatchQueue) {
             dispatchQueue.add(EOS_MESSAGE_DISPATCHER);
@@ skipping 176 matching lines @@
   private static final SignalConverter<AbstractSocketWrapper.ShutdownSignal, CloseReason>
       SOCKET_TO_CONNECTION =
       new SignalConverter<AbstractSocketWrapper.ShutdownSignal, CloseReason>() {
         @Override public CloseReason convert(AbstractSocketWrapper.ShutdownSignal source) {
           return CloseReason.CONNECTION_CLOSED;
         }
       };
 
   private static final RelayOk DISPATCH_THREAD_PROMISES_TO_RELAY_OK = new RelayOk() {};
 }