()
| 366 | } |
| 367 | |
| 368 | function connected() { |
| 369 | try { |
| 370 | statements = {} |
| 371 | needsTypes = options.fetch_types |
| 372 | statementId = Math.random().toString(36).slice(2) |
| 373 | statementCount = 1 |
| 374 | lifeTimer.start() |
| 375 | socket.on('data', data) |
| 376 | keep_alive && socket.setKeepAlive && socket.setKeepAlive(true) |
| 377 | const s = StartupMessage() |
| 378 | write(s) |
| 379 | } catch (err) { |
| 380 | error(err) |
| 381 | } |
| 382 | } |
| 383 | |
| 384 | function error(err) { |
| 385 | if (connection.queue === queues.connecting && options.host[retries + 1]) |
no test coverage detected