Better error handling for exceptions in on_message for websockets: avoid extra IOErrors

diff --git a/tornado/websocket.py b/tornado/websocket.py
index 14073bd478249a7ec25a27b628d8676261480fe9..696a178d78b2272091fd76c577b018ba4b9f093e 100644 (file)
--- a/tornado/websocket.py
+++ b/tornado/websocket.py
@@ -191,6 +191,7 @@ class WebSocketHandler(tornado.web.RequestHandler):
         if not self.client_terminated:
             self.async_callback(self.on_message)(
                     frame[:-1].decode("utf-8", "replace"))
+        if not self.client_terminated:
             self._receive_message()
 
     def _on_length_indicator(self, byte):