| 3408 | Socket.priorWebsocketSuccess = false; |
| 3409 | |
| 3410 | function onTransportOpen(){ |
| 3411 | if (self.onlyBinaryUpgrades) { |
| 3412 | var upgradeLosesBinary = !this.supportsBinary && self.transport.supportsBinary; |
| 3413 | failed = failed || upgradeLosesBinary; |
| 3414 | } |
| 3415 | if (failed) return; |
| 3416 | |
| 3417 | debug('probe transport "%s" opened', name); |
| 3418 | transport.send([{ type: 'ping', data: 'probe' }]); |
| 3419 | transport.once('packet', function (msg) { |
| 3420 | if (failed) return; |
| 3421 | if ('pong' == msg.type && 'probe' == msg.data) { |
| 3422 | debug('probe transport "%s" pong', name); |
| 3423 | self.upgrading = true; |
| 3424 | self.emit('upgrading', transport); |
| 3425 | if (!transport) return; |
| 3426 | Socket.priorWebsocketSuccess = 'websocket' == transport.name; |
| 3427 | |
| 3428 | debug('pausing current transport "%s"', self.transport.name); |
| 3429 | self.transport.pause(function () { |
| 3430 | if (failed) return; |
| 3431 | if ('closed' == self.readyState) return; |
| 3432 | debug('changing transport and sending upgrade packet'); |
| 3433 | |
| 3434 | cleanup(); |
| 3435 | |
| 3436 | self.setTransport(transport); |
| 3437 | transport.send([{ type: 'upgrade' }]); |
| 3438 | self.emit('upgrade', transport); |
| 3439 | transport = null; |
| 3440 | self.upgrading = false; |
| 3441 | self.flush(); |
| 3442 | }); |
| 3443 | } else { |
| 3444 | debug('probe transport "%s" failed', name); |
| 3445 | var err = new Error('probe error'); |
| 3446 | err.transport = transport.name; |
| 3447 | self.emit('upgradeError', err); |
| 3448 | } |
| 3449 | }); |
| 3450 | } |
| 3451 | |
| 3452 | function freezeTransport() { |
| 3453 | if (failed) return; |