aboutsummaryrefslogtreecommitdiffstats
path: root/actioncable/app
diff options
context:
space:
mode:
authorJavan Makhmali <javan@javan.us>2016-02-17 16:07:21 -0500
committerPratik Naik <pratiknaik@gmail.com>2016-02-23 09:37:49 -0600
commit832f88bdf35f5ac3333f3ccc2100223e32ca034a (patch)
treee7fadc56c0ecb03f1d914c8b74527aba988ab137 /actioncable/app
parentc57e7239a8b82957bcb07534cb7c1a3dcef71864 (diff)
downloadrails-832f88bdf35f5ac3333f3ccc2100223e32ca034a.tar.gz
rails-832f88bdf35f5ac3333f3ccc2100223e32ca034a.tar.bz2
rails-832f88bdf35f5ac3333f3ccc2100223e32ca034a.zip
Add client-side console logging to help debug reconnect issues
Diffstat (limited to 'actioncable/app')
-rw-r--r--actioncable/app/assets/javascripts/action_cable/connection.coffee7
-rw-r--r--actioncable/app/assets/javascripts/action_cable/connection_monitor.coffee9
2 files changed, 15 insertions, 1 deletions
diff --git a/actioncable/app/assets/javascripts/action_cable/connection.coffee b/actioncable/app/assets/javascripts/action_cable/connection.coffee
index fbd7dbd35b..866bb20870 100644
--- a/actioncable/app/assets/javascripts/action_cable/connection.coffee
+++ b/actioncable/app/assets/javascripts/action_cable/connection.coffee
@@ -17,8 +17,10 @@ class ActionCable.Connection
open: =>
if @webSocket and not @isState("closed")
+ console.log("[cable] Attemped to open WebSocket, but existing socket is #{@getState()}", Date.now())
throw new Error("Existing connection must be closed before opening")
else
+ console.log("[cable] Opening WebSocket", Date.now())
@webSocket = new WebSocket(@consumer.url)
@installEventHandlers()
true
@@ -27,12 +29,14 @@ class ActionCable.Connection
@webSocket?.close()
reopen: ->
+ console.log("[cable] Reopening WebSocket, current state is #{@getState()}", Date.now())
if @isState("closed")
@open()
else
try
@close()
finally
+ console.log("[cable] Failed to reopen WebSocket, retrying in #{@constructor.reopenDelay}ms", Date.now())
setTimeout(@open, @constructor.reopenDelay)
isOpen: ->
@@ -66,13 +70,16 @@ class ActionCable.Connection
@consumer.subscriptions.notify(identifier, "received", message)
open: ->
+ console.log("[cable] WebSocket onopen event", Date.now())
@disconnected = false
@consumer.subscriptions.reload()
close: ->
+ console.log("[cable] WebSocket onclose event", Date.now())
@disconnect()
error: ->
+ console.log("[cable] WebSocket onerror event", Date.now())
@disconnect()
disconnect: ->
diff --git a/actioncable/app/assets/javascripts/action_cable/connection_monitor.coffee b/actioncable/app/assets/javascripts/action_cable/connection_monitor.coffee
index 99b9a1c6d5..e92a43688a 100644
--- a/actioncable/app/assets/javascripts/action_cable/connection_monitor.coffee
+++ b/actioncable/app/assets/javascripts/action_cable/connection_monitor.coffee
@@ -33,10 +33,12 @@ class ActionCable.ConnectionMonitor
@startedAt = now()
@poll()
document.addEventListener("visibilitychange", @visibilityDidChange)
+ console.log("[cable] ConnectionMonitor started, pollInterval is #{@getInterval()}ms", Date.now())
stop: ->
@stoppedAt = now()
document.removeEventListener("visibilitychange", @visibilityDidChange)
+ console.log("[cable] ConnectionMonitor stopped", Date.now())
poll: ->
setTimeout =>
@@ -52,8 +54,12 @@ class ActionCable.ConnectionMonitor
reconnectIfStale: ->
if @connectionIsStale()
+ console.log("[cable] ConnectionMonitor detected stale connection, reconnectAttempts = #{@reconnectAttempts}", Date.now())
@reconnectAttempts++
- unless @disconnectedRecently()
+ if @disconnectedRecently()
+ console.log("[cable] ConnectionMonitor skipping repopen because recently disconnected at #{@disconnectedAt}", Date.now())
+ else
+ console.log("[cable] ConnectionMonitor reopening", Date.now())
@consumer.connection.reopen()
connectionIsStale: ->
@@ -66,6 +72,7 @@ class ActionCable.ConnectionMonitor
if document.visibilityState is "visible"
setTimeout =>
if @connectionIsStale() or not @consumer.connection.isOpen()
+ console.log("[cable] ConnectionMonitor reopening stale connection after visibilitychange", Date.now())
@consumer.connection.reopen()
, 200