cheykrym/socket.io-client-swift
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix outstanding poll messages after switch to websockets

Browse Source
This commit is contained in:
Erik 2015-04-06 12:49:39 -04:00
parent 9489676009
commit a4e81fee6a
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
SwiftIO/SocketEngine.swift
View File

@ -174,7 +174,12 @@ public class SocketEngine: NSObject, WebSocketDelegate {
}
private func doFastUpgrade() {
self.sendWebSocketMessage("", withType: PacketType.UPGRADE)
if self.waitingForPoll {
NSLog("Outstanding poll when switched to websockets," +
"we'll probably disconnect soon. You should report this.")
}
self.sendWebSocketMessage("", withType: PacketType.UPGRADE, datas: nil)
self._websocket = true
self._polling = false
self.fastUpgrade = false
@ -207,6 +212,8 @@ public class SocketEngine: NSObject, WebSocketDelegate {
} else if err != nil {
if self!.polling {
self?.handlePollingFailed(err.localizedDescription)
} else {
NSLog(err.localizedDescription)
}
return
@ -222,11 +229,10 @@ public class SocketEngine: NSObject, WebSocketDelegate {
}
self?.waitingForPoll = false
if self!.fastUpgrade {
self?.doFastUpgrade()
return
} else if !self!.closed && !self!.websocket {
} else if !self!.closed && self!.polling {
self?.doPoll()
}
}.resume()
@ -291,14 +297,14 @@ public class SocketEngine: NSObject, WebSocketDelegate {
} else if err != nil && self!.polling {
self?.handlePollingFailed(err.localizedDescription)
return
} else if err != nil {
NSLog(err.localizedDescription)
return
}
self?.waitingForPost = false
dispatch_async(self!.emitQueue) {
if self!.fastUpgrade {
self?.doFastUpgrade()
return
} else {
if !self!.fastUpgrade {
self?.flushWaitingForPost()
self?.doPoll()
}
@ -611,6 +617,7 @@ public class SocketEngine: NSObject, WebSocketDelegate {
if self.websocketConnected {
// NSLog("Doing fast upgrade")
// Do a fast upgrade
// At this point, we should not send anymore polling messages-
self.fastUpgrade = true
self.sendPollMessage("", withType: PacketType.NOOP)
}